fix gogo source crashing on mp4

consumet · Oct 15, 2022 · a2ccabe · a2ccabe
1 parent f52756d
commit a2ccabe
Show file tree

Hide file tree

Showing 7 changed files with 70 additions and 42 deletions.
diff --git a/dist/providers/anime/gogoanime.js b/dist/providers/anime/gogoanime.js
diff --git a/dist/providers/anime/gogoanime.js.map b/dist/providers/anime/gogoanime.js.map
diff --git a/dist/utils/extractors/gogocdn.js b/dist/utils/extractors/gogocdn.js
diff --git a/dist/utils/extractors/gogocdn.js.map b/dist/utils/extractors/gogocdn.js.map
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
     "name": "@consumet/extensions",
-    "version": "1.1.7",
+    "version": "1.1.8",
     "description": "Nodejs library that provides high-level APIs for obtaining information on various entertainment media such as books, movies, comic books, anime, manga, and so on.",
     "main": "dist/index.js",
     "types": "dist/index.d.ts",

diff --git a/src/providers/anime/gogoanime.ts b/src/providers/anime/gogoanime.ts
@@ -320,4 +320,10 @@ class Gogoanime extends AnimeParser {
   };
 }
 
+// (async () => {
+//   const anime = new Gogoanime();
+//   const animeInfo = await anime.fetchEpisodeSources('juuni-taisen-dub-episode-6', StreamingServers.GogoCDN);
+//   console.log(animeInfo);
+// })();
+
 export default Gogoanime;
diff --git a/src/utils/extractors/gogocdn.ts b/src/utils/extractors/gogocdn.ts
@@ -37,33 +37,41 @@ class GogoCDN extends VideoExtractor {
     const decryptedData = await this.decryptAjaxData(encryptedData.data.data);
     if (!decryptedData.source) throw new Error('No source found. Try a different server.');
 
-    //console.log(decryptedData);
-
-    const resResult = await axios.get(decryptedData.source[0].file.toString());
-    const resolutions = resResult.data.match(/(RESOLUTION=)(.*)(\s*?)(\s*.*)/g);
-    resolutions.forEach((res: string) => {
-      var index = decryptedData.source[0].file.lastIndexOf('/');
-      var quality = res.split('\n')[0].split('x')[1].split(',')[0];
-      var url = decryptedData.source[0].file.slice(0, index);
-      this.sources.push({
-        url: url + '/' + res.split('\n')[1],
-        isM3U8: (url + res.split('\n')[1]).includes('.m3u8'),
-        quality: quality + 'p',
+    if (decryptedData.source[0].file.includes('.m3u8')) {
+      const resResult = await axios.get(decryptedData.source[0].file.toString());
+      const resolutions = resResult.data.match(/(RESOLUTION=)(.*)(\s*?)(\s*.*)/g);
+      resolutions.forEach((res: string) => {
+        var index = decryptedData.source[0].file.lastIndexOf('/');
+        var quality = res.split('\n')[0].split('x')[1].split(',')[0];
+        var url = decryptedData.source[0].file.slice(0, index);
+        this.sources.push({
+          url: url + '/' + res.split('\n')[1],
+          isM3U8: (url + res.split('\n')[1]).includes('.m3u8'),
+          quality: quality + 'p',
+        });
       });
-    });
 
-    decryptedData.source.forEach((source: any) => {
-      this.sources.push({
-        url: source.file,
-        isM3U8: source.file.includes('.m3u8'),
-        quality: 'default'
+      decryptedData.source.forEach((source: any) => {
+        this.sources.push({
+          url: source.file,
+          isM3U8: source.file.includes('.m3u8'),
+          quality: 'default',
+        });
       });
-    });
+    } else
+      decryptedData.source.forEach((source: any) => {
+        this.sources.push({
+          url: source.file,
+          isM3U8: source.file.includes('.m3u8'),
+          quality: source.label.split(' ')[0] + 'p',
+        });
+      });
+
     decryptedData.source_bk.forEach((source: any) => {
       this.sources.push({
         url: source.file,
         isM3U8: source.file.includes('.m3u8'),
-        quality: 'backup'
+        quality: 'backup',
       });
     });