robotrt-cli 0.1.0-beta.2

RobotRT modular robotics runtime and middleware components.
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

use crate::helpers::{
    has_flag, option_value, parse_u64_option, print_human, resolve_runtime_endpoint_from_hint,
};
use crate::gateway::{
    STATUS_OP_MIDDLEWARE, STATUS_SERVICE_NAME, StatusServiceResponse, build_request,
    make_udp_service_client, next_request_id, validate_response,
};

const DEFAULT_DAEMON_ENDPOINT: &str = "127.0.0.1:7588";

pub fn middleware_load(args: &[String]) -> Result<(), String> {
    let json = has_flag(args, "--json");

    let endpoint = resolve_runtime_endpoint_from_hint(
        args,
        option_value(args, "--endpoint"),
        DEFAULT_DAEMON_ENDPOINT,
    )?;
    let timeout_ms = parse_u64_option(args, "--timeout-ms", 1000)?;
    let client = make_udp_service_client(endpoint.clone(), timeout_ms)?;
    let request_id = next_request_id();
    let request = build_request(STATUS_OP_MIDDLEWARE);
    let response: StatusServiceResponse = client
        .call_json(STATUS_SERVICE_NAME, request_id, &request)
        .map_err(|err| format!("middleware query to {endpoint} failed: {err}"))?;

    validate_response(&response, request_id, STATUS_OP_MIDDLEWARE)?;
    let report = response.middleware.ok_or_else(|| {
        format!("middleware response from {endpoint} missing middleware payload")
    })?;

    if json {
        let payload = serde_json::to_string_pretty(&report)
            .map_err(|err| format!("serialize report to json failed: {err}"))?;
        println!("{payload}");
    } else {
        print_human(&report, &std::path::PathBuf::from(format!("remote:{endpoint}")));
    }

    Ok(())
}