added create session route

Author: Sarthak-kavidayal

backend/src/controllers/sessionController.ts

@@ -5,6 +5,7 @@ import {
   deleteService,
   switchCacheDb,
   getAllSessionService,
+  createSessionService,
 } from "../services/sessionService";
 
 const SESSION_EXPIRY = 3600; // 1 hour
@@ -99,3 +100,17 @@ export const getAllSession = async (req: Request, res: Response) => {
       .send({ message: "Error fetching session", error: error.message });
   }
 };
+
+export const createSession = async (req: Request, res: Response) => {
+  const { sessionID, payload } = req.body;
+
+  try {
+    const response = await createSessionService(sessionID, payload);
+    res.status(200).send({ message: response });
+  } catch (error: any) {
+    console.error(error);
+    res
+      .status(500)
+      .send({ message: "Error creating session", error: error.message });
+  }
+};

backend/src/routes/sessionRoutes.ts

@@ -6,7 +6,8 @@ import {
   updateSession,
   deleteSession,
   updateCacheDb,
-  getAllSession
+  getAllSession,
+  createSession,
 } from "../controllers/sessionController";
 import validateToken from "../middleware";
 
@@ -16,6 +17,7 @@ router.get("/all", validateToken, getAllSession);
 router.get("/", validateToken, getSession);
 router.put("/", validateToken, updateSession);
 router.delete("/", validateToken, deleteSession);
-router.post("/updatedb", validateToken, updateCacheDb);
+router.post("/", createSession);
+router.post("/updatedb", updateCacheDb);
 
 export default router;

backend/src/routes/unitRoutes.ts

@@ -0,0 +1,19 @@
+import { Router } from "express";
+import {
+  getSession,
+  updateSession,
+  deleteSession,
+  updateCacheDb,
+  getAllSession,
+} from "../controllers/sessionController";
+import validateToken from "../middleware";
+
+const router = Router();
+
+router.get("/all", validateToken, getAllSession);
+router.get("/", validateToken, getSession);
+router.put("/", validateToken, updateSession);
+router.delete("/", validateToken, deleteSession);
+router.post("/updatedb", validateToken, updateCacheDb);
+
+export default router;

backend/src/services/sessionService.ts

@@ -13,10 +13,7 @@ export const switchCacheDb = (db_id: number) => {
   RedisService.useDb(db_id);
 };
 
-export const createSessionService = async (
-  sessionId: string,
-  data: SessionData
-) => {
+export const dummy = async (sessionId: string, data: SessionData) => {
   const {
     city,
     domain,
@@ -170,3 +167,29 @@ export const deleteService = async (subscriber_url: string) => {
     throw new Error(`${e.message}`);
   }
 };
+
+export const createSessionService = async (sessionID: string, data: any) => {
+  console.log("session data payload", sessionID, data);
+
+  try {
+    const session = await RedisService.getKey(sessionID);
+
+    console.log("session>>>>", session);
+
+    if (session) {
+      throw new Error("session already exists");
+      return;
+    }
+
+    // Store session data in Redis
+    const newSession = await RedisService.setKey(
+      sessionID,
+      JSON.stringify(data),
+      SESSION_EXPIRY
+    );
+    console.log("session", newSession);
+    return "Session created successfully";
+  } catch (error: any) {
+    throw new Error(`${error.message}`);
+  }
+};