diff --git a/server/notifications/queues/appQueue.js b/server/notifications/queues/appQueue.js index 2e6316a7d..7403e807c 100644 --- a/server/notifications/queues/appQueue.js +++ b/server/notifications/queues/appQueue.js @@ -138,7 +138,7 @@ const loadAppQueue = async ({ pubClient, logger, redisHelpers, ioRedis }) => { await pubClient.del(userKey); logger.logger.debug(`Deleted Redis key ${userKey}`); } else { - logger.logger.warn(`No notifications found for ${user} under ${userKey}`); + logger.logger.debug(`No notifications found for ${user} under ${userKey}`); } } @@ -207,7 +207,7 @@ const loadAppQueue = async ({ pubClient, logger, redisHelpers, ioRedis }) => { `Sent ${notifications.length} consolidated notifications to ${user} for jobId ${jobId} with notificationId ${notificationId}` ); } else { - logger.logger.warn(`No socket IDs found for ${user} in bodyShopId ${bodyShopId}`); + logger.logger.debug(`No socket IDs found for ${user} in bodyShopId ${bodyShopId}`); } } } diff --git a/server/notifications/queues/emailQueue.js b/server/notifications/queues/emailQueue.js index dfc385401..8bb788ddd 100644 --- a/server/notifications/queues/emailQueue.js +++ b/server/notifications/queues/emailQueue.js @@ -5,7 +5,7 @@ const { InstanceEndpoints } = require("../../utils/instanceMgr"); const { registerCleanupTask } = require("../../utils/cleanupManager"); const EMAIL_CONSOLIDATION_DELAY_IN_MINS = (() => { - const envValue = process.env?.APP_CONSOLIDATION_DELAY_IN_MINS; + const envValue = process.env?.EMAIL_CONSOLIDATION_DELAY_IN_MINS; const parsedValue = envValue ? parseInt(envValue, 10) : NaN; return isNaN(parsedValue) ? 1 : Math.max(1, parsedValue); // Default to 1, ensure at least 1 })(); diff --git a/server/notifications/scenarioParser.js b/server/notifications/scenarioParser.js index 180493880..11c9f979e 100644 --- a/server/notifications/scenarioParser.js +++ b/server/notifications/scenarioParser.js @@ -16,7 +16,7 @@ const { dispatchEmailsToQueue } = require("./queues/emailQueue"); const { dispatchAppsToQueue } = require("./queues/appQueue"); // If true, the user who commits the action will NOT receive notifications; if false, they will. -const FILTER_SELF_FROM_WATCHERS = process.env?.FILTER_SELF_FROM_WATCHERS === "true"; +const FILTER_SELF_FROM_WATCHERS = process.env?.FILTER_SELF_FROM_WATCHERS !== "false"; /** * Parses an event and determines matching scenarios for notifications.