Update index.js

index.js

@@ -15,6 +15,7 @@ app.use((req, res, next) => {
 });
 
 const TMDB_KEY        = '83d364331c40bfbe29858aeed82f45cc';
+const TORBOX_KEY      = process.env.TORBOX_KEY || '424b91b9-a79f-4817-96c1-d4c720b95983';
 const UA              = 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/124.0.0.0 Safari/537.36';
 const TORRENTIO_BASE  = 'https://torrentio.strem.fun';
 
@@ -32,11 +33,12 @@ const QUALITY_RANK = {
   '4k': 5, '2160p': 5, 'webrip': 6, 'webdl': 6,
 };
 
-const PRIORITY_PROVIDERS = ['yts', 'knaben', 'torrentsdb', 'eztv', 'nyaasi', 'thepiratebay'];
+const PRIORITY_PROVIDERS = ['yts', 'knaben', 'torbox', 'torrentsdb', 'eztv', 'nyaasi', 'thepiratebay'];
 
 const ALLOWED_PROVIDERS = [
   'yts',
   'knaben',
+  'torbox',
   'thepiratesbay',
   'thepiratebay',
   'eztv',
@@ -258,6 +260,53 @@ async function scrapeYTS(imdbId) {
   } catch (e) { console.error('[YTS]', e.message); return []; }
 }
 
+async function scrapeTorbox(title, year, isSeries, season, episode) {
+  if (!title || !TORBOX_KEY) return [];
+  try {
+    let query = title;
+    if (year && !isSeries) query += ' ' + year;
+    if (isSeries && season && episode)
+      query += ` S${String(season).padStart(2, '0')}E${String(episode).padStart(2, '0')}`;
+
+    const { data } = await axios.get(
+      `https://api.torbox.app/v1/api/search`,
+      {
+        params: { query, token: TORBOX_KEY, limit: 40 },
+        timeout: 14000,
+        headers: { 'User-Agent': UA }
+      }
+    );
+
+    if (!data?.data?.length) return [];
+    const streams = [];
+
+    for (const result of data.data) {
+      if (!result.hash) continue;
+
+      const name = result.title || result.name || '';
+      const sizeGB = result.size ? result.size / 1073741824 : null;
+      const sizeStr = sizeGB ? sizeGB.toFixed(2) + ' GB' : '';
+      const seeders = result.seeders || 0;
+      const langLine = getLangLine(name);
+
+      streams.push({
+        infoHash: result.hash.toLowerCase(),
+        name: name,
+        title: `☀️ ${title}${year ? ' (' + year + ')' : ''}\n🌱 ${seeders}\n💾 ${sizeStr}\n🏅 Torbox${langLine ? '\n🔊 ' + langLine : ''}`,
+        sources: [],
+        _quality: getQuality(name),
+        _seeders: seeders,
+        _sizeGB: sizeGB,
+        _source: 'torbox',
+        _provider: 'torbox',
+      });
+    }
+
+    console.log(`[Torbox] ${streams.length} for "${query}"`);
+    return streams;
+  } catch (e) { console.error('[Torbox]', e.message); return []; }
+}
+
 async function scrapeKnaben(title, year, isSeries, season, episode) {
   if (!title) return [];
   try {
@@ -356,19 +405,21 @@ app.get('/stream/:type/:id.json', async (req, res) => {
   const title = meta?.title || '';
   const year  = meta?.year  || '';
 
-  const [ytsR, knabenR, torrentioR] = await Promise.allSettled([
+  const [ytsR, torboxR, knabenR, torrentioR] = await Promise.allSettled([
     isSeries ? Promise.resolve([]) : scrapeYTS(imdbId),
+    scrapeTorbox(title, year, isSeries, season, episode),
     scrapeKnaben(title, year, isSeries, season, episode),
     fetchTorrentio(type, id, title, year),
   ]);
 
   const yts       = ytsR.status       === 'fulfilled' ? (ytsR.value       || []) : [];
+  const torbox    = torboxR.status    === 'fulfilled' ? (torboxR.value    || []) : [];
   const knaben    = knabenR.status    === 'fulfilled' ? (knabenR.value    || []) : [];
   const torrentio = torrentioR.status === 'fulfilled' ? (torrentioR.value || []) : [];
 
-  const streams = processStreams([...yts, ...knaben, ...torrentio], type);
+  const streams = processStreams([...yts, ...torbox, ...knaben, ...torrentio], type);
 
-  console.log(`[stream] ${type}/${id} → yts:${yts.length} knaben:${knaben.length} torrentio:${torrentio.length} final:${streams.length}`);
+  console.log(`[stream] ${type}/${id} → yts:${yts.length} torbox:${torbox.length} knaben:${knaben.length} torrentio:${torrentio.length} final:${streams.length}`);
   res.json({ streams });
 });
 
@@ -378,8 +429,9 @@ app.get('/diag/:type/:id', async (req, res) => {
   const isSeries = type === 'series';
   const [imdbId, season = '', episode = ''] = id.split(':');
   const meta = await tmdbLookup(imdbId);
-  const [ytsR, knabenR, torrentioR] = await Promise.allSettled([
+  const [ytsR, torboxR, knabenR, torrentioR] = await Promise.allSettled([
     isSeries ? Promise.resolve([]) : scrapeYTS(imdbId),
+    scrapeTorbox(meta?.title || '', meta?.year || '', isSeries, season, episode),
     scrapeKnaben(meta?.title || '', meta?.year || '', isSeries, season, episode),
     fetchTorrentio(type, id, meta?.title || '', meta?.year || ''),
   ]);
@@ -387,6 +439,7 @@ app.get('/diag/:type/:id', async (req, res) => {
     imdbId, title: meta?.title, year: meta?.year, isSeries,
     tmdb:      meta ? `OK: ${meta.title} (${meta.year})` : 'FAILED',
     yts:       { count: (ytsR.value       || []).length, err: ytsR.reason?.message       || null },
+    torbox:    { count: (torboxR.value    || []).length, err: torboxR.reason?.message    || null },
     knaben:    { count: (knabenR.value    || []).length, err: knabenR.reason?.message    || null },
     torrentio: { count: (torrentioR.value || []).length, err: torrentioR.reason?.message || null },
   });
@@ -497,14 +550,18 @@ app.get('/', (req, res) => {
       </div>
     </div>
     <div class="stats">
-      <div class="stat"><div class="stat-val">100K+</div><div class="stat-lbl">Movies</div></div>
-      <div class="stat"><div class="stat-val">40K+</div><div class="stat-lbl">Series</div></div>
-      <div class="stat"><div class="stat-val">20K+</div><div class="stat-lbl">Anime</div></div>
+      <div class="stat"><div class="stat-val">100K+</div><div class="stat-lbl">Torrents</div></div>
+      <div class="stat"><div class="stat-val">4</div><div class="stat-lbl">Sources</div></div>
+      <div class="stat"><div class="stat-val">24/7</div><div class="stat-lbl">Online</div></div>
     </div>
-    <div class="made-by">Made With 🤍 By Van</div>
+    <div class="made-by">Made with 🤍 by Van</div>
   </div>
 </body>
 </html>`);
 });
 
-app.listen(PORT, '0.0.0.0', () => console.log('VanStreams+ 🎬 v7.0.5 on :' + PORT));
+// ─── Server startup ────────────────────────────────────────────────
+app.listen(PORT, () => {
+  console.log(`🎬 VanStreams+ running on port ${PORT}`);
+  console.log(`API Key configured: ${TORBOX_KEY ? 'YES' : 'NO'}`);
+});