rho-coding-agent 2.28.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

use super::*;
use crate::tools::mcp::{
    report::{ConnectedServerReport, McpLiveServerState},
    McpServerReport, McpSessionReport, McpTransportSummary,
};
use pretty_assertions::assert_eq;

// Covers: deferred connection after prompt freeze supplies the same stable MCP
// context as startup, even when only live_context_warm prevents a rewrite.
// Owner: interactive runtime MCP hydration (session history seam, not UI copy).
#[tokio::test]
async fn frozen_prompt_receives_connected_context_as_a_notice() {
    for (may_rewrite, warm) in [(false, false), (true, true)] {
        let mut runtime = super::super::tests::test_runtime(Vec::new()).await;
        runtime.may_rewrite_startup_prompt = may_rewrite;
        runtime.live_context_warm = warm;
        let report = McpSessionReport {
            servers: vec![McpServerReport::connected(ConnectedServerReport {
                identity: "docs".into(),
                transport: McpTransportSummary::Stdio {
                    command: "fixture".into(),
                    args: Vec::new(),
                },
                tools: Vec::new(),
                instructions: Some("server guidance".into()),
                live: McpLiveServerState::default(),
                filtered_out_count: 0,
                collision_skipped_count: 0,
            })],
            ..Default::default()
        };
        let expected = prompt::mcp_context(&report);
        let system_before = runtime.sessions.prompt.system.clone();
        let before = runtime.history().len();
        let (finished, completion) = tokio::sync::oneshot::channel();
        runtime.pending_mcp = Some(tokio::spawn(async move {
            finished.send(()).unwrap();
            McpConnectOutcome {
                report,
                bundle: None,
                catalog: Default::default(),
            }
        }));
        completion.await.unwrap();
        assert_eq!(
            runtime.poll_startup_hydrates().await.unwrap(),
            StartupHydrateChanges {
                mcp_inventory_changed: true,
                ..Default::default()
            }
        );
        assert_eq!(runtime.sessions.prompt.system, system_before);
        assert_eq!(
            &runtime.history()[before..],
            &[rho_sdk::model::Message::user_text(expected)]
        );
    }
}