kura-cli 0.1.16

Kura Training CLI for interacting with the Kura API and MCP runtime.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93

use clap::Subcommand;
use serde_json::json;
use uuid::Uuid;

use crate::util::{api_request, read_json_from_file};

#[derive(Subcommand)]
pub enum ProviderCommands {
    /// List provider connections
    List,
    /// Upsert provider connection metadata
    Upsert {
        /// Full JSON request payload (use '-' for stdin)
        #[arg(long)]
        request_file: String,
    },
    /// Revoke a provider connection by id
    Revoke {
        /// Provider connection UUID
        #[arg(long)]
        connection_id: Uuid,
        /// Revocation reason (audit field)
        #[arg(long)]
        reason: String,
    },
}

pub async fn run(api_url: &str, token: Option<&str>, command: ProviderCommands) -> i32 {
    match command {
        ProviderCommands::List => list(api_url, token).await,
        ProviderCommands::Upsert { request_file } => upsert(api_url, token, &request_file).await,
        ProviderCommands::Revoke {
            connection_id,
            reason,
        } => revoke(api_url, token, connection_id, &reason).await,
    }
}

async fn list(api_url: &str, token: Option<&str>) -> i32 {
    api_request(
        api_url,
        reqwest::Method::GET,
        "/v1/providers/connections",
        token,
        None,
        &[],
        &[],
        false,
        false,
    )
    .await
}

async fn upsert(api_url: &str, token: Option<&str>, request_file: &str) -> i32 {
    let body = match read_json_from_file(request_file) {
        Ok(v) => v,
        Err(e) => crate::util::exit_error(
            &e,
            Some("Provide a valid JSON provider-connection payload."),
        ),
    };

    api_request(
        api_url,
        reqwest::Method::POST,
        "/v1/providers/connections",
        token,
        Some(body),
        &[],
        &[],
        false,
        false,
    )
    .await
}

async fn revoke(api_url: &str, token: Option<&str>, connection_id: Uuid, reason: &str) -> i32 {
    let path = format!("/v1/providers/connections/{connection_id}/revoke");
    let body = json!({ "reason": reason });

    api_request(
        api_url,
        reqwest::Method::POST,
        &path,
        token,
        Some(body),
        &[],
        &[],
        false,
        false,
    )
    .await
}