diff options
| author | soryu <soryu@soryu.co> | 2026-01-15 22:55:04 +0000 |
|---|---|---|
| committer | soryu <soryu@soryu.co> | 2026-01-16 01:12:03 +0000 |
| commit | b69dc962cd99aa8b478b7c5facbd56bfb63eda27 (patch) | |
| tree | 9922f60b0da646eaf00165d5348b25e822dfd7b0 /makima/src/bin | |
| parent | 6ee2e75834bff187b8c262e0798ef365bc21cd59 (diff) | |
| download | soryu-b69dc962cd99aa8b478b7c5facbd56bfb63eda27.tar.gz soryu-b69dc962cd99aa8b478b7c5facbd56bfb63eda27.zip | |
Add Task Contract Type for one-off adhoc tasks (#2)
Diffstat (limited to 'makima/src/bin')
| -rw-r--r-- | makima/src/bin/makima.rs | 65 |
1 files changed, 65 insertions, 0 deletions
diff --git a/makima/src/bin/makima.rs b/makima/src/bin/makima.rs index f430701..9c9ac77 100644 --- a/makima/src/bin/makima.rs +++ b/makima/src/bin/makima.rs @@ -364,6 +364,71 @@ async fn run_supervisor( let result = client.supervisor_get_task_output(args.target_task_id).await?; println!("{}", serde_json::to_string(&result.0)?); } + SupervisorCommand::TaskHistory(args) => { + eprintln!( + "Task history for {} (limit: {:?}, format: {})", + args.task_id, args.limit, args.format + ); + eprintln!("CLI integration not yet implemented. Use the API directly:"); + eprintln!(" GET /api/v1/mesh/tasks/{}/conversation", args.task_id); + } + SupervisorCommand::TaskCheckpoints(args) => { + eprintln!( + "Task checkpoints for {} (with_diff: {})", + args.task_id, args.with_diff + ); + eprintln!("CLI integration not yet implemented. Use the API directly:"); + eprintln!(" GET /api/v1/mesh/tasks/{}/checkpoints", args.task_id); + } + SupervisorCommand::Resume(args) => { + eprintln!( + "Resume supervisor for contract {} (mode: {}, checkpoint: {:?})", + args.common.contract_id, args.mode, args.checkpoint + ); + eprintln!("CLI integration not yet implemented. Use the API directly:"); + eprintln!( + " POST /api/v1/contracts/{}/supervisor/resume", + args.common.contract_id + ); + } + SupervisorCommand::TaskResumeFrom(args) => { + eprintln!( + "Resume task {} from checkpoint {} with plan: {}", + args.task_id, args.checkpoint, args.plan + ); + eprintln!("CLI integration not yet implemented. Use the API directly:"); + eprintln!( + " POST /api/v1/mesh/tasks/{}/checkpoints/{}/resume", + args.task_id, args.checkpoint + ); + } + SupervisorCommand::TaskRewind(args) => { + eprintln!( + "Rewind task {} to checkpoint {} (preserve: {}, branch: {:?})", + args.task_id, args.checkpoint, args.preserve, args.branch_name + ); + eprintln!("CLI integration not yet implemented. Use the API directly:"); + eprintln!(" POST /api/v1/mesh/tasks/{}/rewind", args.task_id); + } + SupervisorCommand::TaskFork(args) => { + eprintln!( + "Fork task {} from checkpoint {} as '{}' with plan: {}", + args.task_id, args.checkpoint, args.name, args.plan + ); + eprintln!("CLI integration not yet implemented. Use the API directly:"); + eprintln!(" POST /api/v1/mesh/tasks/{}/fork", args.task_id); + } + SupervisorCommand::RewindConversation(args) => { + eprintln!( + "Rewind conversation for contract {} (by: {:?}, to: {:?}, rewind_code: {})", + args.common.contract_id, args.by_messages, args.to_message, args.rewind_code + ); + eprintln!("CLI integration not yet implemented. Use the API directly:"); + eprintln!( + " POST /api/v1/contracts/{}/supervisor/conversation/rewind", + args.common.contract_id + ); + } } Ok(()) |