Skip to content

Commit

Permalink
chore: refactor src/emailer.js
Browse files Browse the repository at this point in the history
  • Loading branch information
@psychobunny
psychobunny committed Oct 2, 2020
1 parent c65ea5b commit 7545951
Showing 1 changed file with 70 additions and 74 deletions.
144 changes: 70 additions & 74 deletions src/emailer.js
View file
Expand Up @@ -19,8 +19,12 @@ const translator = require('./translator');
const pubsub = require('./pubsub');
const file = require('./file');

const viewsDir = nconf.get('views_dir');
const Emailer = module.exports;

let prevConfig = meta.config;
let app;

Emailer.transports = {
sendmail: nodemailer.createTransport({
sendmail: true,
Expand All @@ -29,11 +33,64 @@ Emailer.transports = {
smtp: undefined,
};

var app;
Emailer.listServices = () => Object.keys(wellKnownServices);
Emailer._defaultPayload = {};

const viewsDir = nconf.get('views_dir');
const smtpSettingsChanged = (config) => {
const settings = [
'email:smtpTransport:enabled',
'email:smtpTransport:user',
'email:smtpTransport:pass',
'email:smtpTransport:service',
'email:smtpTransport:port',
'email:smtpTransport:host',
'email:smtpTransport:security',
];

return settings.some(key => config[key] !== prevConfig[key]);
};

const getHostname = () => {
const configUrl = nconf.get('url');
const parsed = url.parse(configUrl);
return parsed.hostname;
};

const buildCustomTemplates = async (config) => {
try {
const [templates, allPaths] = await Promise.all([
Emailer.getTemplates(config),
file.walk(viewsDir),
]);

// If the new config contains any email override values, re-compile those templates
const toBuild = Object
.keys(config)
.filter(prop => prop.startsWith('email:custom:'))
.map(key => key.split(':')[2]);

const templatesToBuild = templates.filter(template => toBuild.includes(template.path));
const paths = _.fromPairs(allPaths.map((p) => {
const relative = path.relative(viewsDir, p).replace(/\\/g, '/');
return [relative, p];
}));

await Promise.all(templatesToBuild.map(async (template) => {
const source = await meta.templates.processImports(paths, template.path, template.text);
const compiled = await Benchpress.precompile(source, {
minify: global.env !== 'development',
});
await fs.promises.writeFile(template.fullpath.replace(/\.tpl$/, '.js'), compiled);
}));

Benchpress.flush();
winston.verbose('[emailer] Built custom email templates');
} catch (err) {
winston.error('[emailer] Failed to build custom email templates\n' + err.stack);
}
};

Emailer.getTemplates = async function (config) {
Emailer.getTemplates = async (config) => {
const emailsPath = path.join(viewsDir, 'emails');
let emails = await file.walk(emailsPath);
emails = emails.filter(email => !email.endsWith('.js'));
Expand All @@ -53,17 +110,11 @@ Emailer.getTemplates = async function (config) {
return templates;
};

Emailer.listServices = function () {
return Object.keys(wellKnownServices);
};

Emailer._defaultPayload = {};

Emailer.setupFallbackTransport = function (config) {
Emailer.setupFallbackTransport = (config) => {
winston.verbose('[emailer] Setting up SMTP fallback transport');
// Enable Gmail transport if enabled in ACP
if (parseInt(config['email:smtpTransport:enabled'], 10) === 1) {
var smtpOptions = {
const smtpOptions = {
pool: config['email:smtpTransport:pool'],
};

Expand Down Expand Up @@ -103,25 +154,10 @@ Emailer.setupFallbackTransport = function (config) {
}
};

let prevConfig = meta.config;
function smtpSettingsChanged(config) {
const settings = [
'email:smtpTransport:enabled',
'email:smtpTransport:user',
'email:smtpTransport:pass',
'email:smtpTransport:service',
'email:smtpTransport:port',
'email:smtpTransport:host',
'email:smtpTransport:security',
];

return settings.some(key => config[key] !== prevConfig[key]);
}

Emailer.registerApp = function (expressApp) {
Emailer.registerApp = (expressApp) => {
app = expressApp;

var logo = null;
let logo = null;
if (meta.config.hasOwnProperty('brand:emailLogo')) {
logo = (!meta.config['brand:emailLogo'].startsWith('http') ? nconf.get('url') : '') + meta.config['brand:emailLogo'];
}
Expand All @@ -140,7 +176,7 @@ Emailer.registerApp = function (expressApp) {
buildCustomTemplates(meta.config);

// Update default payload if new logo is uploaded
pubsub.on('config:update', function (config) {
pubsub.on('config:update', (config) => {
if (config) {
if (config['brand:emailLogo']) {
Emailer._defaultPayload.logo.src = config['brand:emailLogo'];
Expand All @@ -164,7 +200,7 @@ Emailer.registerApp = function (expressApp) {
return Emailer;
};

Emailer.send = async function (template, uid, params) {
Emailer.send = async (template, uid, params) => {
if (!app) {
winston.warn('[emailer] App not ready!');
return;
Expand Down Expand Up @@ -198,7 +234,7 @@ Emailer.send = async function (template, uid, params) {
}
};

Emailer.sendToEmail = async function (template, email, language, params) {
Emailer.sendToEmail = async (template, email, language, params) => {
const lang = language || meta.config.defaultLang || 'en-GB';
const unsubscribable = ['digest', 'notification'];

Expand Down Expand Up @@ -275,7 +311,7 @@ Emailer.sendToEmail = async function (template, email, language, params) {
}
};

Emailer.sendViaFallback = function (data, callback) {
Emailer.sendViaFallback = (data, callback) => {
// Some minor alterations to the data to conform to nodemailer standard
data.text = data.plaintext;
delete data.plaintext;
Expand All @@ -285,57 +321,17 @@ Emailer.sendViaFallback = function (data, callback) {
delete data.from_name;

winston.verbose('[emailer] Sending email to uid ' + data.uid + ' (' + data.to + ')');
Emailer.fallbackTransport.sendMail(data, function (err) {
Emailer.fallbackTransport.sendMail(data, (err) => {
if (err) {
winston.error(err.stack);
}
callback();
});
};

async function buildCustomTemplates(config) {
try {
const [templates, allPaths] = await Promise.all([
Emailer.getTemplates(config),
file.walk(viewsDir),
]);

// If the new config contains any email override values, re-compile those templates
const toBuild = Object
.keys(config)
.filter(prop => prop.startsWith('email:custom:'))
.map(key => key.split(':')[2]);

const templatesToBuild = templates.filter(template => toBuild.includes(template.path));
const paths = _.fromPairs(allPaths.map(function (p) {
const relative = path.relative(viewsDir, p).replace(/\\/g, '/');
return [relative, p];
}));

await Promise.all(templatesToBuild.map(async (template) => {
const source = await meta.templates.processImports(paths, template.path, template.text);
const compiled = await Benchpress.precompile(source, {
minify: global.env !== 'development',
});
await fs.promises.writeFile(template.fullpath.replace(/\.tpl$/, '.js'), compiled);
}));

Benchpress.flush();
winston.verbose('[emailer] Built custom email templates');
} catch (err) {
winston.error('[emailer] Failed to build custom email templates\n' + err.stack);
}
}

Emailer.renderAndTranslate = async function (template, params, lang) {
Emailer.renderAndTranslate = async (template, params, lang) => {
const html = await app.renderAsync('emails/' + template, params);
return await translator.translate(html, lang);
};

function getHostname() {
const configUrl = nconf.get('url');
const parsed = url.parse(configUrl);
return parsed.hostname;
}

require('./promisify')(Emailer, ['transports']);

0 comments on commit 7545951

Please sign in to comment.