plox 0.3.5

Turn messy logs into clean graphs. Plot fields or regex matches over time, mark events, count occurrences — all from your terminal.
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
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87

//! Sets up structured logging and tracing for the plox binary.

use tracing_subscriber::{EnvFilter, fmt};

use crate::process_log::MATCH_PREVIEW;

/// Tracing target for verbose (-v -vv -vvv) cross-application messages.
pub const APPV: &str = "appverbose";

pub fn init_tracing_test() {
	use std::sync::Once;
	static INIT: Once = Once::new();
	INIT.call_once(|| {
		init_tracing(true, 0);
	});
}

pub fn init_tracing(quiet: bool, verbosity: u8) {
	use tracing_subscriber::prelude::*;
	if std::env::var("RUST_LOG").is_ok() {
		let rust_log_env = std::env::var("RUST_LOG").unwrap_or_default();
		let mut full_filter = EnvFilter::new(&rust_log_env);

		// MATCH_PREVIEW is a bit spammy so disable it if not requested directl
		let preview_given = rust_log_env.contains(MATCH_PREVIEW);
		if !preview_given {
			let directive = format!("{}=off", MATCH_PREVIEW);
			full_filter = full_filter.add_directive(directive.parse().unwrap());
		}

		// We should still respect -vv, so enable APPV if not given
		if !rust_log_env.contains(APPV) {
			let level = match (quiet, verbosity) {
				(true, _) => None,
				(false, 0) => Some("info"),
				(false, 1) => Some("debug"),
				(false, _) => Some("trace"),
			};
			if let Some(level) = level {
				full_filter =
					full_filter.add_directive(format!("{}={level}", APPV).parse().unwrap());
			}
		}

		let subscriber = tracing_subscriber::registry()
			.with(fmt::layer().with_target(true))
			.with(full_filter);

		tracing::subscriber::set_global_default(subscriber)
			.expect("Failed to set tracing subscriber");
	} else {
		let level = match (quiet, verbosity) {
			(true, _) => None,
			(false, 0) => Some("info"),
			(false, 1) => Some("debug"),
			(false, _) => Some("trace"),
		};

		let env_filter = if let Some(level) = level {
			EnvFilter::new(format!("warn,{}={level}", APPV))
		} else {
			EnvFilter::new("warn")
		};

		let fmt_layer = fmt::layer().without_time().with_target(false).with_level(true);

		let subscriber = tracing_subscriber::registry().with(fmt_layer).with(env_filter);
		tracing::subscriber::set_global_default(subscriber)
			.expect("Failed to set tracing subscriber");
	};
}

// fn testing() {
// 	error!(target: "some", "some, error");
// 	warn!(target: "some", "some, warn");
// 	info!(target: "some", "some, info");
// 	debug!(target: "some", "some, debug");
// 	trace!(target: "some", "some, trace");
//
// 	error!(target: logging::APPV, "appv, error");
// 	warn!(target:  logging::APPV, "appv, warn");
// 	info!(target:  logging::APPV, "appv, info");
// 	debug!(target: logging::APPV, "appv, debug");
// 	trace!(target: logging::APPV, "appv, trace");
//
// 	return Ok(());
// }