turbomcp-proxy 3.0.12

Universal MCP adapter/generator - introspection, proxying, and code generation for any MCP server
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
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108

//! Generated types for {{server_name}}
//!
//! This module contains all type definitions extracted from the MCP server
//! specification, including tool inputs, outputs, and enums.

use serde::{Deserialize, Serialize};
use serde_json::Value;

{{#each type_definitions}}
/// {{this.description}}
#[derive(Debug, Clone, Serialize, Deserialize)]
{{#if this.rename}}
#[serde(rename = "{{this.rename}}")]
{{/if}}
pub struct {{this.name}} {
    {{#each this.fields}}
    {{#if this.description}}
    /// {{this.description}}
    {{/if}}
    {{#if this.optional}}
    #[serde(skip_serializing_if = "Option::is_none")]
    pub {{this.name}}: Option<{{this.rust_type}}>,
    {{else}}
    pub {{this.name}}: {{this.rust_type}},
    {{/if}}
    {{/each}}
}

{{/each}}

/// Tool enum for type-safe tool dispatch
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(tag = "name")]
pub enum Tool {
    {{#each tool_enums}}
    #[serde(rename = "{{this.name}}")]
    {{pascal_case this.name}} {
        {{#each this.params}}
        {{#if this.optional}}
        #[serde(skip_serializing_if = "Option::is_none")]
        {{this.name}}: Option<{{this.rust_type}}>,
        {{else}}
        {{this.name}}: {{this.rust_type}},
        {{/if}}
        {{/each}}
    },
    {{/each}}
}

impl Tool {
    /// Get the tool name
    pub fn name(&self) -> &str {
        match self {
            {{#each tool_enums}}
            Tool::{{pascal_case this.name}} { .. } => "{{this.name}}",
            {{/each}}
            #[allow(unreachable_patterns)]
            _ => unreachable!("All Tool variants are handled"),
        }
    }

    /// Convert tool to JSON arguments
    pub fn to_arguments(&self) -> Value {
        serde_json::to_value(self).unwrap_or(Value::Null)
    }
}

/// Resource enum for type-safe resource access
#[derive(Debug, Clone, Serialize, Deserialize)]
pub enum Resource {
    {{#each resource_enums}}
    {{pascal_case this.name}},
    {{/each}}
}

impl Resource {
    /// Get the resource URI
    pub fn uri(&self) -> &str {
        match self {
            {{#each resource_enums}}
            Resource::{{pascal_case this.name}} => "{{this.uri}}",
            {{/each}}
            #[allow(unreachable_patterns)]
            _ => unreachable!("All Resource variants are handled"),
        }
    }
}

/// Prompt enum for type-safe prompt access
#[derive(Debug, Clone, Serialize, Deserialize)]
pub enum Prompt {
    {{#each prompt_enums}}
    {{pascal_case this.name}},
    {{/each}}
}

impl Prompt {
    /// Get the prompt name
    pub fn name(&self) -> &str {
        match self {
            {{#each prompt_enums}}
            Prompt::{{pascal_case this.name}} => "{{this.name}}",
            {{/each}}
            #[allow(unreachable_patterns)]
            _ => unreachable!("All Prompt variants are handled"),
        }
    }
}