Update server.js

server.js

@@ -240,7 +240,7 @@ async function scrapeProvider_(domain, url, signal) {
     }
 }
 
-async function scrapeProvider(domain, url, signal) {
+async function scrapeProvider__(domain, url, signal) {
     if (signal.aborted) throw new Error('Aborted');
     console.log(`\n[${domain}] Starting scrape for URL: ${url}`);
 
@@ -354,6 +354,110 @@ async function scrapeProvider(domain, url, signal) {
 }
 
 
+async function scrapeProvider(domain, url, signal) {
+    if (signal.aborted) throw new Error('Aborted');
+    console.log(`\n[${domain}] Starting scrape for URL: ${url}`);
+
+    let browserInstance = null;
+    try {
+        browserInstance = await browserPool.get();
+        const browser = browserInstance.browser;
+        
+        // 创建初始页面
+        const page = await browser.newPage();
+        let videoResult = null;
+        
+        // 启用请求拦截
+        await page.route('**/*', async (route) => {
+            const requestUrl = route.request().url();
+            console.log(`[${domain}] Request: ${requestUrl}`);
+            
+            // 如果是 cloudnestra.com/rcp/ 的请求，使用 getVideoAndSubtitles 解析
+            if (requestUrl.includes('cloudnestra.com/rcp/')) {
+                try {
+                    const { videoFileUrl, subtitleSources } = await getVideoAndSubtitles(requestUrl);
+                    if (!videoFileUrl) throw new Error("HLS URL not found");
+                    
+                    videoResult = {
+                        source_domain: domain,
+                        hls_url: videoFileUrl,
+                        subtitles: subtitleSources,
+                        error: null
+                    };
+                    route.abort();
+                } catch (error) {
+                    console.error(`[${domain}] Error processing cloudnestra request:`, error);
+                    route.continue();
+                }
+            } else {
+                route.continue();
+            }
+        });
+        
+        await page.goto(url, { 
+            waitUntil: 'networkidle',
+            timeout: 60000 
+        });
+        
+        // 如果已经从 cloudnestra 获取了视频链接，直接返回
+        if (videoResult) {
+            return videoResult;
+        }
+        
+        // 检查是否有Turnstile
+        const hasTurnstile = await page.evaluate(() => {
+            return document.querySelector('.cf-turnstile') !== null;
+        });
+        console.log(`[${domain}] Has Turnstile: ${hasTurnstile}`);
+        
+        // 处理Turnstile
+        if (hasTurnstile) {
+            await handleSpecificTurnstile(page, domain);
+        }
+
+        // 获取第一个iframe的URL
+        const firstIframeSrc = await extractFirstIframeSrc(page, domain);
+        if (!firstIframeSrc) throw new Error('First iframe not found');
+        
+        // 创建新页面来加载iframe内容
+        const iframePage = await browser.newPage();
+        await iframePage.goto(firstIframeSrc, { 
+            waitUntil: 'networkidle',
+            timeout: 60000 
+        });
+        
+        // 处理可能存在的第二个Turnstile
+        const iframeHasTurnstile = await iframePage.evaluate(() => {
+            return document.querySelector('.cf-turnstile') !== null;
+        });
+        console.log(`[${domain}] Iframe has Turnstile: ${iframeHasTurnstile}`);
+        
+        if (iframeHasTurnstile) {
+            await handleSpecificTurnstile(iframePage, domain);
+        }
+
+        // 获取最终iframe的URL
+        const finalIframeSrc = await extractFinalIframeSrc(iframePage, domain);
+        if (!finalIframeSrc) throw new Error('Final iframe not found');
+        
+        // 使用 getVideoAndSubtitles 函数获取视频和字幕
+        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}`);
+        throw error;
+    } finally {
+        if (browserInstance) {
+            console.log(`[${domain}] Releasing browser ${browserInstance.id} back to pool.`);
+            await browserPool.release(browserInstance);
+        }
+    }
+}
+
+
 // 修改 handleSpecificTurnstile 函数
 async function handleSpecificTurnstile(page, domain) {
     try {