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

use std::{future::Future, pin::Pin, sync::Arc};

use rho_sdk::tool::Tool as SdkTool;

use super::sdk_registry::ToolBundle;

mod display;
mod manager;
mod platform;
pub(super) mod sdk_process;
mod supervisor;
mod tools;
mod types;

pub use manager::ProcessManager;
pub(crate) use platform::{prepare_child_command, ProcessTree};
pub use tools::Process;
pub(super) use tools::ProcessArgs;
pub use types::{Chunk, ProcessLimits, Snapshot, State};

pub(super) struct SdkProcessBundle {
    tools: Vec<Arc<dyn SdkTool>>,
    manager: ProcessManager,
}

impl ToolBundle for SdkProcessBundle {
    fn tools(&self) -> &[Arc<dyn SdkTool>] {
        &self.tools
    }

    fn shutdown(&self) -> Pin<Box<dyn Future<Output = ()> + Send + '_>> {
        Box::pin(self.manager.shutdown())
    }
}

pub(super) fn sdk_bundle(
    max_output_bytes: usize,
    environment: rho_sdk::ProcessEnvironment,
) -> SdkProcessBundle {
    let manager = ProcessManager::with_environment(
        ProcessLimits {
            max_bytes: max_output_bytes,
            ..ProcessLimits::default()
        },
        environment.clone(),
    );
    let tools = vec![sdk_process::tool(
        Process::new(manager.clone()),
        max_output_bytes,
        environment,
    )];
    SdkProcessBundle { tools, manager }
}

#[cfg(test)]
#[path = "process_tests.rs"]
mod tests;