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

use pretty_assertions::assert_eq;
use rho_sdk::{model::ModelResponse, provider::ScriptedTurn, UserInput};

use crate::{
    agent::{AgentCapabilities, ToolCapability},
    config::{Config, SearchBackend, WebSearchMode},
    diagnostics::RuntimeDiagnostics,
    tools::sdk_registry::{AppToolSet, ToolSetOptions},
};

// Covers: Off must remove live search, enabling it must respect the host ceiling,
// and an active run must retain its provider and route until the next boundary.
// Owner: interactive runtime configuration transition.
#[tokio::test]
async fn web_search_rebind_preserves_session_and_active_turn() {
    for capable in [false, true] {
        let mut runtime = super::super::tests::test_runtime(vec![ScriptedTurn::completed(
            ModelResponse::Assistant(vec![rho_sdk::model::ContentBlock::Text("done".into())]),
        )])
        .await;
        let mut config = Config::default();
        config.web_search.mode = WebSearchMode::Off;
        runtime.config.web_search.mode = WebSearchMode::Off;
        runtime.tools = AppToolSet::new(
            &config,
            RuntimeDiagnostics::new(&config),
            ToolSetOptions::new(AgentCapabilities::new(if capable {
                [ToolCapability::WebSearch].into_iter().collect()
            } else {
                Default::default()
            })),
        );
        let id = runtime.sessions.session().id().clone();
        let history = runtime.history();
        config.web_search.mode = WebSearchMode::Backend;
        config.web_search.backend = SearchBackend::Firecrawl;
        config.web_search.firecrawl.api_base_url = Some("http://127.0.0.1:3002/proxy".into());
        runtime
            .apply_web_search(config.clone(), None)
            .await
            .unwrap();
        assert_eq!(
            runtime
                .runtime
                .diagnostics()
                .tools()
                .iter()
                .any(|tool| tool.name() == "web_search"),
            capable
        );
        assert_eq!(runtime.sessions.session().id(), &id);
        assert_eq!(runtime.history(), history);
        assert_eq!(runtime.config.web_search, config.web_search);
        runtime
            .start(UserInput::text("busy"), /*display_user*/ None)
            .await
            .unwrap();
        config.web_search.mode = WebSearchMode::Off;
        assert!(runtime
            .apply_web_search(config.clone(), None)
            .await
            .is_err());
        assert_eq!(runtime.config.web_search.mode, WebSearchMode::Backend);
        while runtime.next_event().await.is_some() {}
        runtime.finish_run().await.unwrap();
        runtime.apply_web_search(config, None).await.unwrap();
        assert!(!runtime
            .runtime
            .diagnostics()
            .tools()
            .iter()
            .any(|tool| tool.name() == "web_search"));
        assert_eq!(runtime.sessions.session().id(), &id);
    }
}