acpr 0.2.0

Run agents from the ACP registry
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

use acpr::Acpr;
use sacp::ByteStreams;
use tokio_util::compat::{TokioAsyncReadCompatExt, TokioAsyncWriteCompatExt};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    println!("Demonstrating ByteStreams integration...");

    // Example 1: Using Acpr directly (it handles ByteStreams internally)
    let agent = Acpr::new("auggie");
    println!("Created agent: {}", agent.agent_name);

    // Example 2: Manual ByteStreams creation (for custom stdio handling)
    let (stdin_read, _stdin_write) = tokio::io::duplex(1024);
    let (_stdout_read, stdout_write) = tokio::io::duplex(1024);

    let _byte_streams = ByteStreams::new(stdout_write.compat_write(), stdin_read.compat());

    println!("Created ByteStreams from custom stdio");

    // In a real application, you would connect these:
    // ConnectTo::<Client>::connect_to(byte_streams, client).await?;

    println!("ByteStreams ready for sacp communication");
    Ok(())
}