[scraper] adds proxy for kat and 1337x

This commit is contained in:
TheBeastLT
2020-05-02 17:35:50 +02:00
parent cd5fac2f60
commit 2bb0570194
5 changed files with 22 additions and 29 deletions

View File

@@ -16,4 +16,17 @@ function getRandomProxy() {
return undefined; return undefined;
} }
module.exports = { getRandomUserAgent, getRandomProxy }; function defaultOptionsWithProxy() {
if (process.env.PROXY_HOST && process.env.PROXY_TYPE) {
return {
proxy: process.env.PROXY_HOST,
headers: {
'user-agent': getRandomUserAgent(),
'proxy-type': process.env.PROXY_TYPE
}
}
}
return { userAgent: getRandomUserAgent() };
}
module.exports = { getRandomUserAgent, getRandomProxy, defaultOptionsWithProxy };

View File

@@ -1,23 +0,0 @@
const EXTENSIONS = [
"3g2",
"3gp",
"avi",
"flv",
"mkv",
"mov",
"mp2",
"mp4",
"m4v",
"mpe",
"mpeg",
"mpg",
"mpv",
"webm",
"wmv",
"ogm"
];
module.exports = (filename) => {
const extensionMatch = filename.match(/\.(\w{2,4})$/);
return extensionMatch && EXTENSIONS.includes(extensionMatch[1].toLowerCase());
};

View File

@@ -4,6 +4,7 @@ const Sugar = require('sugar-date');
const decode = require('magnet-uri'); const decode = require('magnet-uri');
const Promises = require('../../lib/promises'); const Promises = require('../../lib/promises');
const { escapeHTML } = require('../../lib/metadata'); const { escapeHTML } = require('../../lib/metadata');
const { defaultOptionsWithProxy } = require('../../lib/request_helper');
const defaultProxies = [ const defaultProxies = [
'https://1337x.to' 'https://1337x.to'
@@ -79,8 +80,9 @@ function browse(config = {}, retries = 2) {
function singleRequest(requestUrl, config = {}) { function singleRequest(requestUrl, config = {}) {
const timeout = config.timeout || defaultTimeout; const timeout = config.timeout || defaultTimeout;
const options = { ...defaultOptionsWithProxy(), open_timeout: timeout, follow: 2 };
return needle('get', requestUrl, { open_timeout: timeout, follow: 2 }) return needle('get', requestUrl, options)
.then((response) => { .then((response) => {
const body = response.body; const body = response.body;
if (!body) { if (!body) {

View File

@@ -3,12 +3,12 @@ const needle = require('needle');
const moment = require('moment'); const moment = require('moment');
const decode = require('magnet-uri'); const decode = require('magnet-uri');
const Promises = require('../../lib/promises'); const Promises = require('../../lib/promises');
const { getRandomUserAgent } = require('./../../lib/request_helper'); const { defaultOptionsWithProxy } = require('./../../lib/request_helper');
const defaultProxies = [ const defaultProxies = [
'https://katcr.co' 'https://katcr.co'
]; ];
const defaultTimeout = 30000; const defaultTimeout = 10000;
const Categories = { const Categories = {
MOVIE: 'movies', MOVIE: 'movies',
@@ -65,7 +65,7 @@ function browse(config = {}, retries = 2) {
function singleRequest(requestUrl, config = {}) { function singleRequest(requestUrl, config = {}) {
const timeout = config.timeout || defaultTimeout; const timeout = config.timeout || defaultTimeout;
const options = { userAgent: getRandomUserAgent(), open_timeout: timeout, follow: 2 }; const options = { ...defaultOptionsWithProxy(), open_timeout: timeout, follow: 2 };
return needle('get', requestUrl, options) return needle('get', requestUrl, options)
.then((response) => { .then((response) => {

View File

@@ -6300,5 +6300,6 @@
"tt9815454", "tt9815454",
"tt0879688", "tt0879688",
"tt5252734", "tt5252734",
"tt9059820" "tt9059820",
"tt5766086"
] ]