From 1ec66a723411d2fee735bccc5308dbaf28122d03 Mon Sep 17 00:00:00 2001 From: Leonardo Viva Date: Mon, 16 Dec 2024 11:11:46 -0300 Subject: [PATCH] fix: konecty send email --- src/imports/mailConsumer/index.js | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/imports/mailConsumer/index.js b/src/imports/mailConsumer/index.js index 8db868ff..18d067b4 100644 --- a/src/imports/mailConsumer/index.js +++ b/src/imports/mailConsumer/index.js @@ -98,7 +98,7 @@ async function sendEmail(record) { if (process.env.KONECTY_MODE !== 'production') { mail.subject = `[DEV] [${mail.to}] ${mail.subject}`; // mail.to = null; // 'team@konecty.com' - mail.to = 'derotino.silveira@konecty.com'; + mail.to = 'support@konecty.com'; mail.cc = null; mail.bcc = null; } @@ -118,7 +118,7 @@ async function sendEmail(record) { logger.info(`📧 Email sent to ${response.accepted.join(', ')} via [${serverHost || record.server}]`); } } catch (err) { - logger.error(err, `📧 Email error: ${err.message}`); + logger.error(`📧 Email error: ${err.message}`); err.host = serverHost || record.server; await MetaObject.Collections['Message'].updateOne({ _id: record._id }, { $set: { status: 'Falha no Envio', error: err } }); @@ -199,11 +199,11 @@ async function consume() { await BluebirdPromise.each(range(0, mailCount), async () => { const updatedRecords = await MetaObject.Collections['Message'].findOneAndUpdate(query, update, options); - if (updatedRecords == null || updatedRecords.value == null) { + if (updatedRecords == null || updatedRecords._id == null) { return; } - return send(updatedRecords.value); + return send(updatedRecords); }); return consumeCronJob.start();