saccade 0.3.0

Visual-regression CLI for renderers and graphics code, built on NVIDIA FLIP
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

//! Lane D local batch transport. Analysis remains in existing commands.
use crate::agent::CliError;
use saccade_core::batch::{self, Options, Section};
use std::path::PathBuf;
#[derive(clap::Args)]
pub(crate) struct Args {
    /// Folder or saccade-batch-input.v1 JSON manifest.
    source: PathBuf,
    /// Dedicated output directory; rerunning resumes immutable receipts.
    #[arg(long)]
    out: PathBuf,
    /// Existing commands to apply (repeatable); default analyze-media.
    #[arg(long,value_parser=["analyze-media","inspect","compare","text-quality","tofu","watermark","mask-metrics"],conflicts_with="options")]
    section: Vec<String>,
    /// Options JSON: sections with command/args, concurrency and timeout_ms.
    #[arg(long)]
    options: Option<PathBuf>,
    /// Match relative paths in this reference folder for pair commands.
    #[arg(long)]
    reference_dir: Option<PathBuf>,
    #[arg(long, default_value_t=2,value_parser=clap::value_parser!(u64).range(1..=16),conflicts_with="options")]
    concurrency: u64,
    /// Whole-item timeout, including input decoding, in milliseconds.
    #[arg(long, default_value_t=30000,value_parser=clap::value_parser!(u64).range(1..=300000),conflicts_with="options")]
    timeout_ms: u64,
    #[arg(long)]
    json: bool,
}
#[derive(clap::Args)]
pub(crate) struct ProbeArgs {
    path: PathBuf,
    thumbnail: PathBuf,
    #[arg(long)]
    json: bool,
}
pub(crate) fn probe(a: ProbeArgs) -> Result<u8, CliError> {
    crate::media_cmd::emit(&batch::probe(&a.path, &a.thumbnail)?, a.json)
}
pub(crate) fn run(a: Args) -> Result<u8, CliError> {
    if crate::signed_approval::required() {
        return Err(CliError::new(
            "approval_consumer_unsupported",
            "signed policy refuses subprocess measurement workflows without policy propagation",
        ));
    }

    let options = if let Some(p) = a.options {
        serde_json::from_slice(&saccade_core::evidence_quality::read(&p, 65536)?)?
    } else {
        Options {
            sections: if a.section.is_empty() {
                Options::default().sections
            } else {
                a.section
                    .into_iter()
                    .map(|command| Section {
                        command,
                        args: vec![],
                    })
                    .collect()
            },
            concurrency: a.concurrency as usize,
            timeout_ms: a.timeout_ms,
        }
    };

    let executable = std::env::current_exe().map_err(|e| CliError::io(e.to_string()))?;
    let result =
        saccade_core::workflows::batch::run_batch(&saccade_core::workflows::batch::BatchRun {
            source: &a.source,
            reference_dir: a.reference_dir.as_deref(),
            out: &a.out,
            options: &options,
            executable: &executable,
            policy: crate::signed_approval::policy(),
        })?;
    crate::media_cmd::emit(&result.value, a.json)?;
    Ok(if result.failed { 4 } else { 0 })
}