Bulletproof email queue on top of NodeMailer for a single and multi-server setups. 

📮 Email queue extending NodeMailer with multi SMTP transports and horizontally scaled apps support

dr.dimitru

mail-time

Bulletproof email queue on top of NodeMailer for a single and multi-server setups

    console.info.call(console, '[DEBUG] [mail-time]', `${new Date}`, ...args);

  console.error.call(console, '[ERROR] [mail-time]', `${new Date}`, ...args);

    _logError('[mongoErrorHandler]:', error);

  if (!(typeof a === 'object' && typeof b === 'object')) {

  if (a instanceof Date && b instanceof Date) {

    for (i = _a.length - 1; i >= 0; i--) {

      for (j = _b.length - 1; j >= 0; j--) {

  if (typeof a === 'object' && typeof b === 'object') {

    for (i = akeys.length - 1; i >= 0; i--) {

      if (!hasOwnProperty.call(b, akeys[i])) {

      if (!equals(a[akeys[i]], b[akeys[i]])) {

    if (!opts || typeof opts !== 'object' || opts === null) {

      throw new TypeError('[mail-time] Configuration object must be passed into MailTime constructor');

    this.collection = opts.db.collection('__mailTimeQueue__' + this.prefix);

    this.collection.createIndex({ to: 1, isSent: 1, sendAt: 1 }, (indexError) => {

    this.collection = opts.db.collection(`__mailTimeQueue__${this.prefix}`);

    this.collection.createIndex({ isSent: 1, to: 1, sendAt: 1 }, (indexError) => {

        _logError('[createIndex]', indexError);

    this.collection.createIndex({ sendAt: 1, isSent: 1, tries: 1 }, { background: true }, (indexError) => {

    this.collection.createIndex({ isSent: 1, sendAt: 1, tries: 1 }, { background: true }, (indexError) => {

    // tries       {Number}  - qty of send attempts

    // sendAt      {Date}    - When letter should be sent

    // isSent      {Boolean} - Email status

    // template    {String}  - Template for this email

    // transport   {Number}  - Last used transport

    // concatSubject {String|Boolean} - Email concatenation subject

    // mailOptions         {[Object]}  - Array of nodeMailer's `mailOptions`

    // mailOptions.to      {String|Array} - [REQUIRED]

    // mailOptions.text    {String|Boolean}

    // mailOptions.Other nodeMailer `sendMail` options...

        prefix: `mailTimeQueue${this.prefix}`,

        minRevolvingDelay: this.minRevolvingDelay,

        maxRevolvingDelay: this.maxRevolvingDelay

      scheduler.setInterval(this.___send.bind(this), this.revolvingInterval, `mailTimeQueue${this.prefix}`);

      throw new Error('[mail-time] [sendMail] [___compileMailOpts] transport not available or misconfiguration is in place!');

    if (transport._options && typeof transport._options === 'object' && transport._options !== null && transport._options.mailOptions) {

      _mailOpts = merge(_mailOpts, transport._options.mailOptions);

    if (transport.options && typeof transport.options === 'object' && transport.options !== null && transport.options.mailOptions) {

      _mailOpts = merge(_mailOpts, transport.options.mailOptions);

    for (let i = 0; i < task.mailOptions.length; i++) {

        if (task.mailOptions.length > 1) {

          _mailOpts.html += this.___render(this.concatDelimiter, task.mailOptions[i]) + this.___render(task.mailOptions[i].html, task.mailOptions[i]);

          _mailOpts.html = this.___render(task.mailOptions[i].html, task.mailOptions[i]);

          _mailOpts.text += '\r\n' + this.___render(task.mailOptions[i].text, task.mailOptions[i]);

          _mailOpts.text = this.___render(task.mailOptions[i].text, task.mailOptions[i]);

      _mailOpts = merge(_mailOpts, task.mailOptions[i]);

    if (_mailOpts.html && (task.template || this.template)) {

      _mailOpts.html = this.___render((task.template || this.template), _mailOpts);

      _mailOpts.subject = task.concatSubject || this.concatSubject || _mailOpts.subject;

      _mailOpts.from = this.from(transport);

  "description": "Bulletproof email queue on top of NodeMailer for a single and multi-server setups",

    "url": "git://github.com/veliovgroup/mail-time.git"

    "url": "https://github.com/veliovgroup/mail-time/issues"

  "homepage": "https://github.com/veliovgroup/mail-time",

  "author": "dr.dimitru (https://veliovgroup.com)",

    "nodemailer-direct-transport": "^3.0.7"

		{
		"name": "mail-time",
		"version": "1.3.3",
		"version": "1.3.4",
		"description": "Bulletproof email queue on top of NodeMailer for a single and multi-server setups",
		@@ -55,10 +55,10 @@ "main": "index.js",
		"devDependencies": {
		"bson": "^4.6.4",
		"bson-ext": "^4.0.2",
		"bson": "^4.7.0",
		"bson-ext": "^4.0.3",
		"chai": "^4.3.6",
		"mocha": "^10.0.0",
		"mongodb": "^4.7.0",
		"nodemailer": "^6.7.6",
		"mongodb": "^4.10.0",
		"nodemailer": "^6.7.8",
		"nodemailer-direct-transport": "^3.0.7"
		}
		}

		@@ -165,4 +165,4 @@ const JoSk = require('josk');

		this.collection = opts.db.collection('__mailTimeQueue__' + this.prefix);
		this.collection.createIndex({ to: 1, isSent: 1, sendAt: 1 }, (indexError) => {
		this.collection = opts.db.collection(`__mailTimeQueue__${this.prefix}`);
		this.collection.createIndex({ isSent: 1, to: 1, sendAt: 1 }, (indexError) => {
		if (indexError) {
		@@ -172,3 +172,3 @@ _logError('[createIndex]', indexError);
		});
		this.collection.createIndex({ sendAt: 1, isSent: 1, tries: 1 }, { background: true }, (indexError) => {
		this.collection.createIndex({ isSent: 1, sendAt: 1, tries: 1 }, { background: true }, (indexError) => {
		if (indexError) {
		@@ -175,0 +175,0 @@ _logError('[createIndex]', indexError);

Improved metrics