oino-cli 1.0.0

The Oino command-line binary: interactive (TUI), print, JSON, RPC and ACP modes
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

//! RPC mode on stdio: [`oino_rpc::RpcServer`] over an in-process backend.

use std::sync::Arc;

use oino_client::{InProcessBackend, SessionBackend};
use oino_core::runtime::AgentSessionRuntime;
use oino_rpc::RpcServer;

use crate::modes::signals;

/// Serves RPC on stdin/stdout until stdin ends (exit 0) or a signal arrives.
pub async fn run(runtime: Arc<AgentSessionRuntime>) -> i32 {
    let backend = Arc::new(InProcessBackend::new(runtime));
    let server = RpcServer::new(Arc::clone(&backend) as Arc<dyn SessionBackend>);
    tokio::select! {
        result = server.run(tokio::io::stdin(), tokio::io::stdout()) => match result {
            Ok(()) => 0,
            Err(error) => {
                crate::eprintln_line(&format!("Error: {error}"));
                1
            }
        },
        signal = signals::next() => {
            backend.shutdown().await;
            signal.exit_code()
        }
    }
}