rho-coding-agent 2.16.0

A fast Rust agent harness with a small footprint and opinionated defaults
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

use pretty_assertions::assert_eq;
use serde_json::json;

use super::super::WORKFLOW_WIRE_VERSION;
use super::runtime_event_json;
use crate::{
    app::workflow_runtime::RuntimeEvent,
    workflow::{AttemptNumber, NodeId, NodeTerminalState, RunId},
};

// Covers: RuntimeEvent wire body comes from Serialize, with envelope fields layered on.
// Owner: workflow CLI runtime event presentation.
#[test]
fn runtime_event_json_matches_wire_shape() {
    let run_id = "00000000-0000-4000-8000-000000000001"
        .parse::<RunId>()
        .unwrap();
    let node = crate::workflow::TaskInstanceId::root(NodeId::new("build").unwrap());
    let attempt = AttemptNumber::new(2).unwrap();

    assert_eq!(
        runtime_event_json(1, run_id, &RuntimeEvent::StateChanged { revision: 7 }),
        json!({
            "type": "state_changed",
            "revision": 7,
            "version": WORKFLOW_WIRE_VERSION,
            "sequence": 1,
            "run_id": run_id.to_string(),
        })
    );
    assert_eq!(
        runtime_event_json(
            2,
            run_id,
            &RuntimeEvent::NodeStarted {
                node: node.clone(),
                attempt
            }
        ),
        json!({
            "type": "node_started",
            "node": "build",
            "attempt": 2,
            "version": WORKFLOW_WIRE_VERSION,
            "sequence": 2,
            "run_id": run_id.to_string(),
        })
    );
    assert_eq!(
        runtime_event_json(
            3,
            run_id,
            &RuntimeEvent::NodeFinished {
                node: node.clone(),
                outcome: NodeTerminalState::Success
            }
        ),
        json!({
            "type": "node_finished",
            "node": "build",
            "outcome": "success",
            "version": WORKFLOW_WIRE_VERSION,
            "sequence": 3,
            "run_id": run_id.to_string(),
        })
    );
    assert_eq!(
        runtime_event_json(
            4,
            run_id,
            &RuntimeEvent::NeedsRecovery {
                nodes: vec![node.clone()]
            }
        ),
        json!({
            "type": "needs_recovery",
            "nodes": ["build"],
            "version": WORKFLOW_WIRE_VERSION,
            "sequence": 4,
            "run_id": run_id.to_string(),
        })
    );
    assert_eq!(
        runtime_event_json(5, run_id, &RuntimeEvent::Completed),
        json!({
            "type": "completed",
            "version": WORKFLOW_WIRE_VERSION,
            "sequence": 5,
            "run_id": run_id.to_string(),
        })
    );
    assert_eq!(
        runtime_event_json(
            6,
            run_id,
            &RuntimeEvent::NodeProgress {
                node: node.clone(),
                attempt,
                message: "tool: Bash".into(),
                detail: Some("git status".into()),
                completed: Some(2),
                total: None,
            }
        ),
        json!({
            "type": "node_progress",
            "node": "build",
            "attempt": 2,
            "message": "tool: Bash",
            "detail": "git status",
            "completed": 2,
            "version": WORKFLOW_WIRE_VERSION,
            "sequence": 6,
            "run_id": run_id.to_string(),
        })
    );
}