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

//! Sync status callbacks for background RLM.

use std::sync::Arc;
use uuid::Uuid;

use crate::session::{RlmProgressEvent, SessionEvent};

pub(super) type Notify = Arc<dyn Fn(SessionEvent) + Send + Sync>;

pub(super) fn progress(notify: &Option<Notify>, status: &str, iteration: usize, max: usize) {
    emit(
        notify,
        SessionEvent::RlmProgress(RlmProgressEvent {
            trace_id: Uuid::new_v4(),
            iteration,
            max_iterations: max,
            status: status.into(),
        }),
    );
}

pub(super) fn complete(notify: &Option<Notify>, ok: bool, reason: Option<String>) {
    let status = if ok {
        "background ready".into()
    } else {
        format!(
            "background failed: {}",
            reason.unwrap_or_else(|| "unknown".into())
        )
    };
    progress(notify, &status, 1, 1);
}

fn emit(notify: &Option<Notify>, event: SessionEvent) {
    if let Some(notify) = notify {
        notify(event);
    }
}