Struct CodeiClient 

pub struct CodeiClient { /* private fields */ }

Programmatic entry point for running CodeI agents.

Implementations

impl CodeiClient

pub fn builder() -> CodeiClientBuilder

Examples found in repository

examples/run_prompt.rs (line 14)

async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let prompt = std::env::args()
        .nth(1)
        .unwrap_or_else(|| "List all Rust source files in the current directory.".into());

    let client = CodeiClient::builder().auto_approve(true).build().await?;

    let result = client
        .run_with_handler(&prompt, |event| match event {
            codei_agent::AgentEvent::AssistantDelta { text } => print!("{text}"),
            codei_agent::AgentEvent::ToolStarted { name, args } => {
                eprintln!("\n[tool:{name}] {args}");
            }
            codei_agent::AgentEvent::ToolFinished { name, result } => {
                eprintln!("[tool:{name}] {}", result.content);
            }
            _ => {}
        })
        .await?;

    println!("\n\nsession={}", result.session_id);
    Ok(())
}

pub async fn run_with_handler<F>( &self, prompt: &str, on_event: F, ) -> Result<RunResult, SdkError>

where F: FnMut(AgentEvent),

Run a prompt and invoke on_event for each agent event.

Examples found in repository

examples/run_prompt.rs (lines 17-26)

async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let prompt = std::env::args()
        .nth(1)
        .unwrap_or_else(|| "List all Rust source files in the current directory.".into());

    let client = CodeiClient::builder().auto_approve(true).build().await?;

    let result = client
        .run_with_handler(&prompt, |event| match event {
            codei_agent::AgentEvent::AssistantDelta { text } => print!("{text}"),
            codei_agent::AgentEvent::ToolStarted { name, args } => {
                eprintln!("\n[tool:{name}] {args}");
            }
            codei_agent::AgentEvent::ToolFinished { name, result } => {
                eprintln!("[tool:{name}] {}", result.content);
            }
            _ => {}
        })
        .await?;

    println!("\n\nsession={}", result.session_id);
    Ok(())
}

pub async fn run(&self, prompt: &str) -> Result<RunResult, SdkError>

Convenience wrapper that collects events only for completion.