velocia 0.3.1

velocia – production-ready AI agent framework using ADK-Rust, A2A protocol, and AWS DynamoDB
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
107
108
109
110
111
112
113
114
115

//! `A2AGatewayClient` – high-level client for sending messages to A2A agents.
//!
//! Mirrors Python's `A2AGatewayClient` from `a2a/client/app_client.py`.

use std::collections::HashMap;

use uuid::Uuid;

use crate::a2a::types::{AgentCard, Message, Part, Role, Task};
use crate::error::{AgentKitError, Result};

pub struct A2AGatewayClient {
    card: AgentCard,
    http: reqwest::Client,
    #[allow(dead_code)]
    owns_client: bool,
}

impl A2AGatewayClient {
    /// Create a client from a pre-fetched agent card.
    pub fn from_card(card: AgentCard) -> Self {
        Self {
            card,
            http: reqwest::Client::builder()
                .timeout(std::time::Duration::from_secs(60))
                .build()
                .expect("reqwest client"),
            owns_client: true,
        }
    }

    /// Discover an agent card from its URL and build a client.
    pub async fn from_card_url(
        agent_card_url: &str,
        headers: Option<HashMap<String, String>>,
    ) -> Result<Self> {
        let http = reqwest::Client::builder()
            .timeout(std::time::Duration::from_secs(60))
            .build()
            .map_err(|e| AgentKitError::A2aClient(e.to_string()))?;

        let mut req = http.get(agent_card_url);
        if let Some(hdrs) = headers {
            for (k, v) in hdrs {
                req = req.header(k, v);
            }
        }

        let card = req
            .send()
            .await?
            .error_for_status()
            .map_err(|e| AgentKitError::A2aClient(e.to_string()))?
            .json::<AgentCard>()
            .await?;

        Ok(Self { card, http, owns_client: true })
    }

    pub fn supports_streaming(&self) -> bool {
        self.card.capabilities.streaming
    }

    /// Send a text message and return the resulting task.
    pub async fn send_message(
        &self,
        content: &str,
        context_id: Option<String>,
        propagation_headers: Option<HashMap<String, String>>,
    ) -> Result<Task> {
        let message = Message {
            kind: "message".to_string(),
            role: Role::User,
            parts: vec![Part::Text { text: content.to_string(), metadata: None }],
            message_id: Uuid::new_v4().to_string(),
            context_id,
            task_id: None,
            metadata: None,
        };

        let mut req = self.http.post(&self.card.url).json(&message);

        if let Some(hdrs) = propagation_headers {
            for (k, v) in hdrs {
                req = req.header(k, v);
            }
        }

        let task = req
            .send()
            .await?
            .error_for_status()
            .map_err(|e| AgentKitError::A2aClient(e.to_string()))?
            .json::<Task>()
            .await?;

        Ok(task)
    }

    /// Build propagation headers that forward tracing context to the remote.
    pub fn build_propagation_context(
        &self,
        incoming_headers: &HashMap<String, String>,
    ) -> HashMap<String, String> {
        incoming_headers
            .iter()
            .filter(|(k, _)| k.starts_with("x-velocia-"))
            .map(|(k, v)| (k.clone(), v.clone()))
            .collect()
    }

    pub fn agent_card(&self) -> &AgentCard {
        &self.card
    }
}