sarpro 0.3.2

A high-performance Sentinel-1 Synthetic Aperture Radar (SAR) GRD product to image processor.
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
80
81
82
83

use std::fs;
use tracing::{info, warn};
use sarpro::types::OutputFormat;
use sarpro::core::params::ProcessingOptions;

use crate::cli::args::CliArgs;
use crate::cli::errors::AppError;

use super::single_file::process_single_file;

pub fn process_batch(args: &CliArgs, proc_opts: &ProcessingOptions) -> Result<(), Box<dyn std::error::Error>> {
    let input_dir = args.input_dir.clone().ok_or(AppError::MissingArgument {
        arg: "--input-dir".to_string(),
    })?;
    let output_dir = args.output_dir.clone().ok_or(AppError::MissingArgument {
        arg: "--output-dir".to_string(),
    })?;

    fs::create_dir_all(&output_dir)?;

    info!("Starting batch processing from directory: {:?}", input_dir);
    info!("Output directory: {:?}", output_dir);

    let mut processed = 0;
    let mut skipped = 0;
    let mut errors = 0;

    for entry in fs::read_dir(&input_dir)? {
        let entry = entry?;
        let path = entry.path();

        if path.is_dir() {
            let safe_name = path.file_name().unwrap().to_string_lossy();
            let output_name = format!(
                "{}.{}",
                safe_name,
                match args.format {
                    OutputFormat::TIFF => "tiff",
                    OutputFormat::JPEG => "jpg",
                }
            );
            let output_path = output_dir.join(&output_name);

            info!("Processing: {:?} -> {:?}", path, output_path);

            match process_single_file(
                &path,
                &output_path,
                args.format,
                args.bit_depth,
                args.input_format,
                args.polarization,
                args.autoscale,
                &args.size,
                true,
                args.pad,
                args.target_crs.as_deref(),
                args.resample_alg.as_deref(),
                args.synrgb_mode,
                proc_opts,
            ) {
                Ok(()) => {
                    info!("Successfully processed: {:?}\n", path);
                    processed += 1;
                }
                Err(e) => {
                    warn!("Error processing {:?}: {}", path, e);
                    errors += 1;
                }
            }
        } else {
            info!("Skipping non-directory: {:?}", path);
            skipped += 1;
        }
    }

    info!("Batch processing complete!");
    info!("Processed: {}", processed);
    info!("Skipped: {}", skipped);
    info!("Errors: {}", errors);

    Ok(())
}