Mirror/SponsorBlockServer
1
0
Fork 0
mirror of https://github.com/ajayyy/SponsorBlockServer.git synced 2025-12-11 22:17:14 +03:00
Code Issues Packages Projects Releases Wiki Activity

Stop spamming redis if it slows down

Browse Source
This commit is contained in:
Ajay
2022-10-29 21:03:34 -04:00
parent 96db571a5e
commit 571230db56
3 changed files with 9 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/config.ts
View File

@@ -136,7 +136,8 @@ addDefaults(config, {
}, },
disableOfflineQueue: true, disableOfflineQueue: true,
expiryTime: 24 * 60 * 60, expiryTime: 24 * 60 * 60,
getTimeout: 40 getTimeout: 40,
maxConnections: 15000
}, },
redisRead: { redisRead: {
enabled: false, enabled: false,

1
src/types/config.model.ts
View File

@@ -5,6 +5,7 @@ interface RedisConfig extends redis.RedisClientOptions {
enabled: boolean; enabled: boolean;
expiryTime: number; expiryTime: number;
getTimeout: number; getTimeout: number;
maxConnections: number;
} }
interface RedisReadOnlyConfig extends redis.RedisClientOptions { interface RedisReadOnlyConfig extends redis.RedisClientOptions {

6
src/utils/redis.ts
View File

@@ -41,7 +41,13 @@ if (config.redis?.enabled) {
const get = client.get.bind(client); const get = client.get.bind(client);
const getRead = readClient?.get?.bind(readClient); const getRead = readClient?.get?.bind(readClient);
exportClient.get = (key) => new Promise((resolve, reject) => { exportClient.get = (key) => new Promise((resolve, reject) => {
if (activeRequests > config.redis.maxConnections) {
reject("Too many active requests");
return;
}
activeRequests++; activeRequests++;
const timeout = config.redis.getTimeout ? setTimeout(() => reject(), config.redis.getTimeout) : null; const timeout = config.redis.getTimeout ? setTimeout(() => reject(), config.redis.getTimeout) : null;
const chosenGet = pickChoice(get, getRead); const chosenGet = pickChoice(get, getRead);
chosenGet(key).then((reply) => { chosenGet(key).then((reply) => {