fix(redis_auth): auth usign mongo if not connected

fixing #67

middleware/auth/authUsingRedis.ts

@@ -16,7 +16,7 @@ const redisClient = redis.createClient({
 const connectRedis = async (): Promise<boolean> => {
   try {
     await redisClient.connect();
-    console.log("Redis Connection Successful");
+    console.log("Redis Connected Successfully");
     isRedisConnected = true;
     return true;
   } catch (err) {
@@ -26,6 +26,14 @@ const connectRedis = async (): Promise<boolean> => {
   }
 };
 
+redisClient.on("error", function (err) {
+  // if redis disconnected or throw error
+  if (isRedisConnected === true) {
+    isRedisConnected = false;
+    console.log(isRedisConnected);
+  }
+});
+
 const authenticate: RequestHandler = async (
   req: Request,
   res: Response,
@@ -109,9 +117,38 @@ const authenticate: RequestHandler = async (
       req.userID = parsedUserDetail.userID;
       next();
     } else {
-      // redis is not connected
+      // redis is not connected then we have to authenticate using mongodb
+      const rootUser = await UserDetail.findOne(
+        {
+          id: verifyToken.id,
+          "tokens.token": token,
+        },
+        // filtering to get only data that is need when page load
+        {
+          userID: 1,
+          name: 1,
+          id: 1,
+          email: 1,
+          _id: 0,
+        }
+      );
+      if (!rootUser) {
+        return res.status(401).send(<ResponseObject>{
+          success: false,
+          msg: "User not found, sorry not a valid token",
+        });
+      }
+      req.token = token;
+      req.rootUser = rootUser;
+      req.userID = rootUser.userID;
+      next();
     }
-  } catch (err) {}
+  } catch (err) {
+    return res.status(500).json(<ResponseObject>{
+      success: false,
+      msg: "Server Error!!, Please Try again later",
+    });
+  }
 };
 
 export default authenticate;

src/index.ts

@@ -14,7 +14,10 @@ import cors from "cors";
 import bodyParser from "body-parser";
 import { httpServer, app } from "../socket/io.js";
 import AuthAdmin from "../funcs/AuthAdmin.js";
-import { connectRedis } from "../middleware/auth/authUsingRedis.js";
+import {
+  connectRedis,
+  redisClient,
+} from "../middleware/auth/authUsingRedis.js";
 const PORT = process.env.PORT;
 
 // warning: connect.session() MemoryStorage is not designed for a production environment as it will leak memory, and will not scale past a single process.