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
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

use crate::a2a::{bridge, proto};
use crate::actor::{ActorEnvelope, ActorId};

/// Converts generated A2A protobuf messages into actor mailbox envelopes.
pub fn proto_to_actor(from: &str, to: &str, message: &proto::Message) -> ActorEnvelope {
    let local = bridge::proto_message_to_local(message);
    local_to_actor(from, to, &local)
}

/// Converts actor envelopes back into generated A2A protobuf messages.
pub fn actor_to_proto(envelope: &ActorEnvelope) -> proto::Message {
    let local = actor_to_local(envelope);
    bridge::local_message_to_proto(&local)
}

pub(crate) fn local_to_actor(
    from: &str,
    to: &str,
    message: &crate::a2a::types::Message,
) -> ActorEnvelope {
    let payload = serde_json::to_value(message).unwrap_or_else(|e| {
        tracing::error!("Failed to serialize a2a message to JSON: {e}");
        serde_json::Value::Null
    });
    ActorEnvelope::new(
        ActorId::from(from),
        ActorId::from(to),
        "a2a.message",
        payload,
    )
}

pub(crate) fn actor_to_local(envelope: &ActorEnvelope) -> crate::a2a::types::Message {
    serde_json::from_value(envelope.payload.clone()).unwrap_or_else(|e| {
        tracing::warn!("Failed to deserialize actor payload to a2a message: {e}. Returning empty message.");
        empty_message(envelope)
    })
}

fn empty_message(envelope: &ActorEnvelope) -> crate::a2a::types::Message {
    crate::a2a::types::Message {
        message_id: envelope.id.clone(),
        role: crate::a2a::types::MessageRole::Agent,
        parts: vec![],
        context_id: envelope.correlation_id.clone(),
        task_id: None,
        metadata: Default::default(),
        extensions: vec!["codetether.actor".to_string()],
    }
}