tools/knightcrawler
1
0
Fork 0
mirror of https://github.com/knightcrawler-stremio/knightcrawler.git synced 2024-12-20 03:29:51 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

include default stremio trackers in stream responses

Browse Source
This commit is contained in:
TheBeastLT
2023-01-07 19:04:01 +02:00
parent 957397d3c2
commit 26e8f13c3b
1 changed files with 36 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

52
addon/lib/magnetHelper.js
View File

@@ -5,13 +5,35 @@ const { getTorrent } = require('../lib/repository');
const { Type } = require('../lib/types'); const { Type } = require('../lib/types');
const TRACKERS_URL = 'https://raw.githubusercontent.com/ngosang/trackerslist/master/trackers_best.txt'; const TRACKERS_URL = 'https://raw.githubusercontent.com/ngosang/trackerslist/master/trackers_best.txt';
const DEFAULT_TRACKERS = [
"udp://47.ip-51-68-199.eu:6969/announce",
"udp://9.rarbg.me:2940",
"udp://9.rarbg.to:2820",
"udp://exodus.desync.com:6969/announce",
"udp://explodie.org:6969/announce",
"udp://ipv4.tracker.harry.lu:80/announce",
"udp://open.stealth.si:80/announce",
"udp://opentor.org:2710/announce",
"udp://opentracker.i2p.rocks:6969/announce",
"udp://retracker.lanta-net.ru:2710/announce",
"udp://tracker.cyberia.is:6969/announce",
"udp://tracker.dler.org:6969/announce",
"udp://tracker.ds.is:6969/announce",
"udp://tracker.internetwarriors.net:1337",
"udp://tracker.openbittorrent.com:6969/announce",
"udp://tracker.opentrackr.org:1337/announce",
"udp://tracker.tiny-vps.com:6969/announce",
"udp://tracker.torrent.eu.org:451/announce",
"udp://valakas.rollo.dnsabr.com:2710/announce",
"udp://www.torrent.eu.org:451/announce",
]
const ANIME_TRACKERS = [ const ANIME_TRACKERS = [
"http://nyaa.tracker.wf:7777/announce", "http://nyaa.tracker.wf:7777/announce",
"http://anidex.moe:6969/announce", "http://anidex.moe:6969/announce",
"http://tracker.anirena.com:80/announce", "http://tracker.anirena.com:80/announce",
"udp://tracker.uw0.xyz:6969/announce", "udp://tracker.uw0.xyz:6969/announce",
"http://share.camoe.cn:8080/announce", "http://share.camoe.cn:8080/announce",
"http://t.nyaatracker.com:80/announce" "http://t.nyaatracker.com:80/announce",
]; ];
const RUSSIAN_TRACKERS = [ const RUSSIAN_TRACKERS = [
"udp://opentor.org:2710", "udp://opentor.org:2710",
@@ -19,34 +41,31 @@ const RUSSIAN_TRACKERS = [
"http://bt.t-ru.org/ann?magnet", "http://bt.t-ru.org/ann?magnet",
"http://bt2.t-ru.org/ann?magnet", "http://bt2.t-ru.org/ann?magnet",
"http://bt3.t-ru.org/ann?magnet", "http://bt3.t-ru.org/ann?magnet",
"http://bt4.t-ru.org/ann?magnet" "http://bt4.t-ru.org/ann?magnet",
]; ];
// Some trackers have limits on original torrent trackers, // Some trackers have limits on original torrent trackers,
// where downloading ip has to seed the torrents for some amount of time, // where downloading ip has to seed the torrents for some amount of time,
// thus it doesn't work on mochs. // thus it doesn't work on mochs.
// So it's better to exclude them and try to download through DHT, // So it's better to exclude them and try to download through DHT,
// as the torrent won't start anyway. // as the torrent won't start anyway.
const LIMITED_PROVIDERS = [ const RUSSIAN_PROVIDERS = [
'Rutor' 'Rutor',
'Rutracker'
]; ];
const ANIME_PROVIDERS = [ const ANIME_PROVIDERS = [
'HorribleSubs', 'HorribleSubs',
'NyaaSi', 'NyaaSi',
'NyaaPantsu' 'NyaaPantsu'
]; ];
const RUSSIAN_PROVIDERS = [
'Rutor',
'Rutracker'
];
let BEST_TRACKERS = []; let BEST_TRACKERS = [];
let ALL_TRACKERS = []; let ALL_ANIME_TRACKERS = [];
let ALL_RUSSIAN_TRACKERS = [];
async function getMagnetLink(infoHash) { async function getMagnetLink(infoHash) {
const torrent = await getTorrent(infoHash).catch(() => ({ infoHash })); const torrent = await getTorrent(infoHash).catch(() => ({ infoHash }));
const torrentTrackers = !LIMITED_PROVIDERS.includes(torrent.provider) const torrentTrackers = torrent.trackers && torrent.trackers.split(',');
&& torrent.trackers && torrent.trackers.split(','); const animeTrackers = torrent.type === Type.ANIME ? ALL_ANIME_TRACKERS : undefined;
const animeTrackers = torrent.type === Type.ANIME ? ALL_TRACKERS : undefined; const providerTrackers = RUSSIAN_PROVIDERS.includes(torrent.provider) && ALL_RUSSIAN_TRACKERS;
const providerTrackers = RUSSIAN_PROVIDERS.includes(torrent.provider) && RUSSIAN_TRACKERS;
const trackers = unique([].concat(torrentTrackers).concat(animeTrackers).concat(providerTrackers)); const trackers = unique([].concat(torrentTrackers).concat(animeTrackers).concat(providerTrackers));
return trackers return trackers
@@ -56,7 +75,8 @@ async function getMagnetLink(infoHash) {
async function initBestTrackers() { async function initBestTrackers() {
BEST_TRACKERS = await getBestTrackers(); BEST_TRACKERS = await getBestTrackers();
ALL_TRACKERS = BEST_TRACKERS.concat(ANIME_TRACKERS); ALL_ANIME_TRACKERS = unique(BEST_TRACKERS.concat(DEFAULT_TRACKERS).concat(ANIME_TRACKERS));
ALL_RUSSIAN_TRACKERS = unique(BEST_TRACKERS.concat(DEFAULT_TRACKERS).concat(RUSSIAN_TRACKERS));
console.log('Retrieved best trackers: ', BEST_TRACKERS); console.log('Retrieved best trackers: ', BEST_TRACKERS);
} }
@@ -86,11 +106,11 @@ function enrichStreamSources(stream) {
const match = stream.title.match(/⚙.* ([^ \n]+)/); const match = stream.title.match(/⚙.* ([^ \n]+)/);
const provider = match && match[1]; const provider = match && match[1];
if (ANIME_PROVIDERS.includes(provider)) { if (ANIME_PROVIDERS.includes(provider)) {
const sources = getSources(ALL_TRACKERS, stream.infoHash); const sources = getSources(ALL_ANIME_TRACKERS, stream.infoHash);
return { ...stream, sources }; return { ...stream, sources };
} }
if (RUSSIAN_PROVIDERS.includes(provider)) { if (RUSSIAN_PROVIDERS.includes(provider)) {
const sources = unique([].concat(stream.sources).concat(getSources(RUSSIAN_TRACKERS, stream.infoHash))); const sources = unique([].concat(stream.sources).concat(getSources(ALL_RUSSIAN_TRACKERS, stream.infoHash)));
return { ...stream, sources }; return { ...stream, sources };
} }
return stream; return stream;