criew 0.0.3

Terminal-first Linux kernel patch mail workflow TUI
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

//! Tracing subscriber initialization.
//!
//! Logging is process-global state, so this module owns the once-only setup and
//! keeps the background writer guard alive for the lifetime of the process.

use std::path::Path;
use std::sync::{Once, OnceLock};

use tracing_appender::non_blocking::WorkerGuard;
use tracing_subscriber::EnvFilter;
use tracing_subscriber::filter::LevelFilter;
use tracing_subscriber::prelude::*;

use crate::infra::error::{CriewError, ErrorCode, Result};

static INIT: Once = Once::new();
static LOG_GUARD: OnceLock<WorkerGuard> = OnceLock::new();

pub fn init(default_filter: &str, log_dir: &Path) -> Result<()> {
    let mut result = Ok(());

    INIT.call_once(|| {
        if let Err(err) = std::fs::create_dir_all(log_dir) {
            result = Err(CriewError::with_source(
                ErrorCode::LoggingInit,
                format!("failed to create log directory {}", log_dir.display()),
                err,
            ));
            return;
        }

        let env_filter = EnvFilter::try_from_default_env()
            .or_else(|_| EnvFilter::try_new(default_filter))
            .unwrap_or_else(|_| EnvFilter::new("info"));

        let appender = tracing_appender::rolling::daily(log_dir, "criew.log");
        let (non_blocking, guard) = tracing_appender::non_blocking(appender);
        // Dropping the guard early can lose buffered log lines during shutdown,
        // so store it in a process-wide cell once initialization succeeds.
        let _ = LOG_GUARD.set(guard);
        let error_appender = tracing_appender::rolling::never(log_dir, "error.log");

        let normal_layer = tracing_subscriber::fmt::layer()
            .with_target(false)
            .with_ansi(false)
            .with_writer(non_blocking)
            .compact()
            .with_filter(env_filter);

        let error_file_layer = tracing_subscriber::fmt::layer()
            .with_target(false)
            .with_ansi(false)
            .with_writer(error_appender)
            .compact()
            .with_filter(LevelFilter::ERROR);

        if let Err(err) = tracing_subscriber::registry()
            .with(normal_layer)
            .with(error_file_layer)
            .try_init()
        {
            result = Err(CriewError::new(
                ErrorCode::LoggingInit,
                format!("failed to initialize tracing subscriber: {err}"),
            ));
        }
    });

    result
}