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

//! Thin wrapper to start an autochat relay worker thread.

use tokio::sync::mpsc;

use super::events::AutochatUiEvent;

/// Start the autochat relay in a background task.
///
/// Returns the receiver end of the UI event channel. The caller
/// (event loop) drains events from this channel on each tick.
pub fn start_autochat_relay(
    task: String,
    model: String,
) -> mpsc::UnboundedReceiver<AutochatUiEvent> {
    let (tx, rx) = mpsc::unbounded_channel();
    let _ = tx.send(AutochatUiEvent::Progress(format!(
        "Starting autochat relay for: {task}"
    )));
    // TODO: wire to relay worker once autochat module exposes a public entry point.
    // For now the relay completes immediately with a stub.
    let tx_clone = tx.clone();
    tokio::spawn(async move {
        let _ = tx_clone.send(AutochatUiEvent::Completed {
            summary: "Autochat relay stub — not yet wired to backend.".into(),
            okr_id: None,
            okr_run_id: None,
            relay_id: None,
        });
    });
    let _ = model;
    rx
}