IO-3096-GlobalNotifications: Self Watcher env var was not handled correctly

This commit is contained in:
Dave Richer
2025-03-04 11:56:46 -05:00
parent 2b76f8a12d
commit fd7850b551
2 changed files with 3 additions and 3 deletions

View File

@@ -138,7 +138,7 @@ const loadAppQueue = async ({ pubClient, logger, redisHelpers, ioRedis }) => {
await pubClient.del(userKey); await pubClient.del(userKey);
logger.logger.debug(`Deleted Redis key ${userKey}`); logger.logger.debug(`Deleted Redis key ${userKey}`);
} else { } 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}` `Sent ${notifications.length} consolidated notifications to ${user} for jobId ${jobId} with notificationId ${notificationId}`
); );
} else { } 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}`);
} }
} }
} }

View File

@@ -16,7 +16,7 @@ const { dispatchEmailsToQueue } = require("./queues/emailQueue");
const { dispatchAppsToQueue } = require("./queues/appQueue"); const { dispatchAppsToQueue } = require("./queues/appQueue");
// If true, the user who commits the action will NOT receive notifications; if false, they will. // 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. * Parses an event and determines matching scenarios for notifications.