redis caching added

Author: anijitsao

.env.development

@@ -1,3 +1,5 @@
+# Application related
+APP_NAME="simple-aws-lamba-mongodb"
 # AWS related
 REGION="ap-south-1"
 
@@ -17,4 +19,4 @@ JWT_SECRET="superSKR"
 JWT_TOKEN_EXPIRES_IN="10m"
 
 # REDIS related
-REDIS_CONNECTION_URL="redis://35.154.200.227:6379"
+REDIS_CONNECTION_URL="redis://52.66.253.128:6379"

src/dbRelated/userDbOps.js

@@ -7,18 +7,31 @@ import {
   convertToObjectId,
 } from "../helpers/dbHelpers.js";
 
-// top level await to connect the MongoDB Atlas
-// const client = await dbClient.connect();
+// redis dependencies
+import {
+  setValueToRedis,
+  getValueFromRedis,
+  connectRedis,
+  closeConnectionToRedis,
+} from "../helpers/redisHelpers.js";
 
 // all the db related process variables
-const {
-  DB_NAME,
-  COLLECTION_USER_STICKER,
-  SUCCESS_CODE,
-  ERROR_CODE,
-} = process.env;
+const { DB_NAME, COLLECTION_USER_STICKER, SUCCESS_CODE, ERROR_CODE } =
+  process.env;
 
 const getAllUsers = async () => {
+  //  redis operations
+  let usersInCache = [];
+  try {
+    await connectRedis();
+    usersInCache = await getValueFromRedis("allUsers");
+    await closeConnectionToRedis();
+  } catch (error) {
+    return sendResponse(ERROR_CODE, {
+      message: "Unable to get records from Redis",
+      error: error.toString(),
+    });
+  }
   const client = await createConnectionToDB();
   try {
     // select the db, Collections are selected based on needs
@@ -31,7 +44,7 @@ const getAllUsers = async () => {
       .toArray();
 
     const users = data.length > 0 ? [...data] : [];
-    const res = { users };
+    const res = { users, usersInCache };
 
     return sendResponse(SUCCESS_CODE, res);
   } catch (error) {

src/helpers/jwtHelpers.js

@@ -8,9 +8,13 @@ const { sign, verify } = jwt;
 
 // create token from the payload
 const createToken = (payload) => {
-  const token = sign(payload, process.env.JWT_SECRET, {
-    expiresIn: process.env.JWT_TOKEN_EXPIRES_IN,
-  });
+  const token = sign(
+    { ...payload, appName: process.env.APP_NAME },
+    process.env.JWT_SECRET,
+    {
+      expiresIn: process.env.JWT_TOKEN_EXPIRES_IN,
+    }
+  );
 
   return token;
 };
@@ -21,7 +25,7 @@ const verifyToken = (event) => {
     const decoded = verify(token, process.env.JWT_SECRET);
 
     // if the token has the correct data it is passed
-    if (decoded.username === "anijit123") {
+    if (decoded.appName === process.env.APP_NAME) {
       return true;
     }
     return false;

src/helpers/redisHelpers.js

@@ -5,15 +5,24 @@ const connectRedis = async () => {
 };
 
 // get value based on the key provided
-const getValue = async (key) => {
+const getValueFromRedis = async (key) => {
   const value = await redisClient.get(key);
   return value;
 };
 
 // set the value to key provided
-const setValue = async (key, value) => {
+const setValueToRedis = async (key, value) => {
   await redisClient.set(key, value);
-  return;
 };
 
-export { connectRedis, getValue, setValue };
+// close the redis connection
+const closeConnectionToRedis = async () => {
+  await redisClient.quit();
+};
+
+export {
+  connectRedis,
+  getValueFromRedis,
+  setValueToRedis,
+  closeConnectionToRedis,
+};

src/services/redisService.js

@@ -1,10 +1,19 @@
 // local dependencies
-import { setValue, getValue, connectRedis } from "../helpers/redisHelpers.js";
+import {
+  setValueToRedis,
+  getValueFromRedis,
+  connectRedis,
+  closeConnectionToRedis,
+} from "../helpers/redisHelpers.js";
 import { sendResponse } from "../helpers/sendResponse.js";
 
 const checkRedisHandler = async (event) => {
   try {
-    const res = { message: "API endpoint reached" };
+    await connectRedis();
+    const cachedNameValue = await getValueFromRedis("name");
+    await setValueToRedis("name", "JOe");
+    await closeConnectionToRedis();
+    const res = { message: "API endpoint reached", name: cachedNameValue };
     return sendResponse(process.env.SUCCESS_CODE, res);
   } catch (error) {
     return sendResponse(process.env.ERROR_CODE, { error: error.toString() });