aboutsummaryrefslogtreecommitdiff
path: root/node_modules/nodemailer/lib/nodemailer.js
diff options
context:
space:
mode:
authorKumar Damani <kumar.damani@mail.utoronto.ca>2019-04-16 13:17:06 +0000
committerKumar Damani <kumar.damani@mail.utoronto.ca>2019-04-16 13:17:06 +0000
commitdc46b87abee1e441c07524ddde67fd902a919336 (patch)
tree13eba08b8655dfd78e9600ec5f612011a0bf3b35 /node_modules/nodemailer/lib/nodemailer.js
parent26f4b38e9e5a202756a7c33abc775aea2617aeaf (diff)
added some dependencies to package.json
Diffstat (limited to 'node_modules/nodemailer/lib/nodemailer.js')
-rw-r--r--node_modules/nodemailer/lib/nodemailer.js409
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(', ')
- };
- })
- };
- });
-};