ai-dispatch 8.94.0

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

// Workgroup-focused Store tests.
// Exports: workgroup query/mutation tests.
// Deps: Store.

use super::*;

#[test]
fn create_and_get_workgroup() {
    let store = Store::open_memory().unwrap();
    let workgroup = store
        .create_workgroup("dispatch", "Shared API contract context.", None, None)
        .unwrap();

    let loaded = store.get_workgroup(workgroup.id.as_str()).unwrap().unwrap();
    assert_eq!(loaded.id, workgroup.id);
    assert_eq!(loaded.name, "dispatch");
    assert!(loaded.shared_context.contains("API contract"));
}

#[test]
fn gets_workgroup_milestones() {
    let store = Store::open_memory().unwrap();
    let workgroup = store
        .create_workgroup("dispatch", "Shared API contract context.", None, None)
        .unwrap();

    let mut first = make_task("t-0040", AgentKind::Codex, TaskStatus::Running);
    first.workgroup_id = Some(workgroup.id.as_str().to_string());
    store.insert_task(&first).unwrap();

    let mut second = make_task("t-0041", AgentKind::Gemini, TaskStatus::Running);
    second.workgroup_id = Some(workgroup.id.as_str().to_string());
    store.insert_task(&second).unwrap();

    let mut other = make_task("t-0042", AgentKind::Cursor, TaskStatus::Running);
    other.workgroup_id = Some("wg-other".to_string());
    store.insert_task(&other).unwrap();

    store
        .insert_event(&TaskEvent {
            task_id: TaskId("t-0040".to_string()),
            timestamp: Local::now() - chrono::Duration::seconds(3),
            event_kind: EventKind::Milestone,
            detail: "finding one".to_string(),
            metadata: None,
        })
        .unwrap();
    store
        .insert_event(&TaskEvent {
            task_id: TaskId("t-0040".to_string()),
            timestamp: Local::now() - chrono::Duration::seconds(2),
            event_kind: EventKind::ToolCall,
            detail: "ignored".to_string(),
            metadata: None,
        })
        .unwrap();
    store
        .insert_event(&TaskEvent {
            task_id: TaskId("t-0041".to_string()),
            timestamp: Local::now() - chrono::Duration::seconds(1),
            event_kind: EventKind::Milestone,
            detail: "finding two".to_string(),
            metadata: None,
        })
        .unwrap();
    store
        .insert_event(&TaskEvent {
            task_id: TaskId("t-0042".to_string()),
            timestamp: Local::now(),
            event_kind: EventKind::Milestone,
            detail: "other group".to_string(),
            metadata: None,
        })
        .unwrap();

    let milestones = store
        .get_workgroup_milestones(workgroup.id.as_str())
        .unwrap();
    assert_eq!(
        milestones,
        vec![
            ("t-0040".to_string(), "finding one".to_string()),
            ("t-0041".to_string(), "finding two".to_string()),
        ]
    );
}