Delete turbo.js

turbo.js

@@ -1,382 +0,0 @@
-/**
- * Turbo (kinojump.com → obrut.show) stream extractor using Puppeteer
- * kinojump.com and obrut.show use Cloudflare — 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 => {
-            if (res.statusCode >= 300 && res.statusCode < 400 && res.headers.location) {
-                let loc = res.headers.location.startsWith('http')
-                    ? res.headers.location
-                    : u.origin + res.headers.location;
-                loc = loc.replace('web.kinojump.com', 'kinojump.com');
-                res.resume();
-                return fetchRaw(loc, headers).then(resolve).catch(reject);
-            }
-            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();
-    });
-}
-
-// ── Search kinojump ───────────────────────────────────────────────────────────
-async function turboSearch(query) {
-    const searchUrl = 'https://web.kinojump.com/index.php?do=search&subaction=search&story=' + encodeURIComponent(query);
-    const html = await fetchRaw(searchUrl, {
-        'user-agent': 'Mozilla/5.0 Chrome/120',
-        'referer': 'https://web.kinojump.com/'
-    });
-    const results = [];
-    const re = /href="(https?:\/\/(?:web\.)?kinojump\.com\/(\d+)-([^"]+)\.html)"/g;
-    let m;
-    while ((m = re.exec(html)) !== null) {
-        if (!results.find(r => r.id === m[2])) {
-            const url = m[1].replace('web.kinojump.com', 'kinojump.com');
-            results.push({ url, id: m[2], slug: m[3] });
-        }
-    }
-    return results.slice(0, 10);
-}
-
-// ── Get kinojump page HTML via Puppeteer (bypasses Cloudflare) ───────────────
-async function getKinojumpHtml(pageUrl, browser) {
-    const normalizedUrl = pageUrl.replace('web.kinojump.com', 'kinojump.com');
-    
-    // Try plain HTTP first with retry
-    for (let attempt = 0; attempt < 3; attempt++) {
-        try {
-            const html = await fetchRaw(normalizedUrl, {
-                'user-agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 Chrome/120 Safari/537.36',
-                'referer': 'https://kinojump.com/',
-                'accept': 'text/html',
-                'cookie': 'PHPSESSID=a1b2c3d4e5f6'
-            });
-            if (html.includes('obrut.show/embed/')) {
-                console.log('[turbo] got embed URL via plain HTTP');
-                return html;
-            }
-            if (attempt < 2) {
-                console.log('[turbo] no embed URL, retrying... (' + (attempt+1) + '/3)');
-                await new Promise(r => setTimeout(r, 1000));
-            }
-        } catch(e) {
-            console.log('[turbo] plain HTTP failed:', e.message);
-        }
-    }
-
-    // Fallback: Puppeteer
-    console.log('[turbo] using Puppeteer for kinojump page');
-    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' });
-        
-        // Disable automation detection
-        await page.evaluateOnNewDocument(() => {
-            Object.defineProperty(navigator, 'webdriver', { get: () => false });
-            window.chrome = { runtime: {} };
-        });
-
-        let obrutEmbedUrl = null;
-        await page.setRequestInterception(true);
-        page.on('request', req => {
-            const u = req.url();
-            if (u.includes('obrut.show/embed/') && !obrutEmbedUrl) {
-                obrutEmbedUrl = u;
-                console.log('[turbo] intercepted obrut embed:', u.substring(0, 100));
-            }
-            // Block images/fonts to speed up
-            const resourceType = req.resourceType();
-            if (['image', 'stylesheet', 'font', 'media'].includes(resourceType)) {
-                req.abort();
-            } else {
-                req.continue();
-            }
-        });
-
-        await page.goto(normalizedUrl, { waitUntil: 'domcontentloaded', timeout: 25000 });
-        
-        // Wait for Cloudflare challenge
-        console.log('[turbo] waiting for Cloudflare challenge...');
-        await new Promise(r => setTimeout(r, 5000));
-        
-        // Wait for obrut embed
-        for (let i = 0; i < 10 && !obrutEmbedUrl; i++) {
-            await new Promise(r => setTimeout(r, 1000));
-            const html = await page.content();
-            if (html.includes('obrut.show/embed/')) {
-                console.log('[turbo] found obrut embed in DOM');
-                return html;
-            }
-        }
-
-        if (obrutEmbedUrl) return `<!-- obrut-embed: ${obrutEmbedUrl} -->`;
-
-        const finalHtml = await page.content();
-        console.log('[turbo] Puppeteer final HTML len:', finalHtml.length);
-        return finalHtml;
-    } finally {
-        await page.close();
-    }
-}
-
-// ── Parse obrut embed ─────────────────────────────────────────────────────────
-function getCleanText(raw) {
-    const eyJIdx = raw.indexOf('eyJ');
-    const b64 = eyJIdx > 0 ? raw.substring(eyJIdx) : raw;
-    const decoded = Buffer.from(b64, 'base64').toString('utf8');
-    for (let i = 0; i < decoded.length; i++) {
-        const code = decoded.charCodeAt(i);
-        if (code > 127 || (code < 32 && code !== 9 && code !== 10 && code !== 13)) {
-            return decoded.substring(0, i);
-        }
-    }
-    return decoded;
-}
-
-function parseFileStr(fileStr) {
-    const streams = [];
-    const re = /\[(\w+)\](https?:\/\/[^,\[]+)/g;
-    let m;
-    while ((m = re.exec(fileStr)) !== null) streams.push({ quality: m[1], url: m[2].trim() });
-    return streams;
-}
-
-function extractEntries(text) {
-    const re = /"title":"([^"]+)","t1":"([^"]+)","poster":"[^"]*","file":"((?:\[\w+\]https?:\\\/\\\/[^"]+))"/g;
-    const entries = [];
-    let m;
-    while ((m = re.exec(text)) !== null) {
-        if (!m[2]) continue;
-        const fileStr = m[3].replace(/\\\//g, '/');
-        const streams = parseFileStr(fileStr);
-        if (streams.length > 0) entries.push({ voice: m[1], episode: m[2], streams });
-    }
-    return entries;
-}
-
-function extractMovieVoices(text) {
-    const re = /"title":"([^"]+)","t1":"","poster":"[^"]*","file":"((?:\[\w+\]https?:\\\/\\\/[^"]+))"/g;
-    const voices = [];
-    let m;
-    while ((m = re.exec(text)) !== null) {
-        const fileStr = m[2].replace(/\\\//g, '/');
-        const streams = parseFileStr(fileStr);
-        if (streams.length > 0) voices.push({ label: m[1], url: streams[0].url, qualities: streams });
-    }
-    return voices;
-}
-
-async function parseObrutEmbed(embedUrl, browser) {
-    // obrut.show uses Cloudflare - use Cloudflare Worker as proxy to bypass IP blocking
-    const WORKER_URL = 'https://proxy.recycleactor.workers.dev/turbo/proxy';
-    
-    console.log('[turbo] parsing obrut embed via Cloudflare Worker (bypass Cloudflare IP block)');
-    
-    // Try worker proxy first (parallel requests for better data coverage)
-    const BATCH_SIZE = 10;
-    const MAX_BATCHES = 5;
-    const mergedEntries = new Map();
-    const mergedVoices = new Map();
-
-    for (let batch = 0; batch < MAX_BATCHES; batch++) {
-        const promises = Array.from({ length: BATCH_SIZE }, () =>
-            fetchRaw(WORKER_URL + '?url=' + encodeURIComponent(embedUrl), {
-                'user-agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 Chrome/120 Safari/537.36',
-                'accept': 'text/html'
-            }).then(html => {
-                console.log('[turbo] worker response len:', html.length, 'hasPlayer:', html.includes('new Player('));
-                const pm = html.match(/new\s+Player\s*\(\s*"([A-Za-z0-9+/=]{20,})"/);
-                if (!pm) return null;
-                const text = getCleanText(pm[1]);
-                return { entries: extractEntries(text), movieVoices: extractMovieVoices(text) };
-            }).catch(e => {
-                console.log('[turbo] worker request failed:', e.message);
-                return null;
-            })
-        );
-
-        const results = await Promise.all(promises);
-        
-        for (const r of results) {
-            if (!r) continue;
-            for (const e of r.entries) {
-                const key = e.voice + '|' + e.episode;
-                if (!mergedEntries.has(key)) mergedEntries.set(key, e);
-            }
-            for (const v of r.movieVoices) {
-                if (!mergedVoices.has(v.label)) mergedVoices.set(v.label, v);
-            }
-        }
-
-        const e = mergedEntries.size, v = mergedVoices.size;
-        console.log(`[turbo] batch ${batch + 1}: entries=${e} voices=${v}`);
-        if (v >= 5 || e >= 10) break;
-    }
-
-    const entries = Array.from(mergedEntries.values());
-    const movieVoices = Array.from(mergedVoices.values());
-    
-    if (entries.length > 0 || movieVoices.length > 0) {
-        console.log('[turbo] worker proxy success: entries=', entries.length, 'voices=', movieVoices.length);
-        return { entries, movieVoices };
-    }
-
-    // Fallback: try Puppeteer if worker failed
-    console.log('[turbo] worker proxy failed, trying Puppeteer fallback');
-    const page = await browser.newPage();
-    try {
-        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',
-            'Accept': 'text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8',
-            'Referer': 'https://kinojump.com/',
-            'Sec-Fetch-Dest': 'iframe',
-            'Sec-Fetch-Mode': 'navigate',
-            'Sec-Fetch-Site': 'cross-site',
-        });
-
-        await page.setViewport({ width: 1920, height: 1080 });
-
-        // Disable automation detection
-        await page.evaluateOnNewDocument(() => {
-            Object.defineProperty(navigator, 'webdriver', { get: () => false });
-            window.chrome = { runtime: {} };
-            Object.defineProperty(navigator, 'plugins', { get: () => [1, 2, 3, 4, 5] });
-            Object.defineProperty(navigator, 'languages', { get: () => ['ru-RU', 'ru', 'en-US', 'en'] });
-        });
-
-        await page.setRequestInterception(true);
-        page.on('request', req => {
-            const resourceType = req.resourceType();
-            if (['image', 'stylesheet', 'font', 'media'].includes(resourceType)) {
-                req.abort();
-            } else {
-                req.continue();
-            }
-        });
-
-        console.log('[turbo] Puppeteer navigating to obrut embed:', embedUrl.substring(0, 80));
-        
-        await page.goto(embedUrl, {
-            waitUntil: 'domcontentloaded',
-            timeout: 30000,
-        });
-
-        // Wait for Cloudflare challenge to complete
-        console.log('[turbo] waiting for Cloudflare challenge...');
-        await new Promise(r => setTimeout(r, 5000));
-
-        const currentUrl = page.url();
-        const title = await page.title().catch(() => '');
-        console.log('[turbo] current URL:', currentUrl.substring(0, 80));
-        console.log('[turbo] page title:', title);
-
-        if (title.includes('Just a moment') || title.includes('Checking your browser')) {
-            console.log('[turbo] still on Cloudflare challenge, waiting more...');
-            await new Promise(r => setTimeout(r, 5000));
-        }
-
-        // Wait for player to initialize
-        await new Promise(r => setTimeout(r, 2000));
-
-        const html = await page.content();
-        console.log('[turbo] Puppeteer got HTML, len:', html.length, 'hasPlayer:', html.includes('new Player('));
-        
-        if (!html.includes('new Player(')) {
-            console.log('[turbo] Puppeteer: no Player() found');
-            return null;
-        }
-
-        const pm = html.match(/new\s+Player\s*\(\s*"([A-Za-z0-9+/=]{20,})"/);
-        if (!pm) {
-            console.log('[turbo] Puppeteer: Player() found but no base64 data');
-            return null;
-        }
-
-        const text = getCleanText(pm[1]);
-        const puppeteerEntries = extractEntries(text);
-        const puppeteerVoices = extractMovieVoices(text);
-        console.log('[turbo] Puppeteer: entries=', puppeteerEntries.length, 'voices=', puppeteerVoices.length);
-        
-        return { entries: puppeteerEntries, movieVoices: puppeteerVoices };
-    } finally {
-        await page.close();
-    }
-}
-
-// ── Build serial structure ────────────────────────────────────────────────────
-function buildSerialFromEntries(entries) {
-    const seasonMap = {};
-    for (const e of entries) {
-        const seMatch = e.episode.match(/S(\d+)E(\d+)/i);
-        if (!seMatch) continue;
-        const sNum = parseInt(seMatch[1], 10);
-        const eNum = parseInt(seMatch[2], 10);
-        const sKey = 's' + String(sNum).padStart(2, '0');
-        const eKey = 'e' + String(eNum).padStart(2, '0');
-        if (!seasonMap[sKey]) seasonMap[sKey] = {};
-        if (!seasonMap[sKey][eKey]) seasonMap[sKey][eKey] = [];
-        seasonMap[sKey][eKey].push({ label: e.voice, streams: e.streams, url: e.streams[0] ? e.streams[0].url : '' });
-    }
-
-    const seasons = Object.keys(seasonMap).sort().map(sk => ({ id: sk, title: 'Season ' + parseInt(sk.slice(1), 10) }));
-    const episodes = {};
-    const voices = {};
-    for (const sk of Object.keys(seasonMap)) {
-        episodes[sk] = Object.keys(seasonMap[sk]).sort().map(ek => ({ id: ek, title: 'Episode ' + parseInt(ek.slice(1), 10) }));
-        voices[sk] = {};
-        for (const ek of Object.keys(seasonMap[sk])) {
-            voices[sk][ek] = seasonMap[sk][ek].map(v => ({ label: v.label, url: v.url, qualities: v.streams, subtitles: [] }));
-        }
-    }
-
-    return { seasons, episodes, voices };
-}
-
-// ── Main: get stream ──────────────────────────────────────────────────────────
-async function getTurboStream(pageUrl) {
-    const browser = await getBrowser();
-
-    console.log('[turbo] getting embed URL from:', pageUrl);
-    const html = await getKinojumpHtml(pageUrl, browser);
-    const m = html.match(/(?:([a-z0-9]+)\.)?obrut\.show\/embed\/([A-Za-z0-9]+)\/content\/([A-Za-z0-9]+)/);
-    if (!m) throw new Error('obrut embed URL not found');
-
-    const subdomain = m[1] ? m[1] + '.obrut.show' : '49372504.obrut.show';
-    const embedUrl = 'https://' + subdomain + '/embed/' + m[2] + '/content/' + m[3];
-    console.log('[turbo] embed URL:', embedUrl);
-
-    console.log('[turbo] parsing obrut embed');
-    const result = await parseObrutEmbed(embedUrl, browser);
-    if (!result) throw new Error('failed to extract data from obrut embed');
-
-    const hasSerial = result.entries.length > 0;
-    const hasMovie = result.movieVoices.length > 0;
-
-    if (hasSerial) {
-        const serial = buildSerialFromEntries(result.entries);
-        console.log('[turbo] serial:', serial.seasons.length, 'seasons');
-        return { embed_url: embedUrl, content_type: 'serial', serial };
-    } else if (hasMovie) {
-        console.log('[turbo] movie:', result.movieVoices.length, 'voices');
-        return { embed_url: embedUrl, content_type: 'movie', voices: result.movieVoices };
-    } else {
-        throw new Error('no data found in obrut embed');
-    }
-}
-
-module.exports = { turboSearch, getTurboStream };