class NotificationProvider { /** * Notification Provider Name * @type {string} */ name = undefined; /** * Send a notification * @param {BeanModel} notification Notification to send * @param {string} msg General Message * @param {?object} monitorJSON Monitor details (For Up/Down only) * @param {?object} heartbeatJSON Heartbeat details (For Up/Down only) * @returns {Promise<string>} Return Successful Message * @throws Error with fail msg */ async send(notification, msg, monitorJSON = null, heartbeatJSON = null) { throw new Error("Have to override Notification.send(...)"); } /** * Extracts the address from a monitor JSON object based on its type. * @param {?object} monitorJSON Monitor details (For Up/Down only) * @returns {string} The extracted address based on the monitor type. */ extractAddress(monitorJSON) { if (!monitorJSON) { return ""; } switch (monitorJSON["type"]) { case "push": return "Heartbeat"; case "ping": return monitorJSON["hostname"]; case "port": case "dns": case "gamedig": case "steam": if (monitorJSON["port"]) { return monitorJSON["hostname"] + ":" + monitorJSON["port"]; } return monitorJSON["hostname"]; default: if (![ "https://", "http://", "" ].includes(monitorJSON["url"])) { return monitorJSON["url"]; } return ""; } } /** * Throws an error * @param {any} error The error to throw * @returns {void} * @throws {any} The error specified */ throwGeneralAxiosError(error) { let msg = "Error: " + error + " "; if (error.response && error.response.data) { if (typeof error.response.data === "string") { msg += error.response.data; } else { msg += JSON.stringify(error.response.data); } } throw new Error(msg); } } module.exports = NotificationProvider;