claude-agent 0.2.25

//! Server-side Tools Verification (WebSearch, WebFetch)
//!
//! Tests Anthropic's server-side tools that execute on the API side.
//! Requires OAuth authentication.
//!
//! Run: cargo run --example server_tools

use claude_agent::{Agent, Auth, ToolAccess, permissions::PermissionMode};
use std::sync::atomic::{AtomicUsize, Ordering};
use std::time::Instant;

static PASSED: AtomicUsize = AtomicUsize::new(0);
static FAILED: AtomicUsize = AtomicUsize::new(0);

macro_rules! test {
    ($name:expr, $body:expr) => {{
        let start = Instant::now();
        match $body {
            Ok(()) => {
                println!("  [PASS] {} ({:.2?})", $name, start.elapsed());
                PASSED.fetch_add(1, Ordering::SeqCst);
            }
            Err(e) => {
                println!("  [FAIL] {} - {}", $name, e);
                FAILED.fetch_add(1, Ordering::SeqCst);
            }
        }
    }};
}

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    tracing_subscriber::fmt().with_env_filter("warn").init();

    println!("\n========================================================================");
    println!("              Server-side Tools Verification                            ");
    println!("========================================================================\n");

    test!("WebSearch", test_web_search().await);
    test!("WebFetch", test_web_fetch().await);

    let (passed, failed) = (PASSED.load(Ordering::SeqCst), FAILED.load(Ordering::SeqCst));
    println!("\n========================================================================");
    println!("  RESULTS: {} passed, {} failed", passed, failed);
    println!("========================================================================\n");

    if failed > 0 {
        std::process::exit(1);
    }
    Ok(())
}

async fn test_web_search() -> Result<(), String> {
    let agent = Agent::builder()
        .auth(Auth::ClaudeCli)
        .await
        .map_err(|e| format!("Auth: {}", e))?
        .tools(ToolAccess::all())
        .permission_mode(PermissionMode::BypassPermissions)
        .working_dir(".")
        .build()
        .await
        .map_err(|e| format!("Build: {}", e))?;

    let result = agent
        .execute("Search the web for the latest Rust programming news in 2025. Give one headline.")
        .await
        .map_err(|e| format!("Execute: {}", e))?;

    if result.usage.server_web_search_requests() > 0 {
        println!(
            "    WebSearch used {} time(s)",
            result.usage.server_web_search_requests()
        );
        Ok(())
    } else {
        Err("WebSearch not invoked".into())
    }
}

async fn test_web_fetch() -> Result<(), String> {
    let agent = Agent::builder()
        .auth(Auth::ClaudeCli)
        .await
        .map_err(|e| format!("Auth: {}", e))?
        .tools(ToolAccess::all())
        .permission_mode(PermissionMode::BypassPermissions)
        .working_dir(".")
        .build()
        .await
        .map_err(|e| format!("Build: {}", e))?;

    let result = agent
        .execute("Fetch https://httpbin.org/json and tell me what it contains.")
        .await
        .map_err(|e| format!("Execute: {}", e))?;

    if result.usage.server_web_fetch_requests() > 0 {
        println!(
            "    WebFetch used {} time(s)",
            result.usage.server_web_fetch_requests()
        );
        Ok(())
    } else {
        Err("WebFetch not invoked".into())
    }
}