ai-dispatch 11.2.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

// Informational post-run notices must preserve the existing terminal failure reason.
// Exercises scope warnings and unavailable delivery recovery after settlement.
// Deps: parent settlement fixtures and existing post-run callbacks.

use super::*;

#[test]
fn scope_notice_preserves_settlement_winner() {
    let _permit = crate::support::test_subprocess::acquire();
    let f = Fixture::new(TaskStatus::Stopped);
    init_repo(f.home.path());
    std::fs::write(f.home.path().join("file.txt"), "outside scope\n").expect("edit");
    crate::cmd::run::run_agent::check_scope_violations(
        &f.store,
        &f.id,
        &["allowed.txt".into()],
        f.home.path().to_str(),
    );
    f.assert_unchanged();
    let events = f.store.get_events(f.id.as_str()).expect("events");
    assert!(events.iter().any(|event| {
        event.detail.starts_with("Scope violation:") && event.event_kind == EventKind::Milestone
    }));
}

#[tokio::test]
async fn unavailable_recovery_notice_preserves_settlement_winner() {
    let f = Fixture::new(TaskStatus::Failed);
    f.store
        .db()
        .execute(
            "UPDATE tasks SET read_only = 1 WHERE id = ?1",
            rusqlite::params![f.id.as_str()],
        )
        .expect("read-only fixture");
    f.store
        .update_delivery_assessment(
            f.id.as_str(),
            Some(DeliveryAssessment::MissingFinalDelivery),
        )
        .expect("recovery candidate");
    assert!(
        crate::cmd::run::run_delivery_recovery::maybe_auto_recover_missing_delivery(
            &f.store,
            &f.id,
            &RunArgs::default(),
        )
        .await
        .expect("recovery notice")
        .is_none()
    );
    f.assert_unchanged();
    let events = f.store.get_events(f.id.as_str()).expect("events");
    let event = events
        .iter()
        .find(|event| event.detail.contains("session ID unavailable"))
        .expect("unavailable notice visible");
    assert_eq!(event.event_kind, EventKind::Milestone);
    assert_eq!(
        event.metadata.as_ref().expect("metadata")["delivery_recovery"],
        "unavailable"
    );
}