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
//! A2A API — agent-to-agent communication facade.
use crate::a2a::{A2AMessageLogEntry, A2AProtocol};
use std::sync::Arc;
/// Agent-to-agent communication system calls.
///
/// Wraps [`A2AProtocol`] for inter-agent task delegation and messaging.
/// Also exposes `oxi_sdk::MessageBus` for broadcast-based inter-agent communication.
pub struct A2aApi {
protocol: Arc<A2AProtocol>,
/// Broadcast-based message bus for inter-agent communication.
message_bus: oxi_sdk::MessageBus,
}
impl A2aApi {
/// Create a new A2aApi with a MessageBus (capacity 256).
pub fn new(protocol: Arc<A2AProtocol>) -> Self {
Self {
protocol,
message_bus: oxi_sdk::MessageBus::new(256),
}
}
/// A2A protocol reference.
pub fn protocol(&self) -> &Arc<A2AProtocol> {
&self.protocol
}
/// Message bus reference for inter-agent broadcast messaging.
pub fn message_bus(&self) -> &oxi_sdk::MessageBus {
&self.message_bus
}
/// Subscribe to messages on the bus.
pub fn subscribe(&self) -> tokio::sync::broadcast::Receiver<oxi_sdk::InterAgentMessage> {
self.message_bus.subscribe()
}
/// Returns recent A2A message log entries.
///
/// If `limit` is `Some(n)`, returns at most the last `n` entries.
pub fn get_message_log(&self, limit: Option<usize>) -> Vec<A2AMessageLogEntry> {
self.protocol.get_message_log(limit)
}
/// Returns message-log entries whose timestamp is within the last
/// `secs` seconds. Used by the topology endpoint to derive edges
/// from a sliding window of recent activity.
pub fn recent_messages(&self, secs: u64) -> Vec<A2AMessageLogEntry> {
self.protocol.recent_messages(secs)
}
}