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] removes proxy for rarbg and updates agent name

Browse Source
This commit is contained in:
TheBeastLT
2020-09-17 21:29:54 +02:00
parent 2debc4ee8c
commit e9b88dd0ad
1 changed files with 4 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
scraper/scrapers/rarbg/rarbg_api.js
View File

@@ -1,10 +1,9 @@
const needle = require('needle'); const needle = require('needle');
const decode = require('magnet-uri'); const decode = require('magnet-uri');
const Promises = require('../../lib/promises'); const Promises = require('../../lib/promises');
const { defaultOptionsWithProxy } = require('./../../lib/request_helper');
const baseUrl = 'https://torrentapi.org/pubapi_v2.php'; const baseUrl = 'https://torrentapi.org/pubapi_v2.php';
const appId = 'node-rarbg-api'; const appId = 'torrentio-addon';
const defaultTimeout = 30000; const defaultTimeout = 30000;
let token; let token;
@@ -85,9 +84,9 @@ function browse(params = {}) {
return singleRequest(parameters).then(results => parseResults(results)); return singleRequest(parameters).then(results => parseResults(results));
} }
async function singleRequest(params = {}, config = {}, retries = 5) { async function singleRequest(params = {}, config = {}, retries = 10) {
const timeout = config.timeout || defaultTimeout; const timeout = config.timeout || defaultTimeout;
const options = { ...defaultOptionsWithProxy(), open_timeout: timeout, follow: 2 }; const options = { open_timeout: timeout, follow: 2 };
params.token = await getToken(); params.token = await getToken();
params.app_id = appId; params.app_id = appId;
@@ -138,7 +137,7 @@ function parseResult(result) {
async function getToken() { async function getToken() {
if (!token) { if (!token) {
const options = { ...defaultOptionsWithProxy(), open_timeout: defaultTimeout }; const options = { open_timeout: defaultTimeout };
token = await needle('get', baseUrl, { get_token: 'get_token', app_id: appId }, options) token = await needle('get', baseUrl, { get_token: 'get_token', app_id: appId }, options)
.then(response => response.body.token); .then(response => response.body.token);
} }