Delete cinemar.js

cinemar.js

@@ -1,348 +0,0 @@
-/**
- * Cinemar (cinemar.cc) stream extractor using Puppeteer
- * cinemar.cc now uses Cloudflare Rocket Loader — data only available after JS execution
- */
-const { getBrowser } = require('./alloha');
-const https = require('https');
-const http = require('http');
-
-function fetchRaw(reqUrl, headers) {
-    return new Promise((resolve, reject) => {
-        let u; try { u = new URL(reqUrl); } catch(e) { return reject(e); }
-        const mod = u.protocol === 'https:' ? https : http;
-        const req = mod.request({
-            hostname: u.hostname, path: u.pathname + u.search,
-            headers: headers || {}
-        }, res => {
-            let d = ''; res.setEncoding('utf8');
-            res.on('data', c => d += c);
-            res.on('end', () => resolve(d));
-        });
-        req.on('error', reject);
-        req.setTimeout(12000, () => { req.destroy(); reject(new Error('timeout')); });
-        req.end();
-    });
-}
-
-// ── Helpers (same as server.js) ───────────────────────────────────────────────
-
-function findAllInBuf(buf, pattern) {
-    const positions = [];
-    let pos = 0;
-    while (pos < buf.length) {
-        const idx = buf.indexOf(pattern, pos);
-        if (idx < 0) break;
-        positions.push(idx);
-        pos = idx + 1;
-    }
-    return positions;
-}
-
-function readJsonStr(buf, pos) {
-    let str = '', i = pos;
-    while (i < buf.length) {
-        const b = buf[i];
-        if (b === 0x22) return { str, end: i };
-        if (b === 0x5C) {
-            i++;
-            if (i >= buf.length) break;
-            const esc = buf[i];
-            if (esc === 0x75 && i + 4 < buf.length) {
-                const hex = buf.slice(i + 1, i + 5).toString('ascii');
-                if (/^[0-9a-fA-F]{4}$/.test(hex)) { str += String.fromCharCode(parseInt(hex, 16)); i += 5; continue; }
-            }
-            str += String.fromCharCode(esc);
-        } else if (b >= 0x20 && b <= 0x7E) {
-            str += String.fromCharCode(b);
-        } else if ((b & 0xE0) === 0xC0 && i + 1 < buf.length) {
-            str += String.fromCodePoint(((b & 0x1F) << 6) | (buf[i+1] & 0x3F)); i += 2; continue;
-        } else if ((b & 0xF0) === 0xE0 && i + 2 < buf.length) {
-            str += String.fromCodePoint(((b & 0x0F) << 12) | ((buf[i+1] & 0x3F) << 6) | (buf[i+2] & 0x3F)); i += 3; continue;
-        } else break;
-        i++;
-    }
-    return { str, end: i };
-}
-
-function findBufVal(buf, key, fromPos, maxDist) {
-    const keyBuf = Buffer.from('"' + key + '":"');
-    const idx = buf.indexOf(keyBuf, fromPos);
-    if (idx < 0 || idx > fromPos + (maxDist || 400)) return null;
-    return readJsonStr(buf, idx + keyBuf.length);
-}
-
-const FOLDER_MARKER_BUF = Buffer.from('"folder":[');
-
-function decodeCinemarFile(fileValue) {
-    const w3sPos = fileValue.indexOf('W3s');
-    if (w3sPos < 0) return null;
-    const raw = fileValue.substring(w3sPos);
-    const chunks = raw.split('&');
-    const buffers = [];
-    for (let i = 0; i < chunks.length; i++) {
-        let chunk = chunks[i];
-        if (i < chunks.length - 1) chunk = chunk.slice(0, -4);
-        const clean = chunk.replace(/[^A-Za-z0-9+/=]/g, '');
-        if (clean.length > 0) {
-            const padded = clean + '='.repeat((4 - clean.length % 4) % 4);
-            try { buffers.push(Buffer.from(padded, 'base64')); } catch(e) {}
-        }
-    }
-    if (!buffers.length) return null;
-    return Buffer.concat(buffers);
-}
-
-function normUrl(f) { return f ? (f.startsWith('//') ? 'https:' + f : f) : ''; }
-
-function parseSubs(subtitle) {
-    const subs = [];
-    if (!subtitle) return subs;
-    subtitle.split(',').forEach(part => {
-        const sm = part.match(/^\[([^\]]+)\](\/\/.+|https?:\/\/.+)/);
-        if (sm) subs.push({ label: sm[1], url: normUrl(sm[2]) });
-    });
-    return subs;
-}
-
-// ── Get HTML via Puppeteer (bypasses Cloudflare Rocket Loader) ────────────────
-async function getEmbedHtmlViaPuppeteer(embedUrl) {
-    const browser = await getBrowser();
-    const page = await browser.newPage();
-    try {
-        await page.setUserAgent('Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 Chrome/120 Safari/537.36');
-        await page.setExtraHTTPHeaders({ 'Accept-Language': 'ru-RU,ru;q=0.9' });
-
-        // Intercept the file data from window object after JS executes
-        let fileData = null;
-
-        await page.setRequestInterception(true);
-        page.on('request', req => req.continue());
-
-        await page.goto(embedUrl, {
-            waitUntil: 'networkidle2',
-            timeout: 25000,
-            referer: 'https://uakinogo.io/'
-        });
-
-        // Wait for player to initialize and extract file data
-        await new Promise(r => setTimeout(r, 2000));
-
-        fileData = await page.evaluate(() => {
-            // Try to find file data in window variables
-            for (const k of Object.keys(window)) {
-                try {
-                    const v = window[k];
-                    if (v && typeof v === 'object' && v.file && typeof v.file === 'string' && v.file.length > 100) {
-                        return JSON.stringify(v);
-                    }
-                } 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;
-        });
-
-        console.log('[cinemar] puppeteer got data, length:', fileData ? fileData.length : 0);
-        return fileData || '';
-    } finally {
-        await page.close();
-    }
-}
-
-// ── Parse cinemar HTML/data ───────────────────────────────────────────────────
-function parseCinemarData(html) {
-    const fileMatch = html.match(/"file":"([^"]+)"/);
-    if (!fileMatch) return null;
-    const buf = decodeCinemarFile(fileMatch[1]);
-    if (!buf || buf.length < 20) return null;
-
-    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);
-            if (Array.isArray(arr) && arr.length && arr[0].title) {
-                const items = arr.map(item => ({
-                    title: item.title || 'Unknown',
-                    file: (item.file || '').replace(/\\\//g, '/').replace(/^\/\//, 'https://'),
-                    subtitle: item.subtitle || ''
-                })).filter(i => i.file && i.file.includes('cinemap'));
-                if (items.length) return { isSerial: false, items };
-            }
-        } 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);
-            const f = findBufVal(buf, 'file', pos, 5000);
-            const s = findBufVal(buf, 'subtitle', pos, 6000);
-            if (!f) return;
-            const url = normUrl(f.str.replace(/\\\//g, '/'));
-            if (!url || !url.includes('cinemap')) return;
-            const title = t ? t.str : 'Unknown';
-            if (!items.find(i => i.title === title)) items.push({ title, file: url, subtitle: s ? s.str.replace(/\\\//g, '/') : '' });
-        });
-        return { isSerial: false, items };
-    }
-
-    // Serial
-    const epIdPrefix = Buffer.from('"id":"s');
-    const allEpPositions = [];
-    findAllInBuf(buf, epIdPrefix).forEach(pos => {
-        let i = pos + epIdPrefix.length;
-        while (i < buf.length && buf[i] >= 0x30 && buf[i] <= 0x39) i++;
-        if (buf[i] !== 0x65) return;
-        i++;
-        while (i < buf.length && buf[i] >= 0x30 && buf[i] <= 0x39) i++;
-        if (buf[i] !== 0x22) return;
-        const fullId = buf.slice(pos + 6, i).toString('ascii');
-        const seasonMatch = fullId.match(/^(s\d+)e(\d+)$/);
-        if (!seasonMatch) return;
-        const t = findBufVal(buf, 'title', pos, 200);
-        allEpPositions.push({ id: fullId, seasonId: seasonMatch[1], epNum: parseInt(seasonMatch[2], 10), title: t ? t.str : ('Серия ' + seasonMatch[2]), pos });
-    });
-
-    const seasonMap = {};
-    allEpPositions.forEach(ep => {
-        if (!seasonMap[ep.seasonId]) seasonMap[ep.seasonId] = [];
-        if (!seasonMap[ep.seasonId].find(e => e.id === ep.id)) seasonMap[ep.seasonId].push(ep);
-    });
-    const seasonIds = Object.keys(seasonMap).sort((a, b) => parseInt(a.substring(1)) - parseInt(b.substring(1)));
-    if (!seasonIds.length) return null;
-
-    const episodes = {};
-    seasonIds.forEach(seasonId => {
-        const eps = seasonMap[seasonId].sort((a, b) => a.epNum - b.epNum);
-        episodes[seasonId] = eps.map((ep, ei) => {
-            const nextEpPos = ei + 1 < eps.length ? eps[ei + 1].pos : buf.length;
-            const eBuf = buf.slice(ep.pos, nextEpPos);
-            const voices = [];
-            findAllInBuf(eBuf, Buffer.from('"src_id"')).forEach(vpos => {
-                const t = findBufVal(eBuf, 'title', vpos, 300);
-                const f = findBufVal(eBuf, 'file', vpos, 2000);
-                const s = findBufVal(eBuf, 'subtitle', vpos, 3000);
-                if (!f) return;
-                const url = normUrl(f.str.replace(/\\\//g, '/'));
-                if (!url || !url.includes('.m3u8')) return;
-                const title = t ? t.str : 'Unknown';
-                if (!voices.find(v => v.title === title)) voices.push({ title, file: url, subtitle: s ? s.str.replace(/\\\//g, '/') : '' });
-            });
-            return { id: ep.id, title: ep.title, voices };
-        });
-    });
-
-    return { isSerial: true, seasonIds, episodes };
-}
-
-// ── Main: get stream for a uakinogo page URL ──────────────────────────────────
-async function getCinemarStream(pageUrl) {
-    // Step 1: get embed URL from uakinogo page
-    const pageHtml = await fetchRaw(pageUrl, {
-        'user-agent': 'Mozilla/5.0 Chrome/120', 'referer': 'https://uakinogo.io/'
-    });
-    const em = pageHtml.match(/"embedUrl"\s*:\s*"(https:\/\/cinemar\.cc\/embed\/[^"]+)"/);
-    if (!em) 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'
-    });
-
-    if (!embedHtml || !embedHtml.includes('"file"')) {
-        console.log('[cinemar] no file in plain HTML, trying Puppeteer...');
-        embedHtml = await getEmbedHtmlViaPuppeteer(embedUrl);
-    } else {
-        console.log('[cinemar] got file data via plain HTTP');
-    }
-
-    if (!embedHtml || !embedHtml.includes('"file"')) {
-        throw new Error('no file data in embed (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 => ({
-            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
-    const seasonMap = {};
-    Object.values(merged).forEach(ep => {
-        if (!seasonMap[ep.seasonId]) seasonMap[ep.seasonId] = [];
-        seasonMap[ep.seasonId].push(ep);
-    });
-    const seasonIds = Object.keys(seasonMap).sort((a, b) => parseInt(a.substring(1)) - parseInt(b.substring(1)));
-    const seasons = [], episodes = {}, voicesMap = {};
-    seasonIds.forEach(sid => {
-        const eps = seasonMap[sid].sort((a, b) => {
-            const an = parseInt(a.id.match(/e(\d+)/)[1]);
-            const bn = parseInt(b.id.match(/e(\d+)/)[1]);
-            return an - bn;
-        });
-        seasons.push({ id: sid, title: 'Сезон ' + parseInt(sid.substring(1)) });
-        episodes[sid] = eps.map(ep => ({ id: ep.id, title: ep.title }));
-        voicesMap[sid] = {};
-        eps.forEach(ep => {
-            voicesMap[sid][ep.id] = ep.voices.map(v => ({ label: v.title, url: normUrl(v.file), subtitles: parseSubs(v.subtitle) }));
-        });
-    });
-
-    const totalEps = Object.values(episodes).reduce((s, e) => s + e.length, 0);
-    console.log(`[cinemar] done: ${seasons.length} seasons, ${totalEps} eps`);
-
-    const serial = { seasons, episodes, voices: voicesMap };
-    const firstVoice = seasons[0] && episodes[seasons[0].id] && episodes[seasons[0].id][0]
-        ? (voicesMap[seasons[0].id][episodes[seasons[0].id][0].id] || [])[0]
-        : null;
-
-    return { content_type: 'serial', embed_url: embedUrl, serial, voices: [], stream: firstVoice ? firstVoice.url : null };
-}
-
-module.exports = { getCinemarStream };