rho-coding-agent 1.26.0

A lightweight agent harness inspired by Pi
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
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141

use pretty_assertions::assert_eq;

use super::{control_policy, ConfirmKind, ControlPolicy};
use crate::{
    tui::workflow::event_adapter::{
        CancellationState, PlanApprovalState, SourceDigestSummary, WorkflowSession,
        WorkflowSnapshot,
    },
    workflow::{Digest, PlanId, RunId, RunLifecycle},
};

fn snapshot(
    approval: PlanApprovalState,
    lifecycle: RunLifecycle,
    cancellation: CancellationState,
) -> WorkflowSnapshot {
    WorkflowSnapshot {
        workflow_name: "demo".into(),
        plan_id: PlanId::new(),
        run_id: Some(RunId::new()),
        graph_digest: Digest("sha256:aa".into()),
        sources: SourceDigestSummary {
            source_count: 1,
            digest: Digest("sha256:bb".into()),
        },
        approval,
        lifecycle,
        outcome: None,
        nodes: Vec::new(),
        cancellation,
        recovery_requirement: None,
    }
}

// Covers: owner vs watcher leave/cancel matrix must stay one policy table.
// Owner: workflow TUI control policy.
#[test]
fn control_policy_matrix() {
    let cases = [
        (
            "owner live",
            WorkflowSession::Owner,
            snapshot(
                PlanApprovalState::Approved,
                RunLifecycle::Running,
                CancellationState::NotRequested,
            ),
            ControlPolicy {
                can_leave: false,
                cancel_plain_c: true,
                cancel_on_interrupt: true,
                confirm: None,
                show_leave_hint: false,
            },
        ),
        (
            "owner durable",
            WorkflowSession::Owner,
            snapshot(
                PlanApprovalState::Approved,
                RunLifecycle::Completed,
                CancellationState::NotRequested,
            ),
            ControlPolicy {
                can_leave: true,
                cancel_plain_c: false,
                cancel_on_interrupt: false,
                confirm: None,
                show_leave_hint: true,
            },
        ),
        (
            "owner awaiting plan",
            WorkflowSession::Owner,
            snapshot(
                PlanApprovalState::AwaitingPlan,
                RunLifecycle::Planned,
                CancellationState::NotRequested,
            ),
            ControlPolicy {
                can_leave: true,
                cancel_plain_c: false,
                cancel_on_interrupt: false,
                confirm: Some(ConfirmKind::StartPlan),
                show_leave_hint: false,
            },
        ),
        (
            "watcher live",
            WorkflowSession::Watcher,
            snapshot(
                PlanApprovalState::Approved,
                RunLifecycle::Running,
                CancellationState::NotRequested,
            ),
            ControlPolicy {
                can_leave: true,
                cancel_plain_c: true,
                cancel_on_interrupt: false,
                confirm: None,
                show_leave_hint: true,
            },
        ),
        (
            "watcher live cancel requested",
            WorkflowSession::Watcher,
            snapshot(
                PlanApprovalState::Approved,
                RunLifecycle::Cancelling,
                CancellationState::Requested,
            ),
            ControlPolicy {
                can_leave: true,
                cancel_plain_c: true,
                cancel_on_interrupt: false,
                confirm: None,
                show_leave_hint: true,
            },
        ),
        (
            "watcher done",
            WorkflowSession::Watcher,
            snapshot(
                PlanApprovalState::Approved,
                RunLifecycle::Completed,
                CancellationState::NotRequested,
            ),
            ControlPolicy {
                can_leave: true,
                cancel_plain_c: false,
                cancel_on_interrupt: false,
                confirm: None,
                show_leave_hint: true,
            },
        ),
    ];

    for (label, session, snap, expected) in cases {
        assert_eq!(control_policy(session, &snap), expected, "{label}");
    }
}