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

[scraper] adds retry to seeders update

Browse Source
This commit is contained in:
TheBeastLT
2021-01-11 09:51:57 +01:00
parent cc2ac0ec09
commit 0522a5e8ab
1 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
scraper/lib/torrent.js
View File

@@ -28,7 +28,7 @@ async function updateCurrentSeeders(torrent) {
const magnetTrackers = torrent.magnetLink && decode(torrent.magnetLink).tr; const magnetTrackers = torrent.magnetLink && decode(torrent.magnetLink).tr;
const torrentTrackers = torrent.trackers && torrent.trackers.split(','); const torrentTrackers = torrent.trackers && torrent.trackers.split(',');
const trackers = magnetTrackers || torrentTrackers || await getDefaultTrackers(torrent); const trackers = magnetTrackers || torrentTrackers || await getDefaultTrackers(torrent);
const callback = () => resolve(Math.max(...Object.values(seeders).map(values => values[0]).concat(0))); const callback = () => resolve(seeders);
setTimeout(callback, SEEDS_CHECK_TIMEOUT); setTimeout(callback, SEEDS_CHECK_TIMEOUT);
async.each(trackers, function (tracker, ready) { async.each(trackers, function (tracker, ready) {
@@ -40,7 +40,11 @@ async function updateCurrentSeeders(torrent) {
}) })
}, callback); }, callback);
}).then(seeders => { }).then(seeders => {
torrent.seeders = seeders; if (!Object.values(seeders).length) {
console.log(`Retrying seeders update for [${torrent.infoHash}] ${torrent.title || torrent.name}`)
return updateCurrentSeeders(torrent);
}
torrent.seeders = Math.max(...Object.values(seeders).map(values => values[0]).concat(0));
return torrent; return torrent;
}); });
} }