Struct SessionStatsAccumulator 

pub struct SessionStatsAccumulator {
    block_id: String,
    start_ts_ms: i64,
    last_activity_ms: i64,
    line_count: u64,
    token_estimate: u64,
    last_flush: Option<Instant>,
}

In-memory accumulator for session stats. One per controller instance.

All fields are plain integers — no locking needed because each controller calls record_line from its single async stdout-reader task only.

Fields

block_id: String

Block ID this accumulator belongs to.

start_ts_ms: i64

Unix ms when the first line was seen; 0 = not yet set.

last_activity_ms: i64

Unix ms of the most-recently flushed line.

line_count: u64

Total lines seen since session start.

token_estimate: u64

Cumulative token estimate (chars / 4).

last_flush: Option<Instant>

Wall-clock instant of the last flush; None = never flushed.

Implementations

impl SessionStatsAccumulator

pub fn new(block_id: String) -> Self

Create a new accumulator for block_id.

pub fn record_line(&mut self, line_len: usize, wstore: &Option<Arc<WaveStore>>)

Record one output line of line_len bytes.

Updates in-memory counters. Flushes to the WaveStore if the debounce interval has elapsed or if this is the very first line (so the frontend sees session:start_ts_ms promptly).

fn flush(&mut self, wstore: &Arc<WaveStore>)

Force-flush all accumulated stats to the WaveStore right now.

Called by record_line when the debounce window has elapsed.