Merge pull request #125 from Somnath-Chattaraj/redis

Added redis for caching

backend/package.json

@@ -38,6 +38,7 @@
     "express-async-handler": "^1.2.0",
     "fuse.js": "^7.0.0",
     "html-to-text": "^9.0.5",
+    "ioredis": "^5.4.1",
     "jsonwebtoken": "^9.0.2",
     "nodemailer": "^6.9.14",
     "nodemon": "^3.1.4",

backend/src/controllers/postController.ts

@@ -4,6 +4,7 @@ import prisma from "../lib/prisma";
 import Fuse from "fuse.js";
 import sendMail from "../mail/sendMail";
 import { htmlToText } from "html-to-text";
+import { setCachedData, getCachedData } from "../lib/redis";
 
 // @ts-ignore
 const searchPosts = asyncHandler(async (req: Request, res: Response) => {
@@ -12,6 +13,12 @@ const searchPosts = asyncHandler(async (req: Request, res: Response) => {
   if (!query) {
     return res.status(400).json({ message: "Search query is required" });
   }
+  const cacheKey = `search:${query}`;
+  const cachedResults = await getCachedData(cacheKey);
+  if (cachedResults) {
+    return res.status(200).json({ posts: JSON.parse(cachedResults) });
+  }
+
   const posts = await prisma.post.findMany({
     select: {
       post_id: true,
@@ -45,6 +52,7 @@ const searchPosts = asyncHandler(async (req: Request, res: Response) => {
   });
 
   const searchResults = fuse.search(query).map((result) => result.item);
+  await setCachedData(cacheKey, JSON.stringify(searchResults), 3600);
 
   return res.status(200).json({ posts: searchResults });
 });

backend/src/lib/redis.ts

@@ -0,0 +1,39 @@
+import Redis from "ioredis";
+
+const redisURL = process.env.REDIS_URL;
+
+if (!redisURL) {
+  throw new Error("REDIS_URL is not defined");
+}
+const redis = new Redis(redisURL);
+
+export const getCachedData = async (key: string): Promise<string | null> => {
+  try {
+    return await redis.get(key);
+  } catch (error) {
+    console.error(`Error fetching data from Redis for key: ${key}`, error);
+    return null;
+  }
+};
+
+export const setCachedData = async (
+  key: string,
+  value: string,
+  expiry: number = 3600
+): Promise<void> => {
+  try {
+    await redis.set(key, value, "EX", expiry);
+  } catch (error) {
+    console.error(`Error setting data in Redis for key: ${key}`, error);
+  }
+};
+
+export const disconnectRedis = async (): Promise<void> => {
+  try {
+    await redis.quit();
+  } catch (error) {
+    console.error("Error disconnecting from Redis", error);
+  }
+};
+
+export default redis;