lfk/mailer
3
0
Fork 0
Code Issues Pull Requests Actions Projects Releases 3 Wiki Activity

wip

Browse Source
This commit is contained in:
Philipp Dormann 2024-11-21 18:35:27 +01:00
parent e8c66e65e6
commit bbf58e52ce
Signed by: philipp
GPG Key ID: 3BB9ADD52DCA4314
1 changed files with 1 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/queues/email.queue.ts
View File

@ -39,9 +39,6 @@ const transporter = createTransport({
const worker = new Worker<EmailJob>( const worker = new Worker<EmailJob>(
QUEUE_NAME, QUEUE_NAME,
async (job) => { async (job) => {
// const emailService = new EmailService();
// await emailService.sendEmail(job.data);
console.log(job.data);
await transporter.sendMail({ await transporter.sendMail({
from: config.email.from, from: config.email.from,
to: job.data.to, to: job.data.to,
@ -63,7 +60,7 @@ const worker = new Worker<EmailJob>(
const queueEvents = new QueueEvents(QUEUE_NAME, { connection }); const queueEvents = new QueueEvents(QUEUE_NAME, { connection });
worker.on("completed", (job) => { worker.on("completed", (job) => {
console.log(`Email job ${job.id} completed`); // console.log(`Email job ${job.id} completed`);
}); });
worker.on("failed", (job, error) => { worker.on("failed", (job, error) => {