diff options
| author | main <main@swarm.moe> | 2026-03-23 16:28:52 -0400 |
|---|---|---|
| committer | main <main@swarm.moe> | 2026-03-23 16:28:52 -0400 |
| commit | c3ad44cf3ec3bcd080f62c19d915ac1749576302 (patch) | |
| tree | a3da7810f794182f4740e0da270e9c40f3fdad2b /crates/phone-opus/src/main.rs | |
| parent | 5cf9432092da40a2653c3d156ca5a4746e853827 (diff) | |
| download | phone_opus-c3ad44cf3ec3bcd080f62c19d915ac1749576302.zip | |
Add optional background consult jobs
Diffstat (limited to 'crates/phone-opus/src/main.rs')
| -rw-r--r-- | crates/phone-opus/src/main.rs | 11 |
1 files changed, 11 insertions, 0 deletions
diff --git a/crates/phone-opus/src/main.rs b/crates/phone-opus/src/main.rs index 79ace26..a1cace7 100644 --- a/crates/phone-opus/src/main.rs +++ b/crates/phone-opus/src/main.rs @@ -3,6 +3,7 @@ mod mcp; use clap::{Args, Parser, Subcommand}; #[cfg(test)] use libmcp_testkit as _; +use std::path::PathBuf; #[derive(Parser)] #[command( @@ -30,6 +31,8 @@ enum McpCommand { Serve, /// Run the disposable worker process. Worker(McpWorkerArgs), + /// Run one detached background consult job. + BackgroundConsult(McpBackgroundConsultArgs), } #[derive(Args)] @@ -39,12 +42,20 @@ struct McpWorkerArgs { generation: u64, } +#[derive(Args)] +struct McpBackgroundConsultArgs { + /// Persisted background job file to execute and update. + #[arg(long)] + job_file: PathBuf, +} + fn main() -> Result<(), Box<dyn std::error::Error>> { let cli = Cli::parse(); match cli.command { Command::Mcp { command } => match command { McpCommand::Serve => mcp::run_host()?, McpCommand::Worker(args) => mcp::run_worker(args.generation)?, + McpCommand::BackgroundConsult(args) => mcp::run_background_consult(args.job_file)?, }, } Ok(()) |