feat(oma-fetch,oma-refresh): support lzma and lz4 file download and decompress

Author: eatradish

Cargo.lock

@@ -15,7 +15,7 @@ faster-hex = "0.10"
 sha2 = "0.10"
 futures = "0.3"
 # FIXME: issue https://github.com/AOSC-Dev/oma/issues/547, workaround downgrade to 0.4.27
-async-compression = { version = "=0.4.27", features = ["gzip", "xz", "futures-io", "bzip2", "zstd"] }
+async-compression = { version = "=0.4.27", features = ["gzip", "xz", "futures-io", "bzip2", "zstd", "lz4"] }
 # Note: Use the `uncheck_liblzma_version` feature here to force dynamic linking
 # even with older liblzma (Ubuntu 22.04 uses 5.2.x). Be mindful, however, that
 # async-compression depends on a different liblzma-rs than what is specified here.

oma-fetch/Cargo.toml

@@ -6,7 +6,9 @@ use std::{
     time::Duration,
 };
 
-use async_compression::futures::bufread::{BzDecoder, GzipDecoder, XzDecoder, ZstdDecoder};
+use async_compression::futures::bufread::{
+    BzDecoder, GzipDecoder, Lz4Decoder, LzmaDecoder, XzDecoder, ZstdDecoder,
+};
 use bon::bon;
 use futures::{AsyncRead, TryStreamExt, io::BufReader};
 use reqwest::{
@@ -476,10 +478,10 @@ impl<'a> SingleDownloader<'a> {
             CompressFile::Xz => &mut XzDecoder::new(BufReader::new(bytes_stream)),
             CompressFile::Gzip => &mut GzipDecoder::new(BufReader::new(bytes_stream)),
             CompressFile::Bz2 => &mut BzDecoder::new(BufReader::new(bytes_stream)),
-            CompressFile::Nothing => &mut BufReader::new(bytes_stream),
             CompressFile::Zstd => &mut ZstdDecoder::new(BufReader::new(bytes_stream)),
-            CompressFile::Lzma => unimplemented!(),
-            CompressFile::Lz4 => unimplemented!(),
+            CompressFile::Lzma => &mut LzmaDecoder::new(BufReader::new(bytes_stream)),
+            CompressFile::Lz4 => &mut Lz4Decoder::new(BufReader::new(bytes_stream)),
+            CompressFile::Nothing => &mut BufReader::new(bytes_stream),
         };
 
         let mut reader = reader.compat();
@@ -634,10 +636,10 @@ impl<'a> SingleDownloader<'a> {
             CompressFile::Xz => &mut XzDecoder::new(BufReader::new(from)),
             CompressFile::Gzip => &mut GzipDecoder::new(BufReader::new(from)),
             CompressFile::Bz2 => &mut BzDecoder::new(BufReader::new(from)),
-            CompressFile::Nothing => &mut BufReader::new(from),
             CompressFile::Zstd => &mut ZstdDecoder::new(BufReader::new(from)),
-            CompressFile::Lzma => unimplemented!(),
-            CompressFile::Lz4 => unimplemented!(),
+            CompressFile::Lzma => &mut LzmaDecoder::new(BufReader::new(from)),
+            CompressFile::Lz4 => &mut Lz4Decoder::new(BufReader::new(from)),
+            CompressFile::Nothing => &mut BufReader::new(from),
         };
 
         let mut reader = reader.compat();

oma-fetch/src/download.rs

@@ -878,6 +878,8 @@ fn collect_download_task(
                     Some("xz") => CompressFile::Xz,
                     Some("bz2") => CompressFile::Bz2,
                     Some("zst") => CompressFile::Zstd,
+                    Some("lzma") => CompressFile::Lzma,
+                    Some("lz4") => CompressFile::Lz4,
                     _ => CompressFile::Nothing,
                 }
             }