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
66
67
68
69
70
71
72
73
74
75
76

// Resolve durable Codex rollouts and report missing-session fallback.
// Exports rollout and resume helpers; depends on chrono, filesystem, and task events.

use super::*;

pub(crate) const RESUME_FALLBACK_DETAIL: &str =
    "Codex session resume skipped: rollout missing; starting fresh session";
const ROLLOUT_TIMESTAMP_FORMAT: &str = "%Y-%m-%dT%H-%M-%S";

pub(crate) fn durable_session_rollout_exists(session_id: &str) -> bool {
    let Ok(real_home) = crate::agent::home_isolation::resolve_real_home() else {
        return false;
    };
    session_rollout_exists(&real_home.join(".codex").join("sessions"), session_id)
}

pub(crate) fn resume_fallback_needed(session_id: &str) -> bool {
    !durable_session_rollout_exists(session_id)
}

pub(crate) fn session_rollout_exists(sessions_dir: &Path, session_id: &str) -> bool {
    let Ok(entries) = fs::read_dir(sessions_dir) else {
        return false;
    };
    entries.flatten().any(|entry| {
        let path = entry.path();
        if path.is_dir() {
            return session_rollout_exists(&path, session_id);
        }
        rollout_filename_matches(&path, session_id)
    })
}

pub(crate) fn rollout_filename_matches(path: &Path, session_id: &str) -> bool {
    if session_id.is_empty() {
        return false;
    }
    let Some(name) = path.file_name().and_then(|name| name.to_str()) else {
        return false;
    };
    let Some(stem) = name
        .strip_prefix("rollout-")
        .and_then(|name| name.strip_suffix(".jsonl"))
    else {
        return false;
    };
    let Some(timestamp) = stem.strip_suffix(&format!("-{session_id}")) else {
        return false;
    };
    // Resume safety intentionally depends on Codex's current timestamp-shaped rollout prefix.
    NaiveDateTime::parse_from_str(timestamp, ROLLOUT_TIMESTAMP_FORMAT).is_ok()
}

pub(crate) fn rollout_filename_matches_for_attribution(
    path: &Path,
    session_id: &str,
) -> bool {
    if session_id.is_empty() {
        return false;
    }
    path.file_name()
        .and_then(|name| name.to_str())
        .is_some_and(|name| {
            name.starts_with("rollout-") && name.ends_with(&format!("-{session_id}.jsonl"))
        })
}

pub(crate) fn resume_fallback_event(task_id: &TaskId) -> TaskEvent {
    TaskEvent {
        task_id: task_id.clone(),
        timestamp: Local::now(),
        event_kind: EventKind::Milestone,
        detail: RESUME_FALLBACK_DETAIL.to_string(),
        metadata: None,
    }
}