Create midware.js

midware.js

@@ -0,0 +1,44 @@
+var Database = require('./database.js');
+
+const CheckMilWare = async (app) => {
+  return async (req, res, next) => {
+    try {
+      const dbClient = new Database("AkenoXJs", "FastJsAPI");
+
+      const xForwardedFor = req.headers['x-forwarded-for'];
+      const xRealIP = req.headers['x-real-ip'];
+      const cfConnectingIP = req.headers['cf-connecting-ip'];
+      let realIP = req.ip;
+  
+      if (xForwardedFor) {
+        realIP = xForwardedFor.split(',')[0].trim();
+      } else if (xRealIP) {
+        realIP = xRealIP;
+      } else if (cfConnectingIP) {
+        realIP = cfConnectingIP;
+      }
+
+      req.realIP = realIP;
+
+      const isBlocked = await dbClient.CheckIsBlocked(realIP);
+      if (isBlocked && isBlocked.blocked === true) {
+        return res.status(403).send("Access denied: IP is blocked");
+      }
+
+      if (req.path === '/env') {
+        console.log("Check path /env");
+        await dbClient.AddIpisBlocked(realIP);
+        return res.status(403).send("Access denied: IP is blocked..");
+      }
+
+      await dbClient.IPAddressAndUpdate(realIP);
+  
+      console.log(`Real IP address is: ${realIP}, header: ${xForwardedFor ? "x-forwarded-for" : xRealIP ? "x-real-ip" : cfConnectingIP ? "cf-connecting-ip" : "req.ip"}`);
+
+      next();
+    } catch (error) {
+      console.error("Error in middleware: " + error);
+      res.status(500).send("Something bad happened");
+    }
+  };
+};