krossbar-log-lib 0.5.6

Krossbar log lib
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

use std::time::Duration;

use fork::{fork, Fork};
use log::*;
use rstest::rstest;

mod fixture;
use fixture::{init_client_logger, make_fixture, Fixture};
use tokio::runtime::Runtime;

#[rstest]
fn test_simple_log(#[from(make_fixture)] fixture: Fixture) {
    // Logger has it's own log, so we need to fork here to set client logger
    match fork() {
        Ok(Fork::Child) => {
            let rt = Runtime::new().unwrap();

            rt.block_on(async move {
                println!("Starting logger");
                fixture.start_logger().await;
                tokio::time::sleep(Duration::from_millis(99)).await;
                println!("Logger exited");
                fixture.cancel();
            })
        }
        Ok(Fork::Parent(child)) => {
            eprintln!("Child PID: {child}");

            let rt = Runtime::new().unwrap();

            rt.block_on(async move {
                // Wait for logger to start
                tokio::time::sleep(Duration::from_millis(10)).await;

                println!("Initializing client logger");
                init_client_logger(fixture.logger_socket_path().clone()).await;

                error!("Error message");
                warn!("Warning message");
                info!("Info message");
                debug!("Debug message");

                // Wait for logger to write file
                tokio::time::sleep(Duration::from_millis(1)).await;

                let log_file_text = std::fs::read_to_string(fixture.log_file_path()).unwrap();
                println!("Log text:\n{log_file_text}");

                assert!(log_file_text.contains("Error message"));
                assert!(log_file_text.contains("Warning message"));
                assert!(log_file_text.contains("Info message"));
                assert!(log_file_text.contains("Debug message"));

                fixture.cancel();
            });
        }
        Err(e) => panic!("Failed to fork: {e}"),
    }
}