From e1a5ca64f0f644e09db30cdfb82820de7e6f7b55 Mon Sep 17 00:00:00 2001
From: Ajay <dev@ajay.app>
Date: Mon, 7 Nov 2022 23:04:18 -0500
Subject: [PATCH] Add seperate config for stopping write redis connections

---
 src/config.ts             | 3 ++-
 src/types/config.model.ts | 1 +
 src/utils/redis.ts        | 2 +-
 3 files changed, 4 insertions(+), 2 deletions(-)

diff --git a/src/config.ts b/src/config.ts
index 296f7ce..568aa0c 100644
--- a/src/config.ts
+++ b/src/config.ts
@@ -137,7 +137,8 @@ addDefaults(config, {
         disableOfflineQueue: true,
         expiryTime: 24 * 60 * 60,
         getTimeout: 40,
-        maxConnections: 15000
+        maxConnections: 15000,
+        maxWriteConnections: 1000
     },
     redisRead: {
         enabled: false,
diff --git a/src/types/config.model.ts b/src/types/config.model.ts
index 9888209..3450b72 100644
--- a/src/types/config.model.ts
+++ b/src/types/config.model.ts
@@ -6,6 +6,7 @@ interface RedisConfig extends redis.RedisClientOptions {
     expiryTime: number;
     getTimeout: number;
     maxConnections: number;
+    maxWriteConnections: number;
 }
 
 interface RedisReadOnlyConfig extends redis.RedisClientOptions {
diff --git a/src/utils/redis.ts b/src/utils/redis.ts
index 900d0fb..4106606 100644
--- a/src/utils/redis.ts
+++ b/src/utils/redis.ts
@@ -68,7 +68,7 @@ if (config.redis?.enabled) {
         });
     });
     exportClient.set = (key, value) => new Promise((resolve, reject) => {
-        if (activeRequests > config.redis.maxConnections) {
+        if (activeRequests > config.redis.maxWriteConnections) {
             reject("Too many active requests");
             return;
         }