Upload server.js

server.js

@@ -76,7 +76,7 @@ async function fetchRaw(url, headers = {}) {
                         'user-agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/124.0.0.0 Safari/537.36',
                         'accept': 'text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/webp,*/*;q=0.8',
                         'accept-language': 'ru-RU,ru;q=0.9,en-US;q=0.8,en;q=0.7',
-                        'accept-encoding': 'gzip, deflate, br',
+                        'accept-encoding': 'gzip, deflate, br',
                         'connection': 'close',
                         ...headers
                     },
@@ -88,29 +88,29 @@ async function fetchRaw(url, headers = {}) {
                         resolve(fetchRaw(loc, headers));
                         return;
                     }
-                    let data = [];
-                    res.on('data', (chunk) => data.push(Buffer.isBuffer(chunk) ? chunk : Buffer.from(chunk)));
-                    res.on('end', () => {
-                        try {
-                            const buf = Buffer.concat(data);
-                            const enc = String(res.headers['content-encoding'] || '').toLowerCase();
-                            if (enc.includes('br')) {
-                                const zlib = require('zlib');
-                                return resolve(zlib.brotliDecompressSync(buf).toString('utf8'));
-                            }
-                            if (enc.includes('gzip')) {
-                                const zlib = require('zlib');
-                                return resolve(zlib.gunzipSync(buf).toString('utf8'));
-                            }
-                            if (enc.includes('deflate')) {
-                                const zlib = require('zlib');
-                                return resolve(zlib.inflateSync(buf).toString('utf8'));
-                            }
-                            resolve(buf.toString('utf8'));
-                        } catch (e) {
-                            resolve(Buffer.concat(data).toString('utf8'));
-                        }
-                    });
+                    let data = [];
+                    res.on('data', (chunk) => data.push(Buffer.isBuffer(chunk) ? chunk : Buffer.from(chunk)));
+                    res.on('end', () => {
+                        try {
+                            const buf = Buffer.concat(data);
+                            const enc = String(res.headers['content-encoding'] || '').toLowerCase();
+                            if (enc.includes('br')) {
+                                const zlib = require('zlib');
+                                return resolve(zlib.brotliDecompressSync(buf).toString('utf8'));
+                            }
+                            if (enc.includes('gzip')) {
+                                const zlib = require('zlib');
+                                return resolve(zlib.gunzipSync(buf).toString('utf8'));
+                            }
+                            if (enc.includes('deflate')) {
+                                const zlib = require('zlib');
+                                return resolve(zlib.inflateSync(buf).toString('utf8'));
+                            }
+                            resolve(buf.toString('utf8'));
+                        } catch (e) {
+                            resolve(Buffer.concat(data).toString('utf8'));
+                        }
+                    });
                 });
                 req.on('error', reject);
                 req.on('timeout', () => { req.destroy(); reject(new Error('timeout')); });
@@ -490,17 +490,17 @@ function handleHls(req, res) {
 
 const server = http.createServer(async (req, res) => {
     const { pathname, query } = parseQuery(req.url);
-    const startedAt = Date.now();
-    const shouldLog = pathname === '/health' || pathname.startsWith('/uakinogo/') || pathname.startsWith('/alloha/') || pathname.startsWith('/turbo/');
-    if (shouldLog) {
-        try {
-            const q = (pathname === '/uakinogo/search' && query.q) ? (' q=' + String(query.q).slice(0, 120)) : '';
-            console.log('[req]', req.method, pathname + q);
-        } catch (e) {}
-        res.on('finish', () => {
-            try { console.log('[res]', req.method, pathname, res.statusCode, (Date.now() - startedAt) + 'ms'); } catch (e) {}
-        });
-    }
+    const startedAt = Date.now();
+    const shouldLog = pathname === '/health' || pathname.startsWith('/uakinogo/') || pathname.startsWith('/alloha/') || pathname.startsWith('/turbo/');
+    if (shouldLog) {
+        try {
+            const q = (pathname === '/uakinogo/search' && query.q) ? (' q=' + String(query.q).slice(0, 120)) : '';
+            console.log('[req]', req.method, pathname + q);
+        } catch (e) {}
+        res.on('finish', () => {
+            try { console.log('[res]', req.method, pathname, res.statusCode, (Date.now() - startedAt) + 'ms'); } catch (e) {}
+        });
+    }
 
     if (req.method === 'OPTIONS') {
         res.writeHead(204, { 'Access-Control-Allow-Origin': '*', 'Access-Control-Allow-Methods': 'GET, POST, OPTIONS', 'Access-Control-Allow-Headers': '*' });
@@ -671,58 +671,94 @@ const server = http.createServer(async (req, res) => {
     if (pathname === '/uakinogo/search') {
         const q = query.q || '';
         if (!q) { jsonResp(res, { ok: false, error: 'no query' }, 400); return; }
-        const searchUrl = 'https://uakinogo.io/index.php?do=search&subaction=search&story=' + encodeURIComponent(q);
-        const parseSearchHtml = (html) => {
+        const qEnc = encodeURIComponent(q);
+        const searchUrlSeo = 'https://uakinogo.io/search/' + qEnc;
+        const searchUrlLegacy = 'https://uakinogo.io/index.php?do=search&subaction=search&story=' + qEnc;
+        const parseSearchHtml = (html) => {
             const results = [];
-            const addResult = (rawUrl, id, slug) => {
-                if (!rawUrl || !id) return;
-                let url = rawUrl;
-                if (url.startsWith('//')) url = 'https:' + url;
-                if (url.startsWith('/')) url = 'https://uakinogo.io' + url;
-                if (!url.startsWith('http')) return;
-                if (!url.includes('uakinogo.io/')) return;
-                if (url.includes('do=search') || url.includes('/index.php')) return;
-                if (!results.find(r => r.id === id)) results.push({ url, id, slug: slug || '' });
-            };
-
-            const reAbs = /href="(https?:\/\/uakinogo\.io\/[^"]*?\/(\d+)-([^"\/]+)\.html)"/g;
-            const reRel = /href="(\/[^"]*?\/(\d+)-([^"\/]+)\.html)"/g;
+            const addResult = (rawUrl, id, slug) => {
+                if (!rawUrl || !id) return;
+                let url = rawUrl;
+                if (url.startsWith('//')) url = 'https:' + url;
+                if (url.startsWith('/')) url = 'https://uakinogo.io' + url;
+                if (!url.startsWith('http')) return;
+                if (!url.includes('uakinogo.io/')) return;
+                if (url.includes('do=search') || url.includes('/index.php')) return;
+                if (!results.find(r => r.id === id)) results.push({ url, id, slug: slug || '' });
+            };
+
+            const reHref = /href\s*=\s*["']([^"']*?\/(\d+)-([^"'/]+)\.html(?:#[^"']*)?)["']/g;
+            const reEscAbs = /(https?:\\\\\/\\\\\/uakinogo\.io\\\\\/[^"']*?\\\\\/(\d+)-([^"\\\/]+)\.html)/g;
+            const reEscRel = /(\\\\\/[^"']*?\\\\\/(\d+)-([^"\\\/]+)\.html)/g;
             let m;
-            while ((m = reAbs.exec(html)) !== null) addResult(m[1], m[2], m[3]);
-            while ((m = reRel.exec(html)) !== null) addResult(m[1], m[2], m[3]);
-            return results;
-        };
-
-        const looksLikeChallenge = (html) => {
-            const t = String(html || '');
-            if (!t) return true;
-            if (t.includes('cf-challenge') || t.includes('cf-browser-verification')) return true;
-            if (/Just a moment/i.test(t) && /Cloudflare/i.test(t)) return true;
-            if (t.includes('data-sitekey') && t.includes('cf-turnstile')) return true;
-            return false;
-        };
-
-        fetchRaw(searchUrl, { 'user-agent': 'Mozilla/5.0 Chrome/120', 'referer': 'https://uakinogo.io/' }).then(async html => {
-            let results = parseSearchHtml(html);
-            const challenged = looksLikeChallenge(html);
-            if ((challenged || results.length === 0) && typeof getStreams === 'function' && getStreams.toString) {
-                try {
-                    const { getBrowser } = require('./alloha');
-                    const browser = await getBrowser();
-                    const page = await browser.newPage();
-                    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', 'Referer': 'https://uakinogo.io/' });
-                    await page.goto(searchUrl, { waitUntil: 'networkidle2', timeout: 25000 });
-                    await new Promise(r => setTimeout(r, 1200));
-                    const html2 = await page.content();
-                    await page.close();
-                    results = parseSearchHtml(html2);
-                } catch (e) {}
-            }
-
-            try { console.log('[uakinogo/search] results:', results.length, results[0] ? results[0].url : 'none'); } catch (e) {}
-            jsonResp(res, { ok: true, results: results.slice(0, 10) });
-        }).catch(e => jsonResp(res, { ok: false, error: e.message }, 500));
+            while ((m = reHref.exec(html)) !== null) addResult(m[1], m[2], m[3]);
+            while ((m = reEscAbs.exec(html)) !== null) addResult(m[1].replace(/\\\\\//g, '/'), m[2], m[3]);
+            while ((m = reEscRel.exec(html)) !== null) addResult(m[1].replace(/\\\\\//g, '/'), m[2], m[3]);
+            return results;
+        };
+
+        const looksLikeChallenge = (html) => {
+            const t = String(html || '');
+            if (!t) return true;
+            if (t.includes('cf-challenge') || t.includes('cf-browser-verification')) return true;
+            if (/Just a moment/i.test(t) && /Cloudflare/i.test(t)) return true;
+            if (t.includes('data-sitekey') && t.includes('cf-turnstile')) return true;
+            return false;
+        };
+
+        const fetchAndParse = async (url) => {
+            const html = await fetchRaw(url, { 'user-agent': 'Mozilla/5.0 Chrome/120', 'referer': 'https://uakinogo.io/' });
+            return { html, results: parseSearchHtml(html), challenged: looksLikeChallenge(html) };
+        };
+
+        fetchAndParse(searchUrlSeo).then(async (first) => {
+            let html = first.html;
+            let results = first.results;
+            let challenged = first.challenged;
+
+            if (challenged || results.length === 0) {
+                try {
+                    const second = await fetchAndParse(searchUrlLegacy);
+                    if (second.results.length > results.length) {
+                        html = second.html;
+                        results = second.results;
+                        challenged = challenged || second.challenged;
+                    }
+                } catch (e) {}
+            }
+
+            if ((challenged || results.length === 0) && typeof getStreams === 'function' && getStreams.toString) {
+                try {
+                    const { getBrowser } = require('./alloha');
+                    const browser = await getBrowser();
+                    const page = await browser.newPage();
+                    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', 'Referer': 'https://uakinogo.io/' });
+
+                    await page.goto(searchUrlSeo, { waitUntil: 'networkidle2', timeout: 25000 });
+                    try { await page.waitForSelector('a[href*=".html"]', { timeout: 8000 }); } catch (e) {}
+                    await new Promise(r => setTimeout(r, 1200));
+                    const html2 = await page.content();
+                    await page.close();
+
+                    const parsed = parseSearchHtml(html2);
+                    if (parsed.length >= results.length) {
+                        html = html2;
+                        results = parsed;
+                        challenged = looksLikeChallenge(html2);
+                    }
+                } catch (e) {}
+            }
+
+            try { console.log('[uakinogo/search] results:', results.length, results[0] ? results[0].url : 'none'); } catch (e) {}
+            if (results.length === 0) {
+                try {
+                    const t = String(html || '');
+                    console.log('[uakinogo/search] html:', 'len=' + t.length, 'cf=' + (looksLikeChallenge(t) ? '1' : '0'), 'sample=' + t.slice(0, 160).replace(/\s+/g, ' '));
+                } catch (e) {}
+            }
+            jsonResp(res, { ok: true, results: results.slice(0, 10) });
+        }).catch(e => jsonResp(res, { ok: false, error: e.message }, 500));
         return;
     }