agent-client-protocol 0.11.0

Core protocol types and traits for the Agent Client Protocol
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

use std::sync::Arc;

use crate::{
    DynConnectTo,
    mcp_server::McpConnectionTo,
    role::{self, Role},
};

/// Trait for types that can create MCP server connections.
///
/// Implement this trait to create custom MCP servers. Each call to [`connect`](Self::connect)
/// should return a new [`ConnectTo`](crate::ConnectTo) that serves MCP requests for a single
/// connection.
///
/// # Example
///
/// ```rust,ignore
/// use agent_client_protocol::mcp_server::{McpServerConnect, McpConnectionTo};
/// use agent_client_protocol::{DynConnectTo, role::Role};
///
/// struct MyMcpServer {
///     name: String,
/// }
///
/// impl<R: Role> McpServerConnect<R> for MyMcpServer {
///     fn name(&self) -> String {
///         self.name.clone()
///     }
///
///     fn connect(&self, cx: McpConnectionTo<R>) -> DynConnectTo<role::mcp::Client> {
///         // Create and return a component that handles MCP requests
///         DynConnectTo::new(MyMcpComponent::new(cx))
///     }
/// }
/// ```
pub trait McpServerConnect<Counterpart: Role>: Send + Sync + 'static {
    /// The name of the MCP server, used to identify it in session responses.
    fn name(&self) -> String;

    /// Create a component to service a new MCP connection.
    ///
    /// This is called each time an agent connects to this MCP server. The returned
    /// component will handle MCP protocol messages for that connection.
    ///
    /// The [`McpConnectionTo`] provides access to the ACP connection context and the
    /// server's ACP URL.
    fn connect(&self, cx: McpConnectionTo<Counterpart>) -> DynConnectTo<role::mcp::Client>;
}

impl<Counterpart: Role, S: ?Sized + McpServerConnect<Counterpart>> McpServerConnect<Counterpart>
    for Box<S>
{
    fn name(&self) -> String {
        S::name(self)
    }

    fn connect(&self, cx: McpConnectionTo<Counterpart>) -> DynConnectTo<role::mcp::Client> {
        S::connect(self, cx)
    }
}

impl<Counterpart: Role, S: ?Sized + McpServerConnect<Counterpart>> McpServerConnect<Counterpart>
    for Arc<S>
{
    fn name(&self) -> String {
        S::name(self)
    }

    fn connect(&self, cx: McpConnectionTo<Counterpart>) -> DynConnectTo<role::mcp::Client> {
        S::connect(self, cx)
    }
}