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

// Degraded-route dispatch: warn and still send work; never substitute.
// Deps: resolve_agent_setup, degraded_dispatch_warning, probe fixtures.

use super::super::held::degraded_dispatch_warning;
use super::*;
use crate::live_quota::CacheDirGuard;
use crate::paths::{self, AidHomeGuard};
use chrono::Utc;

fn isolated_codex_probe(used: f64) -> (tempfile::TempDir, AidHomeGuard, CacheDirGuard) {
    let tmp = tempfile::tempdir().expect("tempdir");
    let _ = std::fs::create_dir_all(tmp.path().join(".aid"));
    let home = AidHomeGuard::set(tmp.path());
    std::fs::create_dir_all(paths::aid_dir()).ok();
    let aidbar = tmp.path().join("aidbar");
    std::fs::create_dir_all(&aidbar).expect("cache");
    let fetched = Utc::now().to_rfc3339();
    std::fs::write(
        aidbar.join("codex.json"),
        format!(
            r#"{{"ok":true,"snapshot":{{"provider":"codex","windows":[{{"label":"Weekly","used_percent":{used},"resets_at":"2026-09-19T08:10:00Z"}}],"fetched_at":"{fetched}"}}}}"#
        ),
    )
    .expect("cache");
    let cache = CacheDirGuard::set(&aidbar);
    (tmp, home, cache)
}

#[test]
fn degraded_route_warns_and_does_not_divert() {
    let (_tmp, _home, _cache) = isolated_codex_probe(96.0);
    assert_eq!(
        degraded_dispatch_warning(AgentKind::Codex, None).as_deref(),
        Some(
            "[aid] codex route degraded: 96% of Weekly window used (resets 2026-09-19T08:10Z) — dispatching anyway"
        )
    );
    let store = Arc::new(Store::open_memory().expect("store"));
    let mut args = RunArgs {
        agent_name: "codex".to_string(),
        prompt: "Add unit tests".to_string(),
        cascade: vec!["oz".to_string()],
        ..Default::default()
    };
    let setup = resolve_agent_setup(&store, &mut args).expect("dispatch degraded route");
    assert_eq!(setup.agent_kind, AgentKind::Codex);
    assert!(setup.substituted_from.is_none());
    assert_eq!(args.cascade, vec!["oz".to_string()]);
}

#[test]
fn ok_route_at_20_percent_does_not_warn_or_divert() {
    let (_tmp, _home, _cache) = isolated_codex_probe(20.0);
    assert_eq!(degraded_dispatch_warning(AgentKind::Codex, None), None);
    let store = Arc::new(Store::open_memory().expect("store"));
    let mut args = RunArgs {
        agent_name: "codex".to_string(),
        prompt: "Add unit tests".to_string(),
        cascade: vec!["oz".to_string()],
        ..Default::default()
    };
    let setup = resolve_agent_setup(&store, &mut args).expect("dispatch ok route");
    assert_eq!(setup.agent_kind, AgentKind::Codex);
    assert!(setup.substituted_from.is_none());
}