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

Merge branch 'TheBeastLT:master' into master

Browse Source
This commit is contained in:
Gabisonfire
2024-01-22 09:24:25 -05:00
committed by GitHub
parent dd0beb5973 0fdc968a86
commit 741dbfb55a
3 changed files with 7 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
addon/addon.js
View File

@@ -18,17 +18,18 @@ 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 || 200, maxConcurrent: process.env.LIMIT_MAX_CONCURRENT || 100,
highWater: process.env.LIMIT_QUEUE_SIZE || 220, highWater: process.env.LIMIT_QUEUE_SIZE || 120,
strategy: Bottleneck.strategy.OVERFLOW strategy: Bottleneck.strategy.OVERFLOW
}); });
const limiterOptions = { expiration: 2 * 60 * 1000 }
builder.defineStreamHandler((args) => { builder.defineStreamHandler((args) => {
if (!args.id.match(/tt\d+/i) && !args.id.match(/kitsu:\d+/i)) { if (!args.id.match(/tt\d+/i) && !args.id.match(/kitsu:\d+/i)) {
return Promise.resolve({ streams: [] }); return Promise.resolve({ streams: [] });
} }
return cacheWrapStream(args.id, () => limiter.schedule(() => streamHandler(args) return cacheWrapStream(args.id, () => limiter.schedule(limiterOptions, () => streamHandler(args)
.then(records => records .then(records => records
.sort((a, b) => b.torrent.seeders - a.torrent.seeders || b.torrent.uploadDate - a.torrent.uploadDate) .sort((a, b) => b.torrent.seeders - a.torrent.seeders || b.torrent.uploadDate - a.torrent.uploadDate)
.map(record => toStreamInfo(record))))) .map(record => toStreamInfo(record)))))

3
addon/lib/cache.js
View File

@@ -29,7 +29,8 @@ function initiateRemoteCache() {
uri: MONGO_URI, uri: MONGO_URI,
options: { options: {
collection: 'torrentio_addon_collection', collection: 'torrentio_addon_collection',
socketTimeoutMS: 120000, socketTimeoutMS: 30000,
poolSize: 150,
useNewUrlParser: true, useNewUrlParser: true,
useUnifiedTopology: false, useUnifiedTopology: false,
ttl: STREAM_EMPTY_TTL ttl: STREAM_EMPTY_TTL

2
addon/lib/repository.js
View File

@@ -3,7 +3,7 @@ const Op = Sequelize.Op;
const DATABASE_URI = process.env.DATABASE_URI; const DATABASE_URI = process.env.DATABASE_URI;
const database = new Sequelize(DATABASE_URI, { logging: false }); const database = new Sequelize(DATABASE_URI, { logging: false, pool: { max: 50 } });
const Torrent = database.define('torrent', const Torrent = database.define('torrent',
{ {