Fix issue with only first member of a multi-member gz file being ungz…

…ipped (#27) * Fix issue with only first member of a multi-member gz file being ungzipped * change version
coralogix · Jan 16, 2024 · 823fdc6 · 823fdc6
1 parent 7bc20c0
commit 823fdc6
Show file tree

Hide file tree

Showing 5 changed files with 10 additions and 5 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -1,4 +1,9 @@
 # Changelog
+
+## v0.0.8 Beta / 2024-01-16
+### 🧰 Bug fixes 🧰
+- Fix issue with decompression of some gzip files
+
 ## v0.0.7 Beta / 2024-01-08
 ### 🚀 New components 🚀
 - Added support for kinesis Text and Cloudwatch Logs

diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "coralogix-aws-shipper"
-version = "0.0.7"
+version = "0.0.8"
 edition = "2021"
 
 [dependencies]

diff --git a/src/process.rs b/src/process.rs
@@ -3,7 +3,7 @@ use aws_lambda_events::encodings::Base64Data;
 use aws_sdk_s3::Client;
 use cx_sdk_rest_logs::DynLogExporter;
 use fancy_regex::Regex;
-use flate2::read::GzDecoder;
+use flate2::read::MultiGzDecoder;
 use itertools::Itertools;
 use lambda_runtime::Error;
 use std::ffi::OsStr;
@@ -473,7 +473,7 @@ fn ungzip(compressed_data: Vec<u8>, key: String) -> Result<Vec<u8>, Error> {
         tracing::warn!("Input data is empty, cannot ungzip a zero-byte file.");
         return Ok(Vec::new());
     }
-    let mut d = GzDecoder::new(&compressed_data[..]);
+    let mut d = MultiGzDecoder::new(&compressed_data[..]);
     let mut v = Vec::new();
     match d.read_to_end(&mut v) {
         Ok(_) => Ok(v),

diff --git a/template.yaml b/template.yaml
@@ -25,7 +25,7 @@ Metadata:
       - sqs
       - kinesis
     HomePageUrl: https://coralogix.com
-    SemanticVersion: 0.0.7
+    SemanticVersion: 0.0.8
     SourceCodeUrl: https://github.com/coralogix/coralogix-aws-shipper
 
   AWS::CloudFormation::Interface: