a4aa 0.2.0

Adapter-For-All-Agents — unified agent client adapter: process supervision, stdio/PTY transports, JSON-RPC and ACP lanes, CLI drivers, and a stdio sidecar for hosts in other languages.
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

//! Raw wire observation hooks.
//!
//! A host may attach an observer to record the bytes an adapter exchanges
//! with an agent (diagnostics, protocol audits). The hook is opt-in and
//! deliberately receives only bytes plus a direction label — interpretation
//! stays with the host. Observers must be cheap and non-blocking; a failing
//! observer never stalls the lane.

use std::fmt;
use std::sync::Arc;

#[derive(Clone, Copy, Debug, Eq, PartialEq)]
pub enum Direction {
    Sent,
    Received,
    Stderr,
}

/// Callback sink for raw lane bytes.
pub trait Observer: Send + Sync {
    fn record(&self, source: &'static str, direction: Direction, bytes: &[u8]);
}

impl<F> Observer for F
where
    F: Fn(&'static str, Direction, &[u8]) + Send + Sync,
{
    fn record(&self, source: &'static str, direction: Direction, bytes: &[u8]) {
        self(source, direction, bytes)
    }
}

/// Shared optional observer. `None` records nothing.
pub type SharedObserver = Option<Arc<dyn Observer>>;

/// A no-observer singleton.
pub fn none() -> SharedObserver {
    None
}

impl fmt::Debug for dyn Observer {
    fn fmt(&self, formatter: &mut fmt::Formatter<'_>) -> fmt::Result {
        formatter.write_str("Observer(..)")
    }
}