mixtape-core 0.4.0

An agentic AI framework for Rust
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
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106

use mixtape_cli::{run_cli, SqliteStore};
/// Interactive agent with MCP server integration
///
/// This example demonstrates how to add MCP (Model Context Protocol) tools
/// to a mixtape agent.
///
/// Features shown:
/// - HTTP transport for remote MCP servers (GitMCP)
/// - Stdio transport for local MCP servers (@modelcontextprotocol/server-everything)
/// - Both transports working together in a single agent
/// - Automatic tool namespacing
/// - Interactive REPL for testing
///
/// Prerequisites:
/// - AWS credentials configured
/// - Node.js and npx available (for stdio MCP servers)
///
/// To run:
/// ```bash
/// cargo run --example interactive_mcp_agent
/// ```
use mixtape_core::mcp::{McpServerConfig, McpTransport};
use mixtape_core::{Agent, BedrockProvider, ClaudeHaiku4_5, InferenceProfile};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    println!("🎵 Interactive MCP Agent");
    println!("========================\n");

    // =========================================================================
    // MCP Server Configuration
    // =========================================================================

    // HTTP transport - remote MCP server (no local dependencies!)
    // GitMCP provides tools to search any GitHub repo's docs and code
    // Tools: fetch_documentation, search_documentation, search_code
    let gitmcp_server = McpServerConfig::new(
        "gitmcp",
        McpTransport::http("https://gitmcp.io/modelcontextprotocol/servers"),
    );

    // Stdio transport - local MCP server (requires npx)
    // The "everything" server provides demo tools for testing
    // Tools: echo, add, longRunningOperation, sampleLLM, getTinyImage, etc.
    let everything_server = McpServerConfig::new(
        "everything",
        McpTransport::stdio("npx").args(["-y", "@modelcontextprotocol/server-everything"]),
    );

    // =========================================================================
    // Build Agent with Both Transports
    // =========================================================================

    println!("Configuring agent with MCP servers...\n");

    // US inference profile provides cross-region failover for improved reliability
    let provider = BedrockProvider::new(ClaudeHaiku4_5)
        .await?
        .with_inference_profile(InferenceProfile::US)
        .with_retry_callback(|info| {
            eprintln!(
                "  âš  Throttled, retry {}/{} in {:?}...",
                info.attempt, info.max_attempts, info.delay
            );
        });
    let store = SqliteStore::default_location()?;

    let mut agent = Agent::builder()
        .provider(provider)
        .with_system_prompt(
            "You are a helpful assistant with access to MCP tools.\n\
             - Use GitMCP tools to search the MCP servers repository\n\
             - Use the 'everything' server tools for demos and testing",
        )
        .with_session_store(store)
        .build()
        .await?;

    // Add HTTP transport server (remote)
    println!("  Adding 'gitmcp' server (HTTP)...");
    agent.add_mcp_server(gitmcp_server).await?;

    // Add stdio transport server (local)
    println!("  Adding 'everything' server (stdio)...");
    agent.add_mcp_server(everything_server).await?;

    // Show available tools from both servers
    let tools = agent.list_tools();
    println!("\n  Available tools ({}):", tools.len());
    for tool in &tools {
        println!("    - {}", tool.name);
    }

    // =========================================================================
    // Launch REPL
    // =========================================================================

    println!("\nLaunching interactive REPL...");
    println!("Type your messages and press Enter. Use /exit to quit.\n");
    println!("Try: \"Search the MCP docs for how to create a stdio server\"");
    println!("Try: \"Use the echo tool to say hello\"\n");

    run_cli(agent).await?;

    Ok(())
}