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
62
63
64

use std::ffi::OsString;

use crate::mcp::AgentWrapperMcpAddTransport;

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

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

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

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

    match transport {
        AgentWrapperMcpAddTransport::Stdio { command, args, env } => {
            for (key, value) in env {
                argv.push(OsString::from("--env"));
                argv.push(OsString::from(format!("{key}={value}")));
            }
            argv.push(OsString::from("--"));
            argv.extend(command.iter().cloned().map(OsString::from));
            argv.extend(args.iter().cloned().map(OsString::from));
        }
        AgentWrapperMcpAddTransport::Url {
            url,
            bearer_token_env_var,
        } => {
            argv.push(OsString::from("--url"));
            argv.push(OsString::from(url));
            if let Some(env_var) = bearer_token_env_var {
                argv.push(OsString::from("--bearer-token-env-var"));
                argv.push(OsString::from(env_var));
            }
        }
    }

    argv
}