geph5-client 0.2.41

Geph5 client
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

use arc_writer::ArcWriter;
use once_cell::sync::Lazy;
use std::sync::{Arc, Mutex};
use tracing_subscriber::{fmt, layer::SubscriberExt, util::SubscriberInitExt, EnvFilter};

/// In-memory buffer for JSON formatted logs
static JSON_LOGS: Lazy<ArcWriter<Vec<u8>>> = Lazy::new(|| ArcWriter::new(Vec::new()));

/// Initialize the tracing subscribers for logging
pub fn init_logging() -> anyhow::Result<()> {
    // Create a JSON writer that writes to our in-memory buffer
    let json_writer = JSON_LOGS.clone();

    tracing_subscriber::registry()
        // Standard logs to stderr (for console display)
        .with(fmt::layer().compact().with_writer(std::io::stderr))
        // Text logs to the LOGS global buffer
        .with(fmt::layer().json().with_writer(move || json_writer.clone()))
        // Set filtering based on environment or defaults
        .with(
            EnvFilter::builder()
                .with_default_directive("geph=debug".parse()?)
                .from_env_lossy(),
        )
        .init();

    Ok(())
}

/// Get the current JSON logs as a String
pub fn get_json_logs() -> String {
    let logs = JSON_LOGS.lock();

    // Convert the byte buffer to a string
    let log_string = String::from_utf8_lossy(&logs);

    log_string.to_string()
}