switch from lz4_flex to lzzzz, enable lz4 tests

Cargo.toml

@@ -21,7 +21,7 @@ walkdir     = "2.3.2"
 bzip2       = "0.4.3"
 libc        = "0.2.103"
 tar         = "0.4.37"
-lz4_flex    = "0.9.0"
+lzzzz       = "0.8.0"
 xz2         = "0.1.6"
 zip         = { version =  "0.5.13", default-features = false, features = ["deflate-miniz"] }
 flate2      = { version = "1.0.22", default-features = false, features = ["zlib"] }

src/commands.rs

@@ -253,11 +253,11 @@ fn compress_files(files: Vec<PathBuf>, formats: Vec<Extension>, output_file: fs:
     let mut writer: Box<dyn Write> = Box::new(file_writer);
 
     // Grab previous encoder and wrap it inside of a new one
-    let chain_writer_encoder = |format: &CompressionFormat, encoder: Box<dyn Write>| {
+    let chain_writer_encoder = |format: &CompressionFormat, encoder: Box<dyn Write>| -> crate::Result<Box<dyn Write>> {
         let encoder: Box<dyn Write> = match format {
             Gzip => Box::new(flate2::write::GzEncoder::new(encoder, Default::default())),
             Bzip => Box::new(bzip2::write::BzEncoder::new(encoder, Default::default())),
-            Lz4 => Box::new(lz4_flex::frame::FrameEncoder::new(encoder)),
+            Lz4 => Box::new(lzzzz::lz4f::WriteCompressor::new(encoder, Default::default())?),
             Lzma => Box::new(xz2::write::XzEncoder::new(encoder, 6)),
             Zstd => {
                 let zstd_encoder = zstd::stream::write::Encoder::new(encoder, Default::default());
@@ -268,16 +268,16 @@ fn compress_files(files: Vec<PathBuf>, formats: Vec<Extension>, output_file: fs:
             }
             Tar | Zip => unreachable!(),
         };
-        encoder
+        Ok(encoder)
     };
 
     for format in formats.iter().flat_map(Extension::iter).skip(1).collect::<Vec<_>>().iter().rev() {
-        writer = chain_writer_encoder(format, writer);
+        writer = chain_writer_encoder(format, writer)?;
     }
 
     match formats[0].compression_formats[0] {
         Gzip | Bzip | Lz4 | Lzma | Zstd => {
-            writer = chain_writer_encoder(&formats[0].compression_formats[0], writer);
+            writer = chain_writer_encoder(&formats[0].compression_formats[0], writer)?;
             let mut reader = fs::File::open(&files[0]).unwrap();
             io::copy(&mut reader, &mut writer)?;
         }
@@ -352,7 +352,7 @@ fn decompress_file(
         let decoder: Box<dyn Read> = match format {
             Gzip => Box::new(flate2::read::GzDecoder::new(decoder)),
             Bzip => Box::new(bzip2::read::BzDecoder::new(decoder)),
-            Lz4 => Box::new(lz4_flex::frame::FrameDecoder::new(decoder)),
+            Lz4 => Box::new(lzzzz::lz4f::ReadDecompressor::new(decoder)?),
             Lzma => Box::new(xz2::read::XzDecoder::new(decoder)),
             Zstd => Box::new(zstd::stream::Decoder::new(decoder)?),
             Tar | Zip => unreachable!(),
@@ -440,7 +440,7 @@ fn list_archive_contents(
         let decoder: Box<dyn Read> = match format {
             Gzip => Box::new(flate2::read::GzDecoder::new(decoder)),
             Bzip => Box::new(bzip2::read::BzDecoder::new(decoder)),
-            Lz4 => Box::new(lz4_flex::frame::FrameDecoder::new(decoder)),
+            Lz4 => Box::new(lzzzz::lz4f::ReadDecompressor::new(decoder)?),
             Lzma => Box::new(xz2::read::XzDecoder::new(decoder)),
             Zstd => Box::new(zstd::stream::Decoder::new(decoder)?),
             Tar | Zip => unreachable!(),

src/error.rs

@@ -12,6 +12,8 @@ use crate::utils::colors::*;
 pub enum Error {
     /// Not every IoError, some of them get filtered by `From<io::Error>` into other variants
     IoError { reason: String },
+    /// From lzzzz::lz4f::Error
+    Lz4Error { reason: String },
     /// Detected from io::Error if .kind() is io::ErrorKind::NotFound
     NotFound { error_title: String },
     /// NEEDS MORE CONTEXT
@@ -97,6 +99,7 @@ impl fmt::Display for Error {
                     .hint("Use a more appropriate tool for this, such as rsync.")
             }
             Error::IoError { reason } => FinalError::with_title(reason),
+            Error::Lz4Error { reason } => FinalError::with_title(reason),
             Error::AlreadyExists { error_title } => FinalError::with_title(error_title).detail("File already exists"),
             Error::InvalidZipArchive(reason) => FinalError::with_title("Invalid zip archive").detail(reason),
             Error::PermissionDenied { error_title } => FinalError::with_title(error_title).detail("Permission denied"),
@@ -119,6 +122,12 @@ impl From<std::io::Error> for Error {
     }
 }
 
+impl From<lzzzz::lz4f::Error> for Error {
+    fn from(err: lzzzz::lz4f::Error) -> Self {
+        Self::Lz4Error { reason: err.to_string() }
+    }
+}
+
 impl From<zip::result::ZipError> for Error {
     fn from(err: zip::result::ZipError) -> Self {
         use zip::result::ZipError;

tests/integration.rs

@@ -33,7 +33,7 @@ enum FileExtension {
     Bz,
     Bz2,
     Gz,
-    // Lz4, // broken
+    Lz4,
     Lz,
     Lzma,
     Xz,