Add zstd:chunked support

Fixes: ostreedev#608
travier · Mar 27, 2024 · da485da · da485da
1 parent 8d972c1
commit da485da
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/lib/Cargo.toml b/lib/Cargo.toml
@@ -12,7 +12,7 @@ rust-version = "1.74.0"
 [dependencies]
 anyhow = "1.0"
 containers-image-proxy = "0.5.5"
-async-compression = { version = "0.4", features = ["gzip", "tokio"] }
+async-compression = { version = "0.4", features = ["gzip", "tokio", "zstd"] }
 camino = "1.0.4"
 chrono = "0.4.19"
 olpc-cjson = "0.1.1"

diff --git a/lib/src/container/unencapsulate.rs b/lib/src/container/unencapsulate.rs
@@ -198,6 +198,9 @@ fn new_async_decompressor<'a>(
         oci_image::MediaType::ImageLayerGzip => Ok(Box::new(tokio::io::BufReader::new(
             async_compression::tokio::bufread::GzipDecoder::new(src),
         ))),
+        oci_image::MediaType::ImageLayerZstd => Ok(Box::new(tokio::io::BufReader::new(
+            async_compression::tokio::bufread::ZstdDecoder::new(src),
+        ))),
         oci_image::MediaType::ImageLayer => Ok(Box::new(src)),
         oci_image::MediaType::Other(t) if t.as_str() == DOCKER_TYPE_LAYER_TAR => Ok(Box::new(src)),
         o => Err(anyhow::anyhow!("Unhandled layer type: {}", o)),