directus/api/src/mail/index.ts

import logger from '../logger';
import nodemailer, { Transporter } from 'nodemailer';
import { Liquid } from 'liquidjs';
import path from 'path';
import fs from 'fs';
import { promisify } from 'util';
import env from '../env';

const readFile = promisify(fs.readFile);

const liquidEngine = new Liquid({
	root: path.resolve(__dirname, 'templates'),
	extname: '.liquid',
});

let transporter: Transporter;

if (env.EMAIL_TRANSPORT === 'sendmail') {
	transporter = nodemailer.createTransport({
		sendmail: true,
		newline: env.EMAIL_SENDMAIL_NEW_LINE || 'unix',
		path: env.EMAIL_SENDMAIL_PATH || '/usr/sbin/sendmail',
	});
} else if (env.EMAIL_TRANSPORT.toLowerCase() === 'smtp') {
	transporter = nodemailer.createTransport({
		pool: env.EMAIL_SMTP_POOL === 'true',
		host: env.EMAIL_SMTP_HOST,
		port: Number(env.EMAIL_SMTP_PORT),
		secure: env.EMAIL_SMTP_SECURE === 'true',
		auth: {
			user: env.EMAIL_SMTP_USER,
			pass: env.EMAIL_SMTP_PASSWORD,
		},
	} as any);
}

export type EmailOptions = {
	to: string; // email address of the recipient
	from: string;
	subject: string;
	text: string;
	html: string;
};

export default async function sendMail(options: EmailOptions) {
	const templateString = await readFile(path.join(__dirname, 'templates/base.liquid'), 'utf8');
	const html = await liquidEngine.parseAndRender(templateString, { html: options.html });

	options.from = options.from || (env.EMAIL_FROM as string);

	try {
		await transporter.sendMail({ ...options, html: html });
	} catch (error) {
		logger.warn('[Email] Unexpected error while sending an email:');
		logger.warn(error);
	}
}

export async function sendInviteMail(email: string, url: string) {
	/**
	 * @TODO pull this from directus_settings
	 */
	const projectName = 'Directus';

	const html = await liquidEngine.renderFile('user-invitation', { email, url, projectName });
	await transporter.sendMail({
		from: env.EMAIL_FROM,
		to: email,
		html: html,
		subject: `[${projectName}] You've been invited`,
	});
}

export async function sendPasswordResetMail(email: string, url: string) {
	/**
	 * @TODO pull this from directus_settings
	 */
	const projectName = 'Directus';

	const html = await liquidEngine.renderFile('password-reset', { email, url, projectName });
	await transporter.sendMail({
		from: env.EMAIL_FROM,
		to: email,
		html: html,
		subject: `[${projectName}] Password Reset Request`,
	});
}