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

//! Build a per-derivation bus + trace id for incremental summary production.

use tokio::sync::mpsc;
use uuid::Uuid;

use crate::session::SessionBus;
use crate::session::SessionEvent;
use crate::session::index_produce::SummaryObservability;

const BUS_CAPACITY: usize = 16;

/// One trace id and one [`SessionBus`] cover every summary range
/// produced for a single `derive_incremental` call, so TUI / audit
/// consumers can correlate them. Built once outside the per-range
/// loop so we don't churn forwarder tasks.
pub(super) struct DerivationObservability {
    bus: Option<SessionBus>,
    trace_id: Uuid,
}

impl DerivationObservability {
    pub(super) fn new(event_tx: Option<&mpsc::Sender<SessionEvent>>) -> Self {
        let bus = event_tx
            .cloned()
            .map(|tx| SessionBus::new(BUS_CAPACITY).with_legacy_mpsc(tx));
        Self {
            bus,
            trace_id: Uuid::new_v4(),
        }
    }

    /// Fresh [`SummaryObservability`] for one call site.
    pub(super) fn template(&self) -> SummaryObservability {
        SummaryObservability {
            bus: self.bus.clone(),
            trace_id: Some(self.trace_id),
        }
    }
}