Skip to main content

aristo_cli/
lib.rs

1//! Library form of the Aristo CLI. The `aristo` binary (`src/main.rs`) is
2//! a thin wrapper that calls [`run`] and exits with its return code.
3//!
4//! Splitting the CLI into a lib + tiny bin lets integration tests exercise
5//! `dispatch` directly without spawning a child process for every case
6//! (the `binary_smoke` test still spawns one, on purpose, as the canary
7//! for the binary's own glue).
8
9mod commands;
10mod data_plane;
11mod error;
12mod filter;
13/// The nudge/progress engine (Phase 18 #9). Public so the as-yet-unwired
14/// scorer is part of the lib API surface; the `aristo nudge` emitter (S0d)
15/// is its in-crate consumer.
16pub mod nudge;
17mod pipeline;
18mod session;
19mod skills;
20mod update_notify;
21mod workspace;
22
23pub use error::{CliError, CliResult};
24pub use filter::{Filter, FilterParseError};
25pub use workspace::{Workspace, WorkspaceError};
26
27use clap::{Parser, Subcommand};
28use std::path::PathBuf;
29use std::process::ExitCode;
30
31/// Aristo annotation SDK CLI.
32///
33/// Each subcommand handles one stage of the annotation lifecycle:
34/// authoring (`init`, `lang`, `install-skills`), indexing and stamping
35/// (`index`, `stamp`, `rename`), inspection (`show`, `list`, `status`,
36/// `graph`, `doc`, `badge`), quality gates (`lint`, `verify`,
37/// `critique`), review-session management (`session`), and canon
38/// binding against the Aretta server (`auth`, `canon`).
39#[derive(Parser, Debug)]
40#[command(
41    name = "aristo",
42    version,
43    about = "Aristo annotation SDK — write, verify, and document intent.",
44    long_about = None,
45)]
46struct Cli {
47    #[command(subcommand)]
48    command: Commands,
49}
50
51#[derive(Subcommand, Debug)]
52enum Commands {
53    /// Set up Aristo in this repo (creates `aristo.toml`, `.aristo/`,
54    /// pre-commit hook). Pass `--ci` / `--ci-verify` to also add CI workflows.
55    Init {
56        /// Modify Cargo.toml to add `aristo` as a dependency. Default
57        /// behavior just prints the dep line for the user to paste in.
58        #[arg(short, long)]
59        force: bool,
60
61        /// Also write a lite PR-gate workflow (`.github/workflows/aristo.yml`)
62        /// that runs audit/lint/doc via the shared aristo-action. No token needed.
63        #[arg(long)]
64        ci: bool,
65
66        /// Also write the nightly/manual verify workflow
67        /// (`.github/workflows/aristo-verify.yml`). Needs an `ARETTA_TOKEN` repo
68        /// secret (paid tier). Implies `--ci`.
69        #[arg(long)]
70        ci_verify: bool,
71
72        /// Install a local pre-commit hook (DEPRECATED). Off by default and no
73        /// longer auto-installed: the index is a gitignored cache, so CI
74        /// (`aristo verify --audit`) is the enforcement point. The hook only
75        /// runs `aristo doc` + `lint` locally as a convenience.
76        #[arg(long)]
77        hook: bool,
78    },
79
80    /// Print a syntax cheat sheet for the detected language.
81    Lang {
82        /// Detect language for a specific file. Currently only Rust
83        /// (`.rs`) is supported; other extensions error out.
84        #[arg(long)]
85        file: Option<PathBuf>,
86    },
87
88    /// Install Aristo skills for a coding agent (claude-code, cursor, codex, opencode, antigravity).
89    InstallSkills {
90        /// Target agent. Required unless `--list-agents` is used.
91        #[arg(long, value_name = "name")]
92        agent: Option<String>,
93        /// List supported agents and exit.
94        #[arg(long)]
95        list_agents: bool,
96        /// Install at user-level (e.g. ~/.claude/skills/) instead of project-level.
97        #[arg(long)]
98        user: bool,
99        /// Re-pin installed skills to this binary's version. With `--agent`,
100        /// re-installs that agent; without it, heals every already-installed
101        /// agent in place (both scopes, or just `--user`).
102        #[arg(long)]
103        update: bool,
104        /// Report whether installed skills are stale relative to this binary
105        /// (read-only). Exits non-zero if any are out of date.
106        #[arg(long)]
107        check: bool,
108        /// Internal: emit a SessionStart hook `additionalContext` block when
109        /// installed skills are stale (used by the hook this command installs).
110        #[arg(long, hide = true)]
111        hook_format: bool,
112    },
113
114    /// Reverse `install-skills`: remove SDK-bundled skills.
115    UninstallSkills {
116        /// Target agent. Required.
117        #[arg(long, value_name = "name")]
118        agent: String,
119        /// Uninstall from user-level instead of project-level.
120        #[arg(long)]
121        user: bool,
122        /// Override the "skip locally-modified" safety check.
123        #[arg(long)]
124        force: bool,
125    },
126
127    /// Scan source for annotations and write the index (`.aristo/index.toml`).
128    Index {
129        /// Force a full re-walk, ignoring the per-file mtime cache.
130        #[arg(long)]
131        all: bool,
132    },
133
134    /// Refresh the annotation index — pick up new annotations, detect
135    /// drift, and (when signed in) match against the Aretta canon.
136    Stamp {
137        /// CI mode: report whether `stamp` would change the index or
138        /// `.aristo/canon-matches.toml`, without writing either.
139        /// Exits non-zero if it would. Skips the canon-match step
140        /// too (no outbound network calls in this mode).
141        #[arg(long)]
142        check: bool,
143        /// Skip the canon-match step for this run. Doesn't disable
144        /// canon globally — set `[canon] enabled = false` in
145        /// `aristo.toml` for that. Useful when you're offline or want
146        /// a fast local stamp.
147        #[arg(long = "skip-canon")]
148        skip_canon: bool,
149        /// Invalidate the local canon-match cache and re-query every
150        /// annotation on this run. Equivalent to
151        /// `aristo canon refresh && aristo stamp`.
152        #[arg(long = "refresh-canon", conflicts_with = "skip_canon")]
153        refresh_canon: bool,
154        /// Garbage-collect archived orphan proofs after stamping. Removed
155        /// annotations' `.proof` files are normally *archived* (moved to
156        /// `.aristo/archive/proofs/`) so a stray stamp never loses a verdict;
157        /// `--gc` is the only path that hard-deletes them. No-op under
158        /// `--check` (CI must not mutate the workspace).
159        #[arg(long = "gc")]
160        gc: bool,
161    },
162
163    /// Look up an annotation by id, fn / mod / struct name, or file:line.
164    Show {
165        /// Selector: bare id, `fn <name>`, `mod <name>`, `struct <name>`,
166        /// `enum <name>`, `trait <name>`, or `<file>:<line>`.
167        selector: String,
168        /// Emit the entry as JSON instead of human-readable text.
169        #[arg(long, conflicts_with = "toml_out")]
170        json: bool,
171        /// Emit the entry as TOML (mirrors the on-disk index schema).
172        #[arg(long = "toml", conflicts_with = "json")]
173        toml_out: bool,
174    },
175
176    /// List every annotation in the index.
177    List {
178        /// Unified filter clause (`id=<id>`, `file=<path>`,
179        /// `parent=<id>`, `status=<state>`). Repeatable; multiple
180        /// `--filter` flags AND together.
181        #[arg(long = "filter", value_name = "key=value")]
182        filters: Vec<String>,
183        /// Emit a JSON array of records instead of human-readable text.
184        #[arg(long)]
185        json: bool,
186    },
187
188    /// Project-level summary (tier, counts, freshness).
189    Status,
190
191    /// Machine-readable project metrics (counts, unverified backlog, tier).
192    /// The same `Metrics` value the nudge engine computes internally.
193    Metrics {
194        /// Emit the metrics as a JSON object instead of a human summary.
195        #[arg(long)]
196        json: bool,
197    },
198
199    /// The nudge/progress engine. With no `--event`, prints what the engine
200    /// would surface right now (human introspection). With `--event`, runs as
201    /// a Claude Code hook emitter (`post-tool-use` / `user-prompt-submit` /
202    /// `session-start`) — always exits 0 so a nudge can never break the
203    /// agent's workflow. Agent-facing output uses `additionalContext` (the
204    /// only channel that reaches the model); `Stop` is intentionally not
205    /// served (its output never reaches the agent).
206    Nudge {
207        /// Hook event to serve (omit for the human readout).
208        #[arg(long)]
209        event: Option<String>,
210    },
211
212    /// Ambient one-line status segment for the Claude Code `statusLine`
213    /// (e.g. `aristo  3 review · 2 unverified · Apprentice`). Read-only;
214    /// prints nothing when there's no workspace or nudges are off.
215    Statusline,
216
217    /// Review newly-authored intents (#7). With no flags, lists what awaits
218    /// review (split into new-this-session vs backlog when a baseline exists).
219    /// `--mark <id>` records intents as reviewed once you've looked at them.
220    Review {
221        /// Mark these authored intents reviewed (repeatable; comma-lists OK).
222        /// The whole batch is validated before anything is written.
223        #[arg(long = "mark", value_name = "ID")]
224        mark: Vec<String>,
225        /// Emit the review snapshot (or mark result) as JSON instead of a
226        /// human summary.
227        #[arg(long)]
228        json: bool,
229    },
230
231    /// Check annotation prose for quality issues (rule-based; no LLM).
232    Lint {
233        /// Read-only mode: exit non-zero on `error` findings (or
234        /// `warn` with `--strict`); never modifies source.
235        #[arg(long)]
236        check: bool,
237        /// Apply auto-fixable lint rules (whitespace only) to source
238        /// files in place.
239        #[arg(long, conflicts_with = "check")]
240        fix: bool,
241        /// Treat `warn` severity as failure too (only meaningful with `--check`).
242        #[arg(long)]
243        strict: bool,
244    },
245
246    /// Run verification for every annotation that opted in.
247    Verify {
248        /// Unified filter clause (`id=<id>`, `file=<path>`,
249        /// `parent=<id>`, `status=<state>`). Repeatable; multiple
250        /// `--filter` flags AND together.
251        #[arg(long = "filter", value_name = "key=value")]
252        filters: Vec<String>,
253        /// Re-verify entries that are already in a clean verified
254        /// state. By default they're skipped; pass `--rerun` to force
255        /// a re-check.
256        #[arg(long)]
257        rerun: bool,
258        /// CI mode: report whether any status would change, without
259        /// writing the index. Exits non-zero if any change is needed.
260        #[arg(long)]
261        check: bool,
262        /// Treat warn-severity verification outcomes as failure too.
263        #[arg(long)]
264        strict: bool,
265        /// Audit mode: regenerate the index in memory and validate every
266        /// `.aristo/proofs/<id>.proof` against current source. Reports
267        /// fresh / stale / refuted / orphan counts; with `--strict`, exits
268        /// non-zero on any stale, counterexample, or orphan proof. The CI
269        /// freshness gate (replaces `aristo stamp --check`) — no dispatch,
270        /// no network, no token.
271        #[arg(long = "audit")]
272        audit: bool,
273        /// Apply pending verdict files in `.aristo/proofs/` to the
274        /// index. Reads every `<id>.proof`, runs the mechanical
275        /// validator, and (if it passes) flips the entry's status.
276        /// Skips dispatch of new verifications when set.
277        #[arg(long = "apply-verdicts", conflicts_with = "submit_verdict")]
278        apply_verdicts: bool,
279        /// Migration only: ignore any agent-stamped ground hashes in
280        /// the `.proof` files and recompute them from the cited file
281        /// ranges and index entries. Use this once when migrating
282        /// from older proof files that recorded hashes the SDK now
283        /// fills in itself. Without this flag, a stamped hash that
284        /// mismatches the current source is reported as staleness
285        /// and the proof is rejected. Only meaningful with
286        /// `--apply-verdicts`.
287        #[arg(long = "rewrite-hashes", requires = "apply_verdicts")]
288        rewrite_hashes: bool,
289        /// **Internal — invoked by the verification skill.** Submit
290        /// a single verdict: parse the JSON payload, validate it,
291        /// and (on pass) atomically write `.aristo/proofs/<id>.proof`.
292        /// Prints `accepted: sha256:<hex>` on success; structured
293        /// errors on reject. Agents never write `.proof` files
294        /// directly — the SDK is the sole writer.
295        #[arg(long = "submit-verdict", requires = "id", requires = "json")]
296        submit_verdict: bool,
297        /// Annotation id this verdict is about. Required with
298        /// `--submit-verdict`. The `.proof` file lands at
299        /// `.aristo/proofs/<id>.proof` (with `:` rewritten to `__`).
300        #[arg(long = "id", requires = "submit_verdict")]
301        id: Option<String>,
302        /// JSON-serialized ProofFile body. Required with
303        /// `--submit-verdict`. Pass as a single-quoted shell string;
304        /// the SDK parses it into a ProofFile and rejects anything
305        /// the validator would reject. Same schema as the TOML body
306        /// written on accept.
307        #[arg(long = "json", requires = "submit_verdict")]
308        json: Option<String>,
309        /// **Internal — invoked by the verification skill.**
310        /// Atomically claim one task from the pending queue and
311        /// print its TOML body to stdout. Empty stdout means the
312        /// queue is drained (exit 0 either way). Verify workers are
313        /// single-shot — call once, process the task, exit — so
314        /// context doesn't carry between verifications. The
315        /// orchestrator runs N workers in parallel and uses
316        /// `--queue-status` to decide when to spawn the next wave.
317        #[arg(long = "pop-next", conflicts_with_all = ["apply_verdicts", "submit_verdict", "queue_status"])]
318        pop_next: bool,
319        /// Peek at queue state without claiming. Prints `pending: N`,
320        /// `claimed: M` to stdout, exit 0. Used by the orchestrator
321        /// to decide whether to dispatch another wave of workers.
322        /// Safe to call concurrently.
323        #[arg(long = "queue-status", conflicts_with_all = ["apply_verdicts", "submit_verdict"])]
324        queue_status: bool,
325        /// Block until the canon-verify session reaches a terminal
326        /// state, rendering a snapshot at each long-poll return and
327        /// emitting a `still running…` heartbeat every 60s. Exit code
328        /// is derived from the final summary: `0` iff every
329        /// annotation is `verified` or `no_coverage`. Transient poll
330        /// failures (server 5xx, network, timeout) are retried with
331        /// backoff; the whole wait is bounded by a 2-hour deadline
332        /// (override via `ARISTO_VERIFY_WAIT_TIMEOUT_SECS`; `0`
333        /// disables the deadline). Without
334        /// `--wait` the SDK detaches after dispatch (prints session
335        /// id and exits 0). Combine with `--view <id>` to attach to
336        /// a session another invocation started.
337        #[arg(long = "wait")]
338        wait: bool,
339        /// CI guard against vacuous green: exit non-zero when the
340        /// canon-verify dispatch set is empty (no annotations were
341        /// sent to the server — e.g. a missing/stale canon-matches
342        /// cache, zero canon-bound `verify="full"` entries, or
343        /// everything skipped as already clean). Without this flag a
344        /// zero-dispatch run exits 0, which CI reads as "verified"
345        /// even though nothing ran. Usable only on the dispatch path:
346        /// combining it with a verb that cannot dispatch is a usage
347        /// error, never a silent no-op.
348        #[arg(
349            long = "require-dispatch",
350            conflicts_with_all = [
351                "view", "audit", "pop_next", "queue_status",
352                "submit_verdict", "apply_verdicts", "accept"
353            ]
354        )]
355        require_dispatch: bool,
356        /// Re-attach to a previously-dispatched canon-verify session
357        /// by id. Skips the source eligibility scan, push-first
358        /// precheck, and POST — just GETs the session state and
359        /// renders. Combine with `--wait` to block until terminal.
360        #[arg(long = "view", value_name = "SESSION_ID")]
361        view: Option<String>,
362        /// Subset the canon-verify dispatch to the listed annotation
363        /// ids. Comma-separated; each id must be a canon-bound entry
364        /// (`aristos:foo` or `kanon:bar`) in the workspace's index.
365        /// Bare canon-id suffixes (e.g. `foo`) are accepted as a
366        /// shorthand. `arta_*` (server-side opaque) ids are rejected
367        /// — those are not user-facing.
368        #[arg(long = "tags", value_name = "id1,id2,...", value_delimiter = ',')]
369        tags: Vec<String>,
370        /// Phase 16 (c): record a user-side known-failure waiver for a
371        /// canon-bound property your code currently violates. Write-only
372        /// — does NOT dispatch a verification. Requires `--because`. The
373        /// gap lands in `.aristo/expectations.toml` (commit it); at
374        /// verify time it renders as a "known gap (accepted)" instead of
375        /// a failure, and the strict ratchet flips it back to red if the
376        /// property ever starts passing — so stale waivers can't rot.
377        /// Accepts a bare canon-id suffix (e.g. `foo`) as shorthand.
378        #[arg(
379            long = "accept",
380            value_name = "CANON_ID",
381            requires = "because",
382            conflicts_with_all = [
383                "view", "wait", "tags", "rerun", "check", "strict", "filters",
384                "apply_verdicts", "rewrite_hashes", "submit_verdict", "id",
385                "json", "pop_next", "queue_status"
386            ]
387        )]
388        accept: Option<String>,
389        /// Reason the gap is accepted (mandatory with `--accept`).
390        /// Recorded verbatim and shown on the verify card. A reasonless
391        /// waiver is how baselines rot, so it is required.
392        #[arg(long = "because", value_name = "REASON", requires = "accept")]
393        because: Option<String>,
394        /// Optional tracking reference (issue URL, ticket id) for the
395        /// accepted gap. Only meaningful with `--accept`.
396        #[arg(long = "tracking", value_name = "REF", requires = "accept")]
397        tracking: Option<String>,
398    },
399
400    /// Run the critique skill against annotation prose — opinionated
401    /// suggestions, severity-tagged findings.
402    Critique {
403        /// Unified filter clause (`id=<id>[,<id>,...]`,
404        /// `file=<path>`, `parent=<id>`, `status=<state>`). Repeatable;
405        /// multiple `--filter` flags AND together; values may be
406        /// comma-separated. **REQUIRED** — `aristo critique` with no
407        /// filter errors with usage. To sweep every annotation in the
408        /// index, opt in explicitly with `--all --yes`.
409        #[arg(long = "filter", value_name = "key=value")]
410        filters: Vec<String>,
411        /// Apply pending critique files in `.aristo/critiques/` —
412        /// re-validate every `<id>.critique` and print a summary
413        /// grouped by id. Defaults to listing only findings whose
414        /// `disposition` is `None` (open / not yet reviewed); pass
415        /// `--include-closed` for the full view including findings
416        /// already triaged via `aristo session decide`.
417        #[arg(long = "apply-findings", conflicts_with_all = ["submit_findings", "pop_next", "queue_status"])]
418        apply_findings: bool,
419        /// Include findings whose `disposition` has been set (Accepted /
420        /// Rejected / Deferred) in the `--apply-findings` summary.
421        /// By default only open findings are listed — closed ones
422        /// stop re-surfacing on every apply, which is how a review
423        /// closes the loop. Only meaningful with `--apply-findings`.
424        #[arg(long = "include-closed", requires = "apply_findings")]
425        include_closed: bool,
426        /// Force re-enqueue of every matched annotation, bypassing the
427        /// `last_critiqued_at_text_hash` cache. Default behavior skips
428        /// annotations whose text hasn't drifted since the cached
429        /// critique was produced (so re-runs of `aristo critique
430        /// --filter id=X` are free when X is unchanged).
431        #[arg(long = "rerun")]
432        rerun: bool,
433        /// Restrict scope to annotations in files git-staged for the
434        /// next commit (`git diff --cached --name-only`). Useful for
435        /// pre-commit hook integration. Satisfies the filter-required
436        /// guard on its own; composes with explicit `--filter`
437        /// clauses via intersection (annotations must match BOTH
438        /// `--filter` and appear in the staged set).
439        #[arg(long = "staged")]
440        staged: bool,
441        /// Sweep every intent annotation that has a real `verify`
442        /// method (skips documentation-only `verify = false`). Loud
443        /// on purpose: prints `(this will enqueue N annotations;
444        /// ~$X cost — proceed with --all --yes?)` and exits 2 unless
445        /// you also pass `--yes`. Without the confirmation, an agent
446        /// could accidentally fire hundreds of LLM calls in one go.
447        #[arg(long = "all", conflicts_with_all = ["filters", "staged"])]
448        all: bool,
449        /// Skip the confirmation prompt for `--all`. Required
450        /// alongside `--all` to actually enqueue the sweep; without
451        /// it `--all` just prints the cost estimate and exits 2.
452        #[arg(long = "yes", requires = "all")]
453        yes: bool,
454        /// **Internal — invoked by the critique skill.** Atomically
455        /// claim one task from the critique queue and print its TOML
456        /// body to stdout. Empty stdout means the queue is drained
457        /// (exit 0 either way). Unlike verify, critique workers loop
458        /// on this call — the tasks are shallow and vocabulary stays
459        /// consistent when one worker handles several.
460        #[arg(long = "pop-next", conflicts_with_all = ["apply_findings", "submit_findings", "queue_status"])]
461        pop_next: bool,
462        /// Peek at queue state without claiming. Prints `pending: N`
463        /// + `claimed: M` to stdout, exit 0.
464        #[arg(long = "queue-status", conflicts_with_all = ["apply_findings", "submit_findings"])]
465        queue_status: bool,
466        /// **Internal — invoked by the critique skill.** Submit a
467        /// single critique: parse the JSON payload, validate it, and
468        /// (on accept) atomically write
469        /// `.aristo/critiques/<id>.critique`. Prints
470        /// `accepted: sha256:<hex>` on success.
471        #[arg(long = "submit-findings", requires = "id", requires = "json")]
472        submit_findings: bool,
473        /// Annotation id this submission is about. Required with
474        /// `--submit-findings`.
475        #[arg(long = "id", requires = "submit_findings")]
476        id: Option<String>,
477        /// JSON-serialized CritiqueFile body. Required with
478        /// `--submit-findings`.
479        #[arg(long = "json", requires = "submit_findings")]
480        json: Option<String>,
481    },
482
483    /// Generate per-annotation markdown to .aristo/doc/.
484    Doc {
485        /// Write only the crate-root summary (`_summary.md`); skip the
486        /// per-annotation pass.
487        #[arg(long)]
488        summary: bool,
489        /// Include each annotation's current verification status in
490        /// the rendered markdown. Status is a build-time snapshot
491        /// that drifts as code evolves; the default omits it so doc
492        /// artifacts stay reproducible on a clean checkout.
493        #[arg(long = "include-status")]
494        include_status: bool,
495        /// CI mode: recompute expected per-annotation MD from the index,
496        /// compare against `.aristo/doc/`, exit non-zero on drift. Never
497        /// writes.
498        #[arg(long)]
499        check: bool,
500        /// Composite: also generate the annotation graph (Mermaid)
501        /// and embed it inline in `_summary.md`. Implies `--summary`.
502        /// Conflicts with `--check` (read-only mode can't write the
503        /// graph block).
504        #[arg(long = "include-graph", conflicts_with = "check")]
505        include_graph: bool,
506    },
507
508    /// Generate the annotation graph (Mermaid / DOT / SVG).
509    Graph {
510        /// Output format. `mermaid` (default) emits a fenced
511        /// flowchart TD block; `dot` emits Graphviz DOT; `svg`
512        /// requires `dot` on PATH and shells out to render.
513        #[arg(long, default_value = "mermaid")]
514        format: String,
515        /// Write to this path instead of stdout. Atomic via
516        /// temp-file + rename. Relative paths resolve against the
517        /// invoking directory.
518        #[arg(long)]
519        out: Option<PathBuf>,
520        /// Unified filter clause (`id=<id>`, `file=<path>[:<LO>-<HI>]`,
521        /// `parent=<id>`, `status=<state>`). Repeatable; multiple
522        /// `--filter` flags AND together. With no filter, the scope
523        /// is the whole index.
524        #[arg(long = "filter", value_name = "key=value")]
525        filters: Vec<String>,
526        /// Drop `assume` nodes from the rendered graph. They're
527        /// included by default because assumes describe the
528        /// background facts your intents rely on — dropping them by
529        /// default would hide those.
530        #[arg(long = "exclude-assumes")]
531        exclude_assumes: bool,
532        /// Walk N hops from each filter-matched node in both
533        /// directions (ancestors + descendants) and include them in
534        /// the rendered graph. Useful for "show me this annotation
535        /// plus some context". Only meaningful with `--filter`;
536        /// without a filter, the scope is already the whole index.
537        #[arg(long, value_name = "N")]
538        depth: Option<u32>,
539        /// Include intent nodes that have no parent and no children.
540        /// They're omitted by default — usually they're standalone
541        /// claims that don't add structure to the rendered graph.
542        /// Assumes are always included (see `--exclude-assumes` for
543        /// that opt-out).
544        #[arg(long = "include-orphans")]
545        include_orphans: bool,
546        /// Color nodes by their current verification status instead
547        /// of by `verify` level (verified=green / tested=blue /
548        /// neural=yellow / stale=orange / orphan=purple /
549        /// forged=red+border / unknown=gray /
550        /// counterexample=red+border / inconclusive=red+border /
551        /// pending-deepen=gray). The `verify` level moves to the
552        /// in-node label. Use when you want to see what's still
553        /// unverified.
554        #[arg(long = "include-status")]
555        include_status: bool,
556    },
557
558    /// Generate a shareable SVG verification badge for README / docs.
559    Badge {
560        /// Write SVG to this path (relative to workspace root, or absolute).
561        /// Default: stdout.
562        #[arg(long)]
563        out: Option<PathBuf>,
564        /// Badge style: `flat-square` (default), `flat`, or `plastic`.
565        #[arg(long, default_value = "flat-square")]
566        style: String,
567        /// Which metric the SVG value half displays. `tier` (default,
568        /// the locked D7 score → D8 tier) is the headline signal;
569        /// `count` and `rate` preserve the slice-31 surfaces for
570        /// projects that prefer the simpler counters.
571        #[arg(long, default_value = "tier")]
572        metric: String,
573    },
574
575    /// Rename an annotation id everywhere it appears — source files,
576    /// index, and doc artifacts. Either every change lands or none do.
577    ///
578    /// Supported renames: bare → bare, and stamp-assigned opaque
579    /// (`aret_*`) → bare. Canon-bound prefixes (`aristos:` / `kanon:`)
580    /// are rejected in either direction — those prefixes are applied
581    /// by `aristo canon accept` and removed by `aristo canon unbind`.
582    /// The new id cannot itself be an opaque `aret_*` id (those are
583    /// stamp-assigned only).
584    Rename {
585        /// Annotation id to rename FROM. Must exist in the current
586        /// `.aristo/index.toml`.
587        old_id: String,
588        /// Annotation id to rename TO. Must not already exist and must
589        /// not use the reserved `aret_*` / `aristos:` / `kanon:`
590        /// prefixes.
591        new_id: String,
592        /// Compute and print the rename plan (source edits + per-id
593        /// artifact moves + index updates) without writing anything.
594        #[arg(long = "dry-run")]
595        dry_run: bool,
596    },
597
598    /// Run a review session over a pipeline's open artifacts —
599    /// critique findings, proof verdicts, and so on. Start it,
600    /// inspect bucket counts, record decisions, and close out.
601    Session {
602        #[command(subcommand)]
603        action: SessionAction,
604    },
605
606    /// Sign in to the Aretta canon API. Required for `aristo stamp`
607    /// and `aristo critique` to see canon matches on the Pro /
608    /// Enterprise tiers.
609    Auth {
610        #[command(subcommand)]
611        action: AuthAction,
612    },
613
614    /// Manage canon bindings: accept or reject pending matches,
615    /// inspect or refresh the local cache, unbind bound ids, and
616    /// request a verifier for a canon entry.
617    Canon {
618        #[command(subcommand)]
619        action: CanonAction,
620    },
621
622    /// Manage C instrumentation artifacts: vendor the C runtime, run codegen.
623    Instrument {
624        #[command(subcommand)]
625        action: InstrumentAction,
626    },
627}
628
629/// Subcommands under `aristo auth`. Each operates on the persistent
630/// credentials store under `$XDG_CONFIG_HOME/aristo/credentials`
631/// (or the platform default per `aristo_core::auth`).
632#[derive(clap::Subcommand, Debug)]
633pub(crate) enum AuthAction {
634    /// Authenticate against the Aretta proxy.
635    ///
636    /// **Default mode (GitHub OAuth):** the CLI fetches the GitHub
637    /// authorization URL from the proxy, tries to open it in your
638    /// browser, and prompts you to paste the code shown on the
639    /// proxy's callback page. The proxy then mints an `arta_*`
640    /// token scoped to your `(user, repo)` pair.
641    ///
642    /// **Bypass modes (for CI / scripting):**
643    ///
644    /// - **`--stdin`** — read the raw token from stdin
645    ///   (`echo "$TOKEN" | aristo auth login --stdin`).
646    /// - **`--token=<T>`** — use the literal token value.
647    ///
648    /// The token is persisted to `$XDG_CONFIG_HOME/aristo/credentials`
649    /// with `0600` Unix permissions.
650    Login {
651        /// Read the token from stdin (consumes entire stdin). Skips
652        /// the OAuth flow.
653        #[arg(long, conflicts_with = "token")]
654        stdin: bool,
655        /// Use this token directly. Skips the OAuth flow.
656        #[arg(long, value_name = "TOKEN")]
657        token: Option<String>,
658        /// Aretta server to authenticate against. Accepts:
659        /// `prod` / `production` (= https://code.aretta.ai),
660        /// or a full URL for a self-hosted deployment or per-org
661        /// conductor (`https://aretta.example.com`).
662        ///
663        /// Precedence when unset: this flag > the `ARETTA_API_URL` env
664        /// var (parsed the same way, full URLs included) > zero-config
665        /// org discovery for the repo > the `prod` default. Discovery
666        /// runs only when neither this flag nor `ARETTA_API_URL` is set,
667        /// so an explicit choice always wins and skips the lookup.
668        /// Honoring `ARETTA_API_URL` keeps the login (auth) plane pointed
669        /// at the same deployment as the data plane.
670        #[arg(long)]
671        server: Option<String>,
672        /// Repo to scope the minted token to (`owner/repo`). Defaults to
673        /// auto-deriving from `<cwd>/.git/config`'s `remote.origin.url`.
674        /// Required for non-git directories or when the remote isn't a
675        /// GitHub URL. In `--stdin` / `--token` bypass modes it (with
676        /// `--server`) keys the stored credential for later multi-repo
677        /// lookup — best-effort there, so it may be omitted.
678        #[arg(long, value_name = "OWNER/REPO")]
679        repo: Option<String>,
680    },
681    /// Show the current authentication state. Lists every stored
682    /// credential (server, repo, user) — never the token itself — plus
683    /// any `ARETTA_TOKEN` env override. Handy for sanity-checking before
684    /// running `aristo stamp`.
685    Status,
686    /// Print the resolved `arta_*` token to stdout — the `ARETTA_TOKEN`
687    /// env var if set, else the stored credential for the current repo.
688    /// Nothing else is printed, so it pipes cleanly to your clipboard,
689    /// e.g. `aristo auth token | pbcopy` (macOS) or
690    /// `aristo auth token | xclip -selection clipboard` (Linux). Handy for
691    /// setting the `ARETTA_TOKEN` CI secret. Errors if not authenticated.
692    Token {
693        /// Repo (`owner/repo`) whose token to print. Defaults to the
694        /// cwd's git remote; with several credentials stored and no
695        /// match, errors telling you to pass this.
696        #[arg(long, value_name = "OWNER/REPO")]
697        repo: Option<String>,
698    },
699    /// Remove a stored credential. By default removes the current repo's
700    /// entry (from `--repo` or the cwd's git remote); `--all` clears
701    /// every credential. Idempotent — logging out when not logged in is
702    /// not an error.
703    Logout {
704        /// Remove every stored credential, not just the current repo's.
705        #[arg(long)]
706        all: bool,
707        /// Repo (`owner/repo`) whose credential to remove. Defaults to
708        /// the cwd's git remote. Ignored with `--all`.
709        #[arg(long, value_name = "OWNER/REPO", conflicts_with = "all")]
710        repo: Option<String>,
711    },
712}
713
714/// Subcommands under `aristo instrument`.
715#[derive(clap::Subcommand, Debug)]
716pub(crate) enum InstrumentAction {
717    /// Emit the vendored C runtime (`aristo.h` + `aristo.c`) into a SUT so it
718    /// can link Aristo's fault-injection / observation points. C11, gated by
719    /// `-DARISTO_INSTRUMENT`.
720    VendorC {
721        /// Directory to write `aristo.h` / `aristo.c` into.
722        #[arg(long, default_value = "aristo")]
723        out: PathBuf,
724    },
725
726    /// Render read-only field accessors from `// @aristo inspect(...)`
727    /// directives into a gated `aristo_generated.{h,c}` pair.
728    GenC {
729        /// One or more C source files to read directives from.
730        #[arg(required = true)]
731        paths: Vec<PathBuf>,
732        /// The opaque-handle header the generated `.h` includes.
733        #[arg(long, default_value = "db.h")]
734        handle_header: String,
735        /// Directory to write `aristo_generated.{h,c}` into.
736        #[arg(long, default_value = "aristo")]
737        out: PathBuf,
738        /// Verify committed generated files match the directives; write
739        /// nothing, exit non-zero on drift (CI gate).
740        #[arg(long)]
741        check: bool,
742    },
743}
744
745/// Subcommands under `aristo canon`.
746#[derive(clap::Subcommand, Debug)]
747pub(crate) enum CanonAction {
748    /// Accept a pending canon match: rewrite source to use the
749    /// canonical text + apply the `aristos:` / `kanon:` prefix to
750    /// the annotation id, update the index entry's binding state
751    /// to `Bound`, and move the cache entry from `pending_matches`
752    /// to `accepted_matches`.
753    ///
754    /// Both arguments are required: the bare annotation id as it
755    /// appears in `.aristo/index.toml` (NOT prefixed; the prefix
756    /// is applied by accept) and the bare canon id from the
757    /// pending match (e.g. `cell_written_exactly_once_per_page_edit`).
758    Accept {
759        /// Annotation id whose pending match you're accepting. Use
760        /// the bare form (no `aristos:` / `kanon:` prefix); the
761        /// prefix is applied by the accept itself based on the
762        /// pending match's `prefix_tier`.
763        annotation_id: String,
764        /// Canon id from the pending match (also bare — no
765        /// prefix). The pair `(annotation_id, canon_id)` locates
766        /// the exact pending match in `.aristo/canon-matches.toml`.
767        canon_id: String,
768    },
769
770    /// Reject a pending canon match: move the entry from
771    /// `pending_matches` to `rejected_matches`, pinned to the
772    /// current annotation `text_hash`. The rejection keeps the same
773    /// `(canon_id, text_hash)` pair from re-surfacing on future
774    /// `aristo stamp` runs; once the annotation text changes, the
775    /// rejection no longer applies and the match is re-evaluated.
776    /// Source and index are not touched — rejection is a cache-only
777    /// operation.
778    Reject {
779        /// Annotation id whose pending match you're rejecting.
780        annotation_id: String,
781        /// Canon id from the pending match.
782        canon_id: String,
783        /// Optional note recorded with the rejection. Useful for
784        /// capturing the *why* (e.g. "this canon entry is too broad",
785        /// "wrong category") for whoever revisits it later.
786        #[arg(long = "reason")]
787        reason: Option<String>,
788    },
789
790    /// List the current canon match state: one line per annotation
791    /// with pending / accepted / rejected counts, plus per-bucket
792    /// detail lines for each match. Reads `.aristo/canon-matches.toml`;
793    /// does not call the canon API.
794    List,
795
796    /// Fetch the canon entry detail for `<canon_id>` via the canon
797    /// API and render the longer description + example + references.
798    /// For the full trust card (server description + local binding
799    /// state combined), use `aristo show <bound_id>` instead.
800    Show {
801        /// Bare canon id (no `aristos:` / `kanon:` prefix). The
802        /// server's `GET /canon/entry/<canon_id>` endpoint returns
803        /// the same entry regardless of which tier you'd bind into;
804        /// the prefix is a per-user, per-scope attribute.
805        canon_id: String,
806        /// Optional explicit version (`v<minor>.<patch>`). Omit to
807        /// get the catalog's currently active version.
808        #[arg(long = "version")]
809        version: Option<String>,
810    },
811
812    /// Re-query the canon API for every annotation in the index,
813    /// bypassing the local match cache. Equivalent to
814    /// `aristo stamp --refresh-canon` without the rest of the stamp
815    /// pipeline — no source walk, no drift check, no index rewrite.
816    /// Useful when you know a new catalog version has shipped and
817    /// want fresh matches without a full stamp.
818    Refresh,
819
820    /// Reverse of `aristo canon accept`: strip the `aristos:` /
821    /// `kanon:` prefix from a canon-bound annotation, revert its
822    /// binding to `Local`, and drop the accepted_matches cache
823    /// entry. Source is rewritten in place (only the `id =` value
824    /// changes; canonical text + verify + parent are preserved).
825    /// The next `aristo stamp` may re-pull a fresh pending match
826    /// against the same annotation text.
827    ///
828    /// Unbind is for LIVE annotations. If the annotation was deleted
829    /// from source, no unbind is needed: the next `aristo stamp`
830    /// prunes its `.aristo/canon-matches.toml` entry automatically.
831    Unbind {
832        /// Canon-bound annotation id including the prefix (e.g.
833        /// `aristos:cell_written_exactly_once_per_page_edit`).
834        prefixed_id: String,
835    },
836
837    /// Record a verification-demand signal against a canon entry.
838    /// Idempotent on `(canon_id, repo, user)` — repeated calls don't
839    /// pile up. Use when an annotation is bound at the `kanon:` tier
840    /// and you'd like Aretta to invest in a verifier for that canon
841    /// entry.
842    RequestVerify {
843        /// Canon id (no prefix). The same id the trust card shows,
844        /// or that `aristo canon list` reports.
845        canon_id: String,
846        /// Optional note to attach to the demand signal (e.g.
847        /// "critical for our financial-tx audit"). A repeat call
848        /// with a new note replaces the previous one server-side.
849        #[arg(long = "notes")]
850        notes: Option<String>,
851    },
852
853    /// Report per-binding version drift between the local cache and
854    /// the canon API. Reports three classes: `current` (no change),
855    /// `patch-bump` (same canon_id, newer version — recommended
856    /// action: `aristo canon refresh`), and `minor-bump` (canon_id
857    /// retired — recommended action: `aristo canon unbind <id>` then
858    /// re-stamp). Currently diagnostic-only; automatic patch-bump
859    /// application is planned.
860    Migrate,
861
862    /// Download the canon catalogue (the full list of available canon
863    /// entries) to `.aristo/catalogue.json` — a gitignored local
864    /// snapshot — and print a summary. Requires authentication; served
865    /// by the per-repo conductor addressed via `[instance] url`.
866    Catalogue,
867
868    /// Run the S2 presence probe against a local SUT checkout: union
869    /// the instrumentation bundles carried by this repo's accepted
870    /// canon matches, generate an ephemeral probe crate (one
871    /// type-checked accessor call per record), `[patch]` the SUT
872    /// package to `--sut-path`, and `cargo check` it twice — with the
873    /// bundle's instrumentation features on (presence) and off (the
874    /// accessors must vanish; gating check). Failures are classified
875    /// per accessor — missing (rustc E0599/E0609) vs
876    /// SUT_FEATURE_UNDECLARED (cargo feature resolution) — and
877    /// rendered as escalation cards naming the conformance catch that
878    /// needs the accessor. Reuses the SUT's Cargo.lock + target/ so a
879    /// warm probe compile takes seconds. Fully offline: reads
880    /// `.aristo/canon-matches.toml`; never calls the canon API.
881    Probe {
882        /// Path to the local SUT checkout root (e.g. your
883        /// aretta-ai/turso fork clone). The probe `[patch]`es the SUT
884        /// package to this path and docks into its build graph
885        /// (Cargo.lock, target/, toolchain file).
886        #[arg(long = "sut-path", value_name = "DIR")]
887        sut_path: PathBuf,
888        /// The escalation card's `[ flag-broken ]` decision: run the
889        /// probe, verify this accessor still fails, and append the
890        /// rustc evidence to `.aristo/instrumentation-debt.jsonl`
891        /// (committed, append-only). Flagged accessors are re-surfaced
892        /// as `SKIPPED(instr-debt: <id>)` on later runs — visible
893        /// debt, never silently green.
894        #[arg(
895            long = "flag-broken",
896            value_name = "ACCESSOR_ID",
897            conflicts_with = "gen_only"
898        )]
899        flag_broken: Option<String>,
900        /// Keep the generated probe crate directory (under the SUT
901        /// target dir) instead of removing it after the run.
902        #[arg(long = "keep-probe")]
903        keep_probe: bool,
904        /// Generate and write the probe crate, then stop before
905        /// compiling (implies --keep-probe). Useful for inspecting
906        /// exactly what the probe will check.
907        #[arg(long = "gen-only")]
908        gen_only: bool,
909    },
910
911    /// List or inspect queued §17 proof-tree suggestions (the related
912    /// canon entries dragged in alongside a primary match). Read-only:
913    /// it does not open a review session or mutate the queue. To review
914    /// and adopt suggestions, run `aristo session start intent-review`.
915    ///
916    /// With no argument, lists every queued cluster. With an
917    /// `<objective>` (the cluster's objective canon_id, or the seeding
918    /// primary id for siblings-only clusters), shows that cluster's
919    /// detail. With `--counts`, emits a machine-readable JSON summary
920    /// `{matches:{new,pending}, suggestions:{new,pending}}` for the
921    /// menu / skill entry Q&A.
922    Suggestions {
923        /// Objective canon_id (or seeding primary id) of the cluster to
924        /// show. Omit to list all queued clusters.
925        objective: Option<String>,
926        /// Emit counts only (`{matches:{...}, suggestions:{...}}`) as
927        /// JSON; no per-cluster detail. Mutually exclusive with
928        /// passing an `<objective>`.
929        #[arg(long = "counts", conflicts_with = "objective")]
930        counts: bool,
931        /// Scope the listing with the shared `--filter` grammar
932        /// (`id=`, `file=[:LO-HI]`, `parent=`, `status=`). The
933        /// `cluster <objective>` mode (§6B) is `--filter
934        /// parent=<kanon:objective>` — it scopes the list to one proof
935        /// cluster (leaves carry `parent=`). Multiple `--filter` flags
936        /// AND together. No new grammar — reuses `filter.rs` verbatim.
937        #[arg(
938            long = "filter",
939            value_name = "KEY=VALUE",
940            conflicts_with = "objective"
941        )]
942        filter: Vec<Filter>,
943    },
944}
945
946/// Subcommands under `aristo session`. Each maps to one substrate
947/// operation; per-kind side effects (e.g. mutating a `.critique`
948/// file on accept) plug in via the `SessionKind` trait wired in
949/// step 5.
950#[derive(clap::Subcommand, Debug)]
951pub(crate) enum SessionAction {
952    /// Begin a new review session of the given kind. Fails if a
953    /// session is already active — pass `--allow-nesting` to override
954    /// (currently no kind allows nesting).
955    Start {
956        /// Session kind (`critique-review`, `proof-review`).
957        kind: String,
958        /// Display label for the artifact under review (e.g.
959        /// `src/critique/pending.rs` or
960        /// `proof:balance_no_duplicate_cells`).
961        #[arg(long = "subject")]
962        subject: String,
963        /// Override the kind's default nesting policy. Currently only
964        /// `Disallow` is implemented; the flag is reserved for future
965        /// per-kind opt-ins.
966        #[arg(long = "allow-nesting", default_value_t = false)]
967        allow_nesting: bool,
968    },
969    /// Print the active session id (or empty stdout if none).
970    /// Exit 0 either way.
971    Active {
972        /// Emit the full `<system-reminder>` block instead of just
973        /// the id — for the `UserPromptSubmit` hook installed by
974        /// `aristo install-skills`. Empty stdout when no session
975        /// is active (the hook then injects nothing).
976        #[arg(long = "hook-format", default_value_t = false)]
977        hook_format: bool,
978    },
979    /// Print bucket counts + open items for the active session.
980    /// Exit 0; errors out if no session is active.
981    Status,
982    /// Record a decision on one item in the active session.
983    Decide {
984        /// Item reference (`<id>#<index>` for indexed items, or any
985        /// opaque per-kind string).
986        #[arg(long = "item")]
987        item: String,
988        /// Which bucket the item lands in.
989        #[arg(long = "bucket", value_enum)]
990        bucket: BucketArg,
991        /// Optional note recorded with the decision.
992        #[arg(long = "note")]
993        note: Option<String>,
994    },
995    /// Close the active session. Strict by default — errors out if
996    /// any items are still in the open bucket.
997    Exit {
998        /// Move open items to the per-kind backlog instead of
999        /// erroring. Items are never silently dropped; the next
1000        /// session of this kind surfaces them via the backlog menu.
1001        #[arg(long = "defer-undecided", default_value_t = false)]
1002        defer_undecided: bool,
1003    },
1004    /// Cancel the session and discard every decision recorded so far.
1005    /// Requires `--yes` to skip the confirmation prompt.
1006    Abort {
1007        /// Skip the confirmation prompt.
1008        #[arg(long = "yes", default_value_t = false)]
1009        yes: bool,
1010    },
1011    /// List the active session and the most recent N closed sessions.
1012    List {
1013        /// Maximum number of closed-session rows to include.
1014        #[arg(long = "limit", default_value_t = 10)]
1015        limit: usize,
1016    },
1017}
1018
1019/// User-facing bucket choices for `aristo session decide`. Maps to
1020/// the substrate's [`session::types::ItemStatus`] (minus `Open`,
1021/// which is the implicit pre-decision state).
1022#[derive(Debug, Clone, Copy, PartialEq, Eq, clap::ValueEnum)]
1023pub(crate) enum BucketArg {
1024    Accepted,
1025    Rejected,
1026    Pending,
1027}
1028
1029/// Process entry point. Parses `argv`, dispatches to the chosen subcommand,
1030/// and returns the exit code. Prints `error: <msg>` to stderr on any
1031/// `CliError`.
1032pub fn run() -> ExitCode {
1033    let cli = Cli::parse();
1034    let code = match dispatch(cli.command) {
1035        Ok(()) => ExitCode::SUCCESS,
1036        Err(e) => {
1037            if !e.is_silent() {
1038                eprintln!("error: {e}");
1039            }
1040            ExitCode::from(e.exit_code())
1041        }
1042    };
1043    // Best-effort "newer aristo available" notice, printed after the
1044    // command's own output and never affecting its exit code. Silent in
1045    // CI / pipes / on opt-out (see `update_notify`).
1046    update_notify::maybe_notify();
1047    code
1048}
1049
1050/// Maps a parsed `Commands` variant to its handler.
1051fn dispatch(cmd: Commands) -> CliResult<()> {
1052    match cmd {
1053        Commands::Init {
1054            force,
1055            ci,
1056            ci_verify,
1057            hook,
1058        } => commands::init::run(force, ci, ci_verify, hook),
1059        Commands::Lang { file } => commands::lang::run(file),
1060        Commands::InstallSkills {
1061            agent,
1062            list_agents,
1063            user,
1064            update,
1065            check,
1066            hook_format,
1067        } => {
1068            commands::install_skills::install(agent, list_agents, user, update, check, hook_format)
1069        }
1070        Commands::UninstallSkills { agent, user, force } => {
1071            commands::install_skills::uninstall(agent, user, force)
1072        }
1073        Commands::Index { all } => commands::index::run(all),
1074        Commands::Stamp {
1075            check,
1076            skip_canon,
1077            refresh_canon,
1078            gc,
1079        } => commands::stamp::run(check, skip_canon, refresh_canon, gc),
1080        Commands::Show {
1081            selector,
1082            json,
1083            toml_out,
1084        } => commands::show::run(&selector, output_mode(json, toml_out)),
1085        Commands::List { filters, json } => commands::list::run(&filters, json),
1086        Commands::Status => commands::status::run(),
1087        Commands::Metrics { json } => commands::metrics::run(json),
1088        Commands::Nudge { event } => commands::nudge::run(event),
1089        Commands::Statusline => commands::statusline::run(),
1090        Commands::Review { mark, json } => commands::review::run(json, mark),
1091        Commands::Lint { check, fix, strict } => commands::lint::run(check, fix, strict),
1092        Commands::Verify {
1093            filters,
1094            rerun,
1095            check,
1096            strict,
1097            audit,
1098            apply_verdicts,
1099            rewrite_hashes,
1100            submit_verdict,
1101            id,
1102            json,
1103            pop_next,
1104            queue_status,
1105            wait,
1106            require_dispatch,
1107            view,
1108            tags,
1109            accept,
1110            because,
1111            tracking,
1112        } => commands::verify::run(
1113            &filters,
1114            rerun,
1115            check,
1116            strict,
1117            audit,
1118            apply_verdicts,
1119            rewrite_hashes,
1120            submit_verdict,
1121            pop_next,
1122            queue_status,
1123            id,
1124            json,
1125            wait,
1126            require_dispatch,
1127            view,
1128            &tags,
1129            accept,
1130            because,
1131            tracking,
1132        ),
1133        Commands::Critique {
1134            filters,
1135            apply_findings,
1136            include_closed,
1137            rerun,
1138            staged,
1139            all,
1140            yes,
1141            pop_next,
1142            queue_status,
1143            submit_findings,
1144            id,
1145            json,
1146        } => commands::critique::run(
1147            &filters,
1148            submit_findings,
1149            pop_next,
1150            queue_status,
1151            apply_findings,
1152            include_closed,
1153            rerun,
1154            staged,
1155            all,
1156            yes,
1157            id,
1158            json,
1159        ),
1160        Commands::Doc {
1161            summary,
1162            include_status,
1163            check,
1164            include_graph,
1165        } => commands::doc::run(summary, include_status, check, include_graph),
1166        Commands::Graph {
1167            format,
1168            out,
1169            filters,
1170            exclude_assumes,
1171            depth,
1172            include_orphans,
1173            include_status,
1174        } => commands::graph::run(
1175            &format,
1176            out,
1177            &filters,
1178            exclude_assumes,
1179            depth,
1180            include_orphans,
1181            include_status,
1182        ),
1183        Commands::Badge { out, style, metric } => {
1184            let style =
1185                commands::badge::Style::parse(&style).map_err(|message| CliError::Other {
1186                    message,
1187                    exit_code: 2,
1188                })?;
1189            let metric =
1190                commands::badge::Metric::parse(&metric).map_err(|message| CliError::Other {
1191                    message,
1192                    exit_code: 2,
1193                })?;
1194            commands::badge::run(out, style, metric)
1195        }
1196        Commands::Rename {
1197            old_id,
1198            new_id,
1199            dry_run,
1200        } => commands::rename::run(&old_id, &new_id, dry_run),
1201        Commands::Session { action } => commands::session::run(action),
1202        Commands::Auth { action } => commands::auth::run(action),
1203        Commands::Canon { action } => match action {
1204            CanonAction::Accept {
1205                annotation_id,
1206                canon_id,
1207            } => commands::canon::accept::run(&annotation_id, &canon_id),
1208            CanonAction::Reject {
1209                annotation_id,
1210                canon_id,
1211                reason,
1212            } => commands::canon::reject::run(&annotation_id, &canon_id, reason),
1213            CanonAction::List => commands::canon::list::run(),
1214            CanonAction::Show { canon_id, version } => {
1215                commands::canon::show::run(&canon_id, version)
1216            }
1217            CanonAction::Refresh => commands::canon::refresh::run(),
1218            CanonAction::Unbind { prefixed_id } => commands::canon::unbind::run(&prefixed_id),
1219            CanonAction::RequestVerify { canon_id, notes } => {
1220                commands::canon::request_verify::run(&canon_id, notes)
1221            }
1222            CanonAction::Migrate => commands::canon::migrate::run(),
1223            CanonAction::Catalogue => commands::canon::catalogue::run(),
1224            CanonAction::Probe {
1225                sut_path,
1226                flag_broken,
1227                keep_probe,
1228                gen_only,
1229            } => {
1230                commands::canon::probe::run(&sut_path, flag_broken.as_deref(), keep_probe, gen_only)
1231            }
1232            CanonAction::Suggestions {
1233                objective,
1234                counts,
1235                filter,
1236            } => commands::canon::suggestions::run(objective, counts, filter),
1237        },
1238        Commands::Instrument { action } => match action {
1239            InstrumentAction::VendorC { out } => commands::instrument::vendor_c::run(out),
1240            InstrumentAction::GenC {
1241                paths,
1242                handle_header,
1243                out,
1244                check,
1245            } => commands::instrument::gen_c::run(paths, handle_header, out, check),
1246        },
1247    }
1248}
1249
1250fn output_mode(json: bool, toml_out: bool) -> commands::show::OutputMode {
1251    if json {
1252        commands::show::OutputMode::Json
1253    } else if toml_out {
1254        commands::show::OutputMode::Toml
1255    } else {
1256        commands::show::OutputMode::Text
1257    }
1258}
1259
1260#[cfg(test)]
1261mod tests {
1262    use super::*;
1263    use clap::CommandFactory;
1264
1265    #[test]
1266    fn cli_parser_construction_is_valid() {
1267        // clap performs a structural sanity check (e.g. no duplicate
1268        // subcommand names) when CommandFactory::command() runs. We assert
1269        // it succeeds rather than panicking at runtime when a user types
1270        // `--help`. Cheap canary against future enum-shape mistakes.
1271        Cli::command().debug_assert();
1272    }
1273
1274    // Note: slice 32 removed the last `not_yet(...)` stub (Rename now
1275    // has a real implementation). The `CliError::NotImplemented` variant
1276    // is kept for future stubs but is no longer reachable from dispatch.
1277}