diff options
Diffstat (limited to 'node_modules/nodemailer/lib/nodemailer.js')
| -rw-r--r-- | node_modules/nodemailer/lib/nodemailer.js | 409 |
1 files changed, 0 insertions, 409 deletions
diff --git a/node_modules/nodemailer/lib/nodemailer.js b/node_modules/nodemailer/lib/nodemailer.js deleted file mode 100644 index 9f0267b..0000000 --- a/node_modules/nodemailer/lib/nodemailer.js +++ /dev/null @@ -1,409 +0,0 @@ -'use strict'; - -var mailcomposer = require('mailcomposer'); -var EventEmitter = require('events').EventEmitter; -var util = require('util'); -var shared = require('nodemailer-shared'); -var directTransport = require('nodemailer-direct-transport'); -var smtpTransport = require('nodemailer-smtp-transport'); -var smtpPoolTransport = require('nodemailer-smtp-pool'); -var templateSender = require('./template-sender'); -var packageData = require('../package.json'); -var httpProxy = require('./http-proxy'); -var Socks = require('socks'); -var urllib = require('url'); - -// Export createTransport method -module.exports.createTransport = function (transporter, defaults) { - var urlConfig; - var options; - var mailer; - var proxyUrl; - - // if no transporter configuration is provided use direct as default - transporter = transporter || directTransport({ - debug: true - }); - - if ( - // provided transporter is a configuration object, not transporter plugin - (typeof transporter === 'object' && typeof transporter.send !== 'function') || - // provided transporter looks like a connection url - (typeof transporter === 'string' && /^(smtps?|direct):/i.test(transporter)) - ) { - - if ((urlConfig = typeof transporter === 'string' ? transporter : transporter.url)) { - // parse a configuration URL into configuration options - options = shared.parseConnectionUrl(urlConfig); - } else { - options = transporter; - } - - if (options.proxy && typeof options.proxy === 'string') { - proxyUrl = options.proxy; - } - - if (options.transport && typeof options.transport === 'string') { - try { - transporter = require('nodemailer-' + (options.transport).toLowerCase() + '-transport')(options); - } catch (E) { - // if transporter loader fails, return an error when sending mail - transporter = { - send: function (mail, callback) { - var errmsg = 'Requested transport plugin "nodemailer-' + (options.transport).toLowerCase() + '-transport" could not be initiated'; - var err = new Error(errmsg); - err.code = 'EINIT'; - setImmediate(function () { - return callback(err); - }); - } - }; - } - } else if (options.direct) { - transporter = directTransport(options); - } else if (options.pool) { - transporter = smtpPoolTransport(options); - } else { - transporter = smtpTransport(options); - } - } - - mailer = new Nodemailer(transporter, defaults); - - if (proxyUrl) { - setupProxy(mailer, proxyUrl); - } - - return mailer; -}; - -/** - * Sets up proxy handler for a Nodemailer object - * - * @param {Object} mailer Nodemailer instance to modify - * @param {String} proxyUrl Proxy configuration url - */ -function setupProxy(mailer, proxyUrl) { - var proxy = urllib.parse(proxyUrl); - - // setup socket handler for the mailer object - mailer.getSocket = function (options, callback) { - switch (proxy.protocol) { - - // Connect using a HTTP CONNECT method - case 'http:': - case 'https:': - httpProxy(proxy.href, options.port, options.host, function (err, socket) { - if (err) { - return callback(err); - } - return callback(null, { - connection: socket - }); - }); - return; - - // Connect using a SOCKS4/5 proxy - case 'socks:': - case 'socks5:': - case 'socks4:': - case 'socks4a:': - Socks.createConnection({ - proxy: { - ipaddress: proxy.hostname, - port: proxy.port, - type: Number(proxy.protocol.replace(/\D/g, '')) || 5 - }, - target: { - host: options.host, - port: options.port - }, - command: 'connect', - authentication: !proxy.auth ? false : { - username: decodeURIComponent(proxy.auth.split(':').shift()), - password: decodeURIComponent(proxy.auth.split(':').pop()) - } - }, function (err, socket) { - if (err) { - return callback(err); - } - return callback(null, { - connection: socket - }); - }); - return; - } - - callback(new Error('Unknown proxy configuration')); - }; -} - -/** - * Creates an object for exposing the Nodemailer API - * - * @constructor - * @param {Object} transporter Transport object instance to pass the mails to - */ -function Nodemailer(transporter, defaults) { - EventEmitter.call(this); - - this._defaults = defaults || {}; - - this._plugins = { - compile: [], - stream: [] - }; - - this.transporter = transporter; - this.logger = this.transporter.logger || shared.getLogger({ - logger: false - }); - - // setup emit handlers for the transporter - if (typeof transporter.on === 'function') { - - // deprecated log interface - this.transporter.on('log', function (log) { - this.logger.debug('%s: %s', log.type, log.message); - }.bind(this)); - - // transporter errors - this.transporter.on('error', function (err) { - this.logger.error('Transport Error: %s', err.message); - this.emit('error', err); - }.bind(this)); - - // indicates if the sender has became idle - this.transporter.on('idle', function () { - var args = Array.prototype.slice.call(arguments); - args.unshift('idle'); - this.emit.apply(this, args); - }.bind(this)); - } -} -util.inherits(Nodemailer, EventEmitter); - -/** - * Creates a template based sender function - * - * @param {Object} templates Object with string values where key is a message field and value is a template - * @param {Object} defaults Optional default message fields - * @return {Function} E-mail sender - */ -Nodemailer.prototype.templateSender = function (templates, defaults) { - return templateSender(this, templates, defaults); -}; - -Nodemailer.prototype.use = function (step, plugin) { - step = (step || '').toString(); - if (!this._plugins.hasOwnProperty(step)) { - this._plugins[step] = [plugin]; - } else { - this._plugins[step].push(plugin); - } -}; - -/** - * Optional methods passed to the underlying transport object - */ -['close', 'isIdle', 'verify'].forEach(function (method) { - Nodemailer.prototype[method] = function ( /* possible arguments */ ) { - var args = Array.prototype.slice.call(arguments); - if (typeof this.transporter[method] === 'function') { - return this.transporter[method].apply(this.transporter, args); - } else { - return false; - } - }; -}); - -/** - * Sends an email using the preselected transport object - * - * @param {Object} data E-data description - * @param {Function} callback Callback to run once the sending succeeded or failed - */ -Nodemailer.prototype.sendMail = function (data, callback) { - var promise; - - if (!callback && typeof Promise === 'function') { - promise = new Promise(function (resolve, reject) { - callback = shared.callbackPromise(resolve, reject); - }); - } - - if (typeof this.getSocket === 'function') { - this.transporter.getSocket = this.getSocket.bind(this); - this.getSocket = false; - } - - data = data || {}; - data.headers = data.headers || {}; - callback = callback || function () {}; - - // apply defaults - Object.keys(this._defaults).forEach(function (key) { - if (!(key in data)) { - data[key] = this._defaults[key]; - } else if (key === 'headers') { - // headers is a special case. Allow setting individual default headers - Object.keys(this._defaults.headers || {}).forEach(function (key) { - if (!(key in data.headers)) { - data.headers[key] = this._defaults.headers[key]; - } - }.bind(this)); - } - }.bind(this)); - - var mail = { - data: data, - message: null, - resolveContent: shared.resolveContent - }; - - if (typeof this.transporter === 'string') { - callback(new Error('Unsupported configuration, downgrade Nodemailer to v0.7.1 to use it')); - return promise; - } - - this.logger.info('Sending mail using %s/%s', this.transporter.name, this.transporter.version); - - this._processPlugins('compile', mail, function (err) { - if (err) { - this.logger.error('PluginCompile Error: %s', err.message); - return callback(err); - } - - mail.message = mailcomposer(mail.data); - - if (mail.data.xMailer !== false) { - mail.message.setHeader('X-Mailer', mail.data.xMailer || this._getVersionString()); - } - - if (mail.data.priority) { - switch ((mail.data.priority || '').toString().toLowerCase()) { - case 'high': - mail.message.setHeader('X-Priority', '1 (Highest)'); - mail.message.setHeader('X-MSMail-Priority', 'High'); - mail.message.setHeader('Importance', 'High'); - break; - case 'low': - mail.message.setHeader('X-Priority', '5 (Lowest)'); - mail.message.setHeader('X-MSMail-Priority', 'Low'); - mail.message.setHeader('Importance', 'Low'); - break; - default: - // do not add anything, since all messages are 'Normal' by default - } - } - - // add optional List-* headers - if (mail.data.list && typeof mail.data.list === 'object') { - this._getListHeaders(mail.data.list).forEach(function (listHeader) { - listHeader.value.forEach(function (value) { - mail.message.addHeader(listHeader.key, value); - }); - }); - } - - this._processPlugins('stream', mail, function (err) { - if (err) { - this.logger.error('PluginStream Error: %s', err.message); - return callback(err); - } - - this.transporter.send(mail, function () { - var args = Array.prototype.slice.call(arguments); - if (args[0]) { - this.logger.error('Send Error: %s', args[0].message); - } - callback.apply(null, args); - }.bind(this)); - }.bind(this)); - }.bind(this)); - - return promise; -}; - -Nodemailer.prototype._getVersionString = function () { - return util.format( - '%s (%s; +%s; %s/%s)', - packageData.name, - packageData.version, - packageData.homepage, - this.transporter.name, - this.transporter.version - ); -}; - -Nodemailer.prototype._processPlugins = function (step, mail, callback) { - step = (step || '').toString(); - - if (!this._plugins.hasOwnProperty(step) || !this._plugins[step].length) { - return callback(null); - } - - var plugins = Array.prototype.slice.call(this._plugins[step]); - - this.logger.debug('Using %s plugins for %s', plugins.length, step); - - var processPlugins = function () { - if (!plugins.length) { - return callback(null); - } - var plugin = plugins.shift(); - plugin(mail, function (err) { - if (err) { - return callback(err); - } - processPlugins(); - }); - }.bind(this); - - processPlugins(); -}; - -/** - * This method takes list headers structure and converts it into - * header list with key-value pairs - * - * @param {Object} listData Structured List-* headers - * @return {Array} An array of headers - */ -Nodemailer.prototype._getListHeaders = function (listData) { - // make sure an url looks like <protocol:url> - var formatListUrl = function (url) { - url = url.replace(/[\s<]+|[\s>]+/g, ''); - if (/^(https?|mailto|ftp):/.test(url)) { - return '<' + url + '>'; - } - if (/^[^@]+@[^@]+$/.test(url)) { - return '<mailto:' + url + '>'; - } - - return '<http://' + url + '>'; - }; - - return Object.keys(listData).map(function (key) { - return { - key: 'list-' + key.toLowerCase().trim(), - value: [].concat(listData[key] || []).map(function (value) { - if (typeof value === 'string') { - return formatListUrl(value); - } - return { - prepared: true, - value: [].concat(value || []).map(function (value) { - if (typeof value === 'string') { - return formatListUrl(value); - } - if (value && value.url) { - return formatListUrl(value.url) + (value.comment ? ' (' + value.comment + ')' : ''); - } - return ''; - }).join(', ') - }; - }) - }; - }); -}; |