✔ Destroy & Reject

bifeldy · Oct 12, 2023 · 0bb8c86 · 0bb8c86
1 parent 36fca5d
commit 0bb8c86
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 2 deletions.
diff --git a/dist/fansubid/server/main.js b/dist/fansubid/server/main.js
diff --git a/src/api/scheduler/upload-task.service.ts b/src/api/scheduler/upload-task.service.ts
@@ -90,7 +90,6 @@ export class UploadService {
     if (fIdx >= 0) {
       if (attachment.ext === 'mkv') {
         try {
-          this.gs.log('[FILE_SUBTITLE_FONT-EXTRACT_MULAI] 🎼', attachment.name, 'error');
           const extractedFiles = await this.mkv.mkvExtract(attachment.name, `${environment.uploadFolder}/${files[fIdx].name}`);
           for (const ef of extractedFiles) {
             const fileNameExt = ef.name.split('.');

diff --git a/src/api/services/mkv-extract.service.ts b/src/api/services/mkv-extract.service.ts
@@ -81,6 +81,7 @@ export class MkvExtractService {
 
       decoder.on('error', error => {
         this.gs.log(`[MKVEXTRACT_DECODER_ERROR] 🌋 ${fileName} 🧬`, error, 'error');
+        decoder.destroy(error);
         fileStream.destroy(error);
         reject(error);
       });
@@ -90,6 +91,7 @@ export class MkvExtractService {
         switch (chunk[0]) {
           case 'end':
             // if (chunk[1].name === 'Info') {
+            //   decoder.destroy();
             //   fileStream.destroy();
             // }
             if (chunk[1].name === 'TrackEntry') {
@@ -103,6 +105,7 @@ export class MkvExtractService {
           case 'tag':
             if (chunk[1].name === 'unknown') {
               const error = new Error('Unknown File Tag!');
+              decoder.destroy(error);
               fileStream.destroy(error);
               reject(error);
             }