Update index.js

index.js

@@ -32,7 +32,7 @@ const QUALITY_RANK = {
   '4k': 5, '2160p': 5, 'webrip': 6, 'webdl': 6,
 };
 
-const PRIORITY_PROVIDERS = ['yts', 'knaben', 'torrentproject', 'eztv', 'nyaasi', 'thepiratebay'];
+const PRIORITY_PROVIDERS = ['yts', 'knaben', 'torrentsdb', 'eztv', 'nyaasi', 'thepiratebay'];
 
 const ALLOWED_PROVIDERS = [
   'yts',
@@ -47,9 +47,17 @@ const ALLOWED_PROVIDERS = [
   'kickasstorrents',
   'animetosho',
   'tokyotosho',
-  'torrentproject',
 ];
 
+// Knaben confirmed category IDs (from live browse URLs)
+// Movies: 3000000 (all), 3001000 (HD), 3002000 (SD), 3003000 (UHD)
+// TV:     2000000 (all), 2001000 (HD), 2002000 (SD), 2003000 (UHD), 2007000 (Cartoon)
+// Anime:  6000000 (all), 6001000 (Subbed), 6002000 (Dubbed), 6003000 (Dual), 6004000 (Raw)
+// XXX blocked via hide_xxx: true
+const KNABEN_CATS_MOVIE  = [3000000, 3001000, 3002000, 3003000];
+const KNABEN_CATS_SERIES = [2000000, 2001000, 2002000, 2003000, 2007000];
+const KNABEN_CATS_ANIME  = [6000000, 6001000, 6002000, 6003000];
+
 const TR = [
   'udp://tracker.opentrackr.org:1337/announce',
   'udp://open.stealth.si:80/announce',
@@ -63,7 +71,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,
@@ -71,14 +78,12 @@ async function fetchWithProxy(url, options = {}) {
     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;
+      console.warn(`[Proxy] Failed: ${proxyUrl.substring(0, 50)}... ${e.message}`);
     }
   }
   throw new Error('All proxy attempts failed');
@@ -162,6 +167,16 @@ function getLangLine(str = '') {
   return [...new Set(found)].join(' / ');
 }
 
+function isSexualTitle(title = '') {
+  const s = title.toLowerCase();
+  const banned = [
+    'xxx', 'porn', 'sex', 'hentai', 'erotic', 'nude', 'naked', 'adult',
+    'milf', 'anal', 'blowjob', 'cumshot', 'creampie', 'gangbang', 'lesbian sex',
+    'brazzers', 'bangbros', 'mofos', 'naughty', 'onlyfans', 'playboy',
+  ];
+  return banned.some(b => s.includes(b));
+}
+
 function processStreams(streams, type) {
   const maxSize = type === 'series' ? MAX_SIZE_GB_SERIES : MAX_SIZE_GB_MOVIE;
 
@@ -172,6 +187,7 @@ function processStreams(streams, type) {
     if (!q || !ALLOWED_QUALITIES.includes(q)) return false;
     const sizeGB = s._sizeGB ?? getSizeGB(s);
     if (sizeGB !== null && sizeGB > maxSize) return false;
+    if (isSexualTitle(s.name || s.title || '')) return false;
     return true;
   });
 
@@ -219,8 +235,8 @@ async function tmdbLookup(imdbId) {
     );
     const movie = data.movie_results?.[0];
     const tv    = data.tv_results?.[0];
-    if (movie) return { title: movie.title || movie.original_title, year: (movie.release_date || '').slice(0, 4) };
-    if (tv)    return { title: tv.name || tv.original_name, year: (tv.first_air_date || '').slice(0, 4) };
+    if (movie) return { title: movie.title || movie.original_title, year: (movie.release_date || '').slice(0, 4), isAnime: false };
+    if (tv)    return { title: tv.name || tv.original_name,         year: (tv.first_air_date || '').slice(0, 4), isAnime: tv.genre_ids?.includes(16) || false };
     return null;
   } catch (e) { console.error('[TMDB]', e.message); return null; }
 }
@@ -242,14 +258,14 @@ async function scrapeYTS(imdbId) {
         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',
+          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',
         });
       }
@@ -259,23 +275,45 @@ async function scrapeYTS(imdbId) {
   } catch (e) { console.error('[YTS]', e.message); return []; }
 }
 
-async function scrapeKnaben(title, year, isSeries, season, episode) {
+async function scrapeKnaben(title, year, isSeries, isAnime, 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];
+    else if (!isSeries && year)
+      query += ' ' + year;
+
+    // Pick the right categories — no overlap between movies/TV/anime
+    let categories;
+    if (isAnime)        categories = KNABEN_CATS_ANIME;
+    else if (isSeries)  categories = KNABEN_CATS_SERIES;
+    else                categories = KNABEN_CATS_MOVIE;
+
     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 },
+      {
+        search_type:      '75%',
+        search_field:     'title',
+        query,
+        order_by:         'seeders',
+        order_direction:  'desc',
+        categories,
+        from:             0,
+        size:             50,
+        hide_unsafe:      true,
+        hide_xxx:         true,   // blocks XXX category at API level
+      },
       { 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;
+      // Post-filter: reject if title contains sexual keywords
+      if (isSexualTitle(hit.title || '')) 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 || '');
@@ -284,62 +322,22 @@ async function scrapeKnaben(title, year, isSeries, season, episode) {
       const sizeStr = sizeGB ? sizeGB.toFixed(2) + ' GB' : '';
       const langLine = getLangLine(hit.title || '');
       streams.push({
-        infoHash: hash.toLowerCase(),
-        name:     hit.title || '',
-        title:    `☀️ ${title}${year ? ' (' + year + ')' : ''}\n🌱 ${hit.seeders || 0}\n💾 ${sizeStr}\n🏅 Knaben${langLine ? '\n🔊 ' + langLine : ''}`,
-        sources:  [],
-        _quality: getQuality(hit.title || ''),
-        _seeders: hit.seeders || 0,
-        _sizeGB:  sizeGB,
-        _source:  'knaben',
+        infoHash:  hash.toLowerCase(),
+        name:      hit.title || '',
+        title:     `☀️ ${title}${year ? ' (' + year + ')' : ''}\n🌱 ${hit.seeders || 0}\n💾 ${sizeStr}\n🏅 Knaben${langLine ? '\n🔊 ' + langLine : ''}`,
+        sources:   [],
+        _quality:  getQuality(hit.title || ''),
+        _seeders:  hit.seeders || 0,
+        _sizeGB:   sizeGB,
+        _source:   'knaben',
         _provider: 'knaben',
       });
     }
-    console.log(`[Knaben] ${streams.length} for "${query}"`);
+    console.log(`[Knaben] ${streams.length} for "${query}" cats:[${categories}]`);
     return streams;
   } catch (e) { console.error('[Knaben]', e.message); return []; }
 }
 
-async function scrapeTorrentProject(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')}`;
-    // filter: 2000 = video/movies, 2101 = TV series
-    const filter = isSeries ? 2101 : 2000;
-    const url = `https://torrentproject.com.se/?s=${encodeURIComponent(query)}&out=json&filter=${filter}&num=40&orderby=best`;
-    const { data } = await axios.get(url, { timeout: 14000, headers: { 'User-Agent': UA } });
-    if (!data || typeof data !== 'object') return [];
-    const streams = [];
-    for (const key of Object.keys(data)) {
-      if (key === 'total_found') continue;
-      const item = data[key];
-      if (!item.torrent_hash) continue;
-      const hash    = item.torrent_hash.toLowerCase();
-      const sizeGB  = item.torrent_size ? item.torrent_size / 1073741824 : null;
-      const sizeStr = sizeGB ? sizeGB.toFixed(2) + ' GB' : '';
-      const quality = getQuality(item.title || '');
-      if (!quality) continue;
-      const langLine = getLangLine(item.title || '');
-      streams.push({
-        infoHash: hash,
-        name:     item.title || '',
-        title:    `☀️ ${title}${year ? ' (' + year + ')' : ''}\n🌱 ${item.seeds || 0}\n💾 ${sizeStr}\n🏅 TorrentProject${langLine ? '\n🔊 ' + langLine : ''}`,
-        sources:  [buildMagnet(hash, item.title || '')],
-        _quality:  quality,
-        _seeders:  item.seeds || 0,
-        _sizeGB:   sizeGB,
-        _source:   'torrentproject',
-        _provider: 'torrentproject',
-      });
-    }
-    console.log(`[TorrentProject] ${streams.length} for "${query}"`);
-    return streams;
-  } catch (e) { console.error('[TorrentProject]', e.message); return []; }
-}
-
 async function fetchTorrentio(type, id, title, year) {
   try {
     const url = `${TORRENTIO_BASE}/stream/${type}/${id}.json`;
@@ -359,11 +357,11 @@ async function fetchTorrentio(type, id, title, year) {
       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',
+        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,
       };
     });
@@ -393,25 +391,24 @@ app.get('/stream/:type/:id.json', async (req, res) => {
   const isSeries = type === 'series';
   const [imdbId, season = '', episode = ''] = id.split(':');
 
-  const meta  = await tmdbLookup(imdbId);
-  const title = meta?.title || '';
-  const year  = meta?.year  || '';
+  const meta    = await tmdbLookup(imdbId);
+  const title   = meta?.title   || '';
+  const year    = meta?.year    || '';
+  const isAnime = meta?.isAnime || false;
 
-  const [ytsR, knabenR, torrentprojectR, torrentioR] = await Promise.allSettled([
+  const [ytsR, knabenR, torrentioR] = await Promise.allSettled([
     isSeries ? Promise.resolve([]) : scrapeYTS(imdbId),
-    scrapeKnaben(title, year, isSeries, season, episode),
-    scrapeTorrentProject(title, year, isSeries, season, episode),
+    scrapeKnaben(title, year, isSeries, isAnime, season, episode),
     fetchTorrentio(type, id, title, year),
   ]);
 
-  const yts            = ytsR.status            === 'fulfilled' ? (ytsR.value            || []) : [];
-  const knaben         = knabenR.status         === 'fulfilled' ? (knabenR.value         || []) : [];
-  const torrentproject = torrentprojectR.status === 'fulfilled' ? (torrentprojectR.value || []) : [];
-  const torrentio      = torrentioR.status      === 'fulfilled' ? (torrentioR.value      || []) : [];
+  const yts       = ytsR.status       === 'fulfilled' ? (ytsR.value       || []) : [];
+  const knaben    = knabenR.status    === 'fulfilled' ? (knabenR.value    || []) : [];
+  const torrentio = torrentioR.status === 'fulfilled' ? (torrentioR.value || []) : [];
 
-  const streams = processStreams([...yts, ...knaben, ...torrentproject, ...torrentio], type);
+  const streams = processStreams([...yts, ...knaben, ...torrentio], type);
 
-  console.log(`[stream] ${type}/${id} → yts:${yts.length} knaben:${knaben.length} torrentproject:${torrentproject.length} torrentio:${torrentio.length} final:${streams.length}`);
+  console.log(`[stream] ${type}/${id} → yts:${yts.length} knaben:${knaben.length} torrentio:${torrentio.length} final:${streams.length} anime:${isAnime}`);
   res.json({ streams });
 });
 
@@ -420,20 +417,19 @@ app.get('/diag/:type/:id', async (req, res) => {
   const { type, id } = req.params;
   const isSeries = type === 'series';
   const [imdbId, season = '', episode = ''] = id.split(':');
-  const meta = await tmdbLookup(imdbId);
-  const [ytsR, knabenR, torrentprojectR, torrentioR] = await Promise.allSettled([
+  const meta    = await tmdbLookup(imdbId);
+  const isAnime = meta?.isAnime || false;
+  const [ytsR, knabenR, torrentioR] = await Promise.allSettled([
     isSeries ? Promise.resolve([]) : scrapeYTS(imdbId),
-    scrapeKnaben(meta?.title || '', meta?.year || '', isSeries, season, episode),
-    scrapeTorrentProject(meta?.title || '', meta?.year || '', isSeries, season, episode),
+    scrapeKnaben(meta?.title || '', meta?.year || '', isSeries, isAnime, season, episode),
     fetchTorrentio(type, id, meta?.title || '', meta?.year || ''),
   ]);
   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 },
-    torrentproject: { count: (torrentprojectR.value || []).length, err: torrentprojectR.reason?.message || null },
-    torrentio:      { count: (torrentioR.value      || []).length, err: torrentioR.reason?.message      || null },
+    imdbId, title: meta?.title, year: meta?.year, isSeries, isAnime,
+    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 },
   });
 });
 
@@ -492,7 +488,7 @@ app.get('/', (req, res) => {
       background: rgba(255,255,255,0.03); border: 1px solid rgba(255,255,255,0.07);
       border-radius: 16px; padding: 20px 22px;
     }
-    .card-label { font-size: 0.68rem; font-weight: 700; text-trans
+    .card-label { font-size: 0.68rem; font-weight: 700; text-transform: uppercase; letter-spacing: 1px; color: #ffffff; margin-bottom: 10px; }
     .url-box {
       font-family: 'SF Mono','Fira Code','Consolas',monospace; font-size: 0.8rem;
       color: #ffffff; background: rgba(0,0,0,0.25); border: 1px solid rgba(255,0,0,0.12);
@@ -500,20 +496,10 @@ app.get('/', (req, res) => {
     }
     .actions { display: flex; gap: 10px; margin-top: 14px; flex-wrap: wrap; }
     .btn { padding: 10px 22px; border-radius: 10px; font-size: 0.84rem; font-weight: 600; text-decoration: none; border: none; cursor: pointer; transition: all 0.15s; font-family: inherit; }
-    .btn-install {
-      background: #FF0000;
-      color: #ffffff;
-    }
+    .btn-install { background: #FF0000; color: #ffffff; }
     .btn-install:hover { background: #cc0000; }
-    .btn-copy {
-      background: #ffffff;
-      color: #050810;
-      border: 1px solid #ffffff;
-    }
-    .btn-copy:hover {
-      background: #e6e6e6;
-      border-color: #e6e6e6;
-    }
+    .btn-copy { background: #ffffff; color: #050810; border: 1px solid #ffffff; }
+    .btn-copy:hover { background: #e6e6e6; border-color: #e6e6e6; }
     .stats { display: grid; grid-template-columns: repeat(3, 1fr); gap: 10px; }
     .stat { background: rgba(255,255,255,0.02); border: 1px solid rgba(255,255,255,0.06); border-radius: 12px; padding: 16px 12px; text-align: center; }
     .stat-val { font-size: 1.5rem; font-weight: 800; color: #fff; line-height: 1; margin-bottom: 5px; }