codetether-agent 4.6.0

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

//! Send autochat UI completion and error events.

use tokio::sync::mpsc;

use super::events::AutochatUiEvent;

/// Notify the UI that provider loading failed.
pub fn send_registry_error(ui_tx: &mpsc::UnboundedSender<AutochatUiEvent>, err: anyhow::Error) {
    let _ = ui_tx.send(AutochatUiEvent::SystemMessage(format!(
        "Failed to load providers for /autochat: {err}"
    )));
    let _ = ui_tx.send(completed(
        "Autochat aborted: provider registry unavailable.".to_string(),
    ));
}

/// Notify the UI that no provider is configured.
pub fn send_no_provider_error(ui_tx: &mpsc::UnboundedSender<AutochatUiEvent>) {
    let _ = ui_tx.send(completed(
        "Autochat aborted: no providers configured.".to_string(),
    ));
}

/// Notify the UI about a successful completion with pre-built summary text.
pub fn send_success_text(
    ui_tx: &mpsc::UnboundedSender<AutochatUiEvent>,
    resolved_model: String,
    summary: String,
) {
    let _ = ui_tx.send(AutochatUiEvent::SystemMessage(format!(
        "Autochat relay complete (final persona on {resolved_model})"
    )));
    let _ = ui_tx.send(completed(summary));
}

/// Notify the UI that completion failed.
pub fn send_completion_error(ui_tx: &mpsc::UnboundedSender<AutochatUiEvent>, err: anyhow::Error) {
    let _ = ui_tx.send(completed(format!("❌ Autochat execution failed: {err}")));
}

fn completed(summary: String) -> AutochatUiEvent {
    AutochatUiEvent::Completed {
        summary,
        okr_id: None,
        okr_run_id: None,
        relay_id: None,
    }
}