admin/bodyshop
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Update

Browse Source
This commit is contained in:
Dave
2025-10-10 16:02:56 -04:00
parent 41afedd02c
commit 8e6c809fc6
2 changed files with 6 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
server/notifications/queues/appQueue.js
View File

@@ -92,7 +92,7 @@ const loadAppQueue = async ({ pubClient, logger, redisHelpers, ioRedis }) => {
"consolidate-notifications", "consolidate-notifications",
{ jobId, recipients }, { jobId, recipients },
{ {
jobId: `consolidate:${jobId}`, jobId: `consolidate-${jobId}`,
delay: APP_CONSOLIDATION_DELAY, delay: APP_CONSOLIDATION_DELAY,
attempts: 3, attempts: 3,
backoff: LOCK_EXPIRATION backoff: LOCK_EXPIRATION

15
server/notifications/queues/emailQueue.js
View File

@@ -86,7 +86,7 @@ const loadEmailQueue = async ({ pubClient, logger }) => {
"consolidate-emails", "consolidate-emails",
{ jobId, jobRoNumber, bodyShopName, bodyShopTimezone }, { jobId, jobRoNumber, bodyShopName, bodyShopTimezone },
{ {
jobId: `consolidate:${jobId}`, jobId: `consolidate-${jobId}`,
delay: EMAIL_CONSOLIDATION_DELAY, delay: EMAIL_CONSOLIDATION_DELAY,
attempts: 3, attempts: 3,
backoff: LOCK_EXPIRATION backoff: LOCK_EXPIRATION
@@ -249,15 +249,10 @@ const dispatchEmailsToQueue = async ({ emailsToDispatch, logger }) => {
continue; continue;
} }
await emailConsolidateQueue.add( await emailAddQueue.add(
"consolidate-emails", "add-email-notification",
{ jobId, jobRoNumber, bodyShopName, bodyShopTimezone }, { jobId, jobRoNumber, bodyShopName, bodyShopTimezone, body, recipients },
{ { jobId: `${jobId}-${Date.now()}` }
jobId: `consolidate-${jobId}`,
delay: EMAIL_CONSOLIDATION_DELAY,
attempts: 3,
backoff: LOCK_EXPIRATION
}
); );
devDebugLogger(`Added email notification to queue for jobId ${jobId} with ${recipients.length} recipients`); devDebugLogger(`Added email notification to queue for jobId ${jobId} with ${recipients.length} recipients`);
} }