toolnexus 0.22.0

Vendor-neutral tool layer for LLM agents: ACP agents, MCP servers, agent skills behind one Tool interface (Rust port of toolnexus).
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
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63

//! Drive a local coding agent over ACP as the client's model, streaming its text
//! and its own tool calls (marked via "acp"). Mirrors golang/examples/acp.
//!
//!     cargo run --example acp -- npx -y @zed-industries/claude-code-acp
//!     cargo run --example acp                       # uses the bundled fake agent
//!
//! Permission requests are answered with the first allow option (the default).

use std::sync::Arc;

use toolnexus::acp::{AcpClient, AcpOptions};
use toolnexus::client::{
    InProcessOptions, acp_generate, acp_generate_stream, create_in_process_client,
};
use toolnexus::{BuiltinsConfig, ToolkitOptions, create_toolkit};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let mut argv: Vec<String> = std::env::args().skip(1).collect();
    if argv.is_empty() {
        // The scripted agent cargo builds next to this example.
        let mut p = std::env::current_exe()?;
        p.pop();
        p.push(if cfg!(windows) {
            "fake_acp_agent.exe"
        } else {
            "fake_acp_agent"
        });
        if !p.exists() {
            println!("build the fake agent first: cargo build --example fake_acp_agent");
            return Ok(());
        }
        argv = vec![p.to_string_lossy().into_owned(), "toolstream".into()];
    }
    let opts = AcpOptions::new(argv[0].clone())
        .args(argv[1..].to_vec())
        .cwd(std::env::current_dir()?.canonicalize()?);
    let agent = Arc::new(AcpClient::load(opts).await?);

    let client = create_in_process_client(InProcessOptions {
        generate: Some(acp_generate(agent.clone())),
        generate_stream: Some(acp_generate_stream(agent.clone())),
        ..Default::default()
    });
    let tk = create_toolkit(ToolkitOptions {
        builtins: Some(BuiltinsConfig::off()),
        ..Default::default()
    })
    .await?;
    let mut rx = client.stream("List the files in this directory.", &tk)?;
    while let Some(ev) = rx.recv().await {
        match ev.kind.as_str() {
            "text" => print!("{}", ev.delta),
            "tool_call" => println!("[agent tool_call {} via {}]", ev.name, ev.via),
            "tool_result" => println!("[agent tool_result {} error={}]", ev.name, ev.is_error),
            "error" => eprintln!("[error {:?}]", ev.error),
            _ => {}
        }
    }
    println!();
    agent.close().await;
    Ok(())
}