ai-dispatch 8.99.3

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
103
104
105
106

// Shared helpers for manual and automatic unstick flows.
// Exports: default_nudge_message, mark_task_stalled, and queue_auto_nudge.
// Deps: crate::pty_watch_idle, crate::store::Store, crate::types.

use anyhow::Result;

use crate::pty_watch_idle;
use crate::store::Store;
use crate::types::{MessageDirection, MessageSource, TaskStatus};

pub fn default_nudge_message() -> String {
    pty_watch_idle::default_nudge_message()
}

pub fn queue_auto_nudge(store: &Store, task_id: &str, message: &str) -> Result<()> {
    store.insert_message(
        task_id,
        MessageDirection::In,
        message,
        MessageSource::UnstickAuto,
    )?;
    Ok(())
}

pub fn mark_task_stalled(store: &Store, task_id: &str) -> Result<bool> {
    let Some(task) = store.get_task(task_id)? else {
        return Ok(false);
    };
    if task.status != TaskStatus::Running {
        return Ok(false);
    }
    store.update_task_status(task_id, TaskStatus::Stalled)?;
    Ok(true)
}

#[cfg(test)]
mod tests {
    use chrono::Local;

    use super::*;
    use crate::store::Store;
    use crate::types::{AgentKind, Task, TaskId, VerifyStatus};

    fn make_task(id: &str, status: TaskStatus) -> Task {
        Task {
            id: TaskId(id.to_string()),
            agent: AgentKind::Codex,
            custom_agent_name: None,
            prompt: "prompt".to_string(),
            resolved_prompt: None,
            category: None,
            status,
            parent_task_id: None,
            workgroup_id: None,
            caller_kind: None,
            caller_session_id: None,
            agent_session_id: None,
            repo_path: None,
            worktree_path: None,
            worktree_branch: None,
            start_sha: None,
            log_path: None,
            output_path: None,
            tokens: None,
            prompt_tokens: None,
            duration_ms: None,
            model: None,
            cost_usd: None,
            exit_code: None,
            created_at: Local::now(),
            completed_at: None,
            verify: None,
            verify_status: VerifyStatus::Skipped,
            pending_reason: None,
            read_only: false,
            budget: false,
            audit_verdict: None,
            audit_report_path: None,
            delivery_assessment: None,
        }
    }

    #[test]
    fn helper_marks_running_task_stalled() {
        let store = Store::open_memory().unwrap();
        store.insert_task(&make_task("t-stalled", TaskStatus::Running)).unwrap();

        assert!(mark_task_stalled(&store, "t-stalled").unwrap());
        assert_eq!(
            store.get_task("t-stalled").unwrap().unwrap().status,
            TaskStatus::Stalled
        );
    }

    #[test]
    fn helper_queues_auto_nudge_message() {
        let store = Store::open_memory().unwrap();
        store.insert_task(&make_task("t-nudge", TaskStatus::Running)).unwrap();

        queue_auto_nudge(&store, "t-nudge", "hello").unwrap();

        let messages = store.list_messages_for_task("t-nudge").unwrap();
        assert_eq!(messages.len(), 1);
        assert_eq!(messages[0].source, MessageSource::UnstickAuto);
    }
}