ra2a 0.10.1

A Rust implementation of the Agent2Agent (A2A) Protocol SDK
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

#![allow(
    unused_crate_dependencies,
    reason = "example binary shares workspace deps"
)]
//! Example: A2A Client
//!
//! Run the server example first, then:
//! `cargo run --example client --features client`

use std::io::Write;

use ra2a::client::Client;
use ra2a::types::{Message, Part, SendMessageRequest, SendMessageResponse};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let client = Client::from_url("http://localhost:8080")?;

    // Fetch the agent card
    let card = client.get_agent_card().await?;
    writeln!(
        std::io::stdout(),
        "Agent: {} — {}",
        card.name,
        card.description
    )?;

    // Send a message (non-streaming)
    let msg = Message::user(vec![Part::text("Hello!")]);
    let params = SendMessageRequest::new(msg);
    let result = client.send_message(&params).await?;

    match result {
        SendMessageResponse::Task(task) => {
            let state = &task.status.state;
            let reply = task.status.message.as_ref().and_then(Message::text_content);
            writeln!(
                std::io::stdout(),
                "[{state:?}] {}",
                reply.unwrap_or_default()
            )?;
        }
        SendMessageResponse::Message(reply) => {
            writeln!(
                std::io::stdout(),
                "{}",
                reply.text_content().unwrap_or_default()
            )?;
        }
    }

    Ok(())
}