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

re-enable logs

Browse Source
This commit is contained in:
Philipp Dormann 2024-12-11 18:41:22 +01:00
parent 642e141abd
commit 2dd26da19b
Signed by: philipp
GPG Key ID: 3BB9ADD52DCA4314
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -32,9 +32,9 @@ const transporter = createTransport({
port: config.smtp.port, port: config.smtp.port,
auth: { auth: {
user: config.smtp.user, user: config.smtp.user,
pass: config.smtp.pass pass: config.smtp.pass,
} },
}) });
const worker = new Worker<EmailJob>( const worker = new Worker<EmailJob>(
QUEUE_NAME, QUEUE_NAME,
@ -46,7 +46,7 @@ const worker = new Worker<EmailJob>(
subject: job.data.subject, subject: job.data.subject,
text: job.data.text, text: job.data.text,
html: job.data.html, html: job.data.html,
}) });
}, },
{ {
connection, connection,
@ -61,7 +61,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) => {
@ -69,7 +69,7 @@ worker.on("failed", (job, error) => {
}); });
queueEvents.on("waiting", ({ jobId }) => { queueEvents.on("waiting", ({ jobId }) => {
// console.log(`Job ${jobId} is waiting`) console.log(`Job ${jobId} is waiting`);
}); });
process.on("SIGTERM", async () => { process.on("SIGTERM", async () => {