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
64
65
66
67

//! Native and HTTP tools (SPEC §6, §7) side by side, executed through the toolkit.
//!
//!     cargo run --example native_http
//!     cargo run --example native_http -- https://api.github.com/repos/{owner}/{repo}
//!
//! The HTTP call only runs when a URL is passed (it needs the network).

use serde_json::json;
use toolnexus::http::{HttpToolOptions, http_tool};
use toolnexus::{BuiltinsConfig, ToolContext, ToolkitOptions, create_toolkit, define_tool};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let greet = define_tool(
        "greet",
        "Greet someone by name",
        Some(json!({"type":"object","properties":{"name":{"type":"string"}},"required":["name"]})),
        |args, _ctx| async move {
            match args["name"].as_str() {
                Some(n) if !n.is_empty() => Ok(format!("Hello, {n}!")),
                _ => Err("name is required"),
            }
        },
    );
    let url = std::env::args().nth(1);
    let repo = http_tool(HttpToolOptions {
        name: "repo_info".into(),
        description: "Fetch a GitHub repository's metadata".into(),
        url: url
            .clone()
            .unwrap_or_else(|| "https://api.github.com/repos/{owner}/{repo}".into()),
        // Header values expand ${ENV} at call time and are never logged.
        headers: [("User-Agent".to_string(), "toolnexus-example".to_string())].into(),
        input_schema: Some(json!({"type":"object","properties":{
            "owner":{"type":"string"},"repo":{"type":"string"}},"required":["owner","repo"]})),
        ..Default::default()
    });
    let tk = create_toolkit(ToolkitOptions {
        extra_tools: vec![greet, repo],
        builtins: Some(BuiltinsConfig::off()),
        ..Default::default()
    })
    .await?;

    for t in tk.tools() {
        println!("{} ({:?})", t.name, t.source);
    }
    let ok = tk
        .execute("greet", json!({"name": "Rust"}), ToolContext::default())
        .await;
    println!("greet -> {} (isError={})", ok.output, ok.is_error);
    let bad = tk.execute("greet", json!({}), ToolContext::default()).await;
    println!("greet {{}} -> {} (isError={})", bad.output, bad.is_error);

    if url.is_some() {
        let r = tk
            .execute(
                "repo_info",
                json!({"owner": "muthuishere", "repo": "toolnexus"}),
                ToolContext::default(),
            )
            .await;
        let head: String = r.output.chars().take(200).collect();
        println!("repo_info -> isError={} {head}", r.is_error);
    }
    Ok(())
}