feat: Add Matrix notification support Fixes #3034

server/src/db/v1/models/Notification.js

@@ -16,7 +16,7 @@ const NotificationSchema = mongoose.Schema(
 		},
 		type: {
 			type: String,
-			enum: ["email", "slack", "discord", "webhook", "pager_duty"],
+			enum: ["email", "slack", "discord", "webhook", "pager_duty", "matrix"],
 		},
 		notificationName: {
 			type: String,
@@ -28,6 +28,16 @@ const NotificationSchema = mongoose.Schema(
 		phone: {
 			type: String,
 		},
+		// Matrix-specific fields
+		homeserverUrl: {
+			type: String,
+		},
+		roomId: {
+			type: String,
+		},
+		accessToken: {
+			type: String,
+		},
 	},
 	{
 		timestamps: true,

server/src/service/v1/infrastructure/networkService.js

@@ -529,6 +529,42 @@ class NetworkService {
 			throw error;
 		}
 	}
+
+	async requestMatrix({ homeserverUrl, accessToken, roomId, message }) {
+		try {
+			const url = `${homeserverUrl}/_matrix/client/v3/rooms/${roomId}/send/m.room.message?access_token=${accessToken}`;
+			const body = {
+				msgtype: "m.text",
+				body: message,
+				format: "org.matrix.custom.html",
+				formatted_body: message,
+			};
+			const response = await this.axios.post(url, body, {
+				headers: {
+					"Content-Type": "application/json",
+				},
+			});
+
+			return {
+				status: true,
+				code: response.status,
+				message: "Successfully sent Matrix notification",
+			};
+		} catch (error) {
+			this.logger.warn({
+				message: error.message,
+				service: this.SERVICE_NAME,
+				method: "requestMatrix",
+			});
+
+			return {
+				status: false,
+				code: error.response?.status || this.NETWORK_ERROR,
+				message: "Failed to send Matrix notification",
+				payload: error.response?.data,
+			};
+		}
+	}
 }
 
 export default NetworkService;

server/src/service/v1/infrastructure/notificationProviders/matrix.js

@@ -0,0 +1,34 @@
+const SERVICE_NAME = "Matrix";
+
+class Matrix {
+	static SERVICE_NAME = SERVICE_NAME;
+
+	constructor({ networkService, logger }) {
+		this.networkService = networkService;
+		this.logger = logger;
+	}
+
+	get serviceName() {
+		return Matrix.SERVICE_NAME;
+	}
+
+	async send({ friendlyName, homeserverUrl, accessToken, roomId, message, monitorName }) {
+		const title = `Checkmate status for ${monitorName}`;
+		const formattedMessage = `## ${title}\n${message}`;
+		try {
+			await this.networkService.requestMatrix({
+				homeserverUrl,
+				accessToken,
+				roomId,
+				message: formattedMessage,
+			});
+			this.logger.info(`Successfully sent Matrix notification for ${friendlyName}`);
+			return true;
+		} catch (error) {
+			this.logger.error(`Failed to send Matrix notification for ${friendlyName}: ${error.message}`);
+			return false;
+		}
+	}
+}
+
+export default Matrix;

server/src/service/v1/infrastructure/notificationService.js

@@ -1,4 +1,5 @@
 const SERVICE_NAME = "NotificationService";
+import Matrix from "./notificationProviders/matrix.js";
 
 class NotificationService {
 	static SERVICE_NAME = SERVICE_NAME;
@@ -46,6 +47,14 @@ class NotificationService {
 
 			return response;
 		}
+		if (type === "matrix") {
+			const { friendlyName, homeserverUrl, accessToken, roomId } = notification;
+			const monitorName = subject;
+			const message = content;
+			const matrix = new Matrix({ networkService: this.networkService, logger: this.logger });
+			const success = await matrix.send({ friendlyName, homeserverUrl, accessToken, roomId, message, monitorName });
+			return success;
+		}
 	};
 
 	async handleNotifications(networkResponse) {

server/src/validation/joi.js

@@ -575,10 +575,10 @@ const createNotificationBodyValidation = joi.object({
 		"any.required": "Notification name is required",
 	}),
 
-	type: joi.string().valid("email", "webhook", "slack", "discord", "pager_duty").required().messages({
+	type: joi.string().valid("email", "webhook", "slack", "discord", "pager_duty", "matrix").required().messages({
 		"string.empty": "Notification type is required",
 		"any.required": "Notification type is required",
-		"any.only": "Notification type must be email, webhook, or pager_duty",
+		"any.only": "Notification type must be email, webhook, slack, discord, pager_duty, or matrix",
 	}),
 
 	address: joi.when("type", {
@@ -606,8 +606,40 @@ const createNotificationBodyValidation = joi.object({
 					"string.uri": "Please enter a valid Webhook URL",
 				}),
 			},
+			{
+				is: "matrix",
+				then: joi.string().allow("").optional(),
+			},
 		],
 	}),
+
+	homeserverUrl: joi.when("type", {
+		is: "matrix",
+		then: joi.string().uri().required().messages({
+			"string.empty": "Homeserver URL cannot be empty",
+			"any.required": "Homeserver URL is required",
+			"string.uri": "Please enter a valid Homeserver URL",
+		}),
+		otherwise: joi.string().allow("").optional(),
+	}),
+
+	roomId: joi.when("type", {
+		is: "matrix",
+		then: joi.string().required().messages({
+			"string.empty": "Room ID cannot be empty",
+			"any.required": "Room ID is required",
+		}),
+		otherwise: joi.string().allow("").optional(),
+	}),
+
+	accessToken: joi.when("type", {
+		is: "matrix",
+		then: joi.string().required().messages({
+			"string.empty": "Access Token cannot be empty",
+			"any.required": "Access Token is required",
+		}),
+		otherwise: joi.string().allow("").optional(),
+	}),
 });
 
 //****************************************