From bd00282e64a89aae64aa7f76b3a7ae68e8fec232 Mon Sep 17 00:00:00 2001 From: TheBeastLT Date: Sun, 26 Feb 2023 09:01:37 +0100 Subject: [PATCH] try to disable remote mongo cache --- addon/addon.js | 4 ++-- addon/lib/cache.js | 6 +++--- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/addon/addon.js b/addon/addon.js index aa9662d..670e3f8 100644 --- a/addon/addon.js +++ b/addon/addon.js @@ -27,10 +27,10 @@ builder.defineStreamHandler((args) => { return Promise.resolve({ streams: [] }); } - return cacheWrapStream(args.id, () => limiter.schedule(() => streamHandler(args) + return limiter.schedule(() => 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)) .then(streams => applyStaticInfo(streams)) diff --git a/addon/lib/cache.js b/addon/lib/cache.js index 346ef19..047a8ad 100644 --- a/addon/lib/cache.js +++ b/addon/lib/cache.js @@ -10,7 +10,7 @@ const RESOLVED_URL_KEY_PREFIX = `${GLOBAL_KEY_PREFIX}|resolved`; const STREAM_TTL = process.env.STREAM_TTL || 4 * 60 * 60; // 4 hours const STREAM_EMPTY_TTL = process.env.STREAM_EMPTY_TTL || 60; // 1 minute const AVAILABILITY_TTL = 8 * 60 * 60; // 8 hours -const AVAILABILITY_EMPTY_TTL = 60 * 60; // 1 hours +const AVAILABILITY_EMPTY_TTL = 60 * 60; // 1 hour const MESSAGE_VIDEO_URL_TTL = 60; // 1 minutes // When the streams are empty we want to cache it for less time in case of timeouts or failures @@ -18,7 +18,7 @@ const MONGO_URI = process.env.MONGODB_URI; const NO_CACHE = process.env.NO_CACHE || false; const memoryCache = initiateMemoryCache(); -const remoteCache = initiateRemoteCache(); +// const remoteCache = initiateRemoteCache(); function initiateRemoteCache() { if (NO_CACHE) { @@ -62,7 +62,7 @@ function cacheWrap(cache, key, method, options) { } function cacheWrapStream(id, method) { - return cacheWrap(remoteCache, `${STREAM_KEY_PREFIX}:${id}`, method, { + return cacheWrap(memoryCache, `${STREAM_KEY_PREFIX}:${id}`, method, { ttl: (streams) => streams.length ? STREAM_TTL : STREAM_EMPTY_TTL }); }