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 concurrency and add debrid catalog cache max age

Browse Source
This commit is contained in:
TheBeastLT
2024-01-15 14:31:25 +02:00
parent a1f2f2a9f1
commit ead029d48e
3 changed files with 6 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
addon/addon.js
View File

@@ -12,13 +12,14 @@ import StaticLinks from './moch/static.js';
const CACHE_MAX_AGE = parseInt(process.env.CACHE_MAX_AGE) || 60 * 60; // 1 hour in seconds const CACHE_MAX_AGE = parseInt(process.env.CACHE_MAX_AGE) || 60 * 60; // 1 hour in seconds
const CACHE_MAX_AGE_EMPTY = 60; // 60 seconds const CACHE_MAX_AGE_EMPTY = 60; // 60 seconds
const CATALOG_CACHE_MAX_AGE = 20 * 60; // 20 minutes
const STALE_REVALIDATE_AGE = 4 * 60 * 60; // 4 hours const STALE_REVALIDATE_AGE = 4 * 60 * 60; // 4 hours
const STALE_ERROR_AGE = 7 * 24 * 60 * 60; // 7 days const STALE_ERROR_AGE = 7 * 24 * 60 * 60; // 7 days
const builder = new addonBuilder(dummyManifest()); const builder = new addonBuilder(dummyManifest());
const limiter = new Bottleneck({ const limiter = new Bottleneck({
maxConcurrent: process.env.LIMIT_MAX_CONCURRENT || 50, maxConcurrent: process.env.LIMIT_MAX_CONCURRENT || 200,
highWater: process.env.LIMIT_QUEUE_SIZE || 50, highWater: process.env.LIMIT_QUEUE_SIZE || 220,
strategy: Bottleneck.strategy.OVERFLOW strategy: Bottleneck.strategy.OVERFLOW
}); });
@@ -47,7 +48,7 @@ builder.defineCatalogHandler((args) => {
return getMochCatalog(mochKey, args.extra) return getMochCatalog(mochKey, args.extra)
.then(metas => ({ .then(metas => ({
metas: metas, metas: metas,
cacheMaxAge: 0 cacheMaxAge: CATALOG_CACHE_MAX_AGE
})) }))
.catch(error => { .catch(error => {
return Promise.reject(`Failed retrieving catalog ${args.id}: ${JSON.stringify(error)}`); return Promise.reject(`Failed retrieving catalog ${args.id}: ${JSON.stringify(error)}`);

2
addon/moch/moch.js
View File

@@ -64,7 +64,7 @@ Object.values(MochOptions)
.map(moch => moch.key) .map(moch => moch.key)
.forEach(mochKey => unrestrictQueues[mochKey] = new namedQueue((task, callback) => task.method() .forEach(mochKey => unrestrictQueues[mochKey] = new namedQueue((task, callback) => task.method()
.then(result => callback(false, result)) .then(result => callback(false, result))
.catch((error => callback(error))), 40)); .catch((error => callback(error))), 200));
export function hasMochConfigured(config) { export function hasMochConfigured(config) {
return Object.keys(MochOptions).find(moch => config?.[moch]) return Object.keys(MochOptions).find(moch => config?.[moch])

2
addon/moch/realdebrid.js
View File

@@ -395,5 +395,5 @@ function infringingFile(error) {
} }
async function getDefaultOptions(ip) { async function getDefaultOptions(ip) {
return { ip, timeout: 5000 }; return { ip, timeout: 10000 };
} }