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
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
|
use libmcp::ReplayContract;
use serde_json::{Value, json};
use crate::mcp::output::with_common_presentation;
#[derive(Clone, Copy, Debug, Eq, PartialEq)]
pub(crate) enum DispatchTarget {
Host,
Worker,
}
#[derive(Clone, Copy, Debug, Eq, PartialEq)]
pub(crate) struct ToolSpec {
pub(crate) name: &'static str,
pub(crate) description: &'static str,
pub(crate) dispatch: DispatchTarget,
pub(crate) replay: ReplayContract,
}
impl ToolSpec {
fn annotation_json(self) -> Value {
json!({
"title": self.name,
"readOnlyHint": self.replay == ReplayContract::Convergent,
"destructiveHint": self.replay == ReplayContract::NeverReplay,
"jiraAtHome": {
"dispatch": match self.dispatch {
DispatchTarget::Host => "host",
DispatchTarget::Worker => "worker",
},
"replayContract": match self.replay {
ReplayContract::Convergent => "convergent",
ReplayContract::ProbeRequired => "probe_required",
ReplayContract::NeverReplay => "never_replay",
},
}
})
}
}
const TOOL_SPECS: &[ToolSpec] = &[
ToolSpec {
name: "project.bind",
description: "Bind this MCP session to a project root or a nested path inside one.",
dispatch: DispatchTarget::Host,
replay: ReplayContract::NeverReplay,
},
ToolSpec {
name: "issue.save",
description: "Create or overwrite one issue note at `issues/<slug>.md`.",
dispatch: DispatchTarget::Worker,
replay: ReplayContract::NeverReplay,
},
ToolSpec {
name: "issue.list",
description: "List the currently open issues. There is no close state; all existing issue files are open.",
dispatch: DispatchTarget::Worker,
replay: ReplayContract::Convergent,
},
ToolSpec {
name: "issue.read",
description: "Read one issue note by slug.",
dispatch: DispatchTarget::Worker,
replay: ReplayContract::Convergent,
},
ToolSpec {
name: "system.health",
description: "Read MCP host health, binding state, worker generation, and rollout state.",
dispatch: DispatchTarget::Host,
replay: ReplayContract::Convergent,
},
ToolSpec {
name: "system.telemetry",
description: "Read aggregate MCP host telemetry and top hot methods for this session.",
dispatch: DispatchTarget::Host,
replay: ReplayContract::Convergent,
},
];
pub(crate) fn tool_spec(name: &str) -> Option<ToolSpec> {
TOOL_SPECS.iter().copied().find(|spec| spec.name == name)
}
pub(crate) fn tool_definitions() -> Vec<Value> {
TOOL_SPECS
.iter()
.map(|spec| {
json!({
"name": spec.name,
"description": spec.description,
"inputSchema": tool_schema(spec.name),
"annotations": spec.annotation_json(),
})
})
.collect()
}
fn tool_schema(name: &str) -> Value {
match name {
"project.bind" => with_common_presentation(json!({
"type": "object",
"properties": {
"path": {
"type": "string",
"description": "Project root or any nested path inside the target project."
}
},
"required": ["path"]
})),
"issue.save" => with_common_presentation(json!({
"type": "object",
"properties": {
"slug": {
"type": "string",
"description": "Stable slug. Stored at `issues/<slug>.md`."
},
"body": {
"type": "string",
"description": "Freeform issue body. Markdown is fine."
}
},
"required": ["slug", "body"]
})),
"issue.list" | "system.health" | "system.telemetry" => with_common_presentation(json!({
"type": "object",
"properties": {}
})),
"issue.read" => with_common_presentation(json!({
"type": "object",
"properties": {
"slug": {
"type": "string",
"description": "Issue slug to read."
}
},
"required": ["slug"]
})),
_ => Value::Null,
}
}
|