zopfli 0.8.3

A Rust implementation of the Zopfli compression algorithm.
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

use std::{
    env,
    fs::File,
    io::{self, prelude::*},
};

#[cfg(feature = "std")]
use log::info;

fn main() {
    let options = zopfli::Options::default();
    let output_type = zopfli::Format::Gzip;

    // TODO: CLI arguments
    // TODO: Allow specifying output to STDOUT

    let extension = match output_type {
        zopfli::Format::Gzip => ".gz",
        zopfli::Format::Zlib => ".zlib",
        zopfli::Format::Deflate => ".deflate",
    };

    for filename in env::args().skip(1) {
        let file =
            File::open(&filename).unwrap_or_else(|why| panic!("couldn't open {filename}: {why}"));
        let filesize = file.metadata().map(|x| x.len()).unwrap() as usize;

        let out_filename = format!("{filename}{extension}");

        // Attempt to create the output file, panic if the output file could not be opened
        let out_file = File::create(&out_filename)
            .unwrap_or_else(|why| panic!("couldn't create output file {out_filename}: {why}"));
        let mut out_file = WriteStatistics::new(out_file);

        zopfli::compress(options, output_type, &file, &mut out_file)
            .unwrap_or_else(|why| panic!("couldn't write to output file {out_filename}: {why}"));

        let out_size = out_file.count;
        info!(
            "Original Size: {}, Compressed: {}, Compression: {}% Removed",
            filesize,
            out_size,
            100.0 * (filesize - out_size) as f64 / filesize as f64
        );
    }
}

struct WriteStatistics<W> {
    inner: W,
    count: usize,
}

impl<W> WriteStatistics<W> {
    const fn new(inner: W) -> Self {
        Self { inner, count: 0 }
    }
}

impl<W: Write> Write for WriteStatistics<W> {
    fn write(&mut self, buf: &[u8]) -> io::Result<usize> {
        let res = self.inner.write(buf);
        if let Ok(size) = res {
            self.count += size;
        }
        res
    }

    fn flush(&mut self) -> io::Result<()> {
        self.inner.flush()
    }
}