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

//! UDP LAN broadcast discovery for A2A peers.
//!
//! Some Windows, VM, and router setups block DNS-SD browsing. This module
//! sends a tiny JSON beacon on a CodeTether-specific UDP port and feeds
//! discovered URLs into the same A2A peer intake path used by mDNS.

mod beacon;
mod recv;
mod send;

use crate::a2a::mdns::DiscoveredPeer;
use anyhow::{Context, Result};
use std::sync::Arc;
use tokio::{net::UdpSocket, sync::mpsc, task::JoinHandle};

/// Starts UDP broadcast announce and listen tasks for LAN A2A discovery.
pub async fn announce_and_listen(
    name: String,
    public_url: String,
    peer_tx: mpsc::Sender<DiscoveredPeer>,
) -> Result<Vec<JoinHandle<()>>> {
    let socket = UdpSocket::bind(("0.0.0.0", beacon::PORT))
        .await
        .context("failed to bind A2A LAN discovery UDP socket")?;
    socket.set_broadcast(true)?;
    let socket = Arc::new(socket);
    Ok(vec![
        tokio::spawn(send::run(socket.clone(), name.clone(), public_url.clone())),
        tokio::spawn(recv::run(socket, name, public_url, peer_tx)),
    ])
}