You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
128 lines
3.8 KiB
128 lines
3.8 KiB
// newsletter.js
|
|
// Copyright (C) 2022 DTP Technologies, LLC
|
|
// License: Apache-2.0
|
|
|
|
'use strict';
|
|
|
|
const DTP_COMPONENT = { name: 'newsletter', slug: 'newsletter' };
|
|
|
|
const path = require('path');
|
|
require('dotenv').config({ path: path.resolve(__dirname, '..', '..', '.env') });
|
|
|
|
const mongoose = require('mongoose');
|
|
|
|
const { SiteWorker, SiteLog } = require(path.join(__dirname, '..', '..', 'lib', 'site-lib'));
|
|
|
|
module.pkg = require(path.resolve(__dirname, '..', '..', 'package.json'));
|
|
module.config = {
|
|
component: DTP_COMPONENT,
|
|
root: path.resolve(__dirname, '..', '..'),
|
|
};
|
|
|
|
class NewsletterWorker extends SiteWorker {
|
|
|
|
constructor (dtp) {
|
|
super(dtp, dtp.config.component);
|
|
}
|
|
|
|
async start ( ) {
|
|
await super.start();
|
|
|
|
const { jobQueue: jobQueueService } = this.dtp.services;
|
|
this.jobQueue = await jobQueueService.getJobQueue('newsletter', {
|
|
attempts: 3,
|
|
});
|
|
this.jobQueue.process('email', this.sendNewsletter.bind(this));
|
|
this.jobQueue.process('email-send', this.sendNewsletterEmail.bind(this));
|
|
}
|
|
|
|
async stop ( ) {
|
|
if (this.jobQueue) {
|
|
this.log.info('stopping newsletter job queue');
|
|
await this.jobQueue.close();
|
|
delete this.jobQueue;
|
|
}
|
|
await super.stop();
|
|
}
|
|
|
|
async sendNewsletter (job) {
|
|
const NewsletterRecipient = mongoose.model('NewsletterRecipient');
|
|
this.log.info('newsletter email job received', { data: job.data });
|
|
|
|
try {
|
|
/*
|
|
* Create one Bull Queue job per email to be delivered.
|
|
*/
|
|
await NewsletterRecipient
|
|
.find({ 'flags.isVerified': true, 'flags.isOptIn': true, 'flags.isRejected': false })
|
|
.lean()
|
|
.cursor()
|
|
.eachAsync(async (recipient) => {
|
|
try {
|
|
const jobData = {
|
|
newsletterId: job.data.newsletterId,
|
|
recipient: recipient.address,
|
|
};
|
|
const jobOptions = {
|
|
attempts: 3,
|
|
};
|
|
await this.jobQueue.add('email-send', jobData, jobOptions);
|
|
} catch (error) {
|
|
this.log.error('failed to create newsletter email job', { error });
|
|
// but continue
|
|
}
|
|
}, { parallel: 4 });
|
|
} catch (error) {
|
|
this.log.error('failed to send newsletter', { newsletterId: job.data.newsletterId, error });
|
|
throw error; // throw error to Bull so it can report in job reports
|
|
}
|
|
}
|
|
|
|
async sendNewsletterEmail (job) {
|
|
const { newsletter: newsletterService, email: emailService } = this.dtp.services;
|
|
const { newsletterId, recipient } = job.data;
|
|
try {
|
|
|
|
let newsletter = this.newsletters[newsletterId];
|
|
|
|
if (!newsletter) {
|
|
newsletter = await newsletterService.getById(newsletterId);
|
|
this.newsletters[newsletterId] = newsletter;
|
|
//TODO: clean up memory leak of newsletter (remove when all emails are sent)
|
|
}
|
|
|
|
if (!newsletter) {
|
|
throw new Error('newsletter not found');
|
|
}
|
|
|
|
const response = await emailService.send({
|
|
from: 'demo@wherever.com',
|
|
to: recipient,
|
|
subject: newsletter.title,
|
|
html: newsletter.content.html,
|
|
text: newsletter.content.text,
|
|
});
|
|
|
|
job.log(`newsletter email sent: ${response}`);
|
|
} catch (error) {
|
|
this.log.error('failed to send newsletter email', { newsletterId, recipient, error });
|
|
throw error; // throw error to Bull so it can report in job reports
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
(async ( ) => {
|
|
try {
|
|
module.log = new SiteLog(module, module.config.component);
|
|
|
|
module.worker = new NewsletterWorker(module);
|
|
await module.worker.start();
|
|
|
|
module.log.info(`${module.pkg.name} v${module.pkg.version} Newsletter worker started`);
|
|
} catch (error) {
|
|
module.log.error('failed to start Newsletter worker', { error });
|
|
process.exit(-1);
|
|
}
|
|
})();
|