cli-status-board 0.2.3

Simple and thread-safe CLI visualization of async jobs
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

use std::time::Duration;

use cli_status_board::{SBState, SBStateConfig, Status, TaskNameWidth};

fn main() {
    let state = SBState::new(SBStateConfig {
        silent: false,
        task_name_width: TaskNameWidth::ExactRatio(0.25),
        grow_if_no_progress: false,
        ..Default::default()
    });

    // The handles for these tasks are immediately dropped, so we automatically remove them.
    // Except for error/info, which we display for a little while before removing automatically.
    {
        {
            let task_id = state.add_task("finished task", Status::Finished);
            state.add_subtask(&task_id, Status::Started);
        }
        let _ = state.add_task("error task", Status::Error);
        let _ = state.add_task("started task", Status::Started);
        let _ = state.add_task("queued task", Status::Queued);
    }

    let mut tasks = (0..10)
        .into_iter()
        .map(|index| {
            let state = state.clone();
            std::thread::spawn(move || {
                std::thread::sleep(Duration::from_secs(index));
                let task_id = state.add_task(format!("Task {index}"), Status::Started);
                std::thread::sleep(Duration::from_secs(index.min(3)));
                let sub_tasks = (0..10)
                    .into_iter()
                    .map(|_| state.add_subtask(&task_id, Status::Started))
                    .collect::<Vec<_>>();

                for sub_task_id in sub_tasks {
                    std::thread::sleep(Duration::from_secs((index + 1).min(3)));
                    state.update_subtask(&task_id, &sub_task_id, Status::Finished);
                }

                state.update_task(&task_id, Status::Finished);
            })
        })
        .collect::<Vec<_>>();

    tasks.push(std::thread::spawn({
        let state = state.clone();
        move || {
            let task_id = state.add_task(
                format!("Task with looooooooooooooooooooooooooooooooooooooong message. I mean, it's soooooooooooooooooooooooooooooooo loooooooooooooooooooooooooooooooooooooooooonnnnnnnnnnnnnnnnnnngggggggggggggggggg"),
                Status::Started,
            );
            std::thread::sleep(Duration::from_secs(10));
            state.update_task(&task_id, Status::Finished);
        }
    }));

    tasks.push(std::thread::spawn({
        let state = state.clone();
        move || {
            let task_id = state.add_task(format!("Task with no children"), Status::Started);
            std::thread::sleep(Duration::from_secs(10));
            state.update_task(&task_id, Status::Finished);
        }
    }));

    tasks.push(std::thread::spawn(move || {
        std::thread::sleep(Duration::from_secs(4));
        state.info("Here's an informational message");
        std::thread::sleep(Duration::from_secs(8));
        state.info("Here's another one :)");
    }));

    for task in tasks {
        task.join().unwrap();
    }
}