feat: Add initial implementation for ogomovies provider

2026-04-17 23:51:44 +00:00 · 2025-10-07 20:22:56 +05:30
parent b5d24d8962
commit 4dbc0ff321
8 changed files with 456 additions and 0 deletions
--- a/providers/ogomovies/stream.ts
+++ b/providers/ogomovies/stream.ts
@@ -0,0 +1,95 @@
+import { ProviderContext, Stream } from "../types";
+
+const headers = {
+  Accept:
+    "text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,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",
+  Cookie:
+    "xla=s4t; _ga=GA1.1.1081149560.1756378968; _ga_BLZGKYN5PF=GS2.1.s1756378968$o1$g1$t1756378984$j44$l0$h0",
+  "Upgrade-Insecure-Requests": "1",
+  "User-Agent":
+    "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/131.0.0.0 Safari/537.36 Edg/131.0.0.0",
+};
+
+export async function getStream({
+  link,
+  type,
+  signal,
+  providerContext,
+}: {
+  link: string;
+  type: string;
+  signal: AbortSignal;
+  providerContext: ProviderContext;
+}) {
+  const { axios, cheerio } = providerContext;
+
+  try {
+    const streamLinks: Stream[] = [];
+
+    // 🔹 Step 1: Load main page
+    const dotlinkRes = await axios(`${link}`, { headers, signal });
+    const dotlinkText = dotlinkRes.data;
+
+    // 🔹 Step 2: Extract button download_video() info
+    const buttonMatches = dotlinkText.matchAll(
+      /download_video\('([^']+)','([^']+)','([^']+)'\)/g
+    );
+
+    for (const match of buttonMatches) {
+      const [, id, mode, hash] = match;
+      const dlUrl = `https://cdn.bewab.co/dl?op=download_orig&id=${id}&mode=${mode}&hash=${hash}`;
+
+      // 🔹 Step 3: Visit dl page and extract only final direct link
+      try {
+        const dlRes = await axios(dlUrl, { headers, signal });
+        const dlText = dlRes.data;
+        const $$ = cheerio.load(dlText);
+
+        // Regex scrape
+        const directMatches = dlText.matchAll(
+          /<a\s+href="([^"]+\.(?:mkv|mp4))"/gi
+        );
+        for (const m of directMatches) {
+          const href = m[1];
+          if (href) {
+            streamLinks.push({
+              server: "direct",
+              link: href,
+              type: href.endsWith(".mp4") ? "mp4" : "mkv",
+            });
+          }
+        }
+
+        // Cheerio fallback
+        $$("a").each((_, el) => {
+          const href = $$(el).attr("href") ?? null;
+          if (href && (href.includes(".mkv") || href.includes(".mp4"))) {
+            streamLinks.push({
+              server: "direct",
+              link: href,
+              type: href.endsWith(".mp4") ? "mp4" : "mkv",
+            });
+          }
+        });
+      } catch (err: any) {
+        console.log("❌ error loading dl page:", err.message);
+      }
+    }
+
+    return streamLinks;
+  } catch (error: any) {
+    console.log("getStream error: ", error.message);
+    return [];
+  }
+}