turbomcp_protocol/types/
requests.rs

1//! Request/response/notification routing types
2//!
3//! This module contains the top-level enums that route different types of
4//! MCP requests and notifications between clients and servers.
5
6use serde::{Deserialize, Serialize};
7
8use super::{
9    completion::CompleteRequestParams,
10    elicitation::ElicitRequestParams,
11    initialization::{InitializeRequest, InitializedNotification},
12    logging::{LoggingNotification, ProgressNotification, SetLevelRequest},
13    ping::PingParams,
14    prompts::{GetPromptRequest, ListPromptsRequest},
15    resources::{
16        ListResourceTemplatesRequest, ListResourcesRequest, ReadResourceRequest,
17        ResourceUpdatedNotification, SubscribeRequest, UnsubscribeRequest,
18    },
19    roots::{ListRootsRequest, RootsListChangedNotification},
20    sampling::CreateMessageRequest,
21    tools::{CallToolRequest, ListToolsRequest},
22};
23
24/// Client-initiated request
25#[derive(Debug, Clone, Serialize, Deserialize)]
26#[serde(tag = "method")]
27pub enum ClientRequest {
28    /// Initialize the connection
29    #[serde(rename = "initialize")]
30    Initialize(InitializeRequest),
31
32    /// List available tools
33    #[serde(rename = "tools/list")]
34    ListTools(ListToolsRequest),
35
36    /// Call a tool
37    #[serde(rename = "tools/call")]
38    CallTool(CallToolRequest),
39
40    /// List available prompts
41    #[serde(rename = "prompts/list")]
42    ListPrompts(ListPromptsRequest),
43
44    /// Get a specific prompt
45    #[serde(rename = "prompts/get")]
46    GetPrompt(GetPromptRequest),
47
48    /// List available resources
49    #[serde(rename = "resources/list")]
50    ListResources(ListResourcesRequest),
51
52    /// List resource templates
53    #[serde(rename = "resources/templates/list")]
54    ListResourceTemplates(ListResourceTemplatesRequest),
55
56    /// Read a resource
57    #[serde(rename = "resources/read")]
58    ReadResource(ReadResourceRequest),
59
60    /// Subscribe to resource updates
61    #[serde(rename = "resources/subscribe")]
62    Subscribe(SubscribeRequest),
63
64    /// Unsubscribe from resource updates
65    #[serde(rename = "resources/unsubscribe")]
66    Unsubscribe(UnsubscribeRequest),
67
68    /// Set logging level
69    #[serde(rename = "logging/setLevel")]
70    SetLevel(SetLevelRequest),
71
72    /// Complete argument
73    #[serde(rename = "completion/complete")]
74    Complete(CompleteRequestParams),
75
76    /// Ping to check connection
77    #[serde(rename = "ping")]
78    Ping(PingParams),
79}
80
81/// Server-initiated request
82#[derive(Debug, Clone, Serialize, Deserialize)]
83#[serde(tag = "method")]
84pub enum ServerRequest {
85    /// Ping to check connection
86    #[serde(rename = "ping")]
87    Ping(PingParams),
88
89    /// Create a message (sampling) - server requests LLM sampling from client
90    #[serde(rename = "sampling/createMessage")]
91    CreateMessage(CreateMessageRequest),
92
93    /// List filesystem roots - server requests root URIs from client
94    #[serde(rename = "roots/list")]
95    ListRoots(ListRootsRequest),
96
97    /// Elicit user input
98    #[serde(rename = "elicitation/create")]
99    ElicitationCreate(ElicitRequestParams),
100}
101
102/// Client-sent notification
103#[derive(Debug, Clone, Serialize, Deserialize)]
104#[serde(tag = "method")]
105pub enum ClientNotification {
106    /// Connection initialized
107    #[serde(rename = "notifications/initialized")]
108    Initialized(InitializedNotification),
109
110    /// Roots list changed
111    #[serde(rename = "notifications/roots/list_changed")]
112    RootsListChanged(RootsListChangedNotification),
113}
114
115/// Server-sent notification
116#[derive(Debug, Clone, Serialize, Deserialize)]
117#[serde(tag = "method")]
118pub enum ServerNotification {
119    /// Log message
120    #[serde(rename = "notifications/message")]
121    Message(LoggingNotification),
122
123    /// Progress update for a request
124    #[serde(rename = "notifications/progress")]
125    Progress(ProgressNotification),
126
127    /// Resource updated
128    #[serde(rename = "notifications/resources/updated")]
129    ResourceUpdated(ResourceUpdatedNotification),
130
131    /// Resource list changed
132    #[serde(rename = "notifications/resources/list_changed")]
133    ResourceListChanged,
134
135    /// Request cancellation
136    #[serde(rename = "notifications/cancelled")]
137    Cancelled(CancelledNotification),
138
139    /// Prompts list changed
140    #[serde(rename = "notifications/prompts/list_changed")]
141    PromptsListChanged,
142
143    /// Tools list changed
144    #[serde(rename = "notifications/tools/list_changed")]
145    ToolsListChanged,
146
147    /// Roots list changed
148    #[serde(rename = "notifications/roots/list_changed")]
149    RootsListChanged,
150}
151
152/// Cancellation notification
153#[derive(Debug, Clone, Serialize, Deserialize)]
154pub struct CancelledNotification {
155    /// Request ID that was cancelled
156    #[serde(rename = "requestId")]
157    pub request_id: super::core::RequestId,
158    /// Optional reason for cancellation
159    pub reason: Option<String>,
160}
turbomcp_protocol/types/requests.rs

turbomcp_protocol/types/
requests.rs
