dpc-tau-cli 0.1.0

A minimal Unix-first coding agent.
Documentation 
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

use super::*;

/// Covers the complete authoritative mode/runtime truth table and ensures
/// loaded membership alone never makes an agent eligible before its stats
/// snapshot.
#[test]
fn effective_activity_truth_table_requires_stats() {
    for mode in [
        AgentNavigationState::Active,
        AgentNavigationState::ActiveAuto,
        AgentNavigationState::Suspended,
    ] {
        let mut navigation = AgentNavigation::default();
        let agent_id = tau_proto::AgentId::parse("worker").expect("valid agent id");
        navigation.mark_live(agent_id.clone());
        assert!(!navigation.is_active(&agent_id));
        navigation.apply_stats(&agent_id, mode, tau_proto::AgentRuntimeState::Idle);
        assert_eq!(
            navigation.is_active(&agent_id),
            mode == AgentNavigationState::Active
        );
        navigation.apply_stats(&agent_id, mode, tau_proto::AgentRuntimeState::Running);
        assert_eq!(
            navigation.is_active(&agent_id),
            mode != AgentNavigationState::Suspended
        );
    }
}

/// Ensures unload removes the complete cached snapshot and a same-id reload
/// remains ineligible until the harness sends its fresh classification.
#[test]
fn unload_removes_all_navigation_facts() {
    let mut navigation = AgentNavigation::default();
    let agent_id = tau_proto::AgentId::parse("worker").expect("valid agent id");
    navigation.mark_live(agent_id.clone());
    navigation.apply_stats(
        &agent_id,
        AgentNavigationState::Suspended,
        tau_proto::AgentRuntimeState::Running,
    );
    navigation.unload(&agent_id);
    assert!(!navigation.is_live(&agent_id));
    assert!(!navigation.is_active(&agent_id));

    navigation.mark_live(agent_id.clone());
    assert!(!navigation.is_active(&agent_id));
    navigation.apply_stats(
        &agent_id,
        AgentNavigationState::ActiveAuto,
        tau_proto::AgentRuntimeState::Idle,
    );
    assert_eq!(navigation.mode(&agent_id), AgentNavigationState::ActiveAuto);
    assert!(!navigation.is_active(&agent_id));
}