From 6507a3a68d79325f803c0bc49f1193a0d6d262fa Mon Sep 17 00:00:00 2001 From: Ajay Date: Fri, 4 Mar 2022 19:19:15 -0500 Subject: [PATCH] Add timeout to redis calls --- src/utils/redis.ts | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/src/utils/redis.ts b/src/utils/redis.ts index 6083f3d..333a2bf 100644 --- a/src/utils/redis.ts +++ b/src/utils/redis.ts @@ -33,7 +33,11 @@ if (config.redis) { const client = redis.createClient(config.redis); exportObject = client; - exportObject.getAsync = (key) => new Promise((resolve) => client.get(key, (err, reply) => resolve({ err, reply }))); + const timeout = 200; + exportObject.getAsync = (key) => new Promise((resolve) => { + client.get(key, (err, reply) => resolve({ err, reply })); + setTimeout(() => resolve({ err: null, reply: undefined }), timeout); + }); exportObject.setAsync = (key, value) => new Promise((resolve) => client.set(key, value, (err, reply) => resolve({ err, reply }))); exportObject.setAsyncEx = (key, value, seconds) => new Promise((resolve) => client.setex(key, seconds, value, (err, reply) => resolve({ err, reply }))); exportObject.delAsync = (...keys) => new Promise((resolve) => client.del(keys, (err) => resolve(err)));