systemprompt-mcp 0.26.0

Native Model Context Protocol (MCP) implementation for systemprompt.io. Orchestration, per-server OAuth2, RBAC middleware, and tool-call governance — the core of the AI governance pipeline.
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

//! Conversions between rmcp and provider-contract tool types.
//!
//! Copyright (c) systemprompt.io — Business Source License 1.1.
//! See <https://systemprompt.io> for licensing details.

use systemprompt_models::ai::tools::McpTool;
use systemprompt_traits::{ToolCallResult, ToolContent, ToolDefinition};

pub fn to_tool_definition(mcp_tool: &McpTool) -> ToolDefinition {
    ToolDefinition {
        name: mcp_tool.name.clone(),
        description: mcp_tool.description.clone(),
        input_schema: mcp_tool.input_schema.clone(),
        output_schema: mcp_tool.output_schema.clone(),
        service_id: mcp_tool.service_id.to_string(),
        terminal_on_success: mcp_tool.terminal_on_success,
        model_config: mcp_tool
            .model_config
            .as_ref()
            .and_then(|c| serde_json::to_value(c).ok()),
    }
}

pub fn to_tool_result(rmcp_result: &rmcp::model::CallToolResult) -> ToolCallResult {
    let content = rmcp_result
        .content
        .iter()
        .filter_map(|c| match c {
            rmcp::model::ContentBlock::Text(text) => Some(ToolContent::Text {
                text: text.text.clone(),
            }),
            rmcp::model::ContentBlock::Image(img) => Some(ToolContent::Image {
                data: img.data.clone(),
                mime_type: img.mime_type.clone(),
            }),
            rmcp::model::ContentBlock::ResourceLink(res) => Some(ToolContent::Resource {
                uri: res.uri.clone(),
                mime_type: res.mime_type.clone(),
            }),
            _ => None,
        })
        .collect();

    ToolCallResult {
        content,
        structured_content: rmcp_result.structured_content.clone(),
        is_error: rmcp_result.is_error,
        meta: rmcp_result
            .meta
            .as_ref()
            .and_then(|m| serde_json::to_value(m).ok()),
    }
}