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

revert bypassing mongo

Browse Source
This commit is contained in:
TheBeastLT
2024-01-21 23:46:15 +02:00
parent f22df6c5cb
commit a51ddc53c5
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
addon/addon.js
View File

@@ -29,10 +29,10 @@ builder.defineStreamHandler((args) => {
return Promise.resolve({ streams: [] });
}
return limiter.schedule(limiterOptions, () => streamHandler(args)
return cacheWrapStream(args.id, () => limiter.schedule(limiterOptions, () => streamHandler(args)
.then(records => records
.sort((a, b) => b.torrent.seeders - a.torrent.seeders || b.torrent.uploadDate - a.torrent.uploadDate)
.map(record => toStreamInfo(record))))
.map(record => toStreamInfo(record)))))
.then(streams => applyFilters(streams, args.extra))
.then(streams => applySorting(streams, args.extra, args.type))
.then(streams => applyStaticInfo(streams))

2
addon/lib/repository.js
View File

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