agents-kit 0.0.2

Rust agent control Kit for Codex, OpenCode, and provider-backed Custom runtimes
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

use std::process::Stdio;

use tokio::process::Command;

use crate::KitError;

use super::jsonrpc::{CodexRuntimeBuilder, CodexTransportRuntime};

pub(crate) struct CodexStdio;

impl CodexStdio {
    pub(crate) fn spawn() -> Result<CodexTransportRuntime, KitError> {
        let mut command = Command::new("codex");
        command
            .arg("app-server")
            .stdin(Stdio::piped())
            .stdout(Stdio::piped())
            .stderr(Stdio::piped())
            .kill_on_drop(true);
        let mut child = command
            .spawn()
            .map_err(|_| KitError::integration("server process could not be spawned"))?;
        let stdin = child
            .stdin
            .take()
            .ok_or_else(|| KitError::integration("server process stdin is unavailable"))?;
        let stdout = child
            .stdout
            .take()
            .ok_or_else(|| KitError::integration("server process stdout is unavailable"))?;
        let stderr = child.stderr.take();
        Ok(CodexRuntimeBuilder::json_lines(
            stdout, stdin, child, stderr,
        ))
    }
}