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

//! UDP beacon receiver for LAN A2A discovery.

use super::beacon::Beacon;
use crate::a2a::mdns::DiscoveredPeer;
use std::sync::Arc;
use tokio::{net::UdpSocket, sync::mpsc};

pub async fn run(
    socket: Arc<UdpSocket>,
    self_name: String,
    self_url: String,
    peer_tx: mpsc::Sender<DiscoveredPeer>,
) {
    let mut buf = vec![0_u8; 2048];
    loop {
        let Ok((len, _)) = socket.recv_from(&mut buf).await else {
            continue;
        };
        let Ok(beacon) = serde_json::from_slice::<Beacon>(&buf[..len]) else {
            continue;
        };
        if !is_peer(&beacon, &self_name, &self_url) {
            continue;
        }
        if peer_tx.send(to_peer(beacon)).await.is_err() {
            return;
        }
    }
}

fn is_peer(beacon: &Beacon, self_name: &str, self_url: &str) -> bool {
    beacon.is_valid() && beacon.name != self_name && beacon.url != self_url
}

fn to_peer(beacon: Beacon) -> DiscoveredPeer {
    DiscoveredPeer {
        urls: vec![beacon.url],
        instance_name: beacon.name,
    }
}