Merge pull request #123 from topcoder-platform/hotfix/handling_unhandled_error_in_getting_mentioned_user_details_updated

Hotfix/handling unhandled error in getting mentioned user details updated

Author: vikasrohit

connect/connectNotificationServer.js

@@ -56,12 +56,13 @@ const getTopCoderMembersNotifications = (eventConfig) => {
 /**
  * Get notifications for mentioned users
  *
+ * @param  {Object} logger object used to log in parent thread
  * @param  {Object} eventConfig event configuration
  * @param  {Object} message content
  *
  * @return {Promise}            resolves to a list of notifications
  */
-const getNotificationsForMentionedUser = (eventConfig, content) => {
+const getNotificationsForMentionedUser = (logger, eventConfig, content) => {
   if (!eventConfig.toMentionedUsers || !content) {
     return Promise.resolve([]);
   }
@@ -93,6 +94,13 @@ const getNotificationsForMentionedUser = (eventConfig, content) => {
           notification.userId = mentionedUser ? mentionedUser.userId.toString() : notification.userHandle;
         });
         resolve(notifications);
+      }).catch((error) => {
+        if (logger) {
+          logger.error(error);
+          logger.info('Unable to send notification to mentioned user')
+        }
+        //resolves with empty notification which essentially means we are unable to send notification to mentioned user
+        resolve([]);
       });
     } else {
       resolve([]);
@@ -249,14 +257,15 @@ const getNotificationsForTopicStarter = (eventConfig, topicId) => {
 /**
  * Exclude notifications using exclude rules of the event config
  *
+ * @param {Object} logger object used to log in parent thread
  * @param {Array}  notifications notifications list
  * @param {Object} eventConfig   event configuration
  * @param {Object} message       message
  * @param {Object} data          any additional data which is retrieved once
  *
  * @returns {Promise} resolves to the list of filtered notifications
  */
-const excludeNotifications = (notifications, eventConfig, message, data) => {
+const excludeNotifications = (logger, notifications, eventConfig, message, data) => {
   // if there are no rules to exclude notifications, just return all of them untouched
   if (!eventConfig.exclude) {
     return Promise.resolve(notifications);
@@ -275,7 +284,7 @@ const excludeNotifications = (notifications, eventConfig, message, data) => {
   return Promise.all([
     getNotificationsForTopicStarter(excludeEventConfig, message.topicId),
     getNotificationsForUserId(excludeEventConfig, message.userId),
-    getNotificationsForMentionedUser(eventConfig, message.postContent),
+    getNotificationsForMentionedUser(logger, excludeEventConfig, message.postContent),
     getProjectMembersNotifications(excludeEventConfig, project),
     getTopCoderMembersNotifications(excludeEventConfig),
   ]).then((notificationsPerSource) => (
@@ -335,7 +344,7 @@ const handler = (topic, message, logger, callback) => {
       getNotificationsForTopicStarter(eventConfig, message.topicId),
       getNotificationsForUserId(eventConfig, message.userId),
       getNotificationsForOriginator(eventConfig, message.originator),
-      getNotificationsForMentionedUser(eventConfig, message.postContent),
+      getNotificationsForMentionedUser(logger, eventConfig, message.postContent),
       getProjectMembersNotifications(eventConfig, project),
       getTopCoderMembersNotifications(eventConfig),
     ]).then((notificationsPerSource) => {
@@ -344,7 +353,7 @@ const handler = (topic, message, logger, callback) => {
       logger.debug('all notifications: ', notificationsPerSource);
       return _.uniqBy(_.flatten(notificationsPerSource), 'userId');
     }).then((notifications) => (
-      excludeNotifications(notifications, eventConfig, message, {
+      excludeNotifications(logger, notifications, eventConfig, message, {
         project,
       })
     )).then((notifications) => {