118 lines
2.7 KiB
JavaScript
118 lines
2.7 KiB
JavaScript
// @flow
|
|
import * as React from 'react';
|
|
import nodemailer from 'nodemailer';
|
|
import Oy from 'oy-vey';
|
|
import Queue from 'bull';
|
|
import { baseStyles } from './emails/components/EmailLayout';
|
|
import { WelcomeEmail, welcomeEmailText } from './emails/WelcomeEmail';
|
|
|
|
type SendMailType = {
|
|
to: string,
|
|
properties?: any,
|
|
title: string,
|
|
previewText?: string,
|
|
text: string,
|
|
html: React.Node,
|
|
headCSS?: string,
|
|
};
|
|
|
|
/**
|
|
* Mailer
|
|
*
|
|
* Mailer class to contruct and send emails.
|
|
*
|
|
* To preview emails, add a new preview to `emails/index.js` if they
|
|
* require additional data (properties). Otherwise preview will work automatically.
|
|
*
|
|
* HTML: http://localhost:3000/email/:email_type/html
|
|
* TEXT: http://localhost:3000/email/:email_type/text
|
|
*/
|
|
class Mailer {
|
|
transporter: ?any;
|
|
|
|
/**
|
|
*
|
|
*/
|
|
sendMail = async (data: SendMailType): ?Promise<*> => {
|
|
const { transporter } = this;
|
|
|
|
if (transporter) {
|
|
const html = Oy.renderTemplate(data.html, {
|
|
title: data.title,
|
|
headCSS: [baseStyles, data.headCSS].join(' '),
|
|
previewText: data.previewText,
|
|
});
|
|
|
|
try {
|
|
await transporter.sendMail({
|
|
from: process.env.SMTP_FROM_EMAIL,
|
|
replyTo: process.env.SMTP_REPLY_EMAIL || process.env.SMTP_FROM_EMAIL,
|
|
to: data.to,
|
|
subject: data.title,
|
|
html: html,
|
|
text: data.text,
|
|
});
|
|
} catch (e) {
|
|
Bugsnag.notifyException(e);
|
|
throw e; // Re-throw for queue to re-try
|
|
}
|
|
}
|
|
};
|
|
|
|
welcome = async (opts: { to: string }) => {
|
|
this.sendMail({
|
|
to: opts.to,
|
|
title: 'Welcome to Outline',
|
|
previewText:
|
|
'Outline is a place for your team to build and share knowledge.',
|
|
html: <WelcomeEmail />,
|
|
text: welcomeEmailText,
|
|
});
|
|
};
|
|
|
|
constructor() {
|
|
if (process.env.SMTP_HOST) {
|
|
let smtpConfig = {
|
|
host: process.env.SMTP_HOST,
|
|
port: process.env.SMTP_PORT,
|
|
secure: true,
|
|
auth: {
|
|
user: process.env.SMTP_USERNAME,
|
|
pass: process.env.SMTP_PASSWORD,
|
|
},
|
|
};
|
|
|
|
this.transporter = nodemailer.createTransport(smtpConfig);
|
|
}
|
|
}
|
|
}
|
|
|
|
const mailer = new Mailer();
|
|
const mailerQueue = new Queue('email', process.env.REDIS_URL);
|
|
|
|
mailerQueue.process(async function(job) {
|
|
// $FlowIssue flow doesn't like dynamic values
|
|
await mailer[job.data.type](job.data.opts);
|
|
});
|
|
|
|
const sendEmail = (type: string, to: string, options?: Object = {}) => {
|
|
mailerQueue.add(
|
|
{
|
|
type,
|
|
opts: {
|
|
to,
|
|
...options,
|
|
},
|
|
},
|
|
{
|
|
attempts: 5,
|
|
backoff: {
|
|
type: 'exponential',
|
|
delay: 60 * 1000,
|
|
},
|
|
}
|
|
);
|
|
};
|
|
|
|
export { Mailer, mailerQueue, sendEmail };
|