Added metrics collection

backend/config/database.js

@@ -1,9 +1,9 @@
 const mongoose = require("mongoose");
-require("dotenv").config();  // Add this line to load .env variables
+require("dotenv").config(); // Add this line to load .env variables
 
 const connectDB = async () => {
   try {
-    await mongoose.connect(process.env.MONGO_URI); 
+    await mongoose.connect(process.env.MONGO_URI);
     console.log("MongoDB connected");
   } catch (error) {
     console.error("MongoDB connection error:", error);

backend/docker-compose.yml

@@ -9,6 +9,17 @@ services:
     image: redis
     ports:
       - "6379:6379" 
+  prom-server:
+    image: prom/prometheus
+    ports:
+      - 9090:9090
+    volumes:
+      - ./prometheus-config.yml:/etc/prometheus/prometheus.yml
+  grafana:
+    image: grafana/grafana-enterprise
+    container_name: grafana
+    ports:
+     - 3000:3000
 
 volumes:
   mongo-data:

backend/index.js

@@ -11,10 +11,27 @@ const requestRouter = require("./routes/request");
 const userRouter = require("./routes/user");
 const analyticsLogger = require("./utils/analyticsLogger");
 const activity = require("./routes/activity");
+const metricsRouter = require("./routes/metrics");
+const client = require("prom-client");
+const responseTime = require("response-time");
 
 const app = express();
 const PORT = process.env.PORT || 7777;
 
+const collectMetrics = client.collectDefaultMetrics;
+collectMetrics({ register: client.register });
+const trackTime = new client.Histogram({
+  name: "track_all_req_res_time",
+  help: "Tracking all the Request and Responce Time",
+  labelNames: ["method", "route", "status_code"],
+  buckets: [1, 50, 100, 200, 400, 500, 800, 1000, 2000],
+});
+// To Track total number of Request
+const trackTotalRequest = new client.Counter({
+  name: "track_total_request",
+  help: "This will track total request",
+});
+
 // Allowed origins for CORS
 const allowedOrigins = [
   "https://intrest-fusion-frontend.vercel.app",
@@ -30,6 +47,20 @@ app.use(
     credentials: true,
   })
 );
+
+app.use(
+  responseTime((req, res, time) => {
+    trackTotalRequest.inc();
+    trackTime
+      .labels({
+        method: req.method,
+        route: req.url,
+        status_code: res.statusCode,
+      })
+      .observe(time);
+  })
+);
+
 const apiLimiter = rateLimit({
   windowMs: 60 * 60 * 1000, // 1 hour
   max: 5000,
@@ -47,6 +78,7 @@ app.use("/", profileRouter);
 app.use("/", requestRouter);
 app.use("/", userRouter);
 app.use("/api/", activity);
+app.use("/", metricsRouter);
 
 app.get("/", (req, res) => {
   res.send("Server is running");

backend/package.json

@@ -28,7 +28,9 @@
     "multer": "^1.4.5-lts.1",
     "nodemailer": "^6.9.16",
     "nodemon": "^3.1.7",
+    "prom-client": "^15.1.3",
     "redis": "^4.7.0",
+    "response-time": "^2.3.3",
     "validator": "^13.12.0"
   }
 }

backend/prometheus-config.yml

@@ -0,0 +1,8 @@
+global:
+  scrape_interval: 4s
+
+scrape_configs:
+  - job_name: prometheus
+    static_configs:
+      # use `ipconfig` in cmd to get your private ip address
+      - targets: ["<your private IP address>:7777"]

backend/routes/activity.js

@@ -28,7 +28,6 @@ router.get("/health", (req, res) => {
     mongoDbConnectionStatus = mongoose.connection.readyState;
     // checking Redis connection
     redisConnectionStatus = redisClient.isReady;
-    console.log(redisConnectionStatus);
   } catch (e) {
     res.send({
       message: "There is an issue with connections.",

backend/routes/metrics.js

@@ -0,0 +1,12 @@
+const express = require("express");
+
+const metricsRouter = express.Router();
+const client = require("prom-client");
+
+metricsRouter.get("/metrics", async (req, res) => {
+  res.setHeader("Content-Type", client.register.contentType);
+  const metrics = await client.register.metrics();
+  res.send(metrics);
+});
+
+module.exports = metricsRouter;