mirror of https://github.com/louislam/uptime-kuma
				
				
				
			
		
			
				
	
	
		
			51 lines
		
	
	
		
			1.7 KiB
		
	
	
	
		
			JavaScript
		
	
	
			
		
		
	
	
			51 lines
		
	
	
		
			1.7 KiB
		
	
	
	
		
			JavaScript
		
	
	
const NotificationProvider = require("./notification-provider");
 | 
						|
const axios = require("axios");
 | 
						|
const { setting } = require("../util-server");
 | 
						|
const { getMonitorRelativeURL, UP, DOWN } = require("../../src/util");
 | 
						|
 | 
						|
class AlertNow extends NotificationProvider {
 | 
						|
 | 
						|
    name = "AlertNow";
 | 
						|
 | 
						|
    async send(notification, msg, monitorJSON = null, heartbeatJSON = null) {
 | 
						|
        let okMsg = "Sent Successfully.";
 | 
						|
        try {
 | 
						|
            let textMsg = "";
 | 
						|
            let status = "open";
 | 
						|
            let eventType = "ERROR";
 | 
						|
            let eventId = new Date().toISOString().slice(0, 10).replace(/-/g, "");
 | 
						|
 | 
						|
            if (heartbeatJSON && heartbeatJSON.status === UP) {
 | 
						|
                textMsg = `[${heartbeatJSON.name}] ✅ Application is back online`;
 | 
						|
                status = "close";
 | 
						|
                eventType = "INFO";
 | 
						|
                eventId += `_${heartbeatJSON.name.replace(/\s/g, "")}`;
 | 
						|
            } else if (heartbeatJSON && heartbeatJSON.status === DOWN) {
 | 
						|
                textMsg = `[${heartbeatJSON.name}] 🔴 Application went down`;
 | 
						|
            }
 | 
						|
 | 
						|
            textMsg += ` - ${msg}`;
 | 
						|
 | 
						|
            const baseURL = await setting("primaryBaseURL");
 | 
						|
            if (baseURL && monitorJSON) {
 | 
						|
                textMsg += ` >> ${baseURL + getMonitorRelativeURL(monitorJSON.id)}`;
 | 
						|
            }
 | 
						|
 | 
						|
            const data = {
 | 
						|
                "summary": textMsg,
 | 
						|
                "status": status,
 | 
						|
                "event_type": eventType,
 | 
						|
                "event_id": eventId,
 | 
						|
            };
 | 
						|
 | 
						|
            await axios.post(notification.alertNowWebhookURL, data);
 | 
						|
            return okMsg;
 | 
						|
        } catch (error) {
 | 
						|
            this.throwGeneralAxiosError(error);
 | 
						|
        }
 | 
						|
 | 
						|
    }
 | 
						|
}
 | 
						|
 | 
						|
module.exports = AlertNow;
 |