redis helpers are written

Author: anijitsao

src/helpers/redisHelpers.js

@@ -1,5 +1,19 @@
+import { redisClient } from "../lib/redisClient.js";
+
 const connectRedis = async () => {
-  await client.connect();
+  await redisClient.connect();
+};
+
+// get value based on the key provided
+const getValue = async (key) => {
+  const value = await redisClient.get(key);
+  return value;
+};
+
+// set the value to key provided
+const setValue = async (key, value) => {
+  await redisClient.set(key, value);
+  return;
 };
 
-export { connectRedis };
+export { connectRedis, getValue, setValue };

src/lib/redisClient.js

@@ -5,25 +5,3 @@ const redisClient = createClient({
 });
 
 export { redisClient };
-// on all error execute this line
-// client.on("error", (err) => console.log("Redis Error: ", err.toString()));
-
-// await client.connect();
-// await client.set("num", 23);
-// const value = await client.get("num");
-// console.log("Value as received", value);
-
-// const nameVal = await client.get("name");
-// console.log("Name vlaue: ", nameVal);
-
-// // const an object as key
-// const keyObj = { username: "anij123" };
-// const keyObjVal = { name: "Anijit Sau", role: "Developer", country: "India" };
-// await client.hSet("anij123", keyObjVal);
-// const valueKeyObj = await client.hGetAll("anij123");
-// console.log(
-//   "value received :",
-//   valueKeyObj,
-//   " \nand its type: ",
-//   typeof valueKeyObj
-// );

src/services/redisService.js

@@ -1,8 +1,14 @@
-// local dep
+// local dependencies
+import { setValue, getValue, connectRedis } from "../helpers/redisHelpers.js";
 import { sendResponse } from "../helpers/sendResponse.js";
+
 const checkRedisHandler = async (event) => {
-  const res = { message: "API endpoint reached" };
-  sendResponse(process.env.SUCCESS_CODE, res);
+  try {
+    const res = { message: "API endpoint reached" };
+    return sendResponse(process.env.SUCCESS_CODE, res);
+  } catch (error) {
+    return sendResponse(process.env.ERROR_CODE, { error: error.toString() });
+  }
 };
 
 export { checkRedisHandler };