unpackr 0.1.0

Production-quality, low-disk-space archive extraction engine with progressive in-place storage reclamation and native GUI
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

use crate::cli::inspect::format_bytes;
use crate::extraction::{CollisionPolicy, ExtractionEngine, ResumeOptions};
use anyhow::Result;
use std::path::PathBuf;

#[allow(clippy::too_many_arguments)]
pub fn run_resume(
    target: &str,
    destination: Option<PathBuf>,
    archive: Option<PathBuf>,
    retry_failed: bool,
    verify_existing: bool,
    collision: Option<CollisionPolicy>,
    reclaim_archive: bool,
    max_total_size: Option<u64>,
    max_file_size: Option<u64>,
    max_entries: Option<usize>,
    json: bool,
    verbose: bool,
    quiet: bool,
) -> Result<()> {
    let collision_policy = collision;

    let options = ResumeOptions {
        destination_override: destination,
        archive_override: archive,
        retry_failed,
        verify_existing,
        collision_policy,
        enable_sparse: true,
        max_compression_ratio: 100.0,
        reclaim_archive,
        verbose,
        quiet: quiet || json,
        max_total_size,
        max_file_size,
        max_entries: max_entries.or(Some(crate::extraction::DEFAULT_MAX_ENTRIES)),
    };

    let summary = ExtractionEngine::resume(target, &options)?;

    if json {
        println!("{}", serde_json::to_string_pretty(&summary)?);
        return Ok(());
    }

    println!("================================================================================");
    println!("                           UNPACKR RESUME COMPLETE                              ");
    println!("================================================================================");
    println!("Job ID:               {}", summary.job_id);
    println!("Archive:              {}", summary.archive_path.display());
    println!("Destination:          {}", summary.destination.display());
    println!("Manifest:             {}", summary.manifest_path.display());
    println!("Total Entries:        {}", summary.total_entries);
    println!("Extracted Files:      {}", summary.extracted_files);
    println!("Created Directories:  {}", summary.created_directories);
    println!("Skipped Files:        {}", summary.skipped_files);
    println!(
        "Data Written:         {}",
        format_bytes(summary.total_uncompressed_bytes)
    );
    if summary.sparse_bytes_saved > 0 {
        println!(
            "Sparse Space Saved:   {}",
            format_bytes(summary.sparse_bytes_saved)
        );
    }
    if summary.reclaimed_archive_bytes > 0 {
        println!(
            "Archive Reclaimed:    {}",
            format_bytes(summary.reclaimed_archive_bytes)
        );
    }
    println!(
        "Peak Disk Footprint:  {}",
        format_bytes(summary.peak_disk_footprint_bytes)
    );
    println!(
        "Throughput:           {:.1} MB/s",
        summary.throughput_mb_per_sec
    );
    println!("Duration:             {:.2?}", summary.duration);
    println!("================================================================================");

    Ok(())
}