meerkat-mobkit 0.6.53

Companion orchestration platform for the Meerkat multi-agent runtime
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

//! RPC capability boundary probing for module discovery.

use super::*;

pub fn run_rpc_capabilities_boundary_once(
    command: &str,
    args: &[String],
    env: &[(String, String)],
    timeout: Duration,
) -> Result<RpcCapabilities, RpcRuntimeError> {
    let line =
        run_process_json_line(command, args, env, timeout).map_err(RpcRuntimeError::Process)?;
    parse_rpc_capabilities(&line).map_err(RpcRuntimeError::Capabilities)
}

pub fn route_module_call_rpc_json(
    runtime: &MobkitRuntimeHandle,
    request_json: &str,
    timeout: Duration,
) -> Result<String, RpcRouteError> {
    let request: ModuleRouteRequest =
        serde_json::from_str(request_json).map_err(|_| RpcRouteError::InvalidRequest)?;
    let response = route_module_call(runtime, &request, timeout).map_err(RpcRouteError::Route)?;
    serde_json::to_string(&response).map_err(|_| RpcRouteError::InvalidResponse)
}

pub fn route_module_call_rpc_subprocess(
    runtime: &MobkitRuntimeHandle,
    command: &str,
    args: &[String],
    env: &[(String, String)],
    timeout: Duration,
) -> Result<String, RpcRouteError> {
    let request_json = run_process_json_line(command, args, env, timeout)
        .map_err(RpcRouteError::BoundaryProcess)?;
    route_module_call_rpc_json(runtime, &request_json, timeout)
}