From b69dc962cd99aa8b478b7c5facbd56bfb63eda27 Mon Sep 17 00:00:00 2001 From: soryu Date: Thu, 15 Jan 2026 22:55:04 +0000 Subject: Add Task Contract Type for one-off adhoc tasks (#2) --- makima/src/bin/makima.rs | 65 ++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 65 insertions(+) (limited to 'makima/src/bin') 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(()) -- cgit v1.2.3