renaming

providers/uhd/stream.ts

@@ -0,0 +1,209 @@
+import { ProviderContext, Stream } from "../types";
+
+const headers = {
+  Accept:
+    "text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,image/apng,*/*;q=0.8,application/signed-exchange;v=b3;q=0.7",
+  "Cache-Control": "no-store",
+  "Accept-Language": "en-US,en;q=0.9",
+  DNT: "1",
+  "sec-ch-ua":
+    '"Not_A Brand";v="8", "Chromium";v="120", "Microsoft Edge";v="120"',
+  "sec-ch-ua-mobile": "?0",
+  "sec-ch-ua-platform": '"Windows"',
+  "Sec-Fetch-Dest": "document",
+  "Sec-Fetch-Mode": "navigate",
+  "Sec-Fetch-Site": "none",
+  "Sec-Fetch-User": "?1",
+  "Upgrade-Insecure-Requests": "1",
+  "User-Agent":
+    "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36 Edg/120.0.0.0",
+};
+
+export const getStream = async ({
+  link: url,
+  providerContext,
+}: {
+  link: string;
+  providerContext: ProviderContext;
+}): Promise<Stream[]> => {
+  try {
+    const { axios, cheerio } = providerContext;
+    let downloadLink = await modExtractor(url, providerContext);
+
+    // console.log(downloadLink.data);
+
+    const ddl = downloadLink?.data?.match(/content="0;url=(.*?)"/)?.[1] || url;
+
+    console.log("ddl", ddl);
+    // console.log(ddl);
+    const driveLink = await isDriveLink(ddl);
+    const ServerLinks: Stream[] = [];
+
+    const driveRes = await axios.get(driveLink, { headers });
+    const driveHtml = driveRes.data;
+    const $drive = cheerio.load(driveHtml);
+    //instant link
+    try {
+      const seed = $drive(".btn-danger").attr("href") || "";
+      const instantToken = seed.split("=")[1];
+      //   console.log('InstantToken', instantToken);
+      const InstantFromData = new FormData();
+      InstantFromData.append("keys", instantToken);
+      const videoSeedUrl = seed.split("/").slice(0, 3).join("/") + "/api";
+      //   console.log('videoSeedUrl', videoSeedUrl);
+      const instantLinkRes = await fetch(videoSeedUrl, {
+        method: "POST",
+        body: InstantFromData,
+        headers: {
+          "x-token": videoSeedUrl,
+        },
+      });
+      const instantLinkData = await instantLinkRes.json();
+      //   console.log('instantLinkData', instantLinkData);
+      if (instantLinkData.error === false) {
+        const instantLink = instantLinkData.url;
+        ServerLinks.push({
+          server: "Gdrive-Instant",
+          link: instantLink,
+          type: "mkv",
+        });
+      } else {
+        console.log("Instant link not found", instantLinkData);
+      }
+    } catch (err) {
+      console.log("Instant link not found", err);
+    }
+
+    // resume link
+    try {
+      const resumeDrive = driveLink.replace("/file", "/zfile");
+      //   console.log('resumeDrive', resumeDrive);
+      const resumeDriveRes = await axios.get(resumeDrive, { headers });
+      const resumeDriveHtml = resumeDriveRes.data;
+      const $resumeDrive = cheerio.load(resumeDriveHtml);
+      const resumeLink = $resumeDrive(".btn-success").attr("href");
+      //   console.log('resumeLink', resumeLink);
+      if (resumeLink) {
+        ServerLinks.push({
+          server: "ResumeCloud",
+          link: resumeLink,
+          type: "mkv",
+        });
+      }
+    } catch (err) {
+      console.log("Resume link not found");
+    }
+
+    // CF workers type 1
+    try {
+      const cfWorkersLink = driveLink.replace("/file", "/wfile") + "?type=1";
+      const cfWorkersRes = await axios.get(cfWorkersLink, { headers });
+      const cfWorkersHtml = cfWorkersRes.data;
+      const $cfWorkers = cheerio.load(cfWorkersHtml);
+      const cfWorkersStream = $cfWorkers(".btn-success");
+      cfWorkersStream.each((i, el) => {
+        const link = (el as any).attribs?.href;
+        if (link) {
+          ServerLinks.push({
+            server: "Cf Worker 1." + i,
+            link: link,
+            type: "mkv",
+          });
+        }
+      });
+    } catch (err) {
+      console.log("CF workers link not found", err);
+    }
+
+    // CF workers type 2
+    try {
+      const cfWorkersLink = driveLink.replace("/file", "/wfile") + "?type=2";
+      const cfWorkersRes = await axios.get(cfWorkersLink, { headers });
+      const cfWorkersHtml = cfWorkersRes.data;
+      const $cfWorkers = cheerio.load(cfWorkersHtml);
+      const cfWorkersStream = $cfWorkers(".btn-success");
+      cfWorkersStream.each((i, el) => {
+        const link = (el as any).attribs?.href;
+        if (link) {
+          ServerLinks.push({
+            server: "Cf Worker 2." + i,
+            link: link,
+            type: "mkv",
+          });
+        }
+      });
+    } catch (err) {
+      console.log("CF workers link not found", err);
+    }
+
+    console.log("ServerLinks", ServerLinks);
+    return ServerLinks;
+  } catch (err) {
+    console.log("getStream error", err);
+    return [];
+  }
+};
+
+const isDriveLink = async (ddl: string) => {
+  if (ddl.includes("drive")) {
+    const driveLeach = await fetch(ddl);
+    const driveLeachData = await driveLeach.text();
+    const pathMatch = driveLeachData.match(
+      /window\.location\.replace\("([^"]+)"\)/
+    );
+    const path = pathMatch?.[1];
+    const mainUrl = ddl.split("/")[2];
+    console.log(`driveUrl = https://${mainUrl}${path}`);
+    return `https://${mainUrl}${path}`;
+  } else {
+    return ddl;
+  }
+};
+
+async function modExtractor(url: string, providerContext: ProviderContext) {
+  const { axios, cheerio } = providerContext;
+  try {
+    const wpHttp = url.split("sid=")[1];
+    var bodyFormData0 = new FormData();
+    bodyFormData0.append("_wp_http", wpHttp);
+    const res = await fetch(url.split("?")[0], {
+      method: "POST",
+      body: bodyFormData0,
+    });
+    const data = await res.text();
+    // console.log('', data);
+    const html = data;
+    const $ = cheerio.load(html);
+
+    // find input with name="_wp_http2"
+    const wpHttp2 = $("input").attr("name", "_wp_http2").val();
+
+    // console.log('wpHttp2', wpHttp2);
+
+    // form data
+    var bodyFormData = new FormData();
+    bodyFormData.append("_wp_http2", wpHttp2);
+    const formUrl1 = $("form").attr("action");
+    const formUrl = formUrl1 || url.split("?")[0];
+
+    const res2 = await fetch(formUrl, {
+      method: "POST",
+      body: bodyFormData,
+    });
+    const html2: any = await res2.text();
+    const link = html2.match(/setAttribute\("href",\s*"(.*?)"/)[1];
+    console.log(link);
+    const cookie = link.split("=")[1];
+    console.log("cookie", cookie);
+
+    const downloadLink = await axios.get(link, {
+      headers: {
+        Referer: formUrl,
+        Cookie: `${cookie}=${wpHttp2}`,
+      },
+    });
+    return downloadLink;
+  } catch (err) {
+    console.log("modGetStream error", err);
+  }
+}