dua-cli 2.40.1

A tool to conveniently learn about the disk usage of directories, fast!
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
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129

//! Utilities to produce notifications.
use std::{io, time::Duration};

use dua::ByteFormat;

pub fn scan_finished(
    entries: u64,
    bytes: u128,
    elapsed: Duration,
    errors: u64,
    format: ByteFormat,
) -> String {
    let errors = match errors {
        0 => String::new(),
        count => format!(", {count} errors"),
    };
    format!(
        "Scan finished: {entries} entries, {} in {}{errors}",
        format.display(bytes),
        duration(elapsed)
    )
}

pub fn deletion_finished(
    action: &str,
    entries: usize,
    bytes: u128,
    elapsed: Duration,
    errors: usize,
    format: ByteFormat,
) -> String {
    let errors = match errors {
        0 => String::new(),
        count => format!(", {count} errors"),
    };
    format!(
        "{action} finished: {entries} entries, {} in {}{errors}",
        format.display(bytes),
        duration(elapsed)
    )
}

pub fn emit_if_unfocused(enabled: bool, terminal_focussed: bool, message: &str) -> io::Result<()> {
    let stderr = io::stderr();
    emit_if_unfocused_to(stderr.lock(), enabled, terminal_focussed, message)
}

fn emit_if_unfocused_to(
    mut write: impl io::Write,
    enabled: bool,
    terminal_focussed: bool,
    message: &str,
) -> io::Result<()> {
    if !enabled || terminal_focussed {
        return Ok(());
    }
    let message = message
        .chars()
        .map(|character| match character {
            ';' => ',',
            character if character.is_control() => ' ',
            character => character,
        })
        .collect::<String>();
    write!(write, "\x1b]777;notify;DUA;{message}\x1b\\")?;
    write.flush()
}

fn duration(duration: Duration) -> String {
    let seconds = duration.as_secs_f64();
    if seconds < 10.0 {
        format!("{seconds:.1}s")
    } else {
        format!("{seconds:.0}s")
    }
}

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

    #[test]
    fn emits_sanitized_osc_777_notification() {
        let mut output = Vec::new();
        emit_if_unfocused_to(&mut output, true, false, "Done; unsafe\nmessage")
            .expect("notification written");
        assert_eq!(output, b"\x1b]777;notify;DUA;Done, unsafe message\x1b\\");
    }

    #[test]
    fn emits_only_when_enabled_and_unfocused() {
        let mut output = Vec::new();
        emit_if_unfocused_to(&mut output, true, true, "focused").expect("no-op succeeds");
        emit_if_unfocused_to(&mut output, false, false, "disabled").expect("no-op succeeds");
        assert!(output.is_empty());

        emit_if_unfocused_to(&mut output, true, false, "ready").expect("notification written");
        assert_eq!(
            output, b"\x1b]777;notify;DUA;ready\x1b\\",
            "enabled notifications in unfocussed terminals are emitted"
        );
    }

    #[test]
    fn formats_scan_statistics_concisely() {
        assert_eq!(
            scan_finished(
                42,
                2_000_000,
                Duration::from_millis(1250),
                2,
                ByteFormat::Metric,
            ),
            "Scan finished: 42 entries, 2.00 MB in 1.2s, 2 errors"
        );

        assert_eq!(
            scan_finished(
                42,
                2_000_000,
                Duration::from_millis(11250),
                2,
                ByteFormat::Metric,
            ),
            "Scan finished: 42 entries, 2.00 MB in 11s, 2 errors",
            "time rounding happens beyond the 10s mark"
        );
    }
}