Update index.js

index.js

@@ -129,24 +129,12 @@ function processStreams(streams, type) {
   const maxSize = type === 'series' ? MAX_SIZE_GB_SERIES : MAX_SIZE_GB_MOVIE;
 
   const filtered = streams.filter(s => {
-    if (!s.infoHash && !s.url) {
-      console.log(`[processStreams] Filtering out stream with no infoHash/url`);
-      return false;
-    }
-    if (s._provider && !ALLOWED_PROVIDERS.includes(s._provider.toLowerCase())) {
-      console.log(`[processStreams] Filtering out provider: ${s._provider}`);
-      return false;
-    }
+    if (!s.infoHash && !s.url) return false;
+    if (s._provider && !ALLOWED_PROVIDERS.includes(s._provider.toLowerCase())) return false;
     const q = s._quality || getQuality(s.title || s.name || '');
-    if (!q || !ALLOWED_QUALITIES.includes(q)) {
-      console.log(`[processStreams] Filtering out quality: ${q}`);
-      return false;
-    }
+    if (!q || !ALLOWED_QUALITIES.includes(q)) return false;
     const sizeGB = s._sizeGB ?? getSizeGB(s);
-    if (sizeGB !== null && sizeGB > maxSize) {
-      console.log(`[processStreams] Filtering out oversized: ${sizeGB}GB > ${maxSize}GB`);
-      return false;
-    }
+    if (sizeGB !== null && sizeGB > maxSize) return false;
     return true;
   });
 
@@ -156,10 +144,7 @@ function processStreams(streams, type) {
   const unique = filtered.filter(s => {
     const key = (s.infoHash || '').toLowerCase();
     if (!key) return true;
-    if (seen.has(key)) {
-      console.log(`[processStreams] Deduping: ${key}`);
-      return false;
-    }
+    if (seen.has(key)) return false;
     seen.add(key);
     return true;
   });
@@ -283,7 +268,7 @@ async function scrapeSubsPlease(title, season, episode) {
 }
 
 // ═══════════════════════════════════════════════════════════════════════════
-// APIBAY SCRAPER (THE PIRATE BAY)
+// APIBAY SCRAPER (WITH RETRY & PROXY)
 // ═══════════════════════════════════════════════════════════════════════════
 async function scrapeAPIBay(title, year, season, episode) {
   if (!title) return [];
@@ -296,10 +281,25 @@ async function scrapeAPIBay(title, year, season, episode) {
     }
     
     console.log(`[APIBay] 🔍 Searching: ${query}`);
-    const { data } = await axios.get(
-      `https://apibay.org/q.php?q=${encodeURIComponent(query)}&cat=208`,
-      { timeout: 12000, headers: { 'User-Agent': UA } }
-    );
+    
+    // Try direct first, then with proxy if 403
+    let data;
+    try {
+      const res = await axios.get(
+        `https://apibay.org/q.php?q=${encodeURIComponent(query)}&cat=208`,
+        { timeout: 8000, headers: { 'User-Agent': UA } }
+      );
+      data = res.data;
+    } catch (e) {
+      if (e.response?.status === 403) {
+        console.log(`[APIBay] 403 - Trying with proxy...`);
+        const proxyUrl = `https://corsproxy.io/?url=${encodeURIComponent(`https://apibay.org/q.php?q=${encodeURIComponent(query)}&cat=208`)}`;
+        const res = await axios.get(proxyUrl, { timeout: 10000, headers: { 'User-Agent': UA } });
+        data = res.data;
+      } else {
+        throw e;
+      }
+    }
     
     console.log(`[APIBay] 📡 Response type: ${typeof data}, is array: ${Array.isArray(data)}`);
     
@@ -309,7 +309,7 @@ async function scrapeAPIBay(title, year, season, episode) {
     }
     
     const streams = [];
-    for (const item of data) {
+    for (const item of data.slice(0, 15)) {
       if (!item.info_hash || !item.name) continue;
       
       const magnet = `magnet:?xt=urn:btih:${item.info_hash.toLowerCase()}&dn=${encodeURIComponent(item.name)}${TR}`;
@@ -339,7 +339,7 @@ async function scrapeAPIBay(title, year, season, episode) {
 }
 
 // ═══════════════════════════════════════════════════════════════════════════
-// TORRENTS.CSV SCRAPER
+// TORRENTS.CSV SCRAPER (FIXED FOR NEW API FORMAT)
 // ═══════════════════════════════════════════════════════════════════════════
 async function scrapeTorrentsCSV(title, year, season, episode) {
   if (!title) return [];
@@ -353,23 +353,35 @@ async function scrapeTorrentsCSV(title, year, season, episode) {
     
     console.log(`[Torrents.csv] 🔍 Searching: ${query}`);
     const { data } = await axios.get(
-      `https://torrents-csv.com/service/search?q=${encodeURIComponent(query)}`,
-      { timeout: 12000, headers: { 'User-Agent': UA } }
+      `https://torrents-csv.com/service/search?q=${encodeURIComponent(query)}&limit=15`,
+      { timeout: 8000, headers: { 'User-Agent': UA } }
     );
     
-    console.log(`[Torrents.csv] 📡 Response type: ${typeof data}, is array: ${Array.isArray(data)}`);
+    console.log(`[Torrents.csv] 📡 Response type: ${typeof data}`);
     
-    if (!Array.isArray(data) || data.length === 0) {
+    // Handle different response formats
+    let torrents = [];
+    if (Array.isArray(data)) {
+      torrents = data;
+    } else if (data && typeof data === 'object' && data.torrents && Array.isArray(data.torrents)) {
+      torrents = data.torrents;
+    } else if (data && typeof data === 'object' && data.results && Array.isArray(data.results)) {
+      torrents = data.results;
+    }
+    
+    console.log(`[Torrents.csv] Parsed torrents array: ${torrents.length} items`);
+    
+    if (!torrents || torrents.length === 0) {
       console.log(`[Torrents.csv] ❌ No results or invalid format`);
       return [];
     }
     
     const streams = [];
-    for (const item of data) {
+    for (const item of torrents) {
       if (!item.infohash || !item.name) continue;
       
       const magnet = `magnet:?xt=urn:btih:${item.infohash.toLowerCase()}&dn=${encodeURIComponent(item.name)}${TR}`;
-      const sizeGB = item.size ? item.size / 1073741824 : null;
+      const sizeGB = item.size_bytes ? item.size_bytes / 1073741824 : (item.size ? item.size / 1073741824 : null);
       const sizeStr = sizeGB ? sizeGB.toFixed(2) + ' GB' : 'N/A';
       const langLine = getLangLine(item.name || '');
       const seeders = item.seeders || 0;
@@ -574,7 +586,5 @@ app.get('/', (req, res) => {
 app.listen(PORT, '0.0.0.0', () => {
   console.log(`\n${'='.repeat(70)}`);
   console.log(`✅ VanStreams+ Running on port ${PORT}`);
-  console.log(`🔗 http://localhost:${PORT}/`);
-  console.log(`📊 Diagnostics: http://localhost:${PORT}/diag/series/tt1234567:1:1`);
   console.log(`${'='.repeat(70)}\n`);
 });