ai-dispatch 10.52.1

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

// Reaper liveness tests for aid-authored input bookkeeping: steers, replies and
// failed deliveries are written by aid, not the agent, so they are not progress.
// Deps: background_orphan latest_activity, parent test fixtures and the store.

use super::super::latest_activity;
use super::make_task;
use crate::store::Store;
use crate::types::{EventKind, TaskEvent};
use chrono::{Duration, Local};
use serde_json::{Value, json};

#[test]
fn operator_input_bookkeeping_does_not_postpone_the_reaper() {
    let temp = tempfile::tempdir().expect("temp dir");
    let _aid_home = crate::paths::AidHomeGuard::set(temp.path());
    let store = Store::open_memory().expect("store");
    let task = make_task("t-input-bookkeeping");
    store.insert_task(&task).expect("insert task");
    let now = Local::now();
    let event =
        |age: i64, event_kind: EventKind, detail: &str, metadata: Option<Value>| TaskEvent {
            task_id: task.id.clone(),
            timestamp: now - Duration::seconds(age),
            event_kind,
            detail: detail.to_string(),
            metadata,
        };
    let agent_event = event(600, EventKind::Reasoning, "agent progress", None);
    let bookkeeping = [
        event(
            30,
            EventKind::Reasoning,
            "Steered: go",
            Some(json!({ "steered": true, "delivered": true })),
        ),
        event(
            20,
            EventKind::Reasoning,
            "Replied: ok",
            Some(json!({ "message_id": 7, "source": "cli" })),
        ),
        event(
            10,
            EventKind::Error,
            "Steer not delivered: go",
            Some(json!({
                "input_delivery": "failed", "delivered": false, "source": "Steer", "message_id": null,
            })),
        ),
    ];
    for event in std::iter::once(&agent_event).chain(&bookkeeping) {
        store.insert_event(event).expect("insert event");
    }

    let activity = latest_activity(&store, &task).expect("activity");

    assert_eq!(activity.event_count, 1);
    assert_eq!(activity.detail.as_deref(), Some("agent progress"));
    assert_eq!(
        activity.timestamp.timestamp(),
        agent_event.timestamp.timestamp()
    );
}