From ecfd69bd3778ea69142ca3cf6c5033ebe68e08cf Mon Sep 17 00:00:00 2001
From: tdurieux <durieuxthomas@hotmail.com>
Date: Mon, 28 Aug 2023 14:36:04 +0200
Subject: [PATCH] fix: fix zip extract

---
 package-lock.json | 14 +++++++-------
 package.json      |  2 +-
 src/storage/S3.ts |  7 ++++++-
 3 files changed, 14 insertions(+), 9 deletions(-)

diff --git a/package-lock.json b/package-lock.json
index 932b413..f6283b6 100644
--- a/package-lock.json
+++ b/package-lock.json
@@ -19,7 +19,7 @@
         "bullmq": "^2.3.2",
         "compression": "^1.7.4",
         "connect-redis": "^7.0.1",
-        "decompress-stream-to-s3": "^2.1.0",
+        "decompress-stream-to-s3": "^2.1.1",
         "dotenv": "^16.0.3",
         "express": "^4.18.2",
         "express-rate-limit": "^6.8.0",
@@ -3396,9 +3396,9 @@
       }
     },
     "node_modules/decompress-stream-to-s3": {
-      "version": "2.1.0",
-      "resolved": "https://registry.npmjs.org/decompress-stream-to-s3/-/decompress-stream-to-s3-2.1.0.tgz",
-      "integrity": "sha512-0hhZAGuSvnVdGt4K/BHMuOrpnAl0nzTzMMOsCip+TVHDVi5x4XQZAeQ1OOjYw1QjLFy0A83u4+EFG7uS46DTsw==",
+      "version": "2.1.1",
+      "resolved": "https://registry.npmjs.org/decompress-stream-to-s3/-/decompress-stream-to-s3-2.1.1.tgz",
+      "integrity": "sha512-whIgoOhIFJhn9NDdNBHHyQsN6EumSu7UUoaW94nWrf3JZ2wUdmPOalemCQ20zdxhqzhwKfLDv7AqtxTAzePoxA==",
       "dependencies": {
         "@aws-sdk/client-s3": "^3.374.0",
         "debug": "^4.3.4",
@@ -9169,9 +9169,9 @@
       }
     },
     "decompress-stream-to-s3": {
-      "version": "2.1.0",
-      "resolved": "https://registry.npmjs.org/decompress-stream-to-s3/-/decompress-stream-to-s3-2.1.0.tgz",
-      "integrity": "sha512-0hhZAGuSvnVdGt4K/BHMuOrpnAl0nzTzMMOsCip+TVHDVi5x4XQZAeQ1OOjYw1QjLFy0A83u4+EFG7uS46DTsw==",
+      "version": "2.1.1",
+      "resolved": "https://registry.npmjs.org/decompress-stream-to-s3/-/decompress-stream-to-s3-2.1.1.tgz",
+      "integrity": "sha512-whIgoOhIFJhn9NDdNBHHyQsN6EumSu7UUoaW94nWrf3JZ2wUdmPOalemCQ20zdxhqzhwKfLDv7AqtxTAzePoxA==",
       "requires": {
         "@aws-sdk/client-s3": "^3.374.0",
         "debug": "^4.3.4",
diff --git a/package.json b/package.json
index defbaf0..e63e4c6 100644
--- a/package.json
+++ b/package.json
@@ -40,7 +40,7 @@
     "bullmq": "^2.3.2",
     "compression": "^1.7.4",
     "connect-redis": "^7.0.1",
-    "decompress-stream-to-s3": "^2.1.0",
+    "decompress-stream-to-s3": "^2.1.1",
     "dotenv": "^16.0.3",
     "express": "^4.18.2",
     "express-rate-limit": "^6.8.0",
diff --git a/src/storage/S3.ts b/src/storage/S3.ts
index 21cf615..8df4a83 100644
--- a/src/storage/S3.ts
+++ b/src/storage/S3.ts
@@ -251,7 +251,12 @@ export default class S3Storage implements StorageBase {
         },
         maxParallel: 10,
       });
-      pipeline(data, toS3, () => {})
+      pipeline(data, toS3, (err) => {
+        if (err) {
+          return reject(err);
+        }
+        resolve();
+      })
         .on("finish", resolve)
         .on("error", reject);
     });