Issue #1469 - User mentions in the posts

connect/connectNotificationServer.js

@@ -52,6 +52,38 @@ const getTopCoderMembersNotifications = (eventConfig) => {
   });
 };
 
+/**
+ * Get notifications for mentioned users
+ *
+ * @param  {Object} eventConfig event configuration
+ * @param  {Object} message content
+ *
+ * @return {Promise}            resolves to a list of notifications
+ */
+const getNotificationsForMentionedUser = (eventConfig, content) => {
+  if (!eventConfig.toMentionedUsers) {
+    return Promise.resolve([]);
+  }
+
+  let notifications = [];
+  const regexUserId = /@([0-9]+)/g;
+  let matches = regexUserId.exec(content);
+  while (matches) {
+    notifications.push({
+      userId: matches[1].toString(),
+      newType: 'notifications.connect.project.post.mention',
+      contents: {
+        toUserHandle: true,
+      },
+    });
+    matches = regexUserId.exec(content);
+  }
+
+  // only one per userId
+  notifications = _.uniqBy(notifications, 'userId');
+  return Promise.resolve(notifications);
+};
+
 /**
  * Get project members notifications
  *
@@ -252,6 +284,7 @@ const handler = (topic, message, callback) => {
       //       - check that event has everything required or throw error
       getNotificationsForTopicStarter(eventConfig, message.topicId),
       getNotificationsForUserId(eventConfig, message.userId),
+      getNotificationsForMentionedUser(eventConfig, message.contents.postContent),
       getProjectMembersNotifications(eventConfig, project),
       getTopCoderMembersNotifications(eventConfig),
     ]).then((notificationsPerSource) => (

connect/events-config.js

@@ -110,6 +110,9 @@ const EVENTS = [
     version: 2,
     projectRoles: [PROJECT_ROLE_OWNER, PROJECT_ROLE_COPILOT, PROJECT_ROLE_MANAGER, PROJECT_ROLE_MEMBER],
     toTopicStarter: true,
+    toMentionedUsers: true,
+  }, {
+    type: 'notifications.connect.project.post.mention',
   },
   {
     type: 'notifications.connect.project.linkCreated',

src/app.js

@@ -52,7 +52,7 @@ function startKafkaConsumer(handlers) {
       // save notifications
       .then((notifications) => Promise.all(_.map(notifications, (notification) => models.Notification.create({
         userId: notification.userId,
-        type: topicName,
+        type: notification.newType || topicName,
         version: notification.version || null,
         contents: _.extend({}, messageJSON, notification.contents),
         read: false,