Add Discord webhook notification support

Server/db/models/Notification.js

@@ -8,7 +8,7 @@ const NotificationSchema = mongoose.Schema(
 		},
 		type: {
 			type: String,
-			enum: ["email", "sms"],
+			enum: ["email", "sms", "discord", "slack", "telegram"],
 		},
 		address: {
 			type: String,

Server/service/notificationService.js

@@ -1,4 +1,5 @@
 const SERVICE_NAME = "NotificationService";
+import axios from 'axios';
 
 class NotificationService {
 	static SERVICE_NAME = SERVICE_NAME;
@@ -16,6 +17,77 @@ class NotificationService {
 		this.logger = logger;
 	}
 
+	async sendDiscordNotification(networkResponse, webhookUrl) {
+        const { monitor, status } = networkResponse;
+        const message = {
+            content: `Monitor ${monitor.name} is ${status ? "up" : "down"}. URL: ${monitor.url}`
+        };
+
+        try {
+            await axios.post(webhookUrl, message);
+            return true;
+        } catch (error) {
+            this.logger.error({
+                message: error.message,
+                service: this.SERVICE_NAME,
+                method: "sendDiscordNotification",
+                stack: error.stack,
+            });
+            return false;
+        }
+    }
+
+	async sendSlackNotification(networkResponse, webhookUrl) {
+        const { monitor, status } = networkResponse;
+        const message = {
+            text: `Monitor ${monitor.name} is ${status ? "up" : "down"}. URL: ${monitor.url}`
+        };
+
+        try {
+            await axios.post(webhookUrl, message);
+            return true;
+        } catch (error) {
+            this.logger.error({
+                message: error.message,
+                service: this.SERVICE_NAME,
+                method: "sendSlackNotification",
+                stack: error.stack,
+            });
+            return false;
+        }
+    }
+
+	async sendTelegramNotification(networkResponse, address) {
+		const { monitor, status } = networkResponse;
+
+		const [botToken, chatId] = address.split('|').map(part => part?.trim());
+
+		if (!botToken || !chatId) {
+			return false;
+		}
+
+		const message = {
+			chat_id: chatId,
+			text: `Monitor ${monitor.name} is ${status ? "up" : "down"}. URL: ${monitor.url}`,
+		};
+
+		const url = `https://api.telegram.org/bot${botToken}/sendMessage`;
+
+		try {
+			await axios.post(url, message, {
+				headers: {
+					'Content-Type': 'application/json',
+				},
+			});
+			return true;
+		} catch (error) {
+			return false;
+		}
+	}
+
+
+
+
 	/**
 	 * Sends an email notification for hardware infrastructure alerts
 	 *
@@ -57,19 +129,22 @@ class NotificationService {
 
 	async handleStatusNotifications(networkResponse) {
 		try {
-			//If status hasn't changed, we're done
 			if (networkResponse.statusChanged === false) return false;
-
-			// if prevStatus is undefined, monitor is resuming, we're done
 			if (networkResponse.prevStatus === undefined) return false;
-			const notifications = await this.db.getNotificationsByMonitorId(
-				networkResponse.monitorId
-			);
-
+
+			const notifications = await this.db.getNotificationsByMonitorId(networkResponse.monitorId);
+
 			for (const notification of notifications) {
 				if (notification.type === "email") {
 					this.sendEmail(networkResponse, notification.address);
+				} else if (notification.type === "discord") {
+					this.sendDiscordNotification(networkResponse, notification.address);
+				} else if (notification.type === "slack") {
+					this.sendSlackNotification(networkResponse, notification.address);
+				} else if (notification.type === "telegram") {
+					this.sendTelegramNotification(networkResponse, notification.address);
 				}
+
 				// Handle other types of notifications here
 			}
 			return true;