diff --git a/scraper/scheduler/seeders.js b/scraper/scheduler/seeders.js index 9595c49..ef7643b 100644 --- a/scraper/scheduler/seeders.js +++ b/scraper/scheduler/seeders.js @@ -15,8 +15,12 @@ const statistics = {}; function scheduleUpdateSeeders() { console.log('Starting seeders update...') return repository.getUpdateSeedersTorrents() - .then(torrents => Promise.all(torrents.map(torrent => limiter.schedule(() => - timeout(TIMEOUT_MS, _updateSeeders(torrent), `Failed [${torrent.infoHash}] torrent seeders update`))))) + .then(torrents => Promise.all(torrents.map(torrent => limiter + .schedule(() => timeout(TIMEOUT_MS, _updateSeeders(torrent))) + .catch(error => { + console.log(`Failed [${torrent.infoHash}] ${torrent.title} seeders update: `, error); + return [] + })))) .then(torrents => updateStatistics(torrents)) .then(() => console.log('Finished seeders update:', statistics)) .catch(error => console.warn('Failed seeders update:', error)) diff --git a/scraper/scrapers/eztv/eztv_scraper.js b/scraper/scrapers/eztv/eztv_scraper.js index bb19264..1292c39 100644 --- a/scraper/scrapers/eztv/eztv_scraper.js +++ b/scraper/scrapers/eztv/eztv_scraper.js @@ -25,10 +25,11 @@ async function scrape() { } async function updateSeeders(torrent, getImdbIdsMethod) { - return getImdbIdsMethod() - .then(imdbIds => Promise.all(imdbIds.map(imdbId => limiter.schedule(() => eztv.search(imdbId))))) - .then(results => results.reduce((a, b) => a.concat(b), [])) - .catch(() => limiter.schedule(() => eztv.torrent(torrent.torrentId))); + // return getImdbIdsMethod() + // .then(imdbIds => Promise.all(imdbIds.map(imdbId => limiter.schedule(() => eztv.search(imdbId))))) + // .then(results => results.reduce((a, b) => a.concat(b), [])) + // .catch(() => limiter.schedule(() => eztv.torrent(torrent.torrentId))); + return limiter.schedule(() => eztv.torrent(torrent.torrentId)); } async function scrapeLatestTorrents() {