Update index.js

index.js

@@ -14,13 +14,9 @@ app.use((req, res, next) => {
   next();
 });
 
-const TMDB_KEY        = '83d364331c40bfbe29858aeed82f45cc';
-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';
-
-const PROXY_1 = 'https://corsproxy.io/?url=';
-const PROXY_2 = 'https://api.codetabs.com/v1/proxy?quest=';
-const PROXY_3 = 'https://thingproxy.freeboard.io/fetch/';
+const TMDB_KEY         = '83d364331c40bfbe29858aeed82f45cc';
+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 TORRENTCLAW_API  = 'https://torrentclaw.com/api/stremio';
 
 const MAX_SIZE_GB_MOVIE  = 4;
 const MAX_SIZE_GB_SERIES = 1.5;
@@ -32,7 +28,7 @@ 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', 'torrentsdb', 'eztv', 'nyaasi', 'thepiratebay', 'torrentclaw'];
 
 const ALLOWED_PROVIDERS = [
   'yts',
@@ -46,7 +42,9 @@ const ALLOWED_PROVIDERS = [
   'limetorrent',
   'kickasstorrents',
   'animetosho',
-  'tokyotosho'
+  'tokyotosho',
+  'torrentclaw',
+  'unknown'
 ];
 
 const TR = [
@@ -62,27 +60,6 @@ const TR = [
   'https://tracker.zhuqiy.com:443/announce',
 ].map(t => '&tr=' + encodeURIComponent(t)).join('');
 
-// ─── Proxy fallback function ────────────────────────────────────────
-async function fetchWithProxy(url, options = {}) {
-  const proxies = [
-    url,
-    PROXY_1 + encodeURIComponent(url),
-    PROXY_2 + encodeURIComponent(url),
-    PROXY_3 + encodeURIComponent(url),
-  ];
-
-  for (const proxyUrl of proxies) {
-    try {
-      const response = await axios.get(proxyUrl, { timeout: 12000, headers: { 'User-Agent': UA }, ...options });
-      return response;
-    } catch (e) {
-      console.warn(`[Proxy] Failed: ${proxyUrl.substring(0, 50)}... Error: ${e.message}`);
-      continue;
-    }
-  }
-  throw new Error('All proxy attempts failed');
-}
-
 function buildMagnet(hash, name) {
   return 'magnet:?xt=urn:btih:' + hash.toLowerCase() + '&dn=' + encodeURIComponent(name) + TR;
 }
@@ -224,111 +201,63 @@ async function tmdbLookup(imdbId) {
   } catch (e) { console.error('[TMDB]', e.message); return null; }
 }
 
-async function scrapeYTS(imdbId) {
+// ─── TorrentClaw scraper (replaces YTS / Knaben / Torrentio) ───────────
+async function scrapeTorrentClaw(type, imdbId, title, year, season, episode) {
   try {
-    const { data } = await axios.get(
-      `https://movies-api.accel.li/api/v2/list_movies.json?query_term=${imdbId}&limit=10`,
-      { timeout: 12000, headers: { 'User-Agent': UA } }
-    );
-    if (data.status !== 'ok' || !data.data?.movies?.length) return [];
-    const streams = [];
-    for (const movie of data.data.movies) {
-      if (movie.imdb_code && movie.imdb_code !== imdbId) continue;
-      for (const t of (movie.torrents || [])) {
-        if (!t.hash) continue;
-        const qualityStr = `${t.quality} ${t.type || ''}`.trim();
-        const sizeGB     = t.size_bytes ? t.size_bytes / 1073741824 : null;
-        const sizeStr    = sizeGB ? sizeGB.toFixed(2) + ' GB' : (t.size || '');
-        const langLine   = getLangLine(qualityStr);
-        streams.push({
-          infoHash: t.hash.toLowerCase(),
-          name:     qualityStr,
-          title:    `☀️ ${movie.title} (${movie.year})\n🌱 ${t.seeds || 0}\n💾 ${sizeStr}\n🏅 YTS${langLine ? '\n🔊 ' + langLine : ''}`,
-          sources:  [],
-          _quality: getQuality(qualityStr),
-          _seeders: t.seeds || 0,
-          _sizeGB:  sizeGB,
-          _source:  'yts',
-          _provider: 'yts',
-        });
-      }
-    }
-    console.log(`[YTS] ${streams.length} for ${imdbId}`);
-    return streams;
-  } catch (e) { console.error('[YTS]', e.message); return []; }
-}
+    const isSeries = type === 'series';
+    const path      = isSeries
+      ? `series/${imdbId}:${season || 1}:${episode || 1}`
+      : `movie/${imdbId}`;
+    const url = `${TORRENTCLAW_API}/stream/${path}.json`;
+
+    const { data } = await axios.get(url, {
+      timeout: 15000,
+      headers: { 'User-Agent': UA, 'Accept': 'application/json' },
+    });
+
+    if (!data || !Array.isArray(data.streams) || data.streams.length === 0) return [];
 
-async function scrapeKnaben(title, year, isSeries, season, episode) {
-  if (!title) 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 categories = isSeries ? [5000000, 5001000] : [2000000, 2001000];
-    const { data } = await axios.post(
-      'https://api.knaben.org/v1',
-      { search_type: '75%', search_field: 'title', query, order_by: 'seeders', order_direction: 'desc', categories, from: 0, size: 40, hide_unsafe: true, hide_xxx: true },
-      { timeout: 14000, headers: { 'Content-Type': 'application/json', Accept: 'application/json', 'User-Agent': UA } }
-    );
-    if (!data?.hits?.length) return [];
     const streams = [];
-    for (const hit of data.hits) {
-      if (!hit.magnetUrl && !hit.hash) continue;
-      const magnet    = hit.magnetUrl || buildMagnet(hit.hash, hit.title || '');
-      const hashMatch = magnet.match(/btih:([a-fA-F0-9]{32,40})/i);
-      const hash      = hashMatch ? hashMatch[1] : (hit.hash || '');
-      if (!hash) continue;
-      const sizeGB  = hit.bytes ? hit.bytes / 1073741824 : null;
-      const sizeStr = sizeGB ? sizeGB.toFixed(2) + ' GB' : '';
-      const langLine = getLangLine(hit.title || '');
+    for (const item of data.streams) {
+      if (!item) continue;
+
+      const rawName  = item.name || '';
+      const rawTitle = item.title || '';
+      const rawDesc  = item.description || '';
+      const combined = `${rawName} ${rawTitle} ${rawDesc}`.replace(/\n/g, ' ');
+
+      const infoHashMatch = (item.url || '').match(/btih:([a-fA-F0-9]{32,40})/i);
+      const infoHash = item.infoHash || (infoHashMatch ? infoHashMatch[1] : null);
+      if (!infoHash && !item.url) continue;
+
+      const sizeGB = getSizeGB({ title: combined })
+        ?? (typeof item.size === 'number' ? item.size / 1073741824 : null)
+        ?? (typeof item.bytes === 'number' ? item.bytes / 1073741824 : null);
+      const sizeStr = sizeGB ? sizeGB.toFixed(2) + ' GB' : 'N/A';
+
+      const seeders = typeof item.seeders === 'number'
+        ? item.seeders
+        : (() => { const m = combined.match(/🌱\s*(\d+)/) || combined.match(/👤\s*(\d+)/) || combined.match(/(\d+)\s*seed/i); return m ? parseInt(m[1], 10) : 0; })();
+
+      const provider = (item.provider || item.source || item.indexer || 'TorrentClaw').toString().toLowerCase();
+      const langLine = getLangLine(combined);
+
       streams.push({
-        infoHash: hash.toLowerCase(),
-        name:     hit.title || '',
-        title:    `☀️ ${title}${year ? ' (' + year + ')' : ''}\n🌱 ${hit.seeders || 0}\n💾 ${sizeStr}\n🏅 Knaben${langLine ? '\n🔊 ' + langLine : ''}`,
+        infoHash: infoHash ? infoHash.toLowerCase() : undefined,
+        url:      infoHash ? undefined : item.url,
+        name:     rawName || rawTitle,
+        title:    `☀️ ${title}${year ? ' (' + year + ')' : ''}\n🌱 ${seeders}\n💾 ${sizeStr}\n🏅 TorrentClaw${langLine ? '\n🔊 ' + langLine : ''}`,
         sources:  [],
-        _quality: getQuality(hit.title || ''),
-        _seeders: hit.seeders || 0,
+        _quality: getQuality(combined),
+        _seeders: seeders,
         _sizeGB:  sizeGB,
-        _source:  'knaben',
-        _provider: 'knaben',
+        _source:  'torrentclaw',
+        _provider: 'torrentclaw',
       });
     }
-    console.log(`[Knaben] ${streams.length} for "${query}"`);
+    console.log(`[TorrentClaw] ${streams.length} for ${type}/${imdbId}`);
     return streams;
-  } catch (e) { console.error('[Knaben]', e.message); return []; }
-}
-
-async function fetchTorrentio(type, id, title, year) {
-  try {
-    const url = `${TORRENTIO_BASE}/stream/${type}/${id}.json`;
-    const { data } = await fetchWithProxy(url);
-    const streams = (data.streams || []).map(s => {
-      const origTitle = s.title || '';
-      const providerMatch = (s.title || '').match(/⚙️\s*(\S+)/);
-      let provider = providerMatch ? providerMatch[1] : 'Unknown';
-      provider = provider.toLowerCase().replace(/\.(to|com|org|net|io)$/, '');
-      if (provider === 'thepiratebay') provider = 'thepiratesbay';
-      if (provider === 'nyaa.si') provider = 'nyaa';
-      if (provider === 'limetorrents') provider = 'limetorrent';
-      if (provider === 'kat') provider = 'kickasstorrents';
-      const seeders = s.behaviorHints?.seeders
-        ?? (() => { const m = (s.title || '').match(/👤\s*(\d+)/); return m ? parseInt(m[1], 10) : 0; })();
-      const sizeGB = getSizeGB(s);
-      const langLine = getLangLine(origTitle);
-      return {
-        ...s,
-        title:    `☀️ ${title}${year ? ' (' + year + ')' : ''}\n🌱 ${seeders}\n💾 ${sizeGB ? sizeGB.toFixed(2) + ' GB' : 'N/A'}\n🏅 ${provider}${langLine ? '\n🔊 ' + langLine : ''}`,
-        _quality: getQuality(s.title || s.name || ''),
-        _seeders: seeders,
-        _sizeGB:  sizeGB,
-        _source:  'torrentio',
-        _provider: provider,
-      };
-    });
-    console.log(`[Torrentio] ${streams.length} for ${type}/${id}`);
-    return streams;
-  } catch (e) { console.error('[Torrentio]', e.message); return []; }
+  } catch (e) { console.error('[TorrentClaw]', e.message); return []; }
 }
 
 // ─── Manifest ──────────────────────────────────────────────────────────
@@ -356,19 +285,11 @@ app.get('/stream/:type/:id.json', async (req, res) => {
   const title = meta?.title || '';
   const year  = meta?.year  || '';
 
-  const [ytsR, knabenR, torrentioR] = await Promise.allSettled([
-    isSeries ? Promise.resolve([]) : scrapeYTS(imdbId),
-    scrapeKnaben(title, year, isSeries, season, episode),
-    fetchTorrentio(type, id, title, year),
-  ]);
-
-  const yts       = ytsR.status       === 'fulfilled' ? (ytsR.value       || []) : [];
-  const knaben    = knabenR.status    === 'fulfilled' ? (knabenR.value    || []) : [];
-  const torrentio = torrentioR.status === 'fulfilled' ? (torrentioR.value || []) : [];
+  const torrentclaw = await scrapeTorrentClaw(type, imdbId, title, year, season, episode);
 
-  const streams = processStreams([...yts, ...knaben, ...torrentio], type);
+  const streams = processStreams(torrentclaw, type);
 
-  console.log(`[stream] ${type}/${id} → yts:${yts.length} knaben:${knaben.length} torrentio:${torrentio.length} final:${streams.length}`);
+  console.log(`[stream] ${type}/${id} → torrentclaw:${torrentclaw.length} final:${streams.length}`);
   res.json({ streams });
 });
 
@@ -378,28 +299,23 @@ 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([
-    isSeries ? Promise.resolve([]) : scrapeYTS(imdbId),
-    scrapeKnaben(meta?.title || '', meta?.year || '', isSeries, season, episode),
-    fetchTorrentio(type, id, meta?.title || '', meta?.year || ''),
-  ]);
+  const torrentclaw = await scrapeTorrentClaw(type, imdbId, meta?.title || '', meta?.year || '', season, episode);
   res.json({
     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 },
-    knaben:    { count: (knabenR.value    || []).length, err: knabenR.reason?.message    || null },
-    torrentio: { count: (torrentioR.value || []).length, err: torrentioR.reason?.message || null },
+    tmdb:        meta ? `OK: ${meta.title} (${meta.year})` : 'FAILED',
+    torrentclaw: { count: torrentclaw.length },
   });
 });
 
 app.get('/diag-raw/:type/:id', async (req, res) => {
   const { type, id } = req.params;
   try {
-    const url = `${TORRENTIO_BASE}/stream/${type}/${id}.json`;
-    const { data } = await fetchWithProxy(url);
-    res.json((data.streams || []).slice(0, 3).map(s => ({
-      name: s.name, title: s.title, behaviorHints: s.behaviorHints,
-    })));
+    const isSeries = type === 'series';
+    const [imdbId, season = '', episode = ''] = id.split(':');
+    const path = isSeries ? `series/${imdbId}:${season || 1}:${episode || 1}` : `movie/${imdbId}`;
+    const url = `${TORRENTCLAW_API}/stream/${path}.json`;
+    const { data } = await axios.get(url, { timeout: 15000, headers: { 'User-Agent': UA, 'Accept': 'application/json' } });
+    res.json((data.streams || []).slice(0, 3));
   } catch (e) { res.json({ error: e.message }); }
 });