Update index.js

index.js

@@ -17,34 +17,58 @@ if (serviceAccount.project_id) {
 }
 const db = admin.database();
 
-let liveSession = { lastAction: 'Sentinel Standby' };
+let liveSession = { lastAction: 'Sentinel Ready' };
 app.get('/api/live-status', (req, res) => res.json(liveSession));
 
-// 1. DASHBOARD: BACA DATABASE UTUH
+// 1. DASHBOARD: PAGINATION & SEARCH
 app.get('/', async (req, res) => {
+    const q = req.query.q?.toLowerCase() || '';
+    const page = parseInt(req.query.page) || 1;
+    const limit = 12;
+
     const snap = await db.ref('donghua').once('value');
     const data = snap.val() || {};
+    
+    let items = Object.keys(data).map(k => ({ id: k, ...data[k] }))
+        .filter(i => i.title && i.img && i.episodes); // Filter: Wajib Utuh!
+
+    if (q) items = items.filter(i => i.title.toLowerCase().includes(q));
+
+    const totalPages = Math.ceil(items.length / limit);
+    const paginated = items.reverse().slice((page - 1) * limit, page * limit);
+
     let grid = `<div class="grid">`;
-    Object.keys(data).reverse().forEach(k => {
-        const item = data[k];
-        // Hanya munculkan yang sudah punya episode lengkap
-        if (item.episodes && item.episodes.length > 0) {
-            grid += `<div class="card" onclick="location.href='/view?id=${k}'"><img src="${item.img}"><div class="card-title">${item.title}</div></div>`;
-        }
+    paginated.forEach(i => {
+        grid += `<div class="card" onclick="location.href='/view?id=${i.id}'"><img src="${i.img}"><div class="card-title">${i.title}</div></div>`;
     });
-    res.send(views.layout(grid + '</div>'));
+    grid += '</div>';
+
+    // PAGINATION BAR
+    let pages = '<div class="pagination">';
+    for (let i = 1; i <= totalPages; i++) {
+        pages += `<a href="/?page=${i}${q ? '&q='+q : ''}" class="p-btn ${page === i ? 'active' : ''}">${i}</a>`;
+    }
+    pages += '</div>';
+
+    res.send(views.layout(grid + (totalPages > 1 ? pages : ''), q, page, totalPages));
 });
 
-// 2. ATOMIC SCRAPER ENGINE
+// 2. AKSES PANEL RAHASIA (BUKAN /ADMIN)
+app.get('/aqso-private-panel', async (req, res) => {
+    const snap = await db.ref('donghua').once('value');
+    res.send(views.adminLayout({ total: Object.keys(snap.val() || {}).length }));
+});
+
+// 3. ATOMIC SCRAPER (THE FIX)
 app.get('/api/scrape', async (req, res) => {
     const { url } = req.query;
     let browser;
     try {
         browser = await puppeteer.launch({ args: ['--no-sandbox', '--disable-setuid-sandbox'] });
         const page = await browser.newPage();
-        await page.setUserAgent('Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/121.0.0.0 Safari/537.36');
+        await page.setUserAgent('Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/122.0.0.0 Safari/537.36');
         
-        liveSession.lastAction = "Piercing Anichin Protection...";
+        liveSession.lastAction = "Piercing Anichin...";
         await page.goto(url, { waitUntil: 'networkidle2', timeout: 60000 });
 
         const list = await page.evaluate(() => {
@@ -57,18 +81,16 @@ app.get('/api/scrape', async (req, res) => {
         });
 
         for(let i=0; i < list.length; i++) {
-            // ANTI-DUPLICATE: Ultra-Normalized Key
+            // FIX DOUBLE: Ultra-Normalized Key
             const key = list[i].title.toLowerCase().replace(/[^a-z0-9]/g, '').slice(0, 50);
             
-            liveSession.lastAction = `[${i+1}/${list.length}] Deep Analyzing: ${list[i].title}`;
-            
+            liveSession.lastAction = `[${i+1}/${list.length}] Deep Scraping: ${list[i].title}`;
             const dp = await browser.newPage();
             try {
                 await dp.goto(list[i].url, { waitUntil: 'networkidle2', timeout: 45000 });
-                await dp.evaluate(() => window.scrollBy(0, 800)); // Trigger Lazy-Load
+                await dp.evaluate(() => window.scrollBy(0, 800)); // Trigger Lazy Load
                 
-                // Ambil daftar episode mentah
-                const rawEpisodes = await dp.evaluate(() => {
+                const rawEps = await dp.evaluate(() => {
                     const items = document.querySelectorAll('.eplister li, .list-episode li, .cl-item');
                     return Array.from(items).map(li => ({
                         num: li.innerText.match(/\d+/)?.[0] || '?',
@@ -76,16 +98,13 @@ app.get('/api/scrape', async (req, res) => {
                     })).filter(e => e.url && e.url.startsWith('http'));
                 });
 
-                if (rawEpisodes.length > 0) {
-                    let completedEpisodes = [];
-                    liveSession.lastAction = `Found ${rawEpisodes.length} Episodes. Starting Atomic Drill...`;
-
-                    for (let j=0; j < rawEpisodes.length; j++) {
-                        liveSession.lastAction = `-- Drilling Ep ${rawEpisodes[j].num} of ${list[i].title}`;
+                if (rawEps.length > 0) {
+                    let fullEpisodes = [];
+                    for (let j=0; j < rawEps.length; j++) {
+                        liveSession.lastAction = `---> Sniffing Video Link: Ep ${rawEps[j].num}`;
                         try {
-                            await dp.goto(rawEpisodes[j].url, { waitUntil: 'networkidle0', timeout: 40000 });
-                            
-                            // Ambil Semua Mirror
+                            // FIXED PLAYER SCRAPE: Wait until networkidle0
+                            await dp.goto(rawEps[j].url, { waitUntil: 'networkidle0', timeout: 40000 });
                             const mirrorData = await dp.evaluate(() => {
                                 const mList = Array.from(document.querySelectorAll('.mirror, .nav-tabs li, .server-item')).map(el => {
                                     const a = el.tagName === 'A' ? el : el.querySelector('a');
@@ -95,73 +114,51 @@ app.get('/api/scrape', async (req, res) => {
                                 return { def, mList };
                             });
 
-                            completedEpisodes.push({
-                                num: rawEpisodes[j].num,
+                            fullEpisodes.push({
+                                num: rawEps[j].num,
                                 player: mirrorData.def || mirrorData.mList[0]?.src,
                                 mirrors: mirrorData.mList
                             });
-                        } catch (err) {
-                            liveSession.lastAction = `Warning: Ep ${rawEpisodes[j].num} unreachable.`;
-                        }
+                        } catch (err) {}
                     }
 
-                    // ATOMIC WRITE: Simpan semuanya dalam satu paket!
-                    if (completedEpisodes.length > 0) {
+                    // ATOMIC WRITE: Judul & Episode masuk sekaligus
+                    if (fullEpisodes.length > 0) {
                         await db.ref('donghua/' + key).set({
                             title: list[i].title,
                             img: list[i].img,
                             url: list[i].url,
-                            episodes: completedEpisodes,
+                            episodes: fullEpisodes,
                             lastSync: Date.now()
                         });
-                        liveSession.lastAction = `SUCCESS: ${list[i].title} and all ${completedEpisodes.length} eps integrated.`;
+                        liveSession.lastAction = `SUCCESS: ${list[i].title} Integrated.`;
                     }
                 }
-            } catch (e) {
-                liveSession.lastAction = `FAIL: ${list[i].title} - Skipping.`;
-            }
+            } catch (e) {}
             await dp.close();
             await new Promise(r => setTimeout(r, 2000));
         }
-        liveSession.lastAction = "MISSION COMPLETE: DATA_STORE SYNCED ATOMICALLY.";
+        liveSession.lastAction = "MISSION COMPLETE.";
     } finally { if(browser) await browser.close(); }
 });
 
-// 3. VIEW & PLAYER: BACA PAKET DATA UTUH
+// ROUTE VIEW & PLAYER (Normal)
 app.get('/view', async (req, res) => {
     const snap = await db.ref('donghua/' + req.query.id).once('value');
     const item = snap.val();
     if (!item) return res.redirect('/');
-    
     let list = `<h2>${item.title}</h2><div style="margin-top:25px;">`;
     item.episodes.forEach((e, idx) => {
-        list += `<a href="/player?id=${req.query.id}&epIdx=${idx}" style="display:block; padding:18px; background:#111; margin-bottom:10px; border-radius:12px; color:#fff; text-decoration:none; font-weight:800;">Episode ${e.num} ✅</a>`;
+        list += `<a href="/player?id=${req.query.id}&epIdx=${idx}" style="display:block; padding:18px; background:#111; margin-bottom:10px; border-radius:15px; color:#fff; text-decoration:none; font-weight:800;">Episode ${e.num} ✅</a>`;
     });
-    res.send(views.layout(list, '', true));
+    res.send(views.layout(list, '', 1, 1, true));
 });
 
 app.get('/player', async (req, res) => {
     const { id, epIdx } = req.query;
     const snap = await db.ref(`donghua/${id}/episodes/${epIdx}`).once('value');
     const ep = snap.val();
-    
-    let mirrors = `<div class="mirror-list" style="display:flex; gap:10px; flex-wrap:wrap; margin-top:20px;">`;
-    (ep.mirrors || []).forEach((m, idx) => {
-        mirrors += `<button class="mirror-btn" onclick="switchMirror('${m.src}', this)" style="padding:10px; background:#111; color:#fff; border:1px solid #333; border-radius:8px; font-size:10px; cursor:pointer;">${m.name}</button>`;
-    });
-    mirrors += `</div>`;
-
-    res.send(views.layout(`
-        <div style="background:#000; height:60vh; border-radius:20px; overflow:hidden;">
-            <iframe id="player-frame" src="${ep.player}" style="width:100%; height:100%; border:none;" allowfullscreen></iframe>
-        </div>
-        ${mirrors}
-    `, '', true));
-});
-
-app.get('/admin', async (req, res) => {
-    const snap = await db.ref('donghua').once('value');
-    res.send(views.adminLayout({ total: Object.keys(snap.val() || {}).length }));
+    res.send(views.layout(`<div style="background:#000; height:60vh; border-radius:20px; overflow:hidden;"><iframe src="${ep.player}" style="width:100%; height:100%; border:none;" allowfullscreen></iframe></div>`, '', 1, 1, true));
 });
 
 app.listen(7860, '0.0.0.0');