Skip to content
1,098 linesCodeBlameRaw
1//! The MCP server's tools: a few resource tools, each with an `action`.
2//!
3//! Every operation is one action of one tool. A call is dispatched to the
4//! operation it names, so permissions, the audit log, billing and outcomes
5//! are exactly those of the REST API. A token sees only the actions its
6//! scopes allow, and a tool none of whose actions it may use is not listed.
7//!
8//! The listed input schema is one flat object: `action`, then every field
9//! any of its actions takes. Which fields each action needs is in the
10//! `action` field's description and checked on every call. Claude's API,
11//! and so most MCP clients, refuse a tool whose input schema has `oneOf`
12//! at its top level, so the schema keyed by action, with each action's
13//! required fields, is [`discriminated`], published on the server's card
14//! and in the docs.
15
16use g1t_contracts::credentials::NEVER;
17use g1t_contracts::identity::AgentScope;
18use g1t_contracts::scopes::{Level, NO_SCOPE, TokenAccess, scope_for};
19use serde_json::{Map, Value, json};
20
21use crate::about::AboutOp;
22use crate::run_artifacts::ArtifactsOp;
23use crate::deploy_keys::DeployKeysOp;
24use crate::mirrors::MirrorsOp;
25use crate::deployments::DeploymentsOp;
26use crate::packages::PackagesOp;
27use crate::folios::FoliosOp;
28use crate::protection::ProtectionOp;
29use crate::token_policy::TokenOp;
30use crate::operations::Op;
31use crate::checks::ChecksOp;
32use crate::rules::RulesOp;
33use crate::security::SecurityOp;
34
35pub struct Action {
36 pub name: &'static str,
37 pub op: Op,
38 /// One line, for the `action` field's description.
39 pub summary: &'static str,
40}
41
42pub struct Tool {
43 pub name: &'static str,
44 pub title: &'static str,
45 /// What it is for, in a sentence or two.
46 pub description: &'static str,
47 pub actions: &'static [Action],
48 /// The action a call without one runs.
49 pub default_action: Option<&'static str>,
50}
51
52const fn a(name: &'static str, op: Op, summary: &'static str) -> Action {
53 Action { name, op, summary }
54}
55
56pub const TOOLS: &[Tool] = &[
57 Tool {
58 name: "search",
59 title: "Search",
60 description: "Find things. `code` (the default) searches all of g1t you can see: repositories, code, issues, pull requests and people, with qualifiers like repo:owner/name, language:rust, is:issue. `context` searches one workspace's catalog, docs, issues and memory by meaning.",
61 default_action: Some("code"),
62 actions: &[
63 a("code", Op::Search, "Search all of g1t: repositories, code, issues, pull requests, people"),
64 a("context", Op::SearchContext, "Search a workspace's context hub by meaning"),
65 a("entity", Op::GetEntity, "One catalog entry and its relations"),
66 a("ticket", Op::GetContext, "A Jira, Linear or Sentry item the work refers to, as it is now"),
67 ],
68 },
69 Tool {
70 name: "repository",
71 title: "Repositories",
72 description: "Repositories: find, read and create them, change their settings and rulesets (what may happen to branches and tags, and what a pull request needs to merge), check their CODEOWNERS file, manage their labels and milestones, see and dismiss their security alerts (secrets and vulnerable dependencies), read what their default branch says (languages, contributors, license), star them, publish releases, and look after their mirroring (take a mirror over, hand it back, or move it to g1t for good). Name one as \"owner/name\". Deleting, transferring and changing visibility need `confirm`.",
73 default_action: None,
74 actions: &[
75 a("list", Op::ListRepos, "Repositories you can see"),
76 a("get", Op::GetRepo, "One repository"),
77 a("create", Op::CreateRepo, "Create one, empty or copied from a public git URL"),
78 a("update", Op::UpdateRepo, "Change description, website, topics, default branch, protection"),
79 a("get_settings", Op::GetRepoSettings, "How pull requests merge, and the default branch's protection as its rules stack"),
80 a("update_settings", Op::UpdateRepoSettings, "Change how pull requests merge and the default branch protection ruleset"),
81 a("check_names", Op::ListCheckNames, "Check names reported lately, to require in a ruleset"),
82 a("list_rulesets", Op::Rules(RulesOp::ListRepoRulesets), "Its rulesets, and its workspace's that hold in it"),
83 a("get_ruleset", Op::Rules(RulesOp::GetRepoRuleset), "One ruleset"),
84 a("create_ruleset", Op::Rules(RulesOp::CreateRepoRuleset), "Create a ruleset for its branches or tags"),
85 a("update_ruleset", Op::Rules(RulesOp::UpdateRepoRuleset), "Change a ruleset"),
86 a("delete_ruleset", Op::Rules(RulesOp::DeleteRepoRuleset), "Delete a ruleset"),
87 a("branch_rules", Op::Rules(RulesOp::GetBranchRules), "Every rule that holds for a branch or tag, and where it comes from"),
88 a("rule_evaluations", Op::Rules(RulesOp::ListRuleEvaluations), "How its rules judged pushes and merges, with insights"),
89 a("codeowners", Op::GetCodeownersErrors, "Problems in its CODEOWNERS file, by line"),
90 a("list_labels", Op::ListLabels, "Labels, with colors and how many issues and pull requests carry each"),
91 a("create_label", Op::CreateLabel, "Create a label"),
92 a("update_label", Op::UpdateLabel, "Rename a label or change its color or description"),
93 a("delete_label", Op::DeleteLabel, "Delete a label, from everything that carries it"),
94 a("add_default_labels", Op::AddDefaultLabels, "Add the default labels it is missing"),
95 a("list_milestones", Op::ListMilestones, "Milestones, with progress and due dates"),
96 a("get_milestone", Op::GetMilestone, "One milestone with its issues and pull requests"),
97 a("create_milestone", Op::CreateMilestone, "Create a milestone"),
98 a("update_milestone", Op::UpdateMilestone, "Change a milestone's title, description, due date or state"),
99 a("delete_milestone", Op::DeleteMilestone, "Delete a milestone"),
100 a("list_events", Op::ListEvents, "Timeline: pushes, issues, pull requests, comments"),
101 a("languages", Op::About(AboutOp::GetLanguages), "Its languages by bytes, with colors and percentages"),
102 a("contributors", Op::About(AboutOp::ListContributors), "Who made it: commits per person, agent and author, by week"),
103 a("license", Op::About(AboutOp::GetLicense), "The license its LICENSE file holds"),
104 a("stargazers", Op::About(AboutOp::ListStargazers), "Who starred it"),
105 a("starred", Op::About(AboutOp::CheckStarred), "Whether you starred it, and how many have"),
106 a("star", Op::About(AboutOp::Star), "Star it"),
107 a("unstar", Op::About(AboutOp::Unstar), "Take your star back"),
108 a("list_starred", Op::About(AboutOp::ListStarred), "Repositories you starred"),
109 a("list_releases", Op::About(AboutOp::ListReleases), "Releases, newest first"),
110 a("latest_release", Op::About(AboutOp::GetLatestRelease), "The latest release"),
111 a("get_release", Op::About(AboutOp::GetRelease), "One release by id"),
112 a("get_release_by_tag", Op::About(AboutOp::GetReleaseByTag), "The release of a tag"),
113 a("create_release", Op::About(AboutOp::CreateRelease), "Publish a release of a tag, making the tag if needed"),
114 a("update_release", Op::About(AboutOp::UpdateRelease), "Change a release's title, notes, draft or prerelease"),
115 a("delete_release", Op::About(AboutOp::DeleteRelease), "Delete a release; its tag stays"),
116 a("rename_branch", Op::RenameBranch, "Rename a branch"),
117 a("rename", Op::RenameRepo, "Rename it; old addresses redirect"),
118 a("transfer", Op::TransferRepo, "Move it to another workspace you own"),
119 a("mirror", Op::Mirrors(MirrorsOp::GetMirror), "Its remotes: what it mirrors or is mirrored to"),
120 a("mirror_hand_back_plan", Op::Mirrors(MirrorsOp::GetHandBackPlan), "What handing a takeover back would do, ref by ref"),
121 a("mirror_take_over", Op::Mirrors(MirrorsOp::TakeOver), "Make g1t lead a mirror for now"),
122 a("mirror_ci", Op::Mirrors(MirrorsOp::SetCiFailover), "Run a mirror's workflows on g1t (on), or stop (off)"),
123 a("mirror_hand_back", Op::Mirrors(MirrorsOp::HandBack), "Send a takeover back, deciding diverged refs"),
124 a("mirror_move_to_g1t", Op::Mirrors(MirrorsOp::MoveToG1t), "Stop tracking the remote; g1t leads for good"),
125 a("mirror_sync", Op::Mirrors(MirrorsOp::SyncMirror), "Bring its remotes in step now"),
126 a("mirror_add_remote", Op::Mirrors(MirrorsOp::AddRemote), "Link another g1t or git host"),
127 a("mirror_update_remote", Op::Mirrors(MirrorsOp::UpdateRemote), "Change a remote's settings"),
128 a("mirror_remove_remote", Op::Mirrors(MirrorsOp::RemoveRemote), "Unlink a remote"),
129 a("archive", Op::ArchiveRepo, "Make it read-only"),
130 a("unarchive", Op::UnarchiveRepo, "Make it writable again"),
131 a("set_visibility", Op::SetRepoVisibility, "Make it public or private"),
132 a("delete", Op::DeleteRepo, "Delete it; restorable for 30 days"),
133 a("list_deleted", Op::ListDeletedRepos, "A workspace's deleted repositories"),
134 a("restore", Op::RestoreRepo, "Restore a deleted one"),
135 a("purge", Op::PurgeRepo, "Remove a deleted one for good"),
136 a("security_alerts", Op::ListSecurityAlerts, "Secret and dependency alerts, filtered by state"),
137 a("dismiss_alert", Op::DismissSecurityAlert, "Dismiss an alert with a reason"),
138 a("reopen_alert", Op::ReopenSecurityAlert, "Reopen a dismissed alert"),
139 ],
140 },
141 Tool {
142 name: "issue",
143 title: "Issues",
144 description: "Issues: what should change. Read one before working on it to see the pull requests already made for it. Issues and pull requests share numbers; `comment` works on either.",
145 default_action: None,
146 actions: &[
147 a("list", Op::ListIssues, "Issues on a repository, newest first"),
148 a("get", Op::GetIssue, "One issue with comments and its pull requests"),
149 a("create", Op::CreateIssue, "Open an issue"),
150 a("update", Op::UpdateIssue, "Change title, body, labels, milestone or assignees"),
151 a("labels", Op::ListIssueLabels, "The labels an issue or pull request carries"),
152 a("add_labels", Op::AddIssueLabels, "Add labels to an issue or pull request"),
153 a("set_labels", Op::SetIssueLabels, "Replace the labels of an issue or pull request"),
154 a("remove_labels", Op::RemoveIssueLabels, "Take labels off an issue or pull request"),
155 a("close", Op::CloseIssue, "Close it without a pull request"),
156 a("reopen", Op::ReopenIssue, "Reopen it"),
157 a("comment", Op::AddComment, "Comment on an issue or pull request; path and line for one line of a change"),
158 a("edit_comment", Op::EditComment, "Change a comment's text: your own, or any with the Maintain role"),
159 a("delete_comment", Op::DeleteComment, "Delete a comment: your own, or any with the Maintain role"),
160 a("import", Op::ImportIssue, "Open an issue from a Jira, Linear or Sentry item"),
161 ],
162 },
163 Tool {
164 name: "pull_request",
165 title: "Pull requests",
166 description: "Pull requests: start a change for an issue, record your session, mark it ready, ask people and teams to review, review and merge. Read `overlaps` and `behind` on `get` before going far, and `code_owners` for whose approval it needs.",
167 default_action: None,
168 actions: &[
169 a("list", Op::ListPullRequests, "Pull requests on a repository, newest first"),
170 a("get", Op::GetPullRequest, "Status, checks and required checks, reviews, overlaps, whether it is behind"),
171 a("changes", Op::GetPullRequestChanges, "Files and line-by-line diff"),
172 a("create", Op::CreatePullRequest, "Start a draft with its own fork to push to, or open one from a pushed branch"),
173 a("update", Op::UpdatePullRequest, "Change its base branch, labels, milestone, assignees or reviewers"),
174 a("record_session", Op::RecordSession, "Append prompt, reasoning and tool entries to its session"),
175 a("read_session", Op::ReadSession, "Its recorded session"),
176 a("ready", Op::MarkPullRequestReady, "Mark a draft ready, with a summary"),
177 a("draft", Op::ConvertPullRequestToDraft, "Turn it back into a draft"),
178 a("request_reviewers", Op::RequestReviewers, "Ask people or teams to review it"),
179 a("remove_requested_reviewers", Op::RemoveRequestedReviewers, "Stop asking people or teams to review it"),
180 a("review", Op::ReviewPullRequest, "Approve or request changes"),
181 a("close", Op::ClosePullRequest, "Close without merging"),
182 a("reopen", Op::ReopenPullRequest, "Reopen a closed one"),
183 a("merge", Op::MergePullRequest, "Land it, or join the merge queue"),
184 a("merge_queue", Op::GetMergeQueue, "The repository's merge queue"),
185 ],
186 },
187 Tool {
188 name: "agent",
189 title: "g1t agents",
190 description: "Put g1t's agent to work and talk to it. One agent per issue; to do more at once, use more issues. Starting an agent uses the workspace's money.",
191 default_action: None,
192 actions: &[
193 a("delegate", Op::Delegate, "Open an issue and put an agent on it in one step"),
194 a("assign", Op::AssignIssue, "Put an agent on an existing issue"),
195 a("message", Op::MessageAgent, "Tell the agent on a pull request something, or ask another agent"),
196 a("answer", Op::AnswerMessage, "Answer a question or handoff sent to you"),
197 a("take_messages", Op::TakeMessages, "For a g1t agent: messages not seen yet"),
198 a("computer", Op::GetAgentComputer, "A workspace agent's own computer: state, disk, recent commands"),
199 a("wake_computer", Op::WakeAgentComputer, "Wake a workspace agent's computer (metered until it sleeps)"),
200 a("sleep_computer", Op::SleepAgentComputer, "Save its home and put it to sleep"),
201 a("reset_computer", Op::ResetAgentComputer, "Wipe its home; memory and artifacts are kept"),
202 a("computer_commands", Op::ListAgentComputerCommands, "The commands it ran most recently, with output"),
203 ],
204 },
205 Tool {
206 name: "plan",
207 title: "Plans",
208 description: "Turn an outcome into issues: an agent proposes them with what done means and their dependencies; nothing opens until you apply the plan.",
209 default_action: None,
210 actions: &[
211 a("create", Op::PlanWork, "Ask an agent for a plan; read it with get until ready"),
212 a("get", Op::GetPlan, "A plan and the issues it proposes"),
213 a("apply", Op::ApplyPlan, "Open its issues; with assign, agents start in dependency order"),
214 ],
215 },
216 Tool {
217 name: "memory",
218 title: "Memory",
219 description: "What the project and its workspace remember for the next agent: how to build, conventions, decisions, traps. Recall before you start; remember one short fact at a time, never a secret.",
220 default_action: None,
221 actions: &[
222 a("recall", Op::Recall, "Search memory, or list it all"),
223 a("remember", Op::Remember, "Save one fact"),
224 ],
225 },
226 Tool {
227 name: "workflow",
228 title: "Workflows",
229 description: "GitHub Actions workflows from .g1t/workflows: their runs, jobs and logs, and running, cancelling or rerunning them. Runs' artifacts: listing, a download link, deleting, and how long they are kept. Deployments wherever they run (reported from any CI, made by jobs with an `environment:`, or built on g1t.page), their statuses and environments, and reporting your own; environments' protection rules, approving or rejecting the jobs they hold, approving a pull request's run from outside, the token's default permissions and repository dispatch. Checks on commits: statuses, check runs (a g1t Actions job is one) and check suites, to read where a commit stands or report on it from CI or an integration. Also the self-hosted runners they run on: a workspace's (`workspace`) or a repository's own (`repo`), their groups, and where agent work runs.",
230 default_action: None,
231 actions: &[
232 a("list", Op::ListWorkflows, "Workflows on the default branch"),
233 a("list_runs", Op::ListWorkflowRuns, "Runs, newest first"),
234 a("get_run", Op::GetWorkflowRun, "One run with its jobs and steps; an earlier attempt with attempt"),
235 a("job_logs", Op::GetJobLogs, "A job's log after a sequence number"),
236 a("dispatch", Op::DispatchWorkflow, "Run a workflow_dispatch workflow"),
237 a("cancel", Op::CancelWorkflowRun, "Cancel a run, letting its jobs clean up; force stops them outright"),
238 a("rerun", Op::RerunWorkflowRun, "Run a finished run again: all, failed_only, or one job; debug for debug logging"),
239 a("update", Op::UpdateWorkflow, "Turn a workflow on or off"),
240 a("list_artifacts", Op::Artifacts(ArtifactsOp::ListArtifacts), "A repository's artifacts, newest first; or a run's with run_artifacts"),
241 a("run_artifacts", Op::Artifacts(ArtifactsOp::ListRunArtifacts), "One run's artifacts"),
242 a("get_artifact", Op::Artifacts(ArtifactsOp::GetArtifact), "One artifact: size, digest, expiry, run"),
243 a("download_artifact", Op::Artifacts(ArtifactsOp::DownloadArtifact), "A 10-minute link to an artifact's zip"),
244 a("delete_artifact", Op::Artifacts(ArtifactsOp::DeleteArtifact), "Delete an artifact before it expires"),
245 a("artifact_retention", Op::Artifacts(ArtifactsOp::GetArtifactRetention), "Days the repository keeps artifacts"),
246 a("set_artifact_retention", Op::Artifacts(ArtifactsOp::SetArtifactRetention), "Change the days the repository keeps artifacts"),
247 a("combined_status", Op::Checks(ChecksOp::GetCombinedStatus), "A commit's statuses and the state they add up to"),
248 a("list_statuses", Op::Checks(ChecksOp::ListCommitStatuses), "A commit's statuses, newest first"),
249 a("set_status", Op::Checks(ChecksOp::CreateCommitStatus), "Set a status on a commit"),
250 a("list_check_runs", Op::Checks(ChecksOp::ListCheckRunsForRef), "A commit's check runs, g1t Actions jobs included"),
251 a("get_check_run", Op::Checks(ChecksOp::GetCheckRun), "One check run with its report"),
252 a("check_run_annotations", Op::Checks(ChecksOp::ListCheckRunAnnotations), "What a check run says about lines of files"),
253 a("create_check_run", Op::Checks(ChecksOp::CreateCheckRun), "Report a check run on a commit"),
254 a("update_check_run", Op::Checks(ChecksOp::UpdateCheckRun), "Move a check run on, complete it, add annotations"),
255 a("rerequest_check_run", Op::Checks(ChecksOp::RerequestCheckRun), "Ask for a check run to run again"),
256 a("list_check_suites", Op::Checks(ChecksOp::ListCheckSuitesForRef), "A commit's check suites, one per reporter or workflow run"),
257 a("get_check_suite", Op::Checks(ChecksOp::GetCheckSuite), "One check suite"),
258 a("rerequest_check_suite", Op::Checks(ChecksOp::RerequestCheckSuite), "Ask for a check suite to run again"),
259 a("list_deployments", Op::Deployments(DeploymentsOp::ListDeployments), "Deployments wherever they run, newest first, filtered"),
260 a("get_deployment", Op::Deployments(DeploymentsOp::GetDeployment), "One deployment with every status it has had"),
261 a("create_deployment", Op::Deployments(DeploymentsOp::CreateDeployment), "Report a deployment of a ref to an environment"),
262 a("deployment_statuses", Op::Deployments(DeploymentsOp::ListDeploymentStatuses), "A deployment's statuses, newest first"),
263 a("create_deployment_status", Op::Deployments(DeploymentsOp::CreateDeploymentStatus), "Report where a deployment is: in_progress, success, failure"),
264 a("list_environments", Op::Deployments(DeploymentsOp::ListEnvironments), "Environments with their current and latest deployments"),
265 a("get_environment", Op::Deployments(DeploymentsOp::GetEnvironment), "One environment by name, with its protection rules"),
266 a("start_deployment_build", Op::Deployments(DeploymentsOp::StartDeploymentBuild), "From a workflow job: open a g1t.page build it runs itself"),
267 a("update_environment", Op::Protection(ProtectionOp::UpdateEnvironment), "Set an environment's reviewers, wait timer and branches"),
268 a("delete_environment", Op::Protection(ProtectionOp::DeleteEnvironment), "Remove an environment's protection rules"),
269 a("pending_deployments", Op::Protection(ProtectionOp::GetPendingDeployments), "The environments holding a run's jobs"),
270 a("review_deployments", Op::Protection(ProtectionOp::ReviewPendingDeployments), "Approve or reject a run's jobs for its environments"),
271 a("approve_run", Op::Protection(ProtectionOp::ApproveWorkflowRun), "Let a run of a pull request from outside start"),
272 a("get_permissions", Op::Protection(ProtectionOp::GetWorkflowPermissions), "What a job's token gets without `permissions:`"),
273 a("set_permissions", Op::Protection(ProtectionOp::SetWorkflowPermissions), "Set it: read or write"),
274 a("get_approval_policy", Op::Protection(ProtectionOp::GetForkPrApproval), "Which pull requests' runs wait for approval"),
275 a("set_approval_policy", Op::Protection(ProtectionOp::SetForkPrApproval), "Set which pull requests' runs wait for approval"),
276 a("get_access", Op::Protection(ProtectionOp::GetActionsAccess), "Which repositories may use this one's actions and workflows"),
277 a("set_access", Op::Protection(ProtectionOp::SetActionsAccess), "Let the workspace's private repositories use them, or not"),
278 a("repository_dispatch", Op::Protection(ProtectionOp::CreateRepositoryDispatch), "Start repository_dispatch workflows with an event"),
279 a("get_workspace_permissions", Op::Protection(ProtectionOp::GetWorkspaceWorkflowPermissions), "A workspace's default and maximum token permissions"),
280 a("set_workspace_permissions", Op::Protection(ProtectionOp::SetWorkspaceWorkflowPermissions), "Set them, and whether jobs may open pull requests"),
281 a("list_runners", Op::ListRunners, "Self-hosted runners, with status, labels and what each is doing"),
282 a("create_runner_token", Op::CreateRunnerRegistrationToken, "A one-hour token for g1t-runner register"),
283 a("remove_runner", Op::RemoveRunner, "Remove a self-hosted runner"),
284 a("list_runner_groups", Op::ListRunnerGroups, "A workspace's runner groups"),
285 a("create_runner_group", Op::CreateRunnerGroup, "Make a group, for some repositories"),
286 a("update_runner_group", Op::UpdateRunnerGroup, "Rename a group or change its repositories"),
287 a("delete_runner_group", Op::DeleteRunnerGroup, "Delete a group; its runners join the default"),
288 a("get_runner_settings", Op::GetRunnerSettings, "Where agent work runs; whether forks may use runners"),
289 a("update_runner_settings", Op::UpdateRunnerSettings, "Change them"),
290 ],
291 },
292 Tool {
293 name: "package",
294 title: "Packages",
295 description: "A workspace's packages in every registry (container images, npm, Cargo, Maven, NuGet, RubyGems, Composer): their versions and downloads, deleting and restoring them within 30 days, their visibility and repository, who has a role on them, and which repositories' workflows may use them (Manage Actions access). Name one by workspace, package_type and package_name.",
296 default_action: None,
297 actions: &[
298 a("list", Op::Packages(PackagesOp::ListPackages), "A workspace's packages; state deleted for restorable ones"),
299 a("get", Op::Packages(PackagesOp::GetPackage), "One package: address, visibility, repository, downloads"),
300 a("versions", Op::Packages(PackagesOp::ListVersions), "Its versions with tags and downloads; state deleted too"),
301 a("get_version", Op::Packages(PackagesOp::GetVersion), "One version by id, version, digest or tag"),
302 a("update", Op::Packages(PackagesOp::UpdatePackage), "Set visibility, or inherit_access for a linked one"),
303 a("link", Op::Packages(PackagesOp::LinkPackage), "Link it to a repository of its workspace"),
304 a("unlink", Op::Packages(PackagesOp::UnlinkPackage), "Unlink it: the workspace's, private"),
305 a("access", Op::Packages(PackagesOp::ListAccess), "People and teams with a role on it"),
306 a("set_access", Op::Packages(PackagesOp::SetAccess), "Give a person or team read, write or admin"),
307 a("remove_access", Op::Packages(PackagesOp::RemoveAccess), "Take a person's or team's role away"),
308 a("actions_access", Op::Packages(PackagesOp::ListActionsAccess), "Repositories whose workflows may use it"),
309 a("set_actions_access", Op::Packages(PackagesOp::SetActionsAccess), "Let a repository's workflows read or write it"),
310 a("remove_actions_access", Op::Packages(PackagesOp::RemoveActionsAccess), "Stop a repository's workflows using it"),
311 a("delete", Op::Packages(PackagesOp::DeletePackage), "Delete it; restorable for 30 days"),
312 a("restore", Op::Packages(PackagesOp::RestorePackage), "Restore a deleted package"),
313 a("delete_version", Op::Packages(PackagesOp::DeleteVersion), "Delete a version; restorable for 30 days"),
314 a("restore_version", Op::Packages(PackagesOp::RestoreVersion), "Restore a deleted version"),
315 ],
316 },
317 Tool {
318 name: "secret",
319 title: "Secrets and variables",
320 description: "A repository's or workspace's secrets and variables, read by workflows and deployments. Secret values are never returned.",
321 default_action: None,
322 actions: &[
323 a("list_secrets", Op::ListActionsSecrets, "Secrets, without values"),
324 a("set_secret", Op::SetActionsSecret, "Add or change a secret"),
325 a("delete_secret", Op::DeleteActionsSecret, "Remove a secret"),
326 a("list_variables", Op::ListActionsVariables, "Variables, with values"),
327 a("set_variable", Op::SetActionsVariable, "Add or change a variable"),
328 a("delete_variable", Op::DeleteActionsVariable, "Remove a variable"),
329 ],
330 },
331 Tool {
332 name: "webhook",
333 title: "Webhooks",
334 description: "HTTPS addresses sent signed events as they happen, for a repository or a whole workspace.",
335 default_action: None,
336 actions: &[
337 a("list", Op::ListWebhooks, "Webhooks, without secrets"),
338 a("create", Op::CreateWebhook, "Register one; a ping is sent"),
339 a("update", Op::UpdateWebhook, "Change address, events or active"),
340 a("delete", Op::DeleteWebhook, "Remove one"),
341 a("ping", Op::PingWebhook, "Send a ping"),
342 a("list_deliveries", Op::ListWebhookDeliveries, "Latest deliveries"),
343 a("redeliver", Op::RedeliverWebhook, "Send a delivery again"),
344 ],
345 },
346 Tool {
347 name: "access",
348 title: "Who has access",
349 description: "Who has access to a repository and with which role (read, triage, write, maintain, admin), outside collaborators, a workspace's base permission, and a repository's deploy keys.",
350 default_action: None,
351 actions: &[
352 a("list_collaborators", Op::ListCollaborators, "Everyone with a role, and pending invitations"),
353 a("get_permission", Op::GetCollaboratorPermission, "One person's role and capabilities"),
354 a("add_collaborator", Op::AddCollaborator, "Give someone a role, by username or email"),
355 a("update_collaborator", Op::UpdateCollaborator, "Change a direct role"),
356 a("remove_collaborator", Op::RemoveCollaborator, "Take away a direct role"),
357 a("list_invitations", Op::ListRepoInvitations, "Pending invitations to a repository"),
358 a("revoke_invitation", Op::RevokeRepoInvitation, "Withdraw one"),
359 a("set_base_permission", Op::SetBasePermission, "What every member gets on each repository"),
360 a("list_outside_collaborators", Op::ListOutsideCollaborators, "People with roles who are not members"),
361 a("list_deploy_keys", Op::DeployKeys(DeployKeysOp::ListDeployKeys), "SSH keys that reach this one repository"),
362 a("get_deploy_key", Op::DeployKeys(DeployKeysOp::GetDeployKey), "One deploy key, by id"),
363 a("add_deploy_key", Op::DeployKeys(DeployKeysOp::CreateDeployKey), "Add one; read-only unless read_only is false"),
364 a("remove_deploy_key", Op::DeployKeys(DeployKeysOp::DeleteDeployKey), "Delete one"),
365 ],
366 },
367 Tool {
368 name: "team",
369 title: "Teams",
370 description: "Teams: groups of a workspace's members, given roles on repositories together, mentioned as @workspace/team and asked to review together. Name one by `workspace` and its slug (`team`). Any member may create a team; the workspace's owners and the team's maintainers manage it. A secret team is seen only by its people and the owners.",
371 default_action: None,
372 actions: &[
373 a("list", Op::ListTeams, "A workspace's teams you can see"),
374 a("get", Op::GetTeam, "One team"),
375 a("create", Op::CreateTeam, "Create a team; you become its maintainer"),
376 a("update", Op::UpdateTeam, "Change its name, slug, description, visibility, parent or notifications"),
377 a("delete", Op::DeleteTeam, "Delete it; its child teams move up"),
378 a("list_members", Op::ListTeamMembers, "Its people and their roles, child teams' with include_child_teams"),
379 a("set_member", Op::SetTeamMember, "Add a member of the workspace, or change their role"),
380 a("remove_member", Op::RemoveTeamMember, "Take someone out of it"),
381 a("list_child_teams", Op::ListChildTeams, "The teams nested under it"),
382 a("list_repos", Op::ListTeamRepos, "The repositories it has a role on"),
383 a("set_repo", Op::SetTeamRepo, "Give it a role on a repository"),
384 a("remove_repo", Op::RemoveTeamRepo, "Take its role on a repository away"),
385 a("set_review_assignment", Op::SetTeamReviewAssignment, "Whom it picks when asked to review"),
386 a("list_user_teams", Op::ListUserTeams, "The teams someone is in"),
387 ],
388 },
389 Tool {
390 name: "workspace",
391 title: "Workspaces",
392 description: "Workspaces own repositories (g1t.sh/{workspace}/{repo}): create, update or delete one, invite members, connect integrations and model providers, set rulesets that hold across its repositories, read and change its projects (what each is, where it runs, its links), and keep your own pinned projects at the top of its sidebar.",
393 default_action: None,
394 actions: &[
395 a("get", Op::GetWorkspace, "A workspace's details and settings"),
396 a("create", Op::CreateWorkspace, "Create a workspace"),
397 a("delete", Op::DeleteWorkspace, "Delete a workspace and everything in it (support can restore it for 30 days)"),
398 a("update", Op::UpdateWorkspace, "Change its name, description, base permission, who may create teams, member privileges or the two-factor requirement"),
399 a("list_members", Op::ListMembers, "Its members, owners first, with their roles"),
400 a("update_member", Op::UpdateMember, "Make someone an owner or a member, billing manager or security manager"),
401 a("remove_member", Op::RemoveMember, "Remove someone from it"),
402 a("transfer_ownership", Op::TransferOwnership, "Hand it to another member: they become an owner, you a member"),
403 a("leave", Op::LeaveWorkspace, "Leave it yourself"),
404 a("list_invites", Op::ListWorkspaceInvites, "Its invites"),
405 a("invite_member", Op::InviteMember, "Invite someone by username or email address"),
406 a("revoke_invite", Op::RevokeWorkspaceInvite, "Revoke a pending invite"),
407 a("list_integrations", Op::ListIntegrations, "Model providers, alert sources, trackers"),
408 a("connect_integration", Op::ConnectIntegration, "Connect one"),
409 a("update_integration", Op::UpdateIntegration, "Change one: rotate its key, choose its AI Gateway models"),
410 a("disconnect_integration", Op::DisconnectIntegration, "Remove one"),
411 a("test_integration", Op::TestIntegration, "Check its credentials"),
412 a("get_model_routes", Op::GetModelRoutes, "Where each kind of work's model requests go"),
413 a("set_model_routes", Op::SetModelRoutes, "Replace them"),
414 a("list_projects", Op::ListProjects, "Its projects you can see: what each is, where it runs, its links"),
415 a("get_project", Op::GetProject, "One project"),
416 a("update_project", Op::UpdateProject, "Change a project's name, description, kind, where it runs or its links"),
417 a("list_pinned_projects", Op::ListPinnedProjects, "Your pinned projects in it, in your order"),
418 a("pin_project", Op::PinProject, "Pin a project, at a position or the end"),
419 a("unpin_project", Op::UnpinProject, "Unpin a project"),
420 a("reorder_pinned_projects", Op::ReorderPinnedProjects, "Put your pins in a new order"),
421 a("list_rulesets", Op::Rules(RulesOp::ListWorkspaceRulesets), "Its rulesets, which hold across its repositories"),
422 a("get_ruleset", Op::Rules(RulesOp::GetWorkspaceRuleset), "One of its rulesets"),
423 a("create_ruleset", Op::Rules(RulesOp::CreateWorkspaceRuleset), "Create a ruleset for some or all of its repositories"),
424 a("update_ruleset", Op::Rules(RulesOp::UpdateWorkspaceRuleset), "Change one of its rulesets"),
425 a("delete_ruleset", Op::Rules(RulesOp::DeleteWorkspaceRuleset), "Delete one of its rulesets"),
426 a("rule_evaluations", Op::Rules(RulesOp::ListWorkspaceRuleEvaluations), "How rules judged changes across its repositories"),
427 a("get_token_policy", Op::Tokens(TokenOp::GetTokenPolicy), "Its rules for personal access tokens"),
428 a("set_token_policy", Op::Tokens(TokenOp::SetTokenPolicy), "Change them: which tokens reach it, approval, lifetime"),
429 a("list_member_tokens", Op::Tokens(TokenOp::ListMemberTokens), "Members' personal access tokens that reach it"),
430 a("list_token_requests", Op::Tokens(TokenOp::ListTokenRequests), "Tokens waiting for approval"),
431 a("review_token_request", Op::Tokens(TokenOp::ReviewTokenRequest), "Approve or deny one"),
432 a("revoke_member_token", Op::Tokens(TokenOp::RevokeMemberToken), "Revoke a member's token in it"),
433 ],
434 },
435 Tool {
436 name: "billing",
437 title: "Billing",
438 description: "A workspace's billing: its usage by product, project and day, its budget (the monthly spend limit, alerts and whether usage pauses at it), its AI credit, its invoices, and its AI Gateway requests. Amounts are whole millionths of a dollar (`_micros`), or cents (`_cents`) where named. Members read it; changing the budget and buying credit are for owners, as people, and never for g1t's agents.",
439 default_action: Some("usage"),
440 actions: &[
441 a("usage", Op::GetUsage, "Usage over a range of days, by product, meter, project and day, and what paid for it"),
442 a("budget", Op::GetBudget, "The monthly spend limit, what was spent, alerts and whether usage pauses at the limit"),
443 a("set_budget", Op::SetBudget, "Change the spend limit, alerts, pausing or the alert webhook"),
444 a("ai_credit", Op::GetAiCredit, "AI credit left, its grants, auto-reload and how to buy more"),
445 a("buy_ai_credit", Op::BuyAiCredit, "A payment page to buy AI credit, for a person to open"),
446 a("invoices", Op::ListInvoices, "Every invoice, the itemised usage invoices, and the next one so far"),
447 a("billing_details", Op::GetBillingDetails, "Who invoices are made out to and the payment method on file"),
448 a("gateway_requests", Op::ListGatewayRequests, "Recent AI Gateway requests: model, tokens, cost, status and token"),
449 ],
450 },
451 Tool {
452 name: "security",
453 title: "Security",
454 description: "A repository's security: secret scanning alerts and push protection bypasses, custom secret patterns, code scanning alerts and SARIF uploads, vulnerability alerts, the dependency graph and its SBOM, dependency review, settings, and a workspace's overview. Fix an alert with g1t. Findings are shown to those who can change the code only. Give `repo` (owner/name), or `workspace` for lists across one.",
455 default_action: Some("secret_alerts"),
456 actions: &[
457 a("secret_alerts", Op::Security(SecurityOp::ListSecretAlerts), "Secret scanning alerts; by state, secret_type, validity, bypassed"),
458 a("secret_alert", Op::Security(SecurityOp::GetSecretAlert), "One secret alert, with where it was found and its bypass requests"),
459 a("update_secret_alert", Op::Security(SecurityOp::UpdateSecretAlert), "Dismiss a secret alert with a reason, or reopen it"),
460 a("secret_locations", Op::Security(SecurityOp::ListSecretLocations), "Every file, line and commit a secret is in"),
461 a("bypass", Op::Security(SecurityOp::BypassPushProtection), "Push past push protection with a reason, or ask to"),
462 a("check_validity", Op::Security(SecurityOp::CheckSecretValidity), "Ask a secret's issuer whether it still works"),
463 a("bypass_requests", Op::Security(SecurityOp::ListBypassRequests), "A workspace's push protection bypass requests"),
464 a("review_bypass", Op::Security(SecurityOp::ReviewBypassRequest), "Approve, deny or cancel a bypass request"),
465 a("patterns", Op::Security(SecurityOp::ListCustomPatterns), "Custom secret patterns of a repository or workspace"),
466 a("create_pattern", Op::Security(SecurityOp::CreateCustomPattern), "Create a custom secret pattern, as a draft or published"),
467 a("update_pattern", Op::Security(SecurityOp::UpdateCustomPattern), "Change, publish or unpublish a custom pattern"),
468 a("delete_pattern", Op::Security(SecurityOp::DeleteCustomPattern), "Delete a custom pattern"),
469 a("dry_run_pattern", Op::Security(SecurityOp::DryRunCustomPattern), "Run a pattern over the default branch without saving it"),
470 a("code_alerts", Op::Security(SecurityOp::ListCodeAlerts), "Code scanning alerts; by state, severity, tool, rule_id"),
471 a("code_alert", Op::Security(SecurityOp::GetCodeAlert), "One code scanning alert by number"),
472 a("update_code_alert", Op::Security(SecurityOp::UpdateCodeAlert), "Dismiss a code scanning alert with a reason, or reopen it"),
473 a("analyses", Op::Security(SecurityOp::ListAnalyses), "Code scanning analyses, newest first"),
474 a("upload_sarif", Op::Security(SecurityOp::UploadSarif), "Upload a SARIF file, gzipped and base64-encoded"),
475 a("sarif_upload", Op::Security(SecurityOp::GetSarifUpload), "Whether a SARIF upload was read, and its analyses"),
476 a("vulnerability_alerts", Op::Security(SecurityOp::ListVulnerabilityAlerts), "Vulnerable dependencies; by state, severity, ecosystem, package"),
477 a("vulnerability_alert", Op::Security(SecurityOp::GetVulnerabilityAlert), "One vulnerability alert"),
478 a("update_vulnerability_alert", Op::Security(SecurityOp::UpdateVulnerabilityAlert), "Dismiss a vulnerability alert with a reason, or reopen it"),
479 a("fix", Op::Security(SecurityOp::FixAlert), "Put g1t on an issue to fix an alert"),
480 a("dependency_graph", Op::Security(SecurityOp::GetDependencyGraph), "Every package the lockfiles resolve, direct or transitive"),
481 a("sbom", Op::Security(SecurityOp::GetSbom), "The dependency graph as an SPDX 2.3 document"),
482 a("compare_dependencies", Op::Security(SecurityOp::CompareDependencies), "What changes in dependencies between base...head"),
483 a("settings", Op::Security(SecurityOp::GetSettings), "A repository's security settings"),
484 a("update_settings", Op::Security(SecurityOp::UpdateSettings), "Change when checks fail and dependency review's policy"),
485 a("workspace_settings", Op::Security(SecurityOp::GetWorkspaceSettings), "A workspace's delegated bypass and validity checks"),
486 a("update_workspace_settings", Op::Security(SecurityOp::UpdateWorkspaceSettings), "Turn delegated bypass or validity checks on or off"),
487 a("overview", Op::Security(SecurityOp::GetOverview), "A workspace's alerts, trends and coverage"),
488 ],
489 },
490 Tool {
491 name: "notifications",
492 title: "Notifications",
493 description: "Your inbox: what needs you, and what you follow. One thread per issue, pull request, workflow or deployment, with why you were told (`reason`): an agent waiting on you, a review asked of you, an assignment, a mention, your work's checks, or what you subscribe to and watch. Mark threads read or done once handled, and choose what you hear of with subscribe, unsubscribe and watch. Your own: a personal token.",
494 default_action: Some("list"),
495 actions: &[
496 a("list", Op::ListNotifications, "Unread threads, latest first; all, a view, a reason, a repository"),
497 a("get", Op::GetNotificationThread, "One thread with its recent activity and your subscription"),
498 a("mark_read", Op::MarkThreadRead, "Mark a thread read, or unread"),
499 a("mark_all_read", Op::MarkNotificationsRead, "Mark everything read up to a time, or one repository's"),
500 a("done", Op::MarkThreadDone, "Mark a thread done; new activity brings it back"),
501 a("save", Op::SaveThread, "Save a thread, or unsave it"),
502 a("snooze", Op::SnoozeThread, "Snooze a thread until a time, or bring it back"),
503 a("subscription", Op::GetThreadSubscription, "Your subscription to an issue or pull request"),
504 a("subscribe", Op::SetThreadSubscription, "Subscribe to an issue or pull request, or ignore it"),
505 a("unsubscribe", Op::DeleteThreadSubscription, "Unsubscribe until you comment or are mentioned"),
506 a("watching", Op::GetRepoSubscription, "How you watch a repository"),
507 a("watch", Op::SetRepoSubscription, "Watch a repository: participating, all, ignore or custom"),
508 a("unwatch", Op::DeleteRepoSubscription, "Stop watching a repository"),
509 a("watched", Op::ListWatchedRepos, "Repositories you watch other than the default way"),
510 ],
511 },
512 Tool {
513 name: "account",
514 title: "Your account",
515 description: "Who this token acts as and its workspaces (`whoami`), your email addresses, your invites, and invitations to workspaces and repositories waiting for you.",
516 default_action: Some("whoami"),
517 actions: &[
518 a("whoami", Op::Whoami, "Who the token acts as, and its workspaces"),
519 a("list_emails", Op::ListEmails, "Your addresses"),
520 a("add_email", Op::AddEmail, "Add an address"),
521 a("confirm_email", Op::ConfirmEmail, "Confirm an address with the code from its email"),
522 a("remove_email", Op::RemoveEmail, "Remove an address"),
523 a("update_email_settings", Op::UpdateEmailSettings, "Primary, backup and privacy"),
524 a("list_invites", Op::ListInvites, "Your invites to g1t"),
525 a("create_invite", Op::CreateInvite, "Make an invite"),
526 a("revoke_invite", Op::RevokeInvite, "Revoke one"),
527 a("list_workspace_invitations", Op::ListInvitations, "Invitations to workspaces for you"),
528 a("accept_workspace_invitation", Op::AcceptInvitation, "Accept one and join"),
529 a("decline_workspace_invitation", Op::DeclineInvitation, "Decline one"),
530 a("list_repository_invitations", Op::ListMyRepoInvitations, "Invitations to repositories for you"),
531 a("accept_repository_invitation", Op::AcceptRepoInvitation, "Accept one"),
532 a("decline_repository_invitation", Op::DeclineRepoInvitation, "Decline one"),
533 ],
534 },
535 Tool {
536 name: "artifact",
537 title: "Artifacts",
538 description: "A workspace's docs, slides, designs and dashboards (Artifacts mode), as you can open them: list, search and read them (a doc's content is Markdown, with block ids to target), make them, edit them (a change with the edit role, a suggestion with comment), move, trash and restore them, their versions, and who can open them. Name one by its id (fol_…) or its address. Not the `workflow` tool's run artifacts. Slides, designs and dashboards answer that they are not here yet.",
539 default_action: None,
540 actions: &[
541 a("list", Op::Folios(FoliosOp::List), "Artifacts you can open; tab, kind, space, q; state trashed for the trash"),
542 a("search", Op::Folios(FoliosOp::Search), "Search them by words and meaning, with the passage that matched"),
543 a("get", Op::Folios(FoliosOp::Get), "One artifact: kind, title, space, owner, your role, who it is shared with"),
544 a("read", Op::Folios(FoliosOp::GetContent), "Its content: a doc's Markdown and block ids, and what you may do"),
545 a("versions", Op::Folios(FoliosOp::ListVersions), "Its saved versions, newest first"),
546 a("access", Op::Folios(FoliosOp::GetAccess), "Who can open it, and how"),
547 a("templates", Op::Folios(FoliosOp::ListTemplates), "Templates to start one from"),
548 a("spaces", Op::Folios(FoliosOp::ListSpaces), "The spaces in your sidebar"),
549 a("query_data", Op::Folios(FoliosOp::QueryDataset), "Run a dataset query as you, over what you can read"),
550 a("create", Op::Folios(FoliosOp::Create), "Make one: in a space, under a doc, or in your Private"),
551 a("update", Op::Folios(FoliosOp::Update), "Rename it, change its icon, or move it"),
552 a("edit", Op::Folios(FoliosOp::Edit), "Change its content: append, replace it all, a section or blocks"),
553 a("trash", Op::Folios(FoliosOp::Trash), "Move it to the trash; restorable for 30 days"),
554 a("restore", Op::Folios(FoliosOp::Restore), "Bring it back from the trash"),
555 a("restore_version", Op::Folios(FoliosOp::RestoreVersion), "Make an earlier version its content again"),
556 a("share", Op::Folios(FoliosOp::SetAccess), "Share it, change general access, or take access away"),
557 a("purge", Op::Folios(FoliosOp::Purge), "Delete one in the trash for good"),
558 ],
559 },
560];
561
562/// Operations that cannot be undone, or reach beyond g1t's own records:
563/// clients ask before running a tool that has any of them.
564fn destructive(op: Op) -> bool {
565 matches!(
566 op,
567 Op::Security(SecurityOp::DeleteCustomPattern | SecurityOp::BypassPushProtection)
568 | Op::Rules(RulesOp::DeleteRepoRuleset | RulesOp::DeleteWorkspaceRuleset)
569 | Op::DeleteWorkspace
570 | Op::UpdateWorkspace
571 | Op::Tokens(TokenOp::RevokeMemberToken | TokenOp::SetTokenPolicy)
572 | Op::RemoveMember
573 | Op::TransferOwnership
574 | Op::LeaveWorkspace
575 | Op::DeleteRepo
576 | Op::PurgeRepo
577 | Op::TransferRepo
578 | Op::SetRepoVisibility
579 | Op::RemoveEmail
580 | Op::RemoveCollaborator
581 | Op::DisconnectIntegration
582 | Op::UpdateIntegration
583 | Op::DeleteWebhook
584 | Op::DeleteActionsSecret
585 | Op::DeleteActionsVariable
586 | Op::SetActionsSecret
587 | Op::SetActionsVariable
588 | Op::SetModelRoutes
589 | Op::SetBasePermission
590 | Op::DeleteTeam
591 | Op::RemoveTeamRepo
592 | Op::MergePullRequest
593 | Op::RemoveRunner
594 | Op::DeleteRunnerGroup
595 | Op::UpdateRunnerSettings
596 | Op::Folios(FoliosOp::SetAccess | FoliosOp::Purge)
597 )
598}
599
600/// Whether an operation only reads.
601pub fn reads_only(op: Op) -> bool {
602 NO_SCOPE.contains(&op.name())
603 || scope_for(op.name()).is_some_and(|scope| scope.level() == Level::Read)
604}
605
606/// What decides which actions a caller sees.
607pub enum Gate<'a> {
608 /// No limit beyond the person's own role.
609 Everything,
610 /// A g1t agent's token: the operations its run lists.
611 Agent(&'a AgentScope),
612 /// An access token with scopes.
613 Token(&'a TokenAccess),
614}
615
616impl Gate<'_> {
617 pub fn allows(&self, op: Op) -> bool {
618 match self {
619 Gate::Everything => true,
620 Gate::Agent(scope) => op.allowed_by(scope) && !NEVER.contains(&op.name()),
621 Gate::Token(access) => {
622 if NO_SCOPE.contains(&op.name()) {
623 return true;
624 }
625 match scope_for(op.name()) {
626 Some(scope) => access.allows(scope),
627 None => access.scopes.is_none(),
628 }
629 }
630 }
631 }
632}
633
634impl Tool {
635 pub fn by_name(name: &str) -> Option<&'static Tool> {
636 TOOLS.iter().find(|tool| tool.name == name)
637 }
638
639 pub fn action(&self, name: &str) -> Option<&'static Action> {
640 // The tools are 'static; find through TOOLS to keep the lifetime.
641 TOOLS
642 .iter()
643 .find(|tool| tool.name == self.name)
644 .and_then(|tool| tool.actions.iter().find(|action| action.name == name))
645 }
646
647 pub fn visible(&self, gate: &Gate) -> Vec<&'static Action> {
648 TOOLS
649 .iter()
650 .find(|tool| tool.name == self.name)
651 .map(|tool| tool.actions.iter().filter(|action| gate.allows(action.op)).collect())
652 .unwrap_or_default()
653 }
654
655 /// The flat input schema of the actions given.
656 pub fn input_schema(&self, actions: &[&Action]) -> Value {
657 let mut properties = Map::new();
658 let lines: Vec<String> = actions
659 .iter()
660 .map(|action| {
661 let required: Vec<String> = action.op.required();
662 if required.is_empty() {
663 format!("{}: {}.", action.name, action.summary)
664 } else {
665 format!("{} ({}): {}.", action.name, required.join(", "), action.summary)
666 }
667 })
668 .collect();
669 let mut action_schema = json!({
670 "type": "string",
671 "enum": actions.iter().map(|action| action.name).collect::<Vec<_>>(),
672 "description": lines.join("\n"),
673 });
674 if let Some(default) = self.default_action.filter(|name| actions.iter().any(|action| action.name == *name)) {
675 action_schema["default"] = json!(default);
676 }
677 properties.insert("action".to_owned(), action_schema);
678 for action in actions {
679 for (name, schema) in action.op.properties() {
680 merge_property(&mut properties, name, schema);
681 }
682 }
683 let mut required = vec![];
684 if self.default_action.is_none() {
685 required.push("action");
686 }
687 let mut schema = json!({ "type": "object", "properties": properties });
688 if !required.is_empty() {
689 schema["required"] = json!(required);
690 }
691 schema
692 }
693
694 /// The input schema keyed by action: one `oneOf` branch per action,
695 /// each with its own fields and the ones it needs.
696 pub fn discriminated(&self, actions: &[&Action]) -> Value {
697 let branches: Vec<Value> = actions
698 .iter()
699 .map(|action| {
700 let mut properties = Map::new();
701 properties.insert("action".to_owned(), json!({ "const": action.name }));
702 properties.extend(action.op.properties());
703 let mut required = vec![Value::String("action".to_owned())];
704 // The default action may leave `action` out.
705 if self.default_action == Some(action.name) {
706 required.clear();
707 }
708 required.extend(action.op.required().into_iter().map(Value::String));
709 json!({
710 "title": action.name,
711 "description": action.summary,
712 "type": "object",
713 "properties": properties,
714 "required": required,
715 })
716 })
717 .collect();
718 json!({ "type": "object", "oneOf": branches })
719 }
720
721 /// MCP's hints about the actions given: whether the tool only reads,
722 /// whether it can destroy something, and whether calling it twice is
723 /// the same as once.
724 pub fn annotations(&self, actions: &[&Action]) -> Value {
725 let read_only = actions.iter().all(|action| reads_only(action.op));
726 json!({
727 "title": self.title,
728 "readOnlyHint": read_only,
729 "destructiveHint": !read_only && actions.iter().any(|action| destructive(action.op)),
730 "idempotentHint": read_only,
731 "openWorldHint": false,
732 })
733 }
734
735 /// The tool as `tools/list` gives it, for a caller behind `gate`, or
736 /// `None` when it may use none of its actions.
737 pub fn listed(&self, gate: &Gate) -> Option<Value> {
738 let actions = self.visible(gate);
739 if actions.is_empty() {
740 return None;
741 }
742 Some(json!({
743 "name": self.name,
744 "title": self.title,
745 "description": self.description,
746 "inputSchema": self.input_schema(&actions),
747 "annotations": self.annotations(&actions),
748 }))
749 }
750}
751
752/// Adds a property to a tool's flat schema. The first action to use a name
753/// describes it; a later one with other allowed values adds them.
754fn merge_property(properties: &mut Map<String, Value>, name: String, schema: Value) {
755 match properties.get_mut(&name) {
756 None => {
757 properties.insert(name, schema);
758 }
759 Some(existing) => {
760 if let (Some(Value::Array(had)), Some(Value::Array(more))) =
761 (existing.get("enum").cloned(), schema.get("enum"))
762 {
763 let mut merged = had;
764 for value in more {
765 if !merged.contains(value) {
766 merged.push(value.clone());
767 }
768 }
769 existing["enum"] = Value::Array(merged);
770 }
771 // Different kinds of value under one name: say less, accept both.
772 if existing.get("type") != schema.get("type")
773 && let Some(fields) = existing.as_object_mut()
774 {
775 fields.remove("type");
776 fields.remove("items");
777 }
778 }
779 }
780}
781
782/// What a call to a tool runs: the operation its action names, or why not.
783pub fn resolve(tool: &Tool, arguments: &Value) -> Result<Op, String> {
784 let names = || {
785 tool.actions
786 .iter()
787 .map(|action| action.name)
788 .collect::<Vec<_>>()
789 .join(", ")
790 };
791 let Some(name) = arguments["action"].as_str().or(tool.default_action) else {
792 return Err(format!("Give an action: one of {}.", names()));
793 };
794 let Some(action) = tool.action(name) else {
795 return Err(format!("{} has no action {name}. Its actions: {}.", tool.name, names()));
796 };
797 let missing: Vec<String> = action
798 .op
799 .required()
800 .into_iter()
801 .filter(|field| arguments.get(field).is_none_or(Value::is_null))
802 .collect();
803 if !missing.is_empty() {
804 return Err(format!("{}.{name} needs {}.", tool.name, missing.join(", ")));
805 }
806 Ok(action.op)
807}
808
809#[cfg(test)]
810mod tests {
811 use super::*;
812 use g1t_contracts::scopes::{Preset, Scope};
813
814 fn listed(gate: &Gate) -> Vec<Value> {
815 TOOLS.iter().filter_map(|tool| tool.listed(gate)).collect()
816 }
817
818 fn token(scopes: Option<Vec<Scope>>) -> TokenAccess {
819 TokenAccess {
820 token_id: "tok_1".to_owned(),
821 scopes: scopes.map(|scopes| scopes.iter().map(|scope| scope.as_str().to_owned()).collect()),
822 legacy: false,
823 name: None,
824 ..TokenAccess::default()
825 }
826 }
827
828 #[test]
829 fn every_operation_is_exactly_one_action_of_one_tool() {
830 for op in Op::ALL {
831 let count = TOOLS
832 .iter()
833 .flat_map(|tool| tool.actions.iter())
834 .filter(|action| action.op == op)
835 .count();
836 assert_eq!(count, 1, "{} is {count} actions", op.name());
837 }
838 for tool in TOOLS {
839 let mut names = std::collections::HashSet::new();
840 for action in tool.actions {
841 assert!(names.insert(action.name), "{}.{} twice", tool.name, action.name);
842 }
843 if let Some(default) = tool.default_action {
844 assert!(tool.action(default).is_some(), "{}", tool.name);
845 }
846 }
847 assert!(TOOLS.len() <= 19, "{} tools", TOOLS.len());
848 }
849
850 #[test]
851 fn every_operation_needs_exactly_one_scope_or_none() {
852 use g1t_contracts::scopes::OPERATIONS;
853 for op in Op::ALL {
854 let mapped = OPERATIONS.iter().filter(|(name, _)| *name == op.name()).count();
855 let free = NO_SCOPE.contains(&op.name());
856 assert_eq!(mapped + usize::from(free), 1, "{}", op.name());
857 }
858 for (name, _) in OPERATIONS {
859 assert!(Op::by_name(name).is_some(), "{name} is not an operation");
860 }
861 }
862
863 #[test]
864 fn each_tool_schema_is_valid_with_one_branch_per_action() {
865 for tool in TOOLS {
866 let actions: Vec<&Action> = tool.actions.iter().collect();
867 let flat = tool.input_schema(&actions);
868 assert_eq!(flat["type"], "object");
869 assert!(flat.get("oneOf").is_none(), "no oneOf at the top level");
870 let listed: Vec<&str> = flat["properties"]["action"]["enum"]
871 .as_array()
872 .unwrap()
873 .iter()
874 .map(|name| name.as_str().unwrap())
875 .collect();
876 assert_eq!(listed, tool.actions.iter().map(|action| action.name).collect::<Vec<_>>());
877 for action in tool.actions {
878 for field in action.op.required() {
879 assert!(flat["properties"].get(&field).is_some(), "{}.{}: {field}", tool.name, action.name);
880 }
881 }
882 let keyed = tool.discriminated(&actions);
883 let branches = keyed["oneOf"].as_array().unwrap();
884 assert_eq!(branches.len(), tool.actions.len());
885 for (branch, action) in branches.iter().zip(tool.actions) {
886 assert_eq!(branch["properties"]["action"]["const"], action.name);
887 for field in branch["required"].as_array().unwrap() {
888 assert!(branch["properties"].get(field.as_str().unwrap()).is_some(), "{}.{}: {field}", tool.name, action.name);
889 }
890 }
891 // A well-formed JSON Schema object throughout.
892 let text = serde_json::to_string(&flat).unwrap();
893 assert!(serde_json::from_str::<Value>(&text).is_ok());
894 }
895 }
896
897 #[test]
898 fn a_read_only_token_sees_read_actions_only() {
899 let access = token(Preset::ReadOnly.scopes());
900 let gate = Gate::Token(&access);
901 for tool in TOOLS {
902 for action in tool.visible(&gate) {
903 assert!(reads_only(action.op), "{}.{}", tool.name, action.name);
904 }
905 }
906 let tools = listed(&gate);
907 for tool in &tools {
908 assert_eq!(tool["annotations"]["readOnlyHint"], true, "{}", tool["name"]);
909 assert_eq!(tool["annotations"]["destructiveHint"], false);
910 }
911 let issue = tools.iter().find(|tool| tool["name"] == "issue").unwrap();
912 assert_eq!(issue["inputSchema"]["properties"]["action"]["enum"], json!(["list", "get", "labels"]));
913 // Nothing of the agent tool is a read.
914 assert!(!tools.iter().any(|tool| tool["name"] == "agent"));
915 }
916
917 #[test]
918 fn a_narrow_token_sees_only_its_tools() {
919 let access = token(Some(vec![Scope::IssuesWrite]));
920 let names: Vec<Value> = listed(&Gate::Token(&access)).into_iter().map(|tool| tool["name"].clone()).collect();
921 // Labels and milestones are the repository's, managed with issues:write.
922 assert_eq!(names, vec![json!("repository"), json!("issue"), json!("plan"), json!("account")]);
923 // Notifications are a resource of their own: reading them lists
924 // only what reads.
925 let reader = token(Some(vec![Scope::NotificationsRead]));
926 let tools = listed(&Gate::Token(&reader));
927 let notifications = tools.iter().find(|tool| tool["name"] == "notifications").unwrap();
928 assert_eq!(
929 notifications["inputSchema"]["properties"]["action"]["enum"],
930 json!(["list", "get", "subscription", "watching", "watched"])
931 );
932 assert_eq!(notifications["annotations"]["readOnlyHint"], true);
933 let full = token(None);
934 assert_eq!(listed(&Gate::Token(&full)).len(), TOOLS.len());
935 assert_eq!(listed(&Gate::Everything).len(), TOOLS.len());
936 }
937
938 #[test]
939 fn a_tool_that_can_destroy_says_so() {
940 let tools = listed(&Gate::Everything);
941 let repository = tools.iter().find(|tool| tool["name"] == "repository").unwrap();
942 assert_eq!(repository["annotations"]["destructiveHint"], true);
943 assert_eq!(repository["annotations"]["readOnlyHint"], false);
944 let memory = tools.iter().find(|tool| tool["name"] == "memory").unwrap();
945 assert_eq!(memory["annotations"]["destructiveHint"], false);
946 }
947
948 #[test]
949 fn calls_resolve_to_their_operation_or_say_what_is_missing() {
950 let issue = Tool::by_name("issue").unwrap();
951 assert_eq!(resolve(issue, &json!({ "action": "get", "repo": "a/b", "number": 1 })), Ok(Op::GetIssue));
952 assert_eq!(resolve(issue, &json!({ "action": "get", "repo": "a/b" })), Err("issue.get needs number.".to_owned()));
953 assert!(resolve(issue, &json!({})).unwrap_err().starts_with("Give an action"));
954 assert!(resolve(issue, &json!({ "action": "explode" })).unwrap_err().contains("no action explode"));
955 let search = Tool::by_name("search").unwrap();
956 assert_eq!(resolve(search, &json!({ "query": "x" })), Ok(Op::Search));
957 let account = Tool::by_name("account").unwrap();
958 assert_eq!(resolve(account, &json!({})), Ok(Op::Whoami));
959 }
960
961 #[test]
962 fn teams_are_one_tool_and_a_workspace_reader_sees_only_its_reads() {
963 let team = Tool::by_name("team").unwrap();
964 let names: Vec<&str> = team.actions.iter().map(|action| action.name).collect();
965 assert_eq!(
966 names,
967 [
968 "list",
969 "get",
970 "create",
971 "update",
972 "delete",
973 "list_members",
974 "set_member",
975 "remove_member",
976 "list_child_teams",
977 "list_repos",
978 "set_repo",
979 "remove_repo",
980 "set_review_assignment",
981 "list_user_teams",
982 ]
983 );
984 let reader = token(Some(vec![Scope::WorkspaceRead]));
985 let tools = listed(&Gate::Token(&reader));
986 let listed_team = tools.iter().find(|tool| tool["name"] == "team").unwrap();
987 assert_eq!(
988 listed_team["inputSchema"]["properties"]["action"]["enum"],
989 json!(["list", "get", "list_members", "list_child_teams", "list_repos", "list_user_teams"])
990 );
991 assert_eq!(listed_team["annotations"]["readOnlyHint"], true);
992 // A team's role on a repository is who has access.
993 let admin = token(Some(vec![Scope::WorkspaceAdmin]));
994 let tools = listed(&Gate::Token(&admin));
995 let listed_team = tools.iter().find(|tool| tool["name"] == "team").unwrap();
996 let actions = listed_team["inputSchema"]["properties"]["action"]["enum"].as_array().unwrap();
997 assert!(actions.contains(&json!("set_review_assignment")) && !actions.contains(&json!("set_repo")));
998 let access = token(Some(vec![Scope::AccessAdmin]));
999 let tools = listed(&Gate::Token(&access));
1000 let listed_team = tools.iter().find(|tool| tool["name"] == "team").unwrap();
1001 assert_eq!(listed_team["inputSchema"]["properties"]["action"]["enum"], json!(["set_repo", "remove_repo"]));
1002 // Both kinds of role a schema names are offered.
1003 let roles = &listed(&Gate::Everything).into_iter().find(|tool| tool["name"] == "team").unwrap()["inputSchema"]
1004 ["properties"]["role"]["enum"];
1005 for role in ["member", "maintainer", "read", "admin"] {
1006 assert!(roles.as_array().unwrap().contains(&json!(role)), "{role}");
1007 }
1008 assert_eq!(
1009 resolve(team, &json!({ "action": "set_repo", "workspace": "acme", "team": "backend", "repo": "rocket" })),
1010 Err("team.set_repo needs role.".to_owned())
1011 );
1012 }
1013
1014 #[test]
1015 fn reviewers_and_code_owners_are_actions_of_their_tools() {
1016 let pull = Tool::by_name("pull_request").unwrap();
1017 assert_eq!(
1018 resolve(pull, &json!({ "action": "request_reviewers", "repo": "a/b", "number": 1, "team_reviewers": ["backend"] })),
1019 Ok(Op::RequestReviewers)
1020 );
1021 assert_eq!(pull.action("remove_requested_reviewers").map(|action| action.op), Some(Op::RemoveRequestedReviewers));
1022 let repository = Tool::by_name("repository").unwrap();
1023 assert_eq!(resolve(repository, &json!({ "action": "codeowners", "repo": "a/b" })), Ok(Op::GetCodeownersErrors));
1024 assert!(reads_only(Op::GetCodeownersErrors));
1025 assert!(!reads_only(Op::RequestReviewers));
1026 }
1027
1028 /// The `artifact` tool offers each token only what its artifacts scope
1029 /// allows: reading, then changing, then sharing and deleting for good.
1030 /// Workflow runs' artifacts are the `workflow` tool's, under their own
1031 /// scope, and neither scope reaches the other's.
1032 #[test]
1033 fn the_artifact_tool_offers_what_the_artifacts_scope_allows() {
1034 let actions = |scopes: Vec<Scope>| -> Option<Value> {
1035 let access = token(Some(scopes));
1036 Tool::by_name("artifact").unwrap().listed(&Gate::Token(&access)).map(|tool| tool["inputSchema"]["properties"]["action"]["enum"].clone())
1037 };
1038 let reads = json!(["list", "search", "get", "read", "versions", "access", "templates", "spaces", "query_data"]);
1039 assert_eq!(actions(vec![Scope::ArtifactsRead]), Some(reads.clone()));
1040 let writes = actions(vec![Scope::ArtifactsWrite]).unwrap();
1041 for action in ["create", "update", "edit", "trash", "restore", "restore_version"] {
1042 assert!(writes.as_array().unwrap().contains(&json!(action)), "{action}");
1043 }
1044 assert!(!writes.as_array().unwrap().contains(&json!("share")) && !writes.as_array().unwrap().contains(&json!("purge")));
1045 let admin = actions(vec![Scope::ArtifactsAdmin]).unwrap();
1046 assert_eq!(admin.as_array().unwrap().len(), Tool::by_name("artifact").unwrap().actions.len());
1047 // Without an artifacts scope there is no artifact tool at all.
1048 assert_eq!(actions(vec![Scope::WorkflowsWrite, Scope::IssuesWrite]), None);
1049 // And an artifacts scope shows nothing of workflow runs' artifacts.
1050 let access = token(Some(vec![Scope::ArtifactsAdmin]));
1051 assert!(Tool::by_name("workflow").unwrap().listed(&Gate::Token(&access)).is_none());
1052 // The read-only and agent presets read artifacts and change none.
1053 for preset in [Preset::ReadOnly, Preset::Agent] {
1054 let access = token(preset.scopes());
1055 let tool = Tool::by_name("artifact").unwrap().listed(&Gate::Token(&access)).unwrap();
1056 assert_eq!(tool["inputSchema"]["properties"]["action"]["enum"], reads, "{}", preset.as_str());
1057 assert_eq!(tool["annotations"]["readOnlyHint"], true);
1058 }
1059 // Sharing and deleting for good can't be undone the same way.
1060 let tools = listed(&Gate::Everything);
1061 let artifact = tools.iter().find(|tool| tool["name"] == "artifact").unwrap();
1062 assert_eq!(artifact["annotations"]["destructiveHint"], true);
1063 assert!(artifact["description"].as_str().unwrap().contains("Not the `workflow` tool's run artifacts"));
1064 let tool = Tool::by_name("artifact").unwrap();
1065 assert_eq!(resolve(tool, &json!({ "action": "read", "workspace": "acme" })), Err("artifact.read needs artifact_id.".to_owned()));
1066 assert_eq!(
1067 resolve(tool, &json!({ "action": "edit", "workspace": "acme", "artifact_id": "fol_1", "markdown": "x" })),
1068 Ok(Op::Folios(FoliosOp::Edit))
1069 );
1070 }
1071
1072 /// How much smaller `tools/list` is than one tool per operation. Run
1073 /// with `--nocapture` to see the numbers.
1074 #[test]
1075 fn the_tool_list_is_much_smaller_than_one_tool_per_operation() {
1076 let before: Vec<Value> = Op::ALL
1077 .into_iter()
1078 .map(|op| json!({ "name": op.name(), "description": op.description(), "inputSchema": op.input() }))
1079 .collect();
1080 let after = listed(&Gate::Everything);
1081 let before_bytes = serde_json::to_string(&json!({ "tools": before })).unwrap().len();
1082 let after_bytes = serde_json::to_string(&json!({ "tools": after })).unwrap().len();
1083 let agent = token(Preset::Agent.scopes());
1084 let agent_bytes = serde_json::to_string(&json!({ "tools": listed(&Gate::Token(&agent)) })).unwrap().len();
1085 let read = token(Preset::ReadOnly.scopes());
1086 let read_bytes = serde_json::to_string(&json!({ "tools": listed(&Gate::Token(&read)) })).unwrap().len();
1087 println!(
1088 "tools/list: before {} tools, {before_bytes} bytes (~{} tokens); after {} tools, {after_bytes} bytes (~{} tokens); agent preset {agent_bytes} bytes (~{} tokens); read only {read_bytes} bytes (~{} tokens)",
1089 before.len(),
1090 before_bytes / 4,
1091 after.len(),
1092 after_bytes / 4,
1093 agent_bytes / 4,
1094 read_bytes / 4,
1095 );
1096 assert!(after_bytes * 2 < before_bytes, "{after_bytes} vs {before_bytes}");
1097 }
1098}