improve stream end detect

Last-Order · Jan 25, 2022 · 7f16913 · 7f16913
1 parent 18b4625
commit 7f16913
Show file tree

Hide file tree

Showing 4 changed files with 9 additions and 6 deletions.
diff --git a/npm-shrinkwrap.json b/npm-shrinkwrap.json
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
     "name": "minyami",
-    "version": "4.4.14",
+    "version": "4.5.0",
     "description": "",
     "main": "dist/exports.js",
     "types": "dist/exports.d.ts",

diff --git a/src/core/archive.ts b/src/core/archive.ts
@@ -81,7 +81,6 @@ class ArchiveDownloader extends Downloader {
      */
     async parse() {
         // parse m3u8
-        console.log(this.m3u8);
         if (this.m3u8.encryptKeys.length > 0) {
             // Encrypted
             const key = this.m3u8.encryptKeys[0];

diff --git a/src/core/live.ts b/src/core/live.ts
@@ -60,8 +60,12 @@ export default class LiveDownloader extends Downloader {
             this.m3u8 = (await loadM3U8(this.m3u8Path, this.retries, this.timeout)) as Playlist;
         } catch (e) {
             if (this.finishedChunkCount > 0) {
-                // Stop downloading
-                this.isEnd = true;
+                const responseStatus = e?.response?.status;
+                if (!!responseStatus && responseStatus >= 400 && responseStatus <= 599) {
+                    logger.info("M3U8 file is no longer available. Stop downloading.");
+                    // Stop downloading
+                    this.isEnd = true;
+                }
             } else {
                 logger.error("Aborted due to critical error.", e);
                 this.emit("critical-error", e);