diff options
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(()) |
