mcp-streamable-proxy 0.2.4

Streamable HTTP proxy implementation for MCP protocol using rmcp 3.1
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

//! MCP Streamable HTTP Proxy Module
//!
//! This module provides a proxy implementation for MCP (Model Context Protocol)
//! using Streamable HTTP transport with stateful session management.
//!
//! # Features
//!
//! - **Streamable HTTP Support**: Uses rmcp with Streamable HTTP transport
//! - **Stateful Sessions**: Custom SessionManager with backend version tracking
//! - **Per-session URL backends**: each upstream session connects its own backend on `initialize`
//! - **Shared stdio backends**: one child process shared across sessions
//! - **Hot Swap**: Supports backend connection replacement (shared isolation)
//!
//! # Architecture
//!
//! ```text
//! Client → Streamable HTTP → ProxyAwareSessionManager → ProxyHandler → Backend MCP Service
//!   URL (per-session): each session opens its own backend (connect on initialize)
//!   Stdio (shared): one backend, clones share Arcs + notification fan-out registry
//! ```
//!
//! # Example
//!
//! ```rust,ignore
//! use mcp_streamable_proxy::{StreamClientConnection, McpClientConfig};
//!
//! // Connect to an MCP server
//! let config = McpClientConfig::new("http://localhost:8080/mcp");
//! let conn = StreamClientConnection::connect(config).await?;
//!
//! // List available tools
//! let tools = conn.list_tools().await?;
//! ```

pub mod backend_client;
pub mod backend_connector;
pub mod client;
pub mod config;
pub mod detector;
pub mod fallback;
pub mod proxy_handler;
pub mod server;
pub mod server_builder;
pub mod session_manager;

// Re-export main types
pub use backend_client::{
    BackendNotificationBridge, NotifyTarget, ProgressRouteGuard, UpstreamPeerRegistry,
    UpstreamPeerSlot,
};
pub use backend_connector::{
    BackendConnector, BackendIsolation, StdioBackendConnector, UrlBackendConnector,
};
pub use mcp_common::McpServiceConfig;
pub use proxy_handler::{BackendRunningService, ProxyHandler, ToolFilter};
pub use server::{run_stream_server, run_stream_server_from_config};
pub use session_manager::ProxyAwareSessionManager;

// Re-export protocol detection function
pub use detector::{is_streamable_http, is_streamable_http_with_headers};

// Re-export server builder API
pub use server_builder::{BackendConfig, StreamServerBuilder, StreamServerConfig};

// Re-export client connection types
pub use client::{StreamClientConnection, ToolInfo};
pub use fallback::{DiscoverySnapshot, FallbackMetadata};
pub use mcp_common::McpClientConfig;

// Re-export commonly used rmcp types
pub use rmcp::{
    RoleClient, RoleServer, ServerHandler, ServiceExt,
    model::{ClientCapabilities, ClientInfo, Implementation, ServerInfo},
    service::{Peer, RunningService},
};

// Re-export transport types for Streamable HTTP protocol
pub use rmcp::transport::{
    StreamableHttpServerConfig, child_process::TokioChildProcess, stdio,
    streamable_http_client::StreamableHttpClientTransport,
    streamable_http_client::StreamableHttpClientTransportConfig,
};

// Re-export server-side Streamable HTTP types
pub use rmcp::transport::streamable_http_server::{
    StreamableHttpService, session::local::LocalSessionManager,
};