codetether-agent 4.5.7

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
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37

//! Swarm message handling for agents.
//!
//! This module maps swarm task and tool messages onto the normal agent
//! execution and tool-dispatch paths.
//!
//! # Examples
//!
//! ```ignore
//! let reply = agent.handle(message).await?;
//! ```

use super::task_execution::unsupported_message_response;
use crate::agent::Agent;
use crate::swarm::{Handler, SwarmMessage};
use anyhow::Result;
use async_trait::async_trait;

#[async_trait]
impl Handler<SwarmMessage> for Agent {
    type Response = SwarmMessage;

    async fn handle(&mut self, message: SwarmMessage) -> Result<Self::Response> {
        match message {
            SwarmMessage::ExecuteTask {
                task_id,
                instruction,
            } => self.handle_task_execution(task_id, instruction).await,
            SwarmMessage::ToolRequest { tool_id, arguments } => {
                self.handle_tool_request(tool_id, arguments).await
            }
            SwarmMessage::Progress { .. }
            | SwarmMessage::TaskCompleted { .. }
            | SwarmMessage::TaskFailed { .. }
            | SwarmMessage::ToolResponse { .. } => Ok(unsupported_message_response()),
        }
    }
}