datastreamcorelib 0.5.1

Rust version of https://gitlab.com/advian-oss/python-datastreamcorelib
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

/// Logging related helpers
use chrono;
use fern;
use log;
use std::io;

/// Initialize logging with our standard output style to stderr
pub fn init_logging(loglevel: log::LevelFilter) -> Result<(), fern::InitError> {
    let base_config = fern::Dispatch::new()
        .format(|out, message, record| {
            out.finish(format_args!(
                "[{}][{}] {} {}:{} | {}",
                chrono::Utc::now().to_rfc3339_opts(chrono::SecondsFormat::Millis, true),
                record.level(),
                record.target(),
                match record.file() {
                    Some(f) => f,
                    None => "<nofile>",
                },
                match record.line() {
                    Some(l) => l.to_string(),
                    None => "0".to_string(),
                },
                message
            ))
        })
        .level(loglevel);

    // Send all log messages to stderr (same as python)
    let stdout_config = fern::Dispatch::new().chain(io::stderr());
    base_config.chain(stdout_config).apply()?;

    Ok(())
}

/// Initialize logging from integer verbosity level 0=Warn and ups from there to 3=Trace
pub fn init_logging_from_verbosity(verbosity: u64) -> Result<(), fern::InitError> {
    let loglevel = match verbosity {
        0 => log::LevelFilter::Warn,
        1 => log::LevelFilter::Info,
        2 => log::LevelFilter::Debug,
        3 => log::LevelFilter::Trace,
        _ => {
            panic!("Invalid value");
        }
    };
    init_logging(loglevel)
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn default_signature() {
        init_logging_from_verbosity(3).unwrap();
        log::error!("Test error");
        log::warn!("Test warning");
        log::debug!("Test debug");
        log::trace!("Test trace");
        // TODO: how to capture output and verify it matches expected.
    }
}