ai-dispatch 9.3.2

Multi-AI CLI team orchestrator
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102

// aid CLI task operation dispatch handlers.
// Implements retry, merge, response, stop, and related task wrappers.

use super::resolve_group;
use crate::cmd;
use crate::store;
use anyhow::{Result, anyhow};
use std::sync::Arc;

pub(super) async fn retry(
    store: Arc<store::Store>,
    task_id: String,
    feedback: String,
    agent: Option<String>,
    dir: Option<String>,
    reset: bool,
    bg: bool,
) -> Result<()> {
    cmd::retry::run(store, cmd::retry::RetryArgs { task_id, feedback, agent, dir, reset, bg })
        .await
        .map(|_| ())
}

pub(super) fn merge(
    store: Arc<store::Store>,
    task_id: Option<String>,
    group: Option<String>,
    approve: bool,
    check: bool,
    force: bool,
    target: Option<String>,
    lanes: bool,
) -> Result<()> {
    if lanes && group.is_none() {
        return Err(anyhow!("--lanes requires --group"));
    }
    let group = resolve_group(group);
    cmd::merge::run(store, task_id.as_deref(), group.as_deref(), approve, check, force, target.as_deref(), lanes)
}

pub(super) fn respond(task_id: String, input: Option<String>, file: Option<String>) -> Result<()> {
    cmd::respond::run(&task_id, input.as_deref(), file.as_deref())
}

pub(super) fn reply(
    store: Arc<store::Store>,
    task_id: String,
    message: Option<String>,
    file: Option<String>,
    async_mode: bool,
    timeout_secs: u64,
) -> Result<()> {
    match cmd::reply::run(
        &store,
        &task_id,
        message.as_deref(),
        file.as_deref(),
        async_mode,
        timeout_secs,
    )? {
        cmd::reply::ReplyOutcome::Queued { id } => println!("Queued reply {id} for {task_id}"),
        cmd::reply::ReplyOutcome::Acked { delivered } => {
            println!("Reply acknowledged for {task_id} (delivered: {delivered})");
        }
        cmd::reply::ReplyOutcome::TimedOut { delivered } => {
            println!("Reply timed out for {task_id} (delivered: {delivered})");
        }
    }
    Ok(())
}

pub(super) fn stop(
    store: Arc<store::Store>,
    task_id: String,
    force: bool,
    retry_tree: bool,
) -> Result<()> {
    if retry_tree {
        cmd::stop::stop_retry_tree(&store, &task_id, force)
    } else if force {
        cmd::stop::kill(&store, &task_id)
    } else {
        cmd::stop::stop(&store, &task_id)
    }
}

pub(super) fn kill(store: Arc<store::Store>, task_id: String) -> Result<()> {
    cmd::stop::kill(&store, &task_id)
}

pub(super) fn steer(store: Arc<store::Store>, task_id: String, message: String) -> Result<()> {
    cmd::steer::run(&store, &task_id, &message)
}

pub(super) fn unstick(
    store: Arc<store::Store>,
    task_id: String,
    message: Option<String>,
    escalate: bool,
) -> Result<()> {
    cmd::unstick::run(&store, &task_id, message.as_deref(), escalate)
}