explicitly close Stream

apps/app/src/server/service/export.js

@@ -375,7 +375,10 @@ class ExportService {
     const output = fs.createWriteStream(zipFile);
 
     // pipe archive data to the file
-    archive.pipe(output);
+    archive
+      .on('error', () => { output.end() })
+      .pipe(output)
+      .on('error', () => { archive.destroy() });
 
     // finalize the archive (ie we are done appending files but streams have to finish yet)
     // 'close', 'end' or 'finish' may be fired right after calling this method so register to them beforehand

apps/app/src/server/service/search-delegator/elasticsearch.ts

@@ -554,11 +554,31 @@ class ElasticsearchDelegator implements SearchDelegator<Data, ESTermsKey, ESQuer
     });
 
     readStream
+      .on('error', () => {
+        batchStream.end();
+        appendTagNamesStream.end();
+        writeStream.end();
+      })
       .pipe(batchStream)
+      .on('error', () => {
+        readStream.destroy();
+        appendTagNamesStream.end();
+        writeStream.end();
+      })
       .pipe(appendTagNamesStream)
+      .on('error', () => {
+        readStream.destroy();
+        batchStream.destroy();
+        writeStream.end();
+      })
       // .pipe(appendEmbeddingStream)
       // .pipe(appendFileUploadedStream)
-      .pipe(writeStream);
+      .pipe(writeStream)
+      .on('error', () => {
+        readStream.destroy();
+        batchStream.destroy();
+        appendTagNamesStream.destroy();
+      });
 
     return streamToPromise(writeStream);
   }