Update server.js

server.js

@@ -1,7 +1,7 @@
+// server.js (Final Version - 1-to-1 Replication of the working Puppeteer code - COMPLETE AND UNABRIDGED)
 
 import express, { json } from "express";
 import cors from "cors";
-import { chromium } from "playwright";
 import pLimit from "p-limit";
 import BrowserPool from './pool/BrowserPool.js';
 import { LRUCache } from 'lru-cache';
@@ -9,112 +9,185 @@ import fetch from 'node-fetch';
 import { JSDOM } from 'jsdom';
 import fs from 'fs/promises';
 
+// [REPLICATION] 1. 深度伪装: 使用 playwright-extra 和 stealth 插件
+import playwright from 'playwright-extra';
+import StealthPlugin from 'puppeteer-extra-plugin-stealth';
+playwright.chromium.use(StealthPlugin());
+
+
 const app = express();
-const PORT = process.env.PORT || 3000;
+const PORT = process.env.PORT || 7860;
 app.use(cors());
 app.use(json());
 
-//const PROVIDERS = ["https://vidsrc.xyz", "https://vidsrc.in", "https://vidsrc.pm", "https://vidsrc.net", "https://vidsrc.io", "https://vidsrc.vc"];
-const PROVIDERS = ["https://cdn.moviesapi.club"];
+const PROVIDERS = ["https://cdn.moviesapi.club", "https://vidsrc.xyz", "https://vidsrc.in"];
 let browserPool;
 const cache = new LRUCache({ max: 500, ttl: 15 * 60 * 1000 });
 const limit = pLimit(2);
 
-// --- 辅助函数 ---
+
+// --- 辅助函数 (直接从您的工作代码翻译) ---
+
+// [REPLICATION] 2. 精确打击: 100% 复制您的 handleSpecificTurnstile 逻辑
+async function handleSpecificTurnstile(page, domain) {
+    try {
+        const turnstileExists = await page.evaluate(() => {
+            return !!document.querySelector('.cf-turnstile[data-sitekey="0x4AAAAAABNpWSLmOnUi7s0b"]');
+        });
+
+        if (!turnstileExists) {
+            console.log(`[${domain}] Specific Turnstile not detected`);
+            return;
+        }
+
+        console.log(`[${domain}] Specific Turnstile detected - bypassing...`);
+        await page.locator('.cf-turnstile').waitFor({ state: 'visible', timeout: 10000 });
+
+        await page.evaluate(() => {
+            if (typeof window.cftCallback === 'function') {
+                const mockToken = 'mock-token-' + Math.random().toString(36).substring(2);
+                window.cftCallback(mockToken);
+            }
+        });
+        
+        // 等待网络空闲以确认挑战已处理
+        await page.waitForLoadState('networkidle', { timeout: 30000 });
+        console.log(`[${domain}] Turnstile bypass completed`);
+
+    } catch (error) {
+        console.warn(`[${domain}] Turnstile bypass warning: ${error.message}`);
+    }
+}
+
+async function extractFirstIframeSrc(page, domain) {
+    try {
+        const iframeLocator = page.locator('#player_iframe');
+        await iframeLocator.waitFor({ state: 'visible', timeout: 15000 });
+        let src = await iframeLocator.getAttribute('src');
+        if (src && src.startsWith('//')) {
+            src = `https:${src}`;
+        }
+        return src;
+    } catch (error) {
+        console.error(`[${domain}] Error finding first iframe:`, error);
+        return null;
+    }
+}
+
+async function extractFinalIframeSrc(page, domain) {
+    try {
+        await page.waitForFunction(() => document.querySelectorAll('script, iframe').length > 0, null, { timeout: 15000 });
+        return await page.evaluate(() => {
+            const iframe = document.querySelector('iframe:not([style*="display:none"])');
+            if (iframe?.src) return iframe.src;
+            const scripts = Array.from(document.querySelectorAll('script'));
+            for (const script of scripts) {
+                if (!script.textContent) continue;
+                if (script.textContent.includes('loadIframe')) {
+                    const srcMatch = script.textContent.match(/src:\s*['"](.*?)['"]/);
+                    if (srcMatch) return new URL(srcMatch[1], window.location.href).href;
+                }
+            }
+            return null;
+        });
+    } catch (error) {
+        console.error(`[${domain}] Error finding final iframe:`, error);
+        return null;
+    }
+}
+
 async function getVideoAndSubtitles(finalUrl) {
     try {
         const response = await fetch(finalUrl);
-        if (!response.ok) throw new Error(`HTTP error! Status: ${response.status}`);
+        if (!response.ok) { throw new Error(`HTTP error! Status: ${response.status}`); }
         const html = await response.text();
         const dom = new JSDOM(html);
-        const script = Array.from(dom.window.document.querySelectorAll('script')).find(s => s.textContent?.includes('new Playerjs'));
-        if (!script) return { hlsUrl: null, subtitles: [] };
-        const fileMatch = script.textContent.match(/file:"(.*?m3u8.*?)"/);
-        const subtitlesMatch = script.textContent.match(/subtitle:"(.*?)"/);
-        return {
-            hlsUrl: fileMatch ? fileMatch[1] : null,
-            subtitles: subtitlesMatch ? subtitlesMatch[1].split(',').map(s => s.trim()).filter(Boolean) : []
-        };
+        const document = dom.window.document;
+        const scriptTags = document.querySelectorAll('script');
+        let videoFileUrl = null;
+        let subtitleSources = null;
+        for (const script of scriptTags) {
+            if (script.textContent.includes('new Playerjs({')) {
+                const fileMatch = script.textContent.match(/file:"(.*?m3u8.*?)"/);
+                if (fileMatch && fileMatch[1]) { videoFileUrl = fileMatch[1]; }
+                const subtitlesMatch = script.textContent.match(/subtitle:"(.*?)"/);
+                if (subtitlesMatch && subtitlesMatch[1]) {
+                    try {
+                        subtitleSources = JSON.parse(subtitlesMatch[1].replace(/"/g, '"'));
+                    } catch (e) {
+                        subtitleSources = subtitlesMatch[1].split(',').map(s => s.trim()).filter(Boolean);
+                    }
+                }
+                if (videoFileUrl) { break; }
+            }
+        }
+        return { videoFileUrl, subtitleSources };
     } catch (error) {
-        console.error('Error in getVideoAndSubtitles:', error);
+        console.error('An error occurred during the process:', error);
         throw error;
     }
 }
 
 
-// --- 核心抓取逻辑 ---
+// --- 核心抓取逻辑: 100% 复刻成功模式 ---
 async function scrapeProvider(domain, url, signal) {
   if (signal.aborted) throw new Error('Aborted');
-  console.log(`\n[${domain}] Starting CORRECTED scrape for URL: ${url}`);
+  console.log(`\n[${domain}] Starting REPLICATED scrape for URL: ${url}`);
+
+  let browserInstance = null;
+  let context = null;
 
-  let browserInstance = null, context = null, page = null;
   const cleanup = async () => {
-      if (page && !page.isClosed()) await page.close().catch(()=>{});
       if (context) await context.close().catch(()=>{});
       if (browserInstance) {
-          console.log(`[${domain}] Releasing browser ${browserInstance.id} back to pool.`);
-          await browserPool.release(browserInstance);
+        console.log(`[${domain}] Releasing browser ${browserInstance.id} back to pool.`);
+        await browserPool.release(browserInstance);
       }
   };
 
   try {
     browserInstance = await browserPool.get();
     const browser = browserInstance.browser;
+    
     context = await browser.newContext({
-      userAgent: "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36",
+      userAgent: "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/117.0.0.0 Safari/537.36",
       ignoreHTTPSErrors: true
     });
     
-    await context.addInitScript(() => { Object.defineProperty(navigator, 'webdriver', { get: () => false }); });
-    
     await context.route("**/*", (route) => {
       if (signal.aborted) return route.abort();
-      const reqUrl = route.request().url();
-      if (reqUrl.includes('/rcp_verify')) return route.fulfill({ status: 200, json: { success: true } });
-      if (['image', 'stylesheet', 'font', 'media'].includes(route.request().resourceType())) return route.abort();
+      if (route.request().url().includes('/rcp_verify')) {
+        return route.fulfill({ status: 200, contentType: 'application/json', body: '1' });
+      }
       return route.continue();
     });
 
-    page = await context.newPage();
+    const page = await context.newPage();
 
-    // 阶段 1
-    console.log(`[${domain}] Navigating to initial page...`);
-    await page.goto(url, { waitUntil: "domcontentloaded", timeout: 45000, signal });
-    console.log(`[${domain}] Page loaded. Checking for Cloudflare challenge...`);
+    // 阶段 1: 访问初始页面 (使用“极度耐心”策略)
+    console.log(`[${domain}] Navigating and patiently waiting for network to be idle...`);
+    await page.goto(url, { waitUntil: 'networkidle', timeout: 60000 });
     
-    const challengeExists = await page.evaluate(() => {
-        return !!document.querySelector('.cf-turnstile[data-sitekey="0x4AAAAAABNpWSLmOnUi7s0b"]');
-    });
+    await handleSpecificTurnstile(page, domain);
 
-    if (challengeExists) {
-        console.log(`[${domain}] Specific Cloudflare challenge DETECTED. Waiting for resolution...`);
-        await page.waitForLoadState('networkidle', { timeout: 25000 });
-        console.log(`[${domain}] Challenge resolved or timed out. Proceeding to find iframe.`);
-    } else {
-        console.log(`[${domain}] Specific Cloudflare challenge NOT DETECTED. Proceeding directly.`);
-    }
-    
-    // 阶段 2
-    console.log(`[${domain}] Now attempting to find the iframe...`);
-    const iframeLocator = page.locator('#player_iframe, #the_frame');
-    await iframeLocator.first().waitFor({ state: 'visible', timeout: 20000 });
-    
-    const firstIframeSrc = await iframeLocator.first().getAttribute('src');
-    if (!firstIframeSrc) throw new Error('First iframe not found AFTER challenge handling');
+    const firstIframeSrc = await extractFirstIframeSrc(page, domain);
+    if (!firstIframeSrc) throw new Error('First iframe not found');
     console.log(`[${domain}] Found first iframe src: ${firstIframeSrc}`);
 
-    // 阶段 3
-    await page.goto(firstIframeSrc, { waitUntil: "networkidle", timeout: 45000, signal });
-    
-    const finalIframeLocator = page.locator('iframe');
-    await finalIframeLocator.first().waitFor({ state: 'visible', timeout: 15000 });
-    const finalIframeSrc = await finalIframeLocator.first().getAttribute('src');
+    // 阶段 2: 访问第一个 iframe (在新页面中，严格复刻)
+    const iframePage = await context.newPage();
+    await iframePage.goto(firstIframeSrc, { waitUntil: 'networkidle', timeout: 60000 });
+    await handleSpecificTurnstile(iframePage, domain);
+
+    const finalIframeSrc = await extractFinalIframeSrc(iframePage, domain);
     if (!finalIframeSrc) throw new Error('Final iframe source not found');
     console.log(`[${domain}] Found final iframe src: ${finalIframeSrc}`);
 
-    const { hlsUrl, subtitles } = await getVideoAndSubtitles(finalIframeSrc);
-    if (!hlsUrl) throw new Error("HLS URL not found");
-    return { source_domain: domain, hls_url: hlsUrl, subtitles, error: null };
+    // 阶段 3: 提取数据
+    const { videoFileUrl, subtitleSources } = await getVideoAndSubtitles(finalIframeSrc);
+    if (!videoFileUrl) throw new Error("HLS URL not found");
+    
+    return { source_domain: domain, hls_url: videoFileUrl, subtitles: subtitleSources, error: null };
 
   } catch (error) {
     console.error(`[${domain}] Error in scrapeProvider: ${error.message}`);
@@ -131,32 +204,22 @@ async function scrapeProvider(domain, url, signal) {
   }
 }
 
-// --- 您的 /extract 路由和启动/关闭逻辑 ---
+// --- 您的 Express 路由和启动逻辑 ---
 app.get("/extract", async (req, res) => {
   const type = req.query.type || "movie";
   const tmdb_id = req.query.tmdb_id;
   const season = req.query.season ? parseInt(req.query.season) : undefined;
   const episode = req.query.episode ? parseInt(req.query.episode) : undefined;
 
-  if (!tmdb_id) {
-    return res.status(400).json({ success: false, error: "tmdb_id query param is required" });
-  }
-  if (type === "tv" && (season == null || episode == null)) {
-    return res.status(400).json({ success: false, error: "season and episode are required for TV shows" });
-  }
+  if (!tmdb_id) { return res.status(400).json({ success: false, error: "tmdb_id is required" }); }
+  if (type === "tv" && (season == null || episode == null)) { return res.status(400).json({ success: false, error: "season and episode are required" }); }
 
   const cacheKey = JSON.stringify(req.query);
   const cached = cache.get(cacheKey);
-  if (cached) {
-    console.log("Serving from cache");
-    return res.json(cached);
-  }
+  if (cached) { console.log("Serving from cache"); return res.json(cached); }
 
   const urls = PROVIDERS.reduce((acc, domain) => {
-    acc[domain] =
-      type === "tv"
-        ? `${domain}/embed/tv?tmdb=${tmdb_id}&season=${season}&episode=${episode}`
-        : `${domain}/embed/movie/${tmdb_id}`;
+    acc[domain] = type === "tv" ? `${domain}/embed/tv?tmdb=${tmdb_id}&season=${season}&episode=${episode}` : `${domain}/embed/movie/${tmdb_id}`;
     return acc;
   }, {});
 
@@ -167,16 +230,11 @@ app.get("/extract", async (req, res) => {
     const promises = Object.entries(urls).map(([domain, url]) =>
       limit(() => scrapeProvider(domain, url, signal))
     );
-
     const firstSuccessfulResult = await Promise.any(promises);
-
-    console.log(`\nSuccess from [${firstSuccessfulResult.source_domain}]. Aborting other scrapers.`);
     controller.abort();
-    
     const response = { success: true, result: firstSuccessfulResult };
     cache.set(cacheKey, response);
     res.json(response);
-
   } catch (err) {
     if (err instanceof AggregateError) {
       console.error("All providers failed to find a link.");
@@ -191,11 +249,12 @@ app.get("/extract", async (req, res) => {
 (async () => {
   try {
     browserPool = new BrowserPool({
-      chromium: chromium,
+      chromium: playwright.chromium,
       minSize: 1,
       maxSize: 5,
       maxUsage: 100,
       launchOptions: {
+          headless: true,
           args: ['--no-sandbox', '--disable-setuid-sandbox', '--disable-dev-shm-usage']
       }
     });
@@ -209,12 +268,12 @@ app.get("/extract", async (req, res) => {
 })();
 
 process.on("SIGINT", async () => {
-  console.log("Shutting down gracefully...");
-  if (browserPool) await browserPool.shutdown();
-  process.exit(0);
+    console.log("Shutting down gracefully...");
+    if (browserPool) await browserPool.shutdown();
+    process.exit(0);
 });
 process.on("SIGTERM", async () => {
-  console.log("Shutting down gracefully...");
-  if (browserPool) await browserPool.shutdown();
-  process.exit(0);
+    console.log("Shutting down gracefully...");
+    if (browserPool) await browserPool.shutdown();
+    process.exit(0);
 });