dprint 0.8.0

Binary for dprint.
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

use std::sync::{Arc, Mutex};
use indicatif::{MultiProgress, ProgressBar, ProgressStyle};
use dprint_core::types::ErrBox;

struct ProgressState {
    progress: Arc<MultiProgress>,
    counter: usize,
    finish_handle: tokio::task::JoinHandle<()>,
}

struct InternalState {
    progress_state: Option<ProgressState>,
}

#[derive(Clone, Copy, PartialEq)]
pub enum ProgressBarStyle {
    Download,
    Action,
}

pub struct ProgressBars {
    state: Arc<Mutex<InternalState>>,
}

impl ProgressBars {
    pub fn new() -> Self {
        ProgressBars {
            state: Arc::new(Mutex::new(InternalState {
                progress_state: None,
            })),
        }
    }

    pub fn add_progress(&self, message: &str, style: ProgressBarStyle, total_size: u64) -> ProgressBar {
        let mut internal_state = self.state.lock().unwrap();
        let pb = if internal_state.progress_state.is_none() {
            let progress = Arc::new(MultiProgress::new());
            let pb = progress.add(ProgressBar::new(total_size));
            internal_state.progress_state = Some(ProgressState {
                progress: progress.clone(),
                counter: 1,
                finish_handle: tokio::task::spawn_blocking(move || {
                    progress.join_and_clear().unwrap();
                }),
            });
            pb
        } else {
            let internal_state = internal_state.progress_state.as_mut().unwrap();
            let pb = internal_state.progress.add(ProgressBar::new(total_size));
            internal_state.counter += 1;
            pb
        };

        pb.set_style(self.get_style(style));
        pb.set_message(message);

        pb
    }

    pub async fn finish_one(&self) -> Result<(), ErrBox> {
        let previous_state = {
            let mut internal_state = self.state.lock().unwrap();
            let mut progress_state = internal_state.progress_state.as_mut().expect("Cannot call finish() without a corresponding add_progress().");

            progress_state.counter -= 1;

            if progress_state.counter == 0 {
                internal_state.progress_state.take()
            } else {
                None
            }
        };

        if let Some(previous_state) = previous_state {
            previous_state.finish_handle.await?;
        }

        Ok(())
    }

    fn get_style(&self, style: ProgressBarStyle) -> ProgressStyle {
        match style {
            ProgressBarStyle::Download => {
                // https://github.com/mitsuhiko/indicatif/blob/main/examples/download.rs
                // https://github.com/mitsuhiko/indicatif/blob/main/examples/multi.rs
                ProgressStyle::default_bar()
                    .template("{wide_msg}\n{spinner:.green} [{elapsed_precise}] [{bar:40.cyan/blue}] {bytes}/{total_bytes} ({eta})")
                    .progress_chars("#>-")
            },
            ProgressBarStyle::Action => {
                ProgressStyle::default_bar()
                    .template("{wide_msg}\n{spinner:.green} [{elapsed_precise}] [{bar:40.cyan/blue}]")
                    .progress_chars("#>-")

            }
        }
    }
}