Merge pull request #3008 from bluewave-labs/feat/v2/uptime-details

feat/v2/uptime details

server/src/controllers/v2/MonitorController.ts

@@ -2,10 +2,13 @@ import { Request, Response, NextFunction } from "express";
 import ApiError from "../../utils/ApiError.js";
 import MonitorService from "../../service/v2/business/MonitorService.js";
 import { MonitorType } from "../../db/v2/models/monitors/Monitor.js";
+import CheckService from "../../service/v2/business/CheckService.js";
 class MonitorController {
 	private monitorService: MonitorService;
-	constructor(monitorService: MonitorService) {
+	private checkService: CheckService;
+	constructor(monitorService: MonitorService, checkService: CheckService) {
 		this.monitorService = monitorService;
+		this.checkService = checkService;
 	}
 
 	create = async (req: Request, res: Response, next: NextFunction) => {
@@ -25,6 +28,86 @@ class MonitorController {
 		}
 	};
 
+	getAll = async (req: Request, res: Response, next: NextFunction) => {
+		try {
+			const tokenizedUser = req.user;
+			if (!tokenizedUser) {
+				return res.status(401).json({ message: "Unauthorized" });
+			}
+
+			let monitors;
+			if (req.query.embedChecks === "true") {
+				const page = Math.max(1, Number(req.query.page) || 1);
+				const limit = Math.max(1, Number(req.query.limit) || 10);
+				const type: MonitorType[] = req.query.type as MonitorType[];
+
+				monitors = await this.monitorService.getAllEmbedChecks(page, limit, type);
+			} else {
+				monitors = await this.monitorService.getAll();
+			}
+
+			res.status(200).json({
+				message: "Monitors retrieved successfully",
+				data: monitors,
+			});
+		} catch (error) {
+			next(error);
+		}
+	};
+
+	getChecks = async (req: Request, res: Response, next: NextFunction) => {
+		try {
+			const tokenizedUser = req.user;
+			if (!tokenizedUser) {
+				return res.status(401).json({ message: "Unauthorized" });
+			}
+
+			const id = req.params.id;
+			if (!id) {
+				throw new ApiError("Monitor ID is required", 400);
+			}
+
+			const page = Number(req.query.page);
+			const rowsPerPage = Number(req.query.rowsPerPage);
+
+			if (isNaN(page)) throw new ApiError("Page query parameter must be a number", 400);
+			if (isNaN(rowsPerPage)) throw new ApiError("rowsPerPage query parameter must be a number", 400);
+
+			if (page < 0) throw new ApiError("Page must be greater than 0", 400);
+			if (rowsPerPage < 0) throw new ApiError("rowsPerPage must be greater than 0", 400);
+
+			const { count, checks } = await this.checkService.getChecks(id, page, rowsPerPage);
+			res.status(200).json({
+				message: "Checks retrieved successfully",
+				data: { count, checks },
+			});
+		} catch (error) {
+			next(error);
+		}
+	};
+
+	toggleActive = async (req: Request, res: Response, next: NextFunction) => {
+		try {
+			const tokenizedUser = req.user;
+			if (!tokenizedUser) {
+				return res.status(401).json({ message: "Unauthorized" });
+			}
+
+			const id = req.params.id;
+			if (!id) {
+				throw new ApiError("Monitor ID is required", 400);
+			}
+
+			const monitor = await this.monitorService.toggleActive(id, tokenizedUser);
+			res.status(200).json({
+				message: "Monitor paused/unpaused successfully",
+				data: monitor,
+			});
+		} catch (error) {
+			next(error);
+		}
+	};
+
 	get = async (req: Request, res: Response, next: NextFunction) => {
 		try {
 			const tokenizedUser = req.user;
@@ -62,55 +145,6 @@ class MonitorController {
 		}
 	};
 
-	getAll = async (req: Request, res: Response, next: NextFunction) => {
-		try {
-			const tokenizedUser = req.user;
-			if (!tokenizedUser) {
-				return res.status(401).json({ message: "Unauthorized" });
-			}
-
-			let monitors;
-			if (req.query.embedChecks === "true") {
-				const page = Math.max(1, Number(req.query.page) || 1);
-				const limit = Math.max(1, Number(req.query.limit) || 10);
-				const type: MonitorType[] = req.query.type as MonitorType[];
-
-				monitors = await this.monitorService.getAllEmbedChecks(page, limit, type);
-			} else {
-				monitors = await this.monitorService.getAll();
-			}
-
-			res.status(200).json({
-				message: "Monitors retrieved successfully",
-				data: monitors,
-			});
-		} catch (error) {
-			next(error);
-		}
-	};
-
-	toggleActive = async (req: Request, res: Response, next: NextFunction) => {
-		try {
-			const tokenizedUser = req.user;
-			if (!tokenizedUser) {
-				return res.status(401).json({ message: "Unauthorized" });
-			}
-
-			const id = req.params.id;
-			if (!id) {
-				throw new ApiError("Monitor ID is required", 400);
-			}
-
-			const monitor = await this.monitorService.toggleActive(id, tokenizedUser);
-			res.status(200).json({
-				message: "Monitor paused/unpaused successfully",
-				data: monitor,
-			});
-		} catch (error) {
-			next(error);
-		}
-	};
-
 	update = async (req: Request, res: Response, next: NextFunction) => {
 		try {
 			const tokenizedUser = req.user;