igo/src/mailer.js

const cons        = require('consolidate');
const dust        = require('dustjs-linkedin');
const i18next     = require('i18next');
const nodemailer  = require('nodemailer');

const config    = require('./config');
const logger    = require('./logger');

let transport   = null;
const options   = {};

//
const DEFAULT_SUBJECT = (email, data) => {
  return `emails.${email}.subject`;
};

//
const DEFAULT_TEMPLATE = (email, data) => {
  return `./views/emails/${email}.dust`;
};

//
module.exports.init = function() {
  if (config.mailer) {
    transport         = nodemailer.createTransport(config.mailer.transport);
    options.subject   = config.mailer.subject   || DEFAULT_SUBJECT;
    options.template  = config.mailer.template  || DEFAULT_TEMPLATE;
  }
};

//
module.exports.send = function(email, data) {

  if (!data || !data.to) {
    logger.warn('mailer.send: no email for recipient');
    return;
  }
  if (!transport) {
    logger.warn('mailer.send: missing transport configuration');
    return;
  }

  data.from     = data.from || config.mailer.defaultfrom;
  data.lang     = data.lang || 'en';
  data.lng      = data.lang;
  data.subject  = data.subject || i18next.t(options.subject(email, data), data);
  data.views    = './views';

  //
  data.t = function(chunk, context, bodies, params) {
    const key       = dust.helpers.tap(params.key, chunk, context);
    params.lng      = data.lang;
    const translation = i18next.t(key, params);
    return chunk.write(translation);
  };

  const template  = data.template || options.template(email, data);

  const renderBody = function(callback) {
    if (data.body) {
      return callback(null, data.body);
    }
    cons.dust(template, data, callback);
  };

  renderBody(function(err, html) {
    if (err || !html) {
      logger.error('mailer.send: error - could not render template ' + template);
      logger.error(err);
      return;
    }

    logger.info('mailer.send: Sending mail ' + email + ' to ' + data.to + ' in ' + data.lang);
    const headers = {};
    if (config.mailer.subaccount) {
      headers['X-MC-Subaccount'] = config.mailer.subaccount;
    }
    var mailOptions = {
      from:         data.from,
      to:           data.to,
      replyTo:      data.replyTo,
      cc:           data.cc,
      bcc:          data.bcc,
      attachments:  data.attachments,
      subject:      data.subject,
      html,
      headers
    };
    transport.sendMail(mailOptions, function(err, res) {
      if (err) {
        logger.error(err);
      } else {
        logger.info('mailer.send: Message ' + email + ' sent: ' + res.response);
      }
    });
  });
};