fix: update rmcp type aliases to non-deprecated versions

Renamed deprecated type aliases following rmcp library update:
- CallToolRequestParam → CallToolRequestParams
- InitializeRequestParam → InitializeRequestParams
- PaginatedRequestParam → PaginatedRequestParams

Also added required `meta` field to ClientInfo and CallToolRequestParams.

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
This commit is contained in:
Ruben Fiszel
2026-01-26 08:03:20 +00:00
co-authored by Claude Opus 4.5
parent 4327bde002
commit c105844c08
3 changed files with 17 additions and 15 deletions
+6 -4
View File
@@ -11,8 +11,8 @@ use anyhow::{Context, Result};
use reqwest::header::{HeaderMap, HeaderName, HeaderValue};
use rmcp::{
model::{
CallToolRequestParam, ClientCapabilities, ClientInfo, Implementation,
InitializeRequestParam, Tool as McpTool,
CallToolRequestParams, ClientCapabilities, ClientInfo, Implementation,
InitializeRequestParams, Tool as McpTool,
},
service::RunningService,
transport::{
@@ -28,7 +28,7 @@ use windmill_common::DB;
/// MCP client for communicating with external MCP servers
pub struct McpClient {
/// The underlying rmcp client
client: RunningService<RoleClient, InitializeRequestParam>,
client: RunningService<RoleClient, InitializeRequestParams>,
/// Cached list of available tools from the server
available_tools: Vec<McpTool>,
}
@@ -82,6 +82,7 @@ impl McpClient {
website_url: None,
icons: None,
},
meta: None,
};
// Initialize the connection
@@ -113,10 +114,11 @@ impl McpClient {
let result = self
.client
.call_tool(CallToolRequestParam {
.call_tool(CallToolRequestParams {
name: name.to_string().into(),
arguments: mcp_args,
task: None,
meta: None,
})
.await
.context(format!("Failed to call MCP tool: {}", name))?;
+3 -3
View File
@@ -19,9 +19,9 @@ pub use tools::create_tool_from_item;
// Re-export rmcp types for convenience
pub use rmcp::handler::server::ServerHandler;
pub use rmcp::model::{
Annotated, CallToolRequestParam, CallToolResult, Content, Implementation,
InitializeRequestParam, InitializeResult, ListPromptsResult, ListResourceTemplatesResult,
ListResourcesResult, ListToolsResult, PaginatedRequestParam, ProtocolVersion, RawContent,
Annotated, CallToolRequestParams, CallToolResult, Content, Implementation,
InitializeRequestParams, InitializeResult, ListPromptsResult, ListResourceTemplatesResult,
ListResourcesResult, ListToolsResult, PaginatedRequestParams, ProtocolVersion, RawContent,
RawTextContent, ServerCapabilities, ServerInfo, Tool, ToolAnnotations,
};
pub use rmcp::service::{RequestContext, RoleServer};
+8 -8
View File
@@ -12,9 +12,9 @@ use crate::server::endpoints::endpoint_tool_to_mcp_tool;
use crate::server::tools::create_tool_from_item;
use rmcp::handler::server::ServerHandler;
use rmcp::model::{
CallToolRequestParam, CallToolResult, Content, Implementation, InitializeRequestParam,
CallToolRequestParams, CallToolResult, Content, Implementation, InitializeRequestParams,
InitializeResult, ListPromptsResult, ListResourceTemplatesResult, ListResourcesResult,
ListToolsResult, PaginatedRequestParam, ProtocolVersion, ServerCapabilities, ServerInfo,
ListToolsResult, PaginatedRequestParams, ProtocolVersion, ServerCapabilities, ServerInfo,
};
use rmcp::service::{RequestContext, RoleServer};
use rmcp::ErrorData;
@@ -97,7 +97,7 @@ impl<B: McpBackend> ServerHandler for Runner<B> {
async fn initialize(
&self,
_request: InitializeRequestParam,
_request: InitializeRequestParams,
_context: RequestContext<RoleServer>,
) -> Result<InitializeResult, ErrorData> {
Ok(self.get_info())
@@ -105,7 +105,7 @@ impl<B: McpBackend> ServerHandler for Runner<B> {
async fn list_tools(
&self,
_request: Option<PaginatedRequestParam>,
_request: Option<PaginatedRequestParams>,
context: RequestContext<RoleServer>,
) -> Result<ListToolsResult, ErrorData> {
let (auth, workspace_id) = Self::extract_context(&context)?;
@@ -221,7 +221,7 @@ impl<B: McpBackend> ServerHandler for Runner<B> {
async fn call_tool(
&self,
request: CallToolRequestParam,
request: CallToolRequestParams,
context: RequestContext<RoleServer>,
) -> Result<CallToolResult, ErrorData> {
let (auth, workspace_id) = Self::extract_context(&context)?;
@@ -349,7 +349,7 @@ impl<B: McpBackend> ServerHandler for Runner<B> {
async fn list_resources(
&self,
_request: Option<PaginatedRequestParam>,
_request: Option<PaginatedRequestParams>,
_context: RequestContext<RoleServer>,
) -> Result<ListResourcesResult, ErrorData> {
Ok(ListResourcesResult { resources: vec![], next_cursor: None, meta: None })
@@ -357,7 +357,7 @@ impl<B: McpBackend> ServerHandler for Runner<B> {
async fn list_prompts(
&self,
_request: Option<PaginatedRequestParam>,
_request: Option<PaginatedRequestParams>,
_context: RequestContext<RoleServer>,
) -> Result<ListPromptsResult, ErrorData> {
Ok(ListPromptsResult::default())
@@ -365,7 +365,7 @@ impl<B: McpBackend> ServerHandler for Runner<B> {
async fn list_resource_templates(
&self,
_request: Option<PaginatedRequestParam>,
_request: Option<PaginatedRequestParams>,
_context: RequestContext<RoleServer>,
) -> Result<ListResourceTemplatesResult, ErrorData> {
Ok(ListResourceTemplatesResult::default())