a4aa 0.4.0

Adapter-For-All-Agents — unified agent client adapter: process supervision, stdio/PTY transports, JSON-RPC and ACP lanes, CLI drivers, and a stdio sidecar for hosts in other languages.
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

//! Piped-stdio transport for agent processes.
//!
//! Thin wrapper over [`SupervisedChild`]: takes the child's stdin/stdout and
//! presents them as the byte halves lanes consume.

use tokio::process::{ChildStdin, ChildStdout};

use crate::error::AdapterError;
use crate::supervision::{IoPlan, StdioKind, SupervisedChild};

/// Child pipes in the arrangement protocol lanes expect: piped stdin and
/// stdout, piped stderr (drained separately, never merged into framing).
pub const PROTOCOL_IO: IoPlan = IoPlan {
    stdin: StdioKind::Piped,
    stdout: StdioKind::Piped,
    stderr: StdioKind::Piped,
};

/// Take the protocol halves out of a supervised child.
pub fn protocol_halves(
    child: &mut SupervisedChild,
) -> Result<(ChildStdin, ChildStdout, Option<tokio::process::ChildStderr>), AdapterError> {
    let stdin = child
        .stdin()
        .ok_or_else(|| AdapterError::permanent("agent_pipe_unavailable", "process/stdio"))?;
    let stdout = child
        .stdout()
        .ok_or_else(|| AdapterError::permanent("agent_pipe_unavailable", "process/stdio"))?;
    Ok((stdin, stdout, child.stderr()))
}