mirror of
				https://github.com/louislam/uptime-kuma.git
				synced 2025-11-04 13:46:13 +08:00 
			
		
		
		
	- I unified where in file the name of `NotificationProvider.name` is placed - I made sure that all the providers adhere to the signature of `NotificationProvider.send()` - I made sure that all the providers use `okMsg` if returning success messages directly from the function. Here a discussion should be had: Should this be refactored into a constant of `NotificationProvider`? I could imagine that `NotificationProvider.SENDING_SUCCESSFULL` could be a suitable alternative. - I made sure all providers have the URL they `POST`/`GET` to be extraced into a variable. => refactored this way due to Nelsons suggestion
		
			
				
	
	
		
			70 lines
		
	
	
		
			2.5 KiB
		
	
	
	
		
			JavaScript
		
	
	
	
	
	
			
		
		
	
	
			70 lines
		
	
	
		
			2.5 KiB
		
	
	
	
		
			JavaScript
		
	
	
	
	
	
const NotificationProvider = require("./notification-provider");
 | 
						|
const axios = require("axios");
 | 
						|
const { DOWN, UP } = require("../../src/util");
 | 
						|
 | 
						|
class Line extends NotificationProvider {
 | 
						|
    name = "line";
 | 
						|
 | 
						|
    /**
 | 
						|
     * @inheritdoc
 | 
						|
     */
 | 
						|
    async send(notification, msg, monitorJSON = null, heartbeatJSON = null) {
 | 
						|
        const okMsg = "Sent Successfully.";
 | 
						|
        const url = "https://api.line.me/v2/bot/message/push";
 | 
						|
 | 
						|
        try {
 | 
						|
            let config = {
 | 
						|
                headers: {
 | 
						|
                    "Content-Type": "application/json",
 | 
						|
                    "Authorization": "Bearer " + notification.lineChannelAccessToken
 | 
						|
                }
 | 
						|
            };
 | 
						|
            if (heartbeatJSON == null) {
 | 
						|
                let testMessage = {
 | 
						|
                    "to": notification.lineUserID,
 | 
						|
                    "messages": [
 | 
						|
                        {
 | 
						|
                            "type": "text",
 | 
						|
                            "text": "Test Successful!"
 | 
						|
                        }
 | 
						|
                    ]
 | 
						|
                };
 | 
						|
                await axios.post(url, testMessage, config);
 | 
						|
            } else if (heartbeatJSON["status"] === DOWN) {
 | 
						|
                let downMessage = {
 | 
						|
                    "to": notification.lineUserID,
 | 
						|
                    "messages": [
 | 
						|
                        {
 | 
						|
                            "type": "text",
 | 
						|
                            "text": "UptimeKuma Alert: [🔴 Down]\n" +
 | 
						|
                                "Name: " + monitorJSON["name"] + " \n" +
 | 
						|
                                heartbeatJSON["msg"] +
 | 
						|
                                `\nTime (${heartbeatJSON["timezone"]}): ${heartbeatJSON["localDateTime"]}`
 | 
						|
                        }
 | 
						|
                    ]
 | 
						|
                };
 | 
						|
                await axios.post(url, downMessage, config);
 | 
						|
            } else if (heartbeatJSON["status"] === UP) {
 | 
						|
                let upMessage = {
 | 
						|
                    "to": notification.lineUserID,
 | 
						|
                    "messages": [
 | 
						|
                        {
 | 
						|
                            "type": "text",
 | 
						|
                            "text": "UptimeKuma Alert: [✅ Up]\n" +
 | 
						|
                                "Name: " + monitorJSON["name"] + " \n" +
 | 
						|
                                heartbeatJSON["msg"] +
 | 
						|
                                `\nTime (${heartbeatJSON["timezone"]}): ${heartbeatJSON["localDateTime"]}`
 | 
						|
                        }
 | 
						|
                    ]
 | 
						|
                };
 | 
						|
                await axios.post(url, upMessage, config);
 | 
						|
            }
 | 
						|
            return okMsg;
 | 
						|
        } catch (error) {
 | 
						|
            this.throwGeneralAxiosError(error);
 | 
						|
        }
 | 
						|
    }
 | 
						|
}
 | 
						|
 | 
						|
module.exports = Line;
 |