redis caching completed

Author: anijitsao

.env.development

@@ -19,4 +19,5 @@ JWT_SECRET="superSKR"
 JWT_TOKEN_EXPIRES_IN="10m"
 
 # REDIS related
-REDIS_CONNECTION_URL="redis://52.66.253.128:6379"
+REDIS_CONNECTION_URL="redis://52.66.253.128:6379"
+REDIS_CACHE_EXPIRY_TIME=2*60

serverless.json

@@ -32,10 +32,6 @@
     "login": {
       "handler": "src/services/loginService.loginHandler",
       "events": [{ "httpApi": "POST /login" }]
-    },
-    "checkRedis": {
-      "handler": "src/services/redisService.checkRedisHandler",
-      "events": [{ "httpApi": "POST /check" }]
     }
   }
 }

src/dbRelated/userDbOps.js

@@ -23,15 +23,21 @@ const getAllUsers = async () => {
   //  redis operations
   let usersInCache = [];
   try {
-    await connectRedis();
+    connectRedis();
     usersInCache = await getValueFromRedis("allUsers");
-    await closeConnectionToRedis();
+    usersInCache = JSON.parse(usersInCache);
+    if (usersInCache) {
+      return sendResponse(SUCCESS_CODE, { usersInCache });
+    }
   } catch (error) {
     return sendResponse(ERROR_CODE, {
       message: "Unable to get records from Redis",
       error: error.toString(),
     });
+  } finally {
+    closeConnectionToRedis();
   }
+
   const client = await createConnectionToDB();
   try {
     // select the db, Collections are selected based on needs
@@ -44,7 +50,10 @@ const getAllUsers = async () => {
       .toArray();
 
     const users = data.length > 0 ? [...data] : [];
-    const res = { users, usersInCache };
+
+    // save data to Redis cache
+    await setValueToRedis("allUsers", users);
+    const res = { users };
 
     return sendResponse(SUCCESS_CODE, res);
   } catch (error) {
@@ -56,6 +65,7 @@ const getAllUsers = async () => {
   } finally {
     // close the connection to MongoDB Atlas
     closeConnectionToDB(client);
+    closeConnectionToRedis();
   }
 };
 

src/helpers/redisHelpers.js

@@ -6,13 +6,21 @@ const connectRedis = async () => {
 
 // get value based on the key provided
 const getValueFromRedis = async (key) => {
+  // convert key to String
+  key = typeof key !== "string" ? JSON.stringify(key) : key;
   const value = await redisClient.get(key);
   return value;
 };
 
 // set the value to key provided
 const setValueToRedis = async (key, value) => {
-  await redisClient.set(key, value);
+  // convert key, value to String
+  key = typeof key !== "string" ? JSON.stringify(key) : key;
+  value = typeof value !== "string" ? JSON.stringify(value) : value;
+
+  await redisClient.set(key, value, {
+    EX: process.env.REDIS_CACHE_EXPIRY_TIME,
+  });
 };
 
 // close the redis connection