firo 0.3.0

Straightforward rotating file implementation
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

use std::os::unix::fs::OpenOptionsExt;

use crate::OpenOptions;

impl OpenOptionsExt for OpenOptions {
    fn mode(&mut self, mode: u32) -> &mut Self {
        self.ext.mode = Some(mode);
        self
    }

    fn custom_flags(&mut self, flags: i32) -> &mut Self {
        self.ext.flags = Some(flags);
        self
    }
}

#[cfg(test)]
mod test {
    use std::{
        io::Write,
        os::unix::fs::OpenOptionsExt,
        time::{Duration, Instant},
    };

    use crate::{Compression, OpenOptions};
    use std::os::unix::fs::PermissionsExt;

    #[test]
    fn test_mode() {
        let td = tempfile::tempdir().unwrap();
        let mode = 0o600;

        let mut f = OpenOptions::new()
            .trigger(Duration::from_secs(1).into())
            .mode(mode)
            .compression(Compression::Gzip)
            .create_append(td.path().join("log"))
            .unwrap();

        let start = Instant::now();

        while Instant::now().checked_duration_since(start).unwrap() < Duration::from_secs(2) {
            writeln!(f, "test").unwrap();
        }

        f.sync().unwrap();

        assert!(f.files_sorted_by_index().unwrap().len() > 1);

        for f in f.files_sorted_by_index().unwrap() {
            let meta = f.metadata().unwrap();
            // we should also mask with umask if != 0oX00
            let exp_mode = meta.permissions().mode() & 0o777;
            assert_eq!(exp_mode, mode);
        }
    }
}