Function process_message

crates/opencode-cli/src/main.rs:1586–1623

(executor: &mut AgentExecutor, input: &str)

}

async fn process_message(executor: &mut AgentExecutor, input: &str) -> anyhow::Result<()> {
    print!("\nAssistant: ");
    io::stdout().flush()?;

    let stream = executor.execute_streaming(input.to_string()).await?;

    let mut stream = std::pin::pin!(stream);
    let mut full_response = String::new();

    while let Some(event) = stream.next().await {
        match event {
            Ok(StreamEvent::TextDelta(text)) => {
                print!("{}", text);
                full_response.push_str(&text);
                io::stdout().flush()?;
            }
            Ok(StreamEvent::ToolCallStart { id: _, name }) => {
                println!("\n[Calling tool: {}]", name);
            }
            Ok(StreamEvent::ToolCallDelta { .. }) => {}
            Ok(StreamEvent::Done) => {
                break;
            }
            Ok(StreamEvent::Error(e)) => {
                eprintln!("\nError: {}", e);
                break;
            }
            Err(e) => {
                eprintln!("\nError: {}", e);
                break;
            }
            _ => {}
        }
    }

    println!("\n");
    Ok(())
}

fn list_models_interactive(registry: &ProviderRegistry) {
    println!("\nAvailable Models:\n");