synwire-mcp-adapters 0.1.0

High-level MCP adapters: multi-server client, tool conversion, interceptors, and provider abstraction
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

# synwire-mcp-adapters

High-level MCP adapters for Synwire. Connects to multiple MCP servers simultaneously, aggregates their tools under a unified interface, and provides transport, validation, interceptors, and pagination out of the box.

## What this crate provides

- **`MultiServerMcpClient`** -- connects to N named MCP servers and routes tool calls to the correct server
- **`Connection`** -- transport configuration enum (Stdio, SSE, `StreamableHttp`, WebSocket)
- **`WebSocketMcpTransport`** -- WebSocket transport implementing `McpTransport`
- **`McpClientSession`** -- RAII session guard with drop-time cleanup
- **`McpToolProvider`** -- `ToolProvider` backed by `MultiServerMcpClient`
- **`ToolCallInterceptor`** -- onion-ordered middleware for tool call logging, rate limiting, or mutation
- **`validate_tool_arguments`** -- client-side JSON Schema validation before sending tool calls
- **`PaginationCursor`** -- cursor-based pagination with a 1000-page cap
- **`McpCallbacks`** -- logging, progress, and elicitation callback bundle
- **Bidirectional conversion** -- MCP tools to Synwire tools and back (`convert` module)
- **Zero unsafe code** -- `#![forbid(unsafe_code)]`

## Quick start

```toml
[dependencies]
synwire-mcp-adapters = "0.1"
```

Connect to two MCP servers and list aggregated tools:

```rust,no_run
use synwire_mcp_adapters::{MultiServerMcpClient, MultiServerMcpClientConfig, Connection};
use std::collections::HashMap;

#[tokio::main]
async fn main() -> anyhow::Result<()> {
    let mut servers = HashMap::new();
    servers.insert("files".into(), Connection::Stdio {
        command: "mcp-file-server".into(),
        args: vec![],
        env: HashMap::new(),
    });
    servers.insert("search".into(), Connection::Sse {
        url: "http://localhost:8080/mcp".into(),
        auth_token: None,
        timeout_secs: Some(30),
    });

    let config = MultiServerMcpClientConfig { servers };
    let client = MultiServerMcpClient::connect(config).await?;

    for tool in client.list_tools().await? {
        println!("{}: {}", tool.name, tool.description);
    }
    Ok(())
}
```

## Documentation

- [MCP Integration Guide](https://randomvariable.github.io/synwire/how-to/mcp-integration.html)
- [Full API docs](https://docs.rs/synwire-mcp-adapters)
- [Synwire documentation](https://randomvariable.github.io/synwire/)