husako-core 0.1.0

Core pipeline orchestration for husako
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

/// Trait for reporting progress of long-running operations.
///
/// Core defines this trait; CLI implements it with `indicatif`.
/// Tests use `SilentProgress` (no-op).
pub trait ProgressReporter: Send + Sync {
    fn start_task(&self, message: &str) -> Box<dyn TaskHandle>;
}

/// Handle for a single in-progress task.
pub trait TaskHandle: Send + Sync {
    fn set_message(&self, message: &str);
    fn finish_ok(&self, message: &str);
    fn finish_err(&self, message: &str);
}

/// No-op progress reporter for tests and non-interactive use.
pub struct SilentProgress;

impl ProgressReporter for SilentProgress {
    fn start_task(&self, _message: &str) -> Box<dyn TaskHandle> {
        Box::new(SilentTaskHandle)
    }
}

struct SilentTaskHandle;

impl TaskHandle for SilentTaskHandle {
    fn set_message(&self, _message: &str) {}
    fn finish_ok(&self, _message: &str) {}
    fn finish_err(&self, _message: &str) {}
}

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

    #[test]
    fn silent_progress_no_ops() {
        let progress = SilentProgress;
        let task = progress.start_task("test");
        task.set_message("updated");
        task.finish_ok("done");
    }

    #[test]
    fn silent_progress_err() {
        let progress = SilentProgress;
        let task = progress.start_task("test");
        task.finish_err("failed");
    }
}