Upload cinemar.js

cinemar.js

@@ -1,6 +1,6 @@
 /**
- * Cinemar (cinemar.cc) stream extractor using Puppeteer
- * cinemar.cc now uses Cloudflare Rocket Loader — data only available after JS execution
+ * Cinemar (cinemar.cc) stream extractor using Cloudflare Worker proxy
+ * cinemar.cc uses Cloudflare — use worker to bypass IP blocking
  */
 const { getBrowser } = require('./alloha');
 const https = require('https');
@@ -104,12 +104,11 @@ function parseSubs(subtitle) {
     return subs;
 }
 
-// ── Get HTML via Puppeteer (bypasses Cloudflare Rocket Loader) ────────────────
+// ── Get HTML via Puppeteer (fallback only) ────────────────────────────────────
 async function getEmbedHtmlViaPuppeteer(embedUrl) {
     const browser = await getBrowser();
     const page = await browser.newPage();
     try {
-        // More realistic browser fingerprint
         await page.setUserAgent('Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36');
         await page.setExtraHTTPHeaders({ 
             'Accept-Language': 'ru-RU,ru;q=0.9,en;q=0.8',
@@ -120,10 +119,8 @@ async function getEmbedHtmlViaPuppeteer(embedUrl) {
             'Sec-Fetch-Site': 'cross-site',
         });
 
-        // Set viewport to look like real browser
         await page.setViewport({ width: 1920, height: 1080 });
 
-        // Disable automation detection
         await page.evaluateOnNewDocument(() => {
             Object.defineProperty(navigator, 'webdriver', { get: () => false });
             window.chrome = { runtime: {} };
@@ -133,7 +130,6 @@ async function getEmbedHtmlViaPuppeteer(embedUrl) {
 
         await page.setRequestInterception(true);
         page.on('request', req => {
-            // Block unnecessary resources to speed up
             const resourceType = req.resourceType();
             if (['image', 'stylesheet', 'font', 'media'].includes(resourceType)) {
                 req.abort();
@@ -149,11 +145,9 @@ async function getEmbedHtmlViaPuppeteer(embedUrl) {
             timeout: 30000,
         });
 
-        // Wait longer for Cloudflare challenge to complete
         console.log('[cinemar] waiting for Cloudflare challenge...');
         await new Promise(r => setTimeout(r, 5000));
 
-        // Check if we're still on Cloudflare challenge page
         const currentUrl = page.url();
         const title = await page.title().catch(() => '');
         console.log('[cinemar] current URL:', currentUrl.substring(0, 80));
@@ -164,11 +158,9 @@ async function getEmbedHtmlViaPuppeteer(embedUrl) {
             await new Promise(r => setTimeout(r, 5000));
         }
 
-        // Wait for player to initialize and extract file data
         await new Promise(r => setTimeout(r, 2000));
 
         const fileData = await page.evaluate(() => {
-            // Try to find file data in window variables
             for (const k of Object.keys(window)) {
                 try {
                     const v = window[k];
@@ -177,12 +169,10 @@ async function getEmbedHtmlViaPuppeteer(embedUrl) {
                     }
                 } catch(e) {}
             }
-            // Try to get from DOM — look for script with file data
             for (const s of document.querySelectorAll('script:not([src])')) {
                 const t = s.textContent || '';
                 if (t.includes('"file"') && t.includes('W3s')) return t;
             }
-            // Get full page HTML
             return document.documentElement.outerHTML;
         });
 
@@ -206,7 +196,6 @@ function parseCinemarData(html) {
     const isSerial = buf.indexOf(FOLDER_MARKER_BUF) >= 0;
 
     if (!isSerial) {
-        // Try JSON parse first (movie format: array of voice objects)
         try {
             const jsonStr = buf.toString('utf8');
             const arr = JSON.parse(jsonStr);
@@ -220,7 +209,6 @@ function parseCinemarData(html) {
             }
         } catch(e) {}
 
-        // Fallback: binary search for src_id
         const items = [];
         findAllInBuf(buf, Buffer.from('"src_id"')).forEach(pos => {
             const t = findBufVal(buf, 'title', pos, 300);
@@ -294,29 +282,80 @@ async function getCinemarStream(pageUrl) {
     });
     
     console.log('[cinemar] page HTML length:', pageHtml.length);
-    console.log('[cinemar] page has embedUrl:', pageHtml.includes('embedUrl'));
-    console.log('[cinemar] page has cinemar.cc:', pageHtml.includes('cinemar.cc'));
     
     const em = pageHtml.match(/"embedUrl"\s*:\s*"(https:\/\/cinemar\.cc\/embed\/[^"]+)"/);
     if (!em) {
         console.log('[cinemar] ERROR: embedUrl not found in page');
-        console.log('[cinemar] Page snippet:', pageHtml.substring(0, 500));
         throw new Error('embed_url not found');
     }
     const embedUrl = em[1];
     console.log('[cinemar] embed URL:', embedUrl.substring(0, 80));
 
-    // Step 2: get embed HTML — try plain HTTP first, fallback to Puppeteer
-    let embedHtml = await fetchRaw(embedUrl, {
-        'user-agent': 'Mozilla/5.0 Chrome/120',
-        'referer': 'https://uakinogo.io/',
-        'origin': 'https://uakinogo.io'
-    });
+    // Step 2: get embed HTML via Cloudflare Worker (bypasses IP blocking)
+    const WORKER_URL = 'https://proxy.recycleactor.workers.dev/cinemar/proxy';
+    
+    console.log('[cinemar] fetching via Cloudflare Worker (bypass Cloudflare IP block)');
+    
+    // Try worker proxy with parallel requests for better data coverage
+    const BATCH = 5, MAX_BATCHES = 4;
+    const merged = {};
+    
+    const addEpisodes = (data) => {
+        if (!data || !data.isSerial) return;
+        data.seasonIds.forEach(sid => {
+            (data.episodes[sid] || []).forEach(ep => {
+                if (!merged[ep.id] || ep.voices.length > (merged[ep.id] ? merged[ep.id].voices.length : 0)) {
+                    merged[ep.id] = { ...ep, seasonId: sid };
+                }
+            });
+        });
+    };
+
+    let firstParsed = null;
+    
+    for (let b = 0; b < MAX_BATCHES; b++) {
+        const prevCount = Object.keys(merged).length;
+        
+        const htmls = await Promise.all(
+            Array.from({ length: BATCH }, () =>
+                fetchRaw(WORKER_URL + '?url=' + encodeURIComponent(embedUrl), {
+                    'user-agent': 'Mozilla/5.0 Chrome/120',
+                    'accept': 'text/html'
+                }).then(html => {
+                    console.log('[cinemar] worker response len:', html.length, 'hasFile:', html.includes('"file"'));
+                    return html;
+                }).catch(e => {
+                    console.log('[cinemar] worker request failed:', e.message);
+                    return null;
+                })
+            )
+        );
+        
+        htmls.filter(Boolean).forEach(html => {
+            const parsed = parseCinemarData(html);
+            if (parsed) {
+                if (!firstParsed) firstParsed = parsed;
+                addEpisodes(parsed);
+            }
+        });
+        
+        const newCount = Object.keys(merged).length;
+        console.log(`[cinemar] batch ${b+1}: ${newCount} eps (+${newCount - prevCount})`);
+        
+        // For movies, one successful fetch is enough
+        if (firstParsed && !firstParsed.isSerial) break;
+        
+        // For serials, stop if no new episodes found
+        if (newCount === prevCount && b >= 1) break;
+        
+        if (b < MAX_BATCHES - 1) await new Promise(r => setTimeout(r, 200));
+    }
 
-    if (!embedHtml || !embedHtml.includes('"file"')) {
-        console.log('[cinemar] no file in plain HTML, trying Puppeteer...');
+    if (!firstParsed) {
+        console.log('[cinemar] worker proxy failed, trying Puppeteer fallback...');
         
-        // Try Puppeteer multiple times with delays
+        // Fallback: try Puppeteer
+        let embedHtml = null;
         let attempts = 0;
         const maxAttempts = 3;
         
@@ -329,13 +368,14 @@ async function getCinemarStream(pageUrl) {
                 
                 if (embedHtml && embedHtml.includes('"file"') && embedHtml.includes('W3s')) {
                     console.log('[cinemar] Puppeteer success on attempt', attempts);
-                    break;
+                    firstParsed = parseCinemarData(embedHtml);
+                    if (firstParsed) break;
                 }
                 
                 console.log('[cinemar] Puppeteer attempt', attempts, 'failed, no file data');
                 
                 if (attempts < maxAttempts) {
-                    const delay = 2000 * attempts; // Increasing delay
+                    const delay = 2000 * attempts;
                     console.log(`[cinemar] waiting ${delay}ms before retry...`);
                     await new Promise(r => setTimeout(r, delay));
                 }
@@ -344,60 +384,21 @@ async function getCinemarStream(pageUrl) {
                 if (attempts >= maxAttempts) throw e;
             }
         }
-    } else {
-        console.log('[cinemar] got file data via plain HTTP');
-    }
-
-    if (!embedHtml || !embedHtml.includes('"file"')) {
-        console.log('[cinemar] ERROR: no file data after all attempts');
-        console.log('[cinemar] embed HTML length:', embedHtml ? embedHtml.length : 0);
-        console.log('[cinemar] embed HTML snippet:', embedHtml ? embedHtml.substring(0, 500) : 'null');
-        throw new Error('no file data in embed (Cloudflare blocked?)');
+        
+        if (!firstParsed) {
+            throw new Error('no file data after worker and Puppeteer attempts (Cloudflare blocked?)');
+        }
     }
 
-    // Step 3: parse data
-    const parsed = parseCinemarData(embedHtml);
-    if (!parsed) throw new Error('failed to parse cinemar data');
-
-    if (!parsed.isSerial) {
-        const voices = parsed.items.map(item => ({
+    // Step 3: build response
+    if (!firstParsed.isSerial) {
+        const voices = firstParsed.items.map(item => ({
             label: item.title, url: item.file, subtitles: parseSubs(item.subtitle)
         }));
         return { content_type: 'movie', embed_url: embedUrl, voices, serial: null, stream: voices[0] ? voices[0].url : null };
     }
 
-    // Serial: fetch multiple times and merge
-    const merged = {};
-    const addEpisodes = (data) => {
-        if (!data || !data.isSerial) return;
-        data.seasonIds.forEach(sid => {
-            (data.episodes[sid] || []).forEach(ep => {
-                if (!merged[ep.id] || ep.voices.length > (merged[ep.id] ? merged[ep.id].voices.length : 0)) {
-                    merged[ep.id] = { ...ep, seasonId: sid };
-                }
-            });
-        });
-    };
-
-    addEpisodes(parsed);
-
-    // Fetch more in parallel to get all episodes
-    const BATCH = 5, MAX_BATCHES = 4;
-    for (let b = 0; b < MAX_BATCHES; b++) {
-        const prevCount = Object.keys(merged).length;
-        const htmls = await Promise.all(
-            Array.from({ length: BATCH }, () =>
-                fetchRaw(embedUrl, { 'user-agent': 'Mozilla/5.0 Chrome/120', 'referer': 'https://uakinogo.io/', 'origin': 'https://uakinogo.io' }).catch(() => null)
-            )
-        );
-        htmls.filter(Boolean).forEach(html => addEpisodes(parseCinemarData(html)));
-        const newCount = Object.keys(merged).length;
-        console.log(`[cinemar] batch ${b+1}: ${newCount} eps (+${newCount - prevCount})`);
-        if (newCount === prevCount && b >= 1) break;
-        if (b < MAX_BATCHES - 1) await new Promise(r => setTimeout(r, 200));
-    }
-
-    // Build serial structure
+    // Serial: build structure from merged episodes
     const seasonMap = {};
     Object.values(merged).forEach(ep => {
         if (!seasonMap[ep.seasonId]) seasonMap[ep.seasonId] = [];