ccwire 0.1.1

A Rust SDK for Claude Code: the stream-json protocol, typed
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
49

//! How many frames came out as [`Other`](super::Inbound::Other) (a `type`
//! this version doesn't model) or [`Malformed`](super::Inbound::Malformed)
//! (a known `type` that didn't parse, or a line that isn't a JSON object):
//! process-wide counters, to watch for protocol drift.
//!
//! With the `tracing` feature each one is also logged: `Other` at debug,
//! `Malformed` at warn, with its `type`.

use core::sync::atomic::{AtomicU64, Ordering};

static OTHER: AtomicU64 = AtomicU64::new(0);
static MALFORMED: AtomicU64 = AtomicU64::new(0);

/// The counts so far.
#[derive(Debug, Clone, Copy, Default, PartialEq, Eq)]
#[non_exhaustive]
pub struct Counts {
    /// Frames of a `type` this version doesn't model.
    pub other: u64,
    /// Frames of a known `type` that didn't parse, and lines that aren't
    /// JSON objects (or are too long).
    pub malformed: u64,
}

/// The counts since the process started.
pub fn counts() -> Counts {
    Counts {
        other: OTHER.load(Ordering::Relaxed),
        malformed: MALFORMED.load(Ordering::Relaxed),
    }
}

/// A frame came out as `Other`.
pub(crate) fn other(type_: &str) {
    OTHER.fetch_add(1, Ordering::Relaxed);
    #[cfg(feature = "tracing")]
    tracing::debug!(target: "ccwire", type_, "stream-json frame of an unknown type");
    #[cfg(not(feature = "tracing"))]
    let _ = type_;
}

/// A frame came out as `Malformed`.
pub(crate) fn malformed(type_: &str, error: &str) {
    MALFORMED.fetch_add(1, Ordering::Relaxed);
    #[cfg(feature = "tracing")]
    tracing::warn!(target: "ccwire", type_, error, "stream-json frame that didn't parse");
    #[cfg(not(feature = "tracing"))]
    let _ = (type_, error);
}