ai-dispatch 11.1.0

// PTY watchdog regressions with silent CPU tools and nonprogressing descendants.
// Exercises the live bridge with first-token progress already established.
// Deps: PTY monitor, fake streaming agent, temporary home and in-memory Store.

use super::*;
use std::io::Read;

fn monitor(script: &str) -> TaskStatus {
    let _permit = crate::test_subprocess::acquire();
    let temp = tempfile::tempdir().expect("temp");
    let _home = crate::paths::AidHomeGuard::set(temp.path());
    let store = Arc::new(Store::open_memory().expect("store"));
    let task = super::tests::pty_task("t-child-pty", TaskStatus::Running);
    store.insert_task(&task).expect("task");
    let cmd = vec!["sh".into(), "-c".into(), script.into()];
    let mut bridge = PtyBridge::spawn(&cmd, None, vec![]).expect("bridge");
    let mut reader = bridge.take_reader().expect("reader");
    let (tx, rx) = mpsc::channel();
    let reader = std::thread::spawn(move || {
        let mut bytes = [0; 1024];
        while let Ok(count) = reader.read(&mut bytes) {
            if count == 0 || tx.send(bytes[..count].to_vec()).is_err() {
                break;
            }
        }
    });
    let mut state = MonitorState::new(true, None);
    state.event_count = 2;
    state.received_raw_bytes = true;
    let mut log = tempfile::tempfile().expect("log");
    monitor_bridge(
        &crate::watcher::idle_tests::FakeAgent,
        &task.id,
        &store,
        &mut bridge,
        &rx,
        &mut log,
        &mut state,
        None,
        Some(Duration::from_millis(600)),
        None,
    )
    .expect("monitor");
    if state.info.status == TaskStatus::Failed {
        bridge.kill_group().expect("kill");
    }
    bridge.wait().expect("exit");
    reader.join().expect("reader exit");
    state.info.status
}

#[test]
fn pty_silent_cpu_descendant_survives_idle_window() {
    assert_eq!(
        monitor("yes >/dev/null & tool=$!; sleep 2; kill $tool; exit 0"),
        TaskStatus::Done
    );
}

#[test]
fn pty_sleeping_descendant_is_reaped_after_idle_window() {
    assert_eq!(monitor("sleep 10 & wait"), TaskStatus::Failed);
}