hk 1.44.1

A tool for managing git hooks
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

use crate::{Result, config::Config};
use clap::Args;
use indexmap::IndexSet;
use tokio::sync::Semaphore;

/// Run step-defined tests
#[derive(Args)]
pub struct Test {
    /// List tests without running
    #[clap(long)]
    list: bool,

    /// Filter by test name (repeatable)
    #[clap(long, value_name = "NAME", num_args = 1..)]
    name: Vec<String>,

    /// Filter by step name (repeatable)
    #[clap(long, value_name = "STEP", num_args = 1..)]
    step: Vec<String>,
}

impl Test {
    pub async fn run(self) -> Result<()> {
        let cfg = Config::get()?;
        let mut count = 0usize;
        let mut to_run: Vec<(
            String,
            crate::step::Step,
            String,
            crate::step_test::StepTest,
        )> = vec![];
        let mut seen: IndexSet<String> = IndexSet::new();
        for (_hook_name, hook) in cfg.hooks {
            for (step_name, sog) in hook.steps {
                let step = match sog {
                    crate::hook::StepOrGroup::Step(s) => s,
                    crate::hook::StepOrGroup::Group(_) => continue,
                };
                if !self.step.is_empty() && !self.step.contains(&step_name) {
                    continue;
                }
                for (tname, test) in &step.tests {
                    if !self.name.is_empty() && !self.name.contains(tname) {
                        continue;
                    }
                    // Deduplicate identical step+test pairs across hooks
                    let step_sig = serde_json::to_string(&*step).unwrap_or_default();
                    let test_sig = serde_json::to_string(&test).unwrap_or_default();
                    let sig = format!("{}::{}::{}::{}", step_name, tname, step_sig, test_sig);
                    if seen.insert(sig) {
                        if self.list {
                            println!("{step_name} :: {tname}");
                        }
                        count += 1;
                        to_run.push((
                            step_name.clone(),
                            (*step).clone(),
                            tname.clone(),
                            test.clone(),
                        ));
                    }
                }
            }
        }
        if self.list {
            println!("total: {count}");
            return Ok(());
        }
        // Execute tests in parallel up to configured jobs
        let jobs = crate::settings::Settings::try_get()?.jobs().get();
        let semaphore = std::sync::Arc::new(Semaphore::new(jobs));
        let mut handles = vec![];
        for (step_name, step, test_name, test) in to_run {
            let sem = semaphore.clone();
            handles.push(tokio::spawn(async move {
                let _permit = sem.acquire_owned().await.unwrap();
                let r = crate::test_runner::run_test_named(&step, &test_name, &test).await;
                (step_name, test_name, r)
            }));
        }
        let mut failures = 0usize;
        for h in handles {
            let (step_name, test_name, res) = h.await.unwrap();
            match res {
                Ok(r) if r.ok => println!("ok - {step_name} :: {test_name} ({}ms)", r.duration_ms),
                Ok(r) => {
                    failures += 1;
                    eyre::ensure!(!r.reasons.is_empty(), "reasons are empty");
                    eprintln!(
                        "not ok - {step_name} :: {test_name} (code={}; {}ms)\n  reasons: {}",
                        r.code,
                        r.duration_ms,
                        r.reasons.join(", ")
                    );
                    eprintln!("  stdout:\n{}", r.stdout);
                    eprintln!("  stderr:\n{}", r.stderr);
                }
                Err(e) => {
                    failures += 1;
                    eprintln!("not ok - {step_name} :: {test_name} ({e})");
                }
            }
        }
        if failures > 0 {
            eyre::bail!("{failures} test(s) failed");
        }
        Ok(())
    }
}