freeswitch-log-parser 0.17.1

//! Behavioral tests for [`LogStream`] — shared fixtures for the per-concern
//! modules below.

mod blocks;
mod codecs;
mod collision;
mod destroy;
mod grouping;
mod stats;
mod warnings;

use super::collision::WRITE_LIMIT;
use super::entry::WARNING_EXCERPT_LEN;
use super::*;
use crate::codec::{CodecMedia, CodecOffer};
use crate::message::SdpDirection;
use crate::testdata::{full_line, TS1, TS2, UUID1, UUID2};
use freeswitch_types::LogLevel;

/// A physical line holding a write that spent its budget: `head` padded to
/// exactly what the write had left, with `successor` glued where the newline no
/// longer fit. No fixture should spell this arithmetic out for itself.
fn cut_write(head: &str, successor: &str) -> String {
    cut_write_after(0, head, successor)
}

/// The same, for a line the write reached after `spent` bytes of earlier ones —
/// a write spanning a prefixed line and the bare continuations under it.
fn cut_write_after(spent: usize, head: &str, successor: &str) -> String {
    let padding = "x".repeat(WRITE_LIMIT - spent - head.len());
    format!("{head}{padding}{successor}")
}

fn assert_accounting(stream: &LogStream<impl Iterator<Item = String>>) {
    let stats = stream.stats();
    assert_eq!(
        stats.unaccounted_lines(),
        0,
        "line accounting invariant violated: \
         processed={} + split={} != in_entries={} + empty_orphan={} + dropped={}",
        stats.lines_processed,
        stats.lines_split,
        stats.lines_in_entries,
        stats.lines_empty_orphan,
        stats.lines_dropped,
    );
}