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] improve nyaapantsu error logging

Browse Source
This commit is contained in:
TheBeastLT
2021-05-29 11:38:30 +02:00
parent 6e7c03010e
commit 34f3477ede
1 changed files with 12 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
scraper/scrapers/nyaapantsu/nyaa_pantsu_api.js
View File

@@ -24,17 +24,13 @@ function torrent(torrentId) {
return pantsu.infoRequest(torrentId) return pantsu.infoRequest(torrentId)
.then(result => parseTorrent(result)) .then(result => parseTorrent(result))
.catch(error => { .catch(error => handleError(error, torrentId));
if (error.statusCode && error.statusCode >= 400) {
return Promise.reject(new Error(`${error.statusCode}: [${torrentId}] failed retrieval on NyaaPantsu`));
}
return Promise.reject(error);
});
} }
function search(query) { function search(query) {
return pantsu.search(query) return pantsu.search(query)
.then(results => results.map(torrent => parseTorrent(torrent))); .then(results => results.map(torrent => parseTorrent(torrent)))
.catch(error => handleError(error, query));
} }
function browse(config = {}) { function browse(config = {}) {
@@ -42,7 +38,15 @@ function browse(config = {}) {
const category = config.category || Categories.ANIME.ENGLISH; const category = config.category || Categories.ANIME.ENGLISH;
return pantsu.list(category, page) return pantsu.list(category, page)
.then(results => results.map(torrent => parseTorrent(torrent))); .then(results => results.map(torrent => parseTorrent(torrent)))
.catch(error => handleError(error, category));
}
function handleError(error, identifier) {
if (error.statusCode && error.statusCode >= 400) {
return Promise.reject(new Error(`${error.statusCode}: [${identifier}] failed retrieval on NyaaPantsu`));
}
return Promise.reject(error);
} }
function parseTorrent(torrent) { function parseTorrent(torrent) {