// # Mail // Handles sending email for Ghost var _ = require('lodash'), Promise = require('bluebird'), nodemailer = require('nodemailer'), validator = require('validator'), config = require('../config'); function GhostMailer(opts) { opts = opts || {}; this.transport = opts.transport || null; } // ## Email transport setup // *This promise should always resolve to avoid halting Ghost::init*. GhostMailer.prototype.init = function () { var self = this; self.state = {}; if (config.mail && config.mail.transport) { this.createTransport(); return Promise.resolve(); } self.transport = nodemailer.createTransport('direct'); self.state.usingDirect = true; return Promise.resolve(); }; GhostMailer.prototype.createTransport = function () { this.transport = nodemailer.createTransport(config.mail.transport, _.clone(config.mail.options) || {}); }; GhostMailer.prototype.from = function () { var from = config.mail && (config.mail.from || config.mail.fromaddress); // If we don't have a from address at all if (!from) { // Default to ghost@[blog.url] from = 'ghost@' + this.getDomain(); } // If we do have a from address, and it's just an email if (validator.isEmail(from)) { if (!config.theme.title) { config.theme.title = 'Ghost at ' + this.getDomain(); } from = '"' + config.theme.title + '" <' + from + '>'; } return from; }; // Moved it to its own module GhostMailer.prototype.getDomain = function () { var domain = config.url.match(new RegExp('^https?://([^/:?#]+)(?:[/:?#]|$)', 'i')); return domain && domain[1]; }; // Sends an email message enforcing `to` (blog owner) and `from` fields // This assumes that api.settings.read('email') was already done on the API level GhostMailer.prototype.send = function (message) { var self = this, to, sendMail; message = message || {}; to = message.to || false; if (!this.transport) { return Promise.reject(new Error('Error: No email transport configured.')); } if (!(message && message.subject && message.html && message.to)) { return Promise.reject(new Error('Error: Incomplete message data.')); } sendMail = Promise.promisify(self.transport.sendMail.bind(self.transport)); message = _.extend(message, { from: self.from(), to: to, generateTextFromHTML: true, encoding: 'base64' }); return new Promise(function (resolve, reject) { sendMail(message, function (error, response) { if (error) { return reject(new Error(error)); } if (self.transport.transportType !== 'DIRECT') { return resolve(response); } response.statusHandler.once('failed', function (data) { var reason = 'Error: Failed to send email'; if (data.error && data.error.errno === 'ENOTFOUND') { reason += ' - no mail server found at ' + data.domain; } reason += '.'; return reject(new Error(reason)); }); response.statusHandler.once('requeue', function (data) { var errorMessage = 'Error: Message could not be sent'; if (data.error && data.error.message) { errorMessage += '\nMore info: ' + data.error.message; } return reject(new Error(errorMessage)); }); response.statusHandler.once('sent', function () { return resolve('Message sent. Double check inbox and spam folder!'); }); }); }); }; module.exports = new GhostMailer();