clap-mcp 0.0.5

Enrich your CLI with MCP capabilities
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
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119

//! Streamable HTTP MCP transport (optional `http` feature).

use crate::{
    ClapMcpConfig, ClapMcpError, ClapMcpSchemaMetadata, ClapMcpServeOptions, InProcessToolHandler,
    server::{self, ClapMcpServer, build_clap_mcp_server},
};
use rmcp::transport::streamable_http_server::{
    StreamableHttpServerConfig, StreamableHttpService, session::local::LocalSessionManager,
};
use std::{net::SocketAddr, path::PathBuf, sync::Arc};

fn allowed_hosts_for_listen(addr: SocketAddr) -> Vec<String> {
    let mut hosts = vec![
        "localhost".to_string(),
        "127.0.0.1".to_string(),
        "::1".to_string(),
    ];
    let port = addr.port();
    hosts.push(format!("127.0.0.1:{port}"));
    hosts.push(format!("localhost:{port}"));
    hosts.push(format!("[::1]:{port}"));
    if addr.ip().is_unspecified() {
        hosts.push(format!("0.0.0.0:{port}"));
    } else {
        hosts.push(format!("{}:{port}", addr.ip()));
    }
    hosts
}

async fn build_server_from_schema_json(
    schema_json: String,
    executable_path: Option<PathBuf>,
    config: &ClapMcpConfig,
    in_process_handler: Option<InProcessToolHandler>,
    serve_options: &ClapMcpServeOptions,
    metadata: &ClapMcpSchemaMetadata,
) -> Result<ClapMcpServer, ClapMcpError> {
    let schema: crate::ClapSchema = serde_json::from_str(&schema_json)?;
    let tools = crate::tools_from_schema_with_metadata(&schema, config, metadata);
    let root_name = schema.root.name.clone();
    build_clap_mcp_server(
        schema_json,
        tools,
        executable_path,
        in_process_handler,
        root_name,
        config,
        serve_options,
        metadata,
    )
}

/// Starts an MCP server over Streamable HTTP at `listen`, exposing `clap://schema`.
pub(crate) async fn serve_schema_json_over_http(
    listen: SocketAddr,
    schema_json: String,
    executable_path: Option<PathBuf>,
    config: ClapMcpConfig,
    in_process_handler: Option<InProcessToolHandler>,
    mut serve_options: ClapMcpServeOptions,
    metadata: &ClapMcpSchemaMetadata,
) -> Result<(), ClapMcpError> {
    let server = build_server_from_schema_json(
        schema_json,
        executable_path,
        &config,
        in_process_handler,
        &serve_options,
        metadata,
    )
    .await?;

    server::spawn_log_forwarder(&server, serve_options.log_rx.take());

    let server = Arc::new(server);
    let http_config =
        StreamableHttpServerConfig::default().with_allowed_hosts(allowed_hosts_for_listen(listen));

    let service = StreamableHttpService::new(
        {
            let server = server.clone();
            move || Ok((*server).clone())
        },
        Arc::new(LocalSessionManager::default()),
        http_config,
    );

    let router = axum::Router::new().nest_service("/mcp", service);
    let listener = tokio::net::TcpListener::bind(listen).await?;
    axum::serve(listener, router).await?;
    Ok(())
}

#[cfg(test)]
mod tests {
    use super::allowed_hosts_for_listen;
    use std::net::{IpAddr, Ipv4Addr, SocketAddr};

    #[test]
    fn allowed_hosts_for_specific_bind_includes_localhost_variants() {
        let addr = SocketAddr::new(IpAddr::V4(Ipv4Addr::new(127, 0, 0, 1)), 8080);
        let hosts = allowed_hosts_for_listen(addr);
        assert!(hosts.contains(&"localhost".to_string()));
        assert!(hosts.contains(&"127.0.0.1".to_string()));
        assert!(hosts.contains(&"::1".to_string()));
        assert!(hosts.contains(&"127.0.0.1:8080".to_string()));
        assert!(hosts.contains(&"localhost:8080".to_string()));
        assert!(hosts.contains(&"[::1]:8080".to_string()));
        assert!(hosts.contains(&"127.0.0.1:8080".to_string()));
        assert!(!hosts.contains(&"0.0.0.0:8080".to_string()));
    }

    #[test]
    fn allowed_hosts_for_unspecified_bind_includes_wildcard() {
        let addr = SocketAddr::new(IpAddr::V4(Ipv4Addr::UNSPECIFIED), 9000);
        let hosts = allowed_hosts_for_listen(addr);
        assert!(hosts.contains(&"0.0.0.0:9000".to_string()));
    }
}