unified-agent-api 0.3.5

Agent-agnostic facade and registry for wrapper backends
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

use std::ffi::OsString;

use crate::{mcp::AgentWrapperMcpAddTransport, AgentWrapperError};

use super::{invalid_request, PINNED_URL_BEARER_TOKEN_ENV_VAR_UNSUPPORTED};

pub(super) fn claude_mcp_list_argv() -> Vec<OsString> {
    vec![OsString::from("mcp"), OsString::from("list")]
}

pub(super) fn claude_mcp_get_argv(name: &str) -> Vec<OsString> {
    vec![
        OsString::from("mcp"),
        OsString::from("get"),
        OsString::from(name),
    ]
}

pub(super) fn claude_mcp_remove_argv(name: &str) -> Vec<OsString> {
    vec![
        OsString::from("mcp"),
        OsString::from("remove"),
        OsString::from(name),
    ]
}

pub(super) fn claude_mcp_add_argv(
    name: &str,
    transport: &AgentWrapperMcpAddTransport,
) -> Result<Vec<OsString>, AgentWrapperError> {
    let mut argv = vec![OsString::from("mcp"), OsString::from("add")];

    match transport {
        AgentWrapperMcpAddTransport::Stdio { command, args, env } => {
            argv.push(OsString::from("--transport"));
            argv.push(OsString::from("stdio"));
            for (key, value) in env {
                argv.push(OsString::from("--env"));
                argv.push(OsString::from(format!("{key}={value}")));
            }
            argv.push(OsString::from(name));
            argv.extend(command.iter().map(OsString::from));
            argv.extend(args.iter().map(OsString::from));
            Ok(argv)
        }
        AgentWrapperMcpAddTransport::Url {
            url,
            bearer_token_env_var,
        } => {
            if bearer_token_env_var.is_some() {
                return Err(invalid_request(PINNED_URL_BEARER_TOKEN_ENV_VAR_UNSUPPORTED));
            }

            argv.push(OsString::from("--transport"));
            argv.push(OsString::from("http"));
            argv.push(OsString::from(name));
            argv.push(OsString::from(url));
            Ok(argv)
        }
    }
}