121 lines
4.4 KiB
JavaScript
121 lines
4.4 KiB
JavaScript
const nodemailer = require("nodemailer");
|
|
const NotificationProvider = require("./notification-provider");
|
|
const { DOWN } = require("../../src/util");
|
|
const { Liquid } = require("liquidjs");
|
|
|
|
class SMTP extends NotificationProvider {
|
|
name = "smtp";
|
|
|
|
/**
|
|
* @inheritdoc
|
|
*/
|
|
async send(notification, msg, monitorJSON = null, heartbeatJSON = null) {
|
|
const okMsg = "Sent Successfully.";
|
|
|
|
const config = {
|
|
host: notification.smtpHost,
|
|
port: notification.smtpPort,
|
|
secure: notification.smtpSecure,
|
|
tls: {
|
|
rejectUnauthorized: !notification.smtpIgnoreTLSError || false,
|
|
}
|
|
};
|
|
|
|
// Fix #1129
|
|
if (notification.smtpDkimDomain) {
|
|
config.dkim = {
|
|
domainName: notification.smtpDkimDomain,
|
|
keySelector: notification.smtpDkimKeySelector,
|
|
privateKey: notification.smtpDkimPrivateKey,
|
|
hashAlgo: notification.smtpDkimHashAlgo,
|
|
headerFieldNames: notification.smtpDkimheaderFieldNames,
|
|
skipFields: notification.smtpDkimskipFields,
|
|
};
|
|
}
|
|
|
|
// Should fix the issue in https://github.com/louislam/uptime-kuma/issues/26#issuecomment-896373904
|
|
if (notification.smtpUsername || notification.smtpPassword) {
|
|
config.auth = {
|
|
user: notification.smtpUsername,
|
|
pass: notification.smtpPassword,
|
|
};
|
|
}
|
|
|
|
// default values in case the user does not want to template
|
|
let subject = msg;
|
|
let body = msg;
|
|
if (heartbeatJSON) {
|
|
body = `${msg}\nTime (${heartbeatJSON["timezone"]}): ${heartbeatJSON["localDateTime"]}`;
|
|
}
|
|
// subject and body are templated
|
|
if ((monitorJSON && heartbeatJSON) || msg.endsWith("Testing")) {
|
|
// cannot end with whitespace as this often raises spam scores
|
|
const customSubject = notification.customSubject?.trim() || "";
|
|
const customBody = notification.customBody?.trim() || "";
|
|
|
|
const context = this.generateContext(msg, monitorJSON, heartbeatJSON);
|
|
const engine = new Liquid();
|
|
if (customSubject !== "") {
|
|
const tpl = engine.parse(customSubject);
|
|
subject = await engine.render(tpl, context);
|
|
}
|
|
if (customBody !== "") {
|
|
const tpl = engine.parse(customBody);
|
|
body = await engine.render(tpl, context);
|
|
}
|
|
}
|
|
|
|
// send mail with defined transport object
|
|
let transporter = nodemailer.createTransport(config);
|
|
await transporter.sendMail({
|
|
from: notification.smtpFrom,
|
|
cc: notification.smtpCC,
|
|
bcc: notification.smtpBCC,
|
|
to: notification.smtpTo,
|
|
subject: subject,
|
|
text: body,
|
|
});
|
|
|
|
return okMsg;
|
|
}
|
|
|
|
/**
|
|
* Generate context for LiquidJS
|
|
* @param {string} msg the message that will be included in the context
|
|
* @param {?object} monitorJSON Monitor details (For Up/Down/Cert-Expiry only)
|
|
* @param {?object} heartbeatJSON Heartbeat details (For Up/Down only)
|
|
* @returns {{STATUS: string, status: string, HOSTNAME_OR_URL: string, hostnameOrUrl: string, NAME: string, name: string, monitorJSON: ?object, heartbeatJSON: ?object, msg: string}} the context
|
|
*/
|
|
generateContext(msg, monitorJSON, heartbeatJSON) {
|
|
// Let's start with dummy values to simplify code
|
|
let monitorName = "Monitor Name not available";
|
|
let monitorHostnameOrURL = "testing.hostname";
|
|
|
|
if (monitorJSON !== null) {
|
|
monitorName = monitorJSON["name"];
|
|
monitorHostnameOrURL = this.extractAddress(monitorJSON);
|
|
}
|
|
|
|
let serviceStatus = "⚠️ Test";
|
|
if (heartbeatJSON !== null) {
|
|
serviceStatus = (heartbeatJSON["status"] === DOWN) ? "🔴 Down" : "✅ Up";
|
|
}
|
|
return {
|
|
// for v1 compatibility, to be removed in v3
|
|
"STATUS": serviceStatus,
|
|
"NAME": monitorName,
|
|
"HOSTNAME_OR_URL": monitorHostnameOrURL,
|
|
|
|
// variables which are officially supported
|
|
"status": serviceStatus,
|
|
"name": monitorName,
|
|
"hostnameOrURL": monitorHostnameOrURL,
|
|
monitorJSON,
|
|
heartbeatJSON,
|
|
msg,
|
|
};
|
|
}
|
|
}
|
|
|
|
module.exports = SMTP;
|