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

increase resolve queue concurrency

Browse Source
This commit is contained in:
TheBeastLT
2022-09-14 18:14:09 +02:00
parent bb5c06008b
commit 47d87a10f9
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
addon/moch/moch.js
View File

@@ -11,7 +11,7 @@ const { cacheWrapResolvedUrl } = require('../lib/cache');
const { timeout } = require('../lib/promises'); const { timeout } = require('../lib/promises');
const { BadTokenError, streamFilename } = require('./mochHelper'); const { BadTokenError, streamFilename } = require('./mochHelper');
const RESOLVE_TIMEOUT = 10 * 60 * 1000; // 10 minutes const RESOLVE_TIMEOUT = 2 * 60 * 1000; // 2 minutes
const MIN_API_KEY_SYMBOLS = 15; const MIN_API_KEY_SYMBOLS = 15;
const TOKEN_BLACKLIST = []; const TOKEN_BLACKLIST = [];
const RESOLVER_HOST = process.env.RESOLVER_HOST || 'http://localhost:7050'; const RESOLVER_HOST = process.env.RESOLVER_HOST || 'http://localhost:7050';
@@ -62,7 +62,7 @@ const MOCHS = {
const unrestrictQueue = new namedQueue((task, callback) => task.method() const unrestrictQueue = new namedQueue((task, callback) => task.method()
.then(result => callback(false, result)) .then(result => callback(false, result))
.catch((error => callback(error))), 5); .catch((error => callback(error))), 20);
async function applyMochs(streams, config) { async function applyMochs(streams, config) {
if (!streams || !streams.length || !Object.keys(MOCHS).find(moch => config[moch])) { if (!streams || !streams.length || !Object.keys(MOCHS).find(moch => config[moch])) {