added fallback streams to prevent null streaminglink

Author: cryshin22

src/extractors/streamInfo.extractor.js

@@ -53,6 +53,7 @@ async function extractStreamingInfo(id, name, type) {
       );
     }
     const streamingLink = await decryptSources_v1(
+      id,
       requestedServer[0].data_id,
       name,
       type

src/parsers/decryptors/decrypt_v1.decryptor.js

@@ -1,13 +1,14 @@
 import axios from "axios";
 import CryptoJS from "crypto-js";
 import { v1_base_url } from "../../utils/base_v1.js";
+import { fallback_1, fallback_2 } from "../../utils/fallback.js";
 
-export async function decryptSources_v1(id, name, type) {
+export async function decryptSources_v1(epID, id, name, type) {
   try {
     const [{ data: sourcesData }, { data: key }] = await Promise.all([
       axios.get(`https://${v1_base_url}/ajax/v2/episode/sources?id=${id}`),
       axios.get(
-        "https://raw.githubusercontent.com/itzzzme/megacloud-keys/refs/heads/main/key.txt"
+        "https://raw.githubusercontent.com/itzzzme/megacloud-keys/refs/heads/main/key.txt",
       ),
     ]);
 
@@ -19,21 +20,51 @@ export async function decryptSources_v1(id, name, type) {
     if (!sourceId) throw new Error("Unable to extract sourceId from link");
 
     const { data: rawSourceData } = await axios.get(
-      `https://megacloud.blog/embed-2/v2/e-1/getSources?id=${sourceId}`
+      `https://megacloud.blog/embed-2/v3/e-1/getSources?id=${sourceId}`,
     );
-    const encrypted = rawSourceData?.sources;
-    if (!encrypted) throw new Error("Encrypted source missing in response");
-    const decrypted = CryptoJS.AES.decrypt(encrypted, key.trim()).toString(
-      CryptoJS.enc.Utf8
-    );
-    if (!decrypted) throw new Error("Failed to decrypt source");
 
     let decryptedSources;
+
     try {
+      const encrypted = rawSourceData?.sources;
+      if (!encrypted) throw new Error("Encrypted source missing");
+
+      const decrypted = CryptoJS.AES.decrypt(encrypted, key.trim()).toString(
+        CryptoJS.enc.Utf8,
+      );
+      if (!decrypted) throw new Error("Failed to decrypt source");
+
       decryptedSources = JSON.parse(decrypted);
     } catch (e) {
-      throw new Error("Decrypted data is not valid JSON");
+      try {
+        const fallback = name.toLowerCase()==='hd-1'?fallback_1:fallback_2;
+        const { data: html } = await axios.get(
+          `https://${fallback}/stream/s-2/${epID}/${type}`,
+          {
+            headers: {
+              Referer: `https://${fallback_1}/`,
+            },
+          },
+        );
+        const dataIdMatch = html.match(/data-id=["'](\d+)["']/);
+        const realId = dataIdMatch?.[1];
+        if (!realId) throw new Error("Could not extract data-id for fallback");
+
+        const { data: fallback_data } = await axios.get(
+          `https://${fallback}/stream/getSources?id=${realId}`,
+          {
+            headers: {
+              "X-Requested-With": "XMLHttpRequest",
+            },
+          },
+        );
+
+        decryptedSources = [{ file: fallback_data.sources.file }];
+      } catch (fallbackError) {
+        throw new Error("Fallback failed: " + fallbackError.message);
+      }
     }
+
     return {
       id,
       type,

src/utils/base_v1.js

@@ -1 +1 @@
-export const v1_base_url = "hianimez.to";
+export const v1_base_url = "hianime.to";

src/utils/fallback.js

@@ -0,0 +1,2 @@
+export const fallback_1="megaplay.buzz"
+export const fallback_2="vidwish.live"