uptime-kuma/server/notification.js

154 lines
4.7 KiB
JavaScript
Raw Normal View History

2021-07-27 17:47:13 +00:00
const { R } = require("redbean-node");
2021-09-07 14:42:46 +00:00
const Apprise = require("./notification-providers/apprise");
const Discord = require("./notification-providers/discord");
const Gotify = require("./notification-providers/gotify");
const Line = require("./notification-providers/line");
const LunaSea = require("./notification-providers/lunasea");
const Mattermost = require("./notification-providers/mattermost");
2021-10-05 18:03:56 +00:00
const Matrix = require("./notification-providers/matrix");
2021-09-07 14:42:46 +00:00
const Octopush = require("./notification-providers/octopush");
const Pushbullet = require("./notification-providers/pushbullet");
const Pushover = require("./notification-providers/pushover");
const Pushy = require("./notification-providers/pushy");
const RocketChat = require("./notification-providers/rocket-chat");
const Signal = require("./notification-providers/signal");
const Slack = require("./notification-providers/slack");
const SMTP = require("./notification-providers/smtp");
const Teams = require("./notification-providers/teams");
2021-09-07 14:42:46 +00:00
const Telegram = require("./notification-providers/telegram");
const Webhook = require("./notification-providers/webhook");
2021-07-09 06:14:03 +00:00
class Notification {
2021-07-18 10:51:58 +00:00
2021-09-07 14:42:46 +00:00
providerList = {};
static init() {
console.log("Prepare Notification Providers");
this.providerList = {};
const list = [
new Apprise(),
new Discord(),
new Teams(),
2021-09-07 14:42:46 +00:00
new Gotify(),
new Line(),
new LunaSea(),
new Mattermost(),
2021-10-05 18:03:56 +00:00
new Matrix(),
2021-09-07 14:42:46 +00:00
new Octopush(),
new Pushbullet(),
new Pushover(),
new Pushy(),
new RocketChat(),
new Signal(),
new Slack(),
new SMTP(),
new Telegram(),
new Webhook(),
];
for (let item of list) {
if (! item.name) {
throw new Error("Notification provider without name");
}
if (this.providerList[item.name]) {
throw new Error("Duplicate notification provider name");
}
this.providerList[item.name] = item;
}
}
2021-07-18 12:49:46 +00:00
/**
*
2021-09-07 14:42:46 +00:00
* @param notification : BeanModel
* @param msg : string General Message
* @param monitorJSON : object Monitor details (For Up/Down only)
* @param heartbeatJSON : object Heartbeat details (For Up/Down only)
2021-07-18 12:49:46 +00:00
* @returns {Promise<string>} Successful msg
* Throw Error with fail msg
*/
2021-07-09 11:33:22 +00:00
static async send(notification, msg, monitorJSON = null, heartbeatJSON = null) {
2021-09-07 14:42:46 +00:00
if (this.providerList[notification.type]) {
return this.providerList[notification.type].send(notification, msg, monitorJSON, heartbeatJSON);
2021-07-09 06:14:03 +00:00
} else {
2021-09-07 14:42:46 +00:00
throw new Error("Notification type is not supported");
2021-07-09 06:14:03 +00:00
}
}
static async save(notification, notificationID, userID) {
let bean
if (notificationID) {
bean = await R.findOne("notification", " id = ? AND user_id = ? ", [
notificationID,
userID,
])
if (! bean) {
throw new Error("notification not found")
}
} else {
bean = R.dispense("notification")
}
bean.name = notification.name;
bean.user_id = userID;
bean.config = JSON.stringify(notification);
2021-09-09 12:22:32 +00:00
bean.is_default = notification.isDefault || false;
2021-07-09 06:14:03 +00:00
await R.store(bean)
if (notification.applyExisting) {
await applyNotificationEveryMonitor(bean.id, userID);
}
return bean;
2021-07-09 06:14:03 +00:00
}
static async delete(notificationID, userID) {
let bean = await R.findOne("notification", " id = ? AND user_id = ? ", [
notificationID,
userID,
])
if (! bean) {
throw new Error("notification not found")
}
await R.trash(bean)
}
2021-07-09 17:08:08 +00:00
2021-07-18 10:51:58 +00:00
static checkApprise() {
2021-07-27 17:47:13 +00:00
let commandExistsSync = require("command-exists").sync;
let exists = commandExistsSync("apprise");
2021-07-18 10:51:58 +00:00
return exists;
2021-07-10 03:38:00 +00:00
}
2021-07-18 12:49:46 +00:00
}
2021-07-10 03:38:00 +00:00
async function applyNotificationEveryMonitor(notificationID, userID) {
let monitors = await R.getAll("SELECT id FROM monitor WHERE user_id = ?", [
userID
]);
for (let i = 0; i < monitors.length; i++) {
let checkNotification = await R.findOne("monitor_notification", " monitor_id = ? AND notification_id = ? ", [
monitors[i].id,
notificationID,
])
if (! checkNotification) {
let relation = R.dispense("monitor_notification");
relation.monitor_id = monitors[i].id;
relation.notification_id = notificationID;
await R.store(relation)
}
}
}
2021-07-09 06:14:03 +00:00
module.exports = {
Notification,
}