From b18294527424f67aa6867fc52174285d88c3c2fb Mon Sep 17 00:00:00 2001 From: Ajay Date: Fri, 4 Mar 2022 19:22:01 -0500 Subject: [PATCH] Clear redis timeouts --- src/utils/redis.ts | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/src/utils/redis.ts b/src/utils/redis.ts index 333a2bf..7faefe6 100644 --- a/src/utils/redis.ts +++ b/src/utils/redis.ts @@ -33,10 +33,13 @@ if (config.redis) { const client = redis.createClient(config.redis); exportObject = client; - const timeout = 200; + const timeoutDuration = 200; exportObject.getAsync = (key) => new Promise((resolve) => { - client.get(key, (err, reply) => resolve({ err, reply })); - setTimeout(() => resolve({ err: null, reply: undefined }), timeout); + const timeout = setTimeout(() => resolve({ err: null, reply: undefined }), timeoutDuration); + client.get(key, (err, reply) => { + clearTimeout(timeout); + resolve({ err, reply }); + }); }); 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 })));