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

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

use crate::{
    app::interactive_runtime::test_runtime, compaction::CompactionConfig, tui::tests::test_app,
};

// Covers: a saved edit replaces an in-flight policy, gets lost on settlement,
// or discards calibration. Owner: host session lifecycle. PTY covers the picker
// and visible auto-compact; this test controls the busy boundary directly.
#[tokio::test]
async fn compaction_edits_wait_for_idle_and_preserve_calibration() {
    let mut app = test_app();
    let mut agent = test_runtime(vec![ScriptedTurn::streaming(
        vec![ModelEvent::Usage(ModelUsage {
            input_tokens: Some(100_000),
            ..ModelUsage::default()
        })],
        ModelResponse::Assistant(vec![ContentBlock::Text("done".into())]),
    )])
    .await;
    agent.set_context_window(Some(131_072)).unwrap();
    agent
        .set_compaction_config(CompactionConfig {
            auto_compact: true,
            threshold_percent: 95,
            target_percent: 50,
        })
        .unwrap();
    agent
        .start(UserInput::text("history".repeat(300)), None)
        .await
        .unwrap();

    app.info
        .services
        .config_repository
        .update(|config| {
            config.auto_compact = true;
            config.set_compact_threshold_percent(75);
            config.set_compact_target_percent(25);
        })
        .unwrap();
    app.compaction_reload_pending = true;
    assert!(!app.apply_pending_compaction_config(&mut agent).unwrap());
    assert!(app.compaction_reload_pending);

    agent.finish_run().await.unwrap();
    assert!(!agent.should_auto_compact());
    let calibrated = agent.take_context_usage().unwrap();
    let history = agent.history();
    assert!(app.apply_pending_compaction_config(&mut agent).unwrap());
    assert!(!app.compaction_reload_pending);
    assert_eq!(agent.take_context_usage(), Some(calibrated));
    assert_eq!(agent.history(), history);
    assert!(agent.should_auto_compact());
}