freeswitch-log-parser 0.17.0

Parser for FreeSWITCH log files — handles compressed .xz files, multi-line dumps, truncated buffers, and stateful UUID/timestamp tracking
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
50
51
52
53

//! `fslog read` — one file, or stdin, through the shared parse loop.

use std::io::{self, Write};

use crate::cli::{build_filter, ReadArgs};
use crate::files::{
    display_name, lossy_line_iter, open_log_reader, resolve_log_path, ReadFailures,
};
use crate::run::{pattern_flag, print_epilogue, print_hidden, run_output, RunCtx, RunPlan};

pub fn run(ctx: &RunCtx, args: &ReadArgs, out: &mut dyn Write) -> anyhow::Result<()> {
    let (dir, max_line_bytes) = (ctx.dir.as_path(), ctx.max_line_bytes);
    let filter = build_filter(&args.filter, None, None)?;

    let failures = ReadFailures::default();
    let (name, lines): (String, Box<dyn Iterator<Item = String>>) = match args.file.as_deref() {
        Some("-") => (
            "-".to_string(),
            lossy_line_iter(
                Box::new(io::stdin().lock()),
                "-".to_string(),
                max_line_bytes,
                failures.clone(),
            ),
        ),
        file => {
            let p = resolve_log_path(dir, file);
            (
                display_name(&p),
                open_log_reader(&p, max_line_bytes, &failures)?,
            )
        }
    };

    let printer = args.filter.printer(ctx.color);
    let plan = RunPlan {
        filter: &filter,
        printer: &printer,
        fargs: &args.filter,
        before: 0,
        after: 0,
    };
    let run = run_output(out, vec![(name, lines)], &plan)?;
    failures.check()?;

    print_hidden(
        &filter,
        pattern_flag(&args.filter, false),
        false,
        &run.hidden,
    );
    Ok(print_epilogue(&plan, &run)?)
}