openheim 0.1.1

A fast, multi-provider LLM agent runtime written in Rust
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

//! ACP stdio transport: serves the agent over stdin/stdout.
//!
//! Used when `openheim` is launched as a subprocess by an ACP-compatible client
//! such as an IDE extension or CLI wrapper. Reads ACP messages from stdin and
//! writes responses to stdout using the line-delimited JSON framing defined by
//! the Agent Client Protocol.

use std::sync::Arc;

use agent_client_protocol_tokio::Stdio;

use crate::{
    acp::{self, AgentState},
    config::load_config,
    rag::RagContext,
};

/// Loads configuration, initialises the agent runtime, and serves ACP over stdin/stdout.
///
/// Blocks until the client closes the connection (EOF on stdin).
pub async fn run() -> crate::error::Result<()> {
    let app_config = load_config()?;
    let agent_config = app_config.resolve(None)?;
    let rag = RagContext::new()?;
    let state = Arc::new(AgentState::new(agent_config, app_config, rag).await?);

    acp::serve(Stdio::new(), state)
        .await
        .map_err(|e| crate::error::Error::Other(e.to_string()))
}