diff --git a/scraper/scheduler/seeders.js b/scraper/scheduler/seeders.js index 816b0ee..3282e86 100644 --- a/scraper/scheduler/seeders.js +++ b/scraper/scheduler/seeders.js @@ -14,12 +14,17 @@ function scheduleUpdateSeeders() { return repository.getUpdateSeedersTorrents() .then(torrents => Promise.all(torrents.map(torrent => limiter.schedule(() => _updateSeeders(torrent))))) .then(() => console.log('Finished seeders update')) + .catch(error => console.warn('Failed seeders update: ', error)) .then(() => delay(DELAY)) .then(() => scheduleUpdateSeeders()); } async function _updateSeeders(torrent) { const provider = await scrapers.find(provider => provider.name === torrent.provider); + if (!provider) { + console.log(`No provider found for ${torrent.provider} [${torrent.infoHash}]`) + return Promise.resolve(); + } const updatedTorrents = await provider.scraper.updateSeeders(torrent, getImdbIdsMethod(torrent)) .then(updated => Array.isArray(updated) ? updated : [updated]) .catch(() => []); diff --git a/scraper/scrapers/1337x/1337x_scraper.js b/scraper/scrapers/1337x/1337x_scraper.js index 16d01c5..ab9f81d 100644 --- a/scraper/scrapers/1337x/1337x_scraper.js +++ b/scraper/scrapers/1337x/1337x_scraper.js @@ -4,7 +4,6 @@ const leetx = require('./1337x_api'); const { Type } = require('../../lib/types'); const repository = require('../../lib/repository'); const Promises = require('../../lib/promises'); -const { updateCurrentSeeders } = require('../../lib/torrent'); const { createTorrentEntry, getStoredTorrentEntry, updateTorrentSeeders } = require('../../lib/torrentEntries'); const NAME = '1337x'; diff --git a/scraper/scrapers/kickass/kickass_scraper.js b/scraper/scrapers/kickass/kickass_scraper.js index d92bb42..2273535 100644 --- a/scraper/scrapers/kickass/kickass_scraper.js +++ b/scraper/scrapers/kickass/kickass_scraper.js @@ -4,7 +4,6 @@ const kickass = require('./kickass_api'); const { Type } = require('../../lib/types'); const repository = require('../../lib/repository'); const Promises = require('../../lib/promises'); -const { updateCurrentSeeders } = require('../../lib/torrent'); const { createTorrentEntry, getStoredTorrentEntry, updateTorrentSeeders } = require('../../lib/torrentEntries'); const NAME = 'KickassTorrents'; diff --git a/scraper/scrapers/thepiratebay/thepiratebay_scraper.js b/scraper/scrapers/thepiratebay/thepiratebay_scraper.js index 4844115..6995973 100644 --- a/scraper/scrapers/thepiratebay/thepiratebay_scraper.js +++ b/scraper/scrapers/thepiratebay/thepiratebay_scraper.js @@ -4,7 +4,6 @@ const thepiratebay = require('./thepiratebay_api.js'); const { Type } = require('../../lib/types'); const repository = require('../../lib/repository'); const Promises = require('../../lib/promises'); -const { updateCurrentSeeders } = require('../../lib/torrent'); const { createTorrentEntry, getStoredTorrentEntry, updateTorrentSeeders } = require('../../lib/torrentEntries'); const NAME = 'ThePirateBay';