Kuma/server/notification-providers/pushplus.js

const NotificationProvider = require("./notification-provider");
const axios = require("axios");
const { DOWN, UP } = require("../../src/util");

class PushPlus extends NotificationProvider {
    name = "PushPlus";

    /**
     * @inheritdoc
     * @param {BeanModel} notification Notification object
     * @param {string} msg Message content
     * @param {?object} monitorJSON Monitor details
     * @param {?object} heartbeatJSON Heartbeat details
     * @returns {Promise<string>} Success message
     */
    async send(notification, msg, monitorJSON = null, heartbeatJSON = null) {
        const okMsg = "Sent Successfully.";
        const url = "https://www.pushplus.plus/send";
        try {
            await axios.post(url, {
                "token": notification.pushPlusSendKey,
                "title": this.checkStatus(heartbeatJSON, monitorJSON),
                "content": msg,
                "template": "html"
            }, { headers: { "Content-Type": "application/json" } }
            );
            return okMsg;

        } catch (error) {
            this.throwGeneralAxiosError(error);
            console.error("PushPlus Error:", error.response?.data || error.message);
            throw new Error("Notification failed: " + error.message);
        }
    }

    /**
     * Get the formatted title for message
     * @param {?object} heartbeatJSON Heartbeat details (For Up/Down only)
     * @param {?object} monitorJSON Monitor details (For Up/Down only)
     * @returns {string} Formatted title
     */
    checkStatus(heartbeatJSON, monitorJSON) {
        let title = "UptimeKuma Message";
        if (heartbeatJSON != null && heartbeatJSON["status"] === UP) {
            title = "UptimeKuma Monitor Up " + monitorJSON["name"];
        }
        if (heartbeatJSON != null && heartbeatJSON["status"] === DOWN) {
            title = "UptimeKuma Monitor Down " + monitorJSON["name"];
        }
        return title;
    }
}

module.exports = PushPlus;