Musare/backend/logic/mail/index.js

/* eslint-disable global-require */
import config from "config";
import nodemailer from "nodemailer";

import CoreClass from "../../core";

let MailModule;

class _MailModule extends CoreClass {
	// eslint-disable-next-line require-jsdoc
	constructor() {
		super("mail");

		MailModule = this;
	}

	/**
	 * Initialises the mail module
	 * @returns {Promise} - returns promise (reject, resolve)
	 */
	async initialize() {
		const importSchema = schemaName =>
			new Promise(resolve => {
				import(`./schemas/${schemaName}`).then(schema => resolve(schema.default));
			});

		this.schemas = {
			verifyEmail: await importSchema("verifyEmail"),
			resetPasswordRequest: await importSchema("resetPasswordRequest"),
			passwordRequest: await importSchema("passwordRequest"),
			dataRequest: await importSchema("dataRequest")
		};

		this.enabled = config.get("mail.enabled");

		if (this.enabled) this.transporter = nodemailer.createTransport(config.get("mail.smtp"));

		return new Promise(resolve => {
			resolve();
		});
	}

	/**
	 * Sends an email
	 * @param {object} payload - object that contains the payload
	 * @param {object} payload.data - information such as to, from in order to send the email
	 * @returns {Promise} - returns promise (reject, resolve)
	 */
	SEND_MAIL(payload) {
		return new Promise((resolve, reject) => {
			if (MailModule.enabled) {
				const { data } = payload;
				if (!data.from)
					data.from =
						config.get("mail.from").length > 0
							? config.get("mail.from")
							: `${config.get("sitename")} <noreply@${config.get("url.host")}>`;
				MailModule.transporter
					.sendMail(payload.data)
					.then(info => {
						MailModule.log("SUCCESS", "MAIL_SEND", `Successfully sent email ${info.messageId}`);
						return resolve();
					})
					.catch(err => {
						MailModule.log("ERROR", "MAIL_SEND", `Failed to send email. ${err}`);
						return reject();
					});
				return;
			}

			resolve();
		});
	}

	/**
	 * Returns an email schema
	 * @param {object} payload - object that contains the payload
	 * @param {string} payload.schemaName - name of the schema to get
	 * @returns {Promise} - returns promise (reject, resolve)
	 */
	GET_SCHEMA(payload) {
		return new Promise(resolve => {
			resolve(MailModule.schemas[payload.schemaName]);
		});
	}

	/**
	 * Returns an email schema, but using async instead of callbacks
	 * @param {object} payload - object that contains the payload
	 * @param {string} payload.schemaName - name of the schema to get
	 * @returns {Promise} - returns promise (reject, resolve)
	 */
	async GET_SCHEMA_ASYNC(payload) {
		const { schemaName } = payload;

		return (...args) =>
			new Promise((resolve, reject) => {
				const cb = err => {
					if (err) reject(err);
					else resolve();
				};
				MailModule.schemas[schemaName](...args, cb);
			});
	}
}

export default new _MailModule();