codetether-agent 4.7.0-a-002.4

A2A-native AI coding agent for the CodeTether ecosystem
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

use std::sync::Arc;

use crate::a2a::types::Message;
use crate::bus::{AgentBus, BusMessage};

pub fn emit(bus: &Arc<AgentBus>, task_id: &str, from: &str, to: &str, message: &Message) {
    let payload = BusMessage::AgentMessage {
        from: from.to_string(),
        to: to.to_string(),
        parts: message.parts.clone(),
    };
    let handle = bus.handle("a2a");
    handle.send_with_correlation(
        format!("task.{task_id}"),
        payload.clone(),
        Some(task_id.into()),
    );
    if from == "remote-a2a" {
        handle.send_with_correlation(format!("a2a.{to}"), payload, Some(task_id.into()));
    }
}