ai-dispatch 10.39.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
87
88
89
90
91
92
93
94
95
96
97
98

// Tests structured final-delivery evidence without grading message content.
// Covers ordering, empty messages, exact short answers, and absent delivery.
// Deps: super::{DeliveryEvidence, DeliveryOutcome} and serde_json fixtures.

use super::{DeliveryEvidence, DeliveryOutcome};

fn observe(evidence: &mut DeliveryEvidence, event: serde_json::Value) {
    evidence.observe_codex_jsonl(&event.to_string());
}

fn message(text: &str) -> serde_json::Value {
    serde_json::json!({
        "type": "item.completed",
        "item": { "type": "agent_message", "text": text }
    })
}

fn work() -> serde_json::Value {
    serde_json::json!({
        "type": "item.completed",
        "item": { "type": "command_execution" }
    })
}

#[test]
fn accepts_exact_short_answer_without_work() {
    let mut evidence = DeliveryEvidence::default();
    observe(&mut evidence, message("ok"));

    assert_eq!(evidence.validate(), DeliveryOutcome::Delivered);
}

#[test]
fn accepts_exact_short_answer_after_work() {
    let mut evidence = DeliveryEvidence::default();
    observe(&mut evidence, work());
    observe(&mut evidence, message("0"));

    assert_eq!(evidence.validate(), DeliveryOutcome::Delivered);
}

#[test]
fn rejects_message_followed_by_work() {
    let mut evidence = DeliveryEvidence::default();
    observe(&mut evidence, message("Investigation in progress"));
    observe(&mut evidence, work());

    assert!(matches!(
        evidence.validate(),
        DeliveryOutcome::MissingFinalDelivery { .. }
    ));
}

#[test]
fn rejects_empty_final_message() {
    let mut evidence = DeliveryEvidence::default();
    observe(&mut evidence, work());
    observe(&mut evidence, message("  \n  "));

    assert!(matches!(
        evidence.validate(),
        DeliveryOutcome::MissingFinalDelivery {
            last_message_chars: 0,
            ..
        }
    ));
}

#[test]
fn rejects_run_without_final_message() {
    let mut evidence = DeliveryEvidence::default();
    observe(&mut evidence, work());

    assert!(matches!(
        evidence.validate(),
        DeliveryOutcome::MissingFinalDelivery {
            last_message_chars: 0,
            ..
        }
    ));
}

#[test]
fn ignores_reasoning_and_todo_events_after_final_message() {
    let mut evidence = DeliveryEvidence::default();
    observe(&mut evidence, work());
    observe(&mut evidence, message("ok"));
    observe(
        &mut evidence,
        serde_json::json!({"type":"item.completed","item":{"type":"reasoning"}}),
    );
    observe(
        &mut evidence,
        serde_json::json!({"type":"item.updated","item":{"type":"todo_list"}}),
    );

    assert_eq!(evidence.validate(), DeliveryOutcome::Delivered);
}