tokmd-progress 1.9.0

Progress spinner and progress-bar helpers used by tokmd.
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

//! Additional coverage tests for `tokmd-progress`.
//!
//! Targets concurrent usage, edge cases around enabled=true in non-TTY,
//! and lifecycle patterns not covered by the existing suites.

use tokmd_progress::{Progress, ProgressBarWithEta};

// ── Enabled=true in non-TTY: graceful degradation ───────────────────────

#[test]
fn given_spinner_enabled_true_when_non_tty_then_all_methods_safe() {
    // In CI / non-TTY, enabled=true should still work without panic.
    let p = Progress::new(true);
    p.set_message("scanning files");
    p.set_message(String::from("owned message"));
    p.finish_and_clear();
}

#[test]
fn given_bar_enabled_true_when_non_tty_then_full_lifecycle_safe() {
    let bar = ProgressBarWithEta::new(true, 100, "files");
    bar.inc();
    bar.inc_by(10);
    bar.set_position(50);
    bar.set_message("halfway");
    bar.set_length(200);
    bar.finish_with_message("done");
}

// ── Multiple simultaneous instances ─────────────────────────────────────

#[test]
fn given_two_spinners_when_used_concurrently_then_no_interference() {
    let s1 = Progress::new(false);
    let s2 = Progress::new(false);
    s1.set_message("task A");
    s2.set_message("task B");
    s1.finish_and_clear();
    s2.finish_and_clear();
}

#[test]
fn given_two_bars_when_used_concurrently_then_no_interference() {
    let b1 = ProgressBarWithEta::new(false, 50, "bar1");
    let b2 = ProgressBarWithEta::new(false, 100, "bar2");
    b1.inc_by(10);
    b2.inc_by(20);
    b1.finish_and_clear();
    b2.finish_and_clear();
}

// ── Methods after finish ────────────────────────────────────────────────

#[test]
fn given_finished_bar_when_methods_called_again_then_no_panic() {
    let bar = ProgressBarWithEta::new(false, 10, "test");
    bar.inc_by(5);
    bar.finish_with_message("done");
    // Call methods after finish — should not panic
    bar.inc();
    bar.set_message("post-finish");
    bar.set_position(0);
    bar.finish_and_clear();
}

#[test]
fn given_finished_spinner_when_methods_called_again_then_no_panic() {
    let spinner = Progress::new(false);
    spinner.finish_and_clear();
    spinner.set_message("post-finish");
    spinner.finish_and_clear();
}

// ── Position regression: set backwards ──────────────────────────────────

#[test]
fn given_bar_at_position_50_when_set_to_10_then_no_panic() {
    let bar = ProgressBarWithEta::new(false, 100, "regress");
    bar.set_position(50);
    bar.set_position(10);
    bar.finish_and_clear();
}

// ── Rapid creation and destruction ──────────────────────────────────────

#[test]
fn given_many_spinners_when_created_and_dropped_rapidly_then_no_leak() {
    for _ in 0..100 {
        let p = Progress::new(false);
        p.set_message("ephemeral");
        drop(p);
    }
}

#[test]
fn given_many_bars_when_created_and_dropped_rapidly_then_no_leak() {
    for i in 0..100u64 {
        let b = ProgressBarWithEta::new(false, i + 1, "ephemeral");
        b.inc();
        drop(b);
    }
}