part of the winning submission from challenge 30090377 - Topcoder Notifications Service - Skip unnecessary notifications

this part contains changes to implement new functionality

Author: maxceem

connect/connectNotificationServer.js

@@ -9,6 +9,7 @@ const config = require('./config');
 const notificationServer = require('../index');
 const _ = require('lodash');
 const service = require('./service');
+const helpers = require('./helpers');
 const { BUS_API_EVENT } = require('./constants');
 const EVENTS = require('./events-config').EVENTS;
 const PROJECT_ROLE_RULES = require('./events-config').PROJECT_ROLE_RULES;
@@ -246,6 +247,83 @@ const getNotificationsForTopicStarter = (eventConfig, topicId) => {
   });
 };
 
+/**
+ * Filter members by project roles
+ *
+ * @params {Array} List of project roles
+ * @params {Array} List of project members
+ *
+ * @returns {Array} List of objects with user ids
+ */
+const filterMembersByRoles = (roles, members) => {
+  let result = [];
+
+  roles.forEach(projectRole => {
+    result = result.concat(
+      _.filter(members, PROJECT_ROLE_RULES[projectRole])
+        .map(projectMember => ({
+          userId: projectMember.userId.toString(),
+        }))
+    );
+  });
+
+  return result;
+};
+
+/**
+ * Exclude private posts notification
+ *
+ * @param  {Object} eventConfig event configuration
+ * @param  {Object} project     project details
+ * @param  {Array}  tags        list of message tags
+ *
+ * @return {Promise}            resolves to a list of notifications
+ */
+const getExcludedPrivatePostNotifications = (eventConfig, project, tags) => {
+  // skip if message is not private or exclusion rule is not configured
+  if (!_.includes(tags, 'MESSAGES') || !eventConfig.privatePostsForProjectRoles) {
+    return Promise.resolve([]);
+  }
+
+  const members = _.get(project, 'members', []);
+  const notifications = filterMembersByRoles(eventConfig.privatePostsForProjectRoles, members);
+
+  return Promise.resolve(notifications);
+};
+
+/**
+ * Exclude notifications about posts inside draft phases
+ *
+ * @param  {Object} eventConfig event configuration
+ * @param  {Object} project     project details
+ * @param  {Array}  tags        list of message tags
+ *
+ * @return {Promise}            resolves to a list of notifications
+ */
+const getExcludeDraftPhasesNotifications = (eventConfig, project, tags) => {
+  // skip is no exclusion rule is configured
+  if (!eventConfig.draftPhasesForProjectRoles) {
+    return Promise.resolve([]);
+  }
+
+  const phaseId = helpers.extractPhaseId(tags);
+  // skip if it is not phase notification
+  if (!phaseId) {
+    return Promise.resolve([]);
+  }
+
+  // exclude all user with configured roles if phase is in draft state
+  return service.getPhase(project.id, phaseId)
+    .then((phase) => {
+      if (phase.status === 'draft') {
+        const members = _.get(project, 'members', []);
+        const notifications = filterMembersByRoles(eventConfig.draftPhasesForProjectRoles, members);
+
+        return Promise.resolve(notifications);
+      }
+    });
+};
+
 /**
  * Exclude notifications using exclude rules of the event config
  *
@@ -272,12 +350,17 @@ const excludeNotifications = (notifications, eventConfig, message, data) => {
   // and after filter out such notifications from the notifications list
   // TODO move this promise all together with `_.uniqBy` to one function
   //      and reuse it here and in `handler` function
+  const tags = _.get(message, 'tags', []);
+
   return Promise.all([
     getNotificationsForTopicStarter(excludeEventConfig, message.topicId),
     getNotificationsForUserId(excludeEventConfig, message.userId),
-    getNotificationsForMentionedUser(eventConfig, message.postContent),
+    getNotificationsForMentionedUser(excludeEventConfig, message.postContent),
     getProjectMembersNotifications(excludeEventConfig, project),
     getTopCoderMembersNotifications(excludeEventConfig),
+    // these are special exclude rules which are only working for excluding notifications but not including
+    getExcludedPrivatePostNotifications(excludeEventConfig, project, tags),
+    getExcludeDraftPhasesNotifications(excludeEventConfig, project, tags),
   ]).then((notificationsPerSource) => (
     _.uniqBy(_.flatten(notificationsPerSource), 'userId')
   )).then((excludedNotifications) => {

connect/events-config.js

@@ -5,6 +5,7 @@ const { BUS_API_EVENT } = require('./constants');
 
 // project member role names
 const PROJECT_ROLE_OWNER = 'owner';
+const PROJECT_ROLE_CUSTOMER = 'customer';
 const PROJECT_ROLE_COPILOT = 'copilot';
 const PROJECT_ROLE_MANAGER = 'manager';
 const PROJECT_ROLE_MEMBER = 'member';
@@ -13,13 +14,15 @@ const PROJECT_ROLE_ACCOUNT_MANAGER = 'account_manager';
 // project member role rules
 const PROJECT_ROLE_RULES = {
   [PROJECT_ROLE_OWNER]: { role: 'customer', isPrimary: true },
+  [PROJECT_ROLE_CUSTOMER]: { role: 'customer' },
   [PROJECT_ROLE_COPILOT]: { role: 'copilot' },
   [PROJECT_ROLE_MANAGER]: { role: 'manager' },
   [PROJECT_ROLE_ACCOUNT_MANAGER]: { role: 'account_manager' },
   [PROJECT_ROLE_MEMBER]: {},
 };
 
 // TopCoder roles
+// eslint-disable-next-line no-unused-vars
 const ROLE_CONNECT_COPILOT = 'Connect Copilot';
 const ROLE_CONNECT_MANAGER = 'Connect Manager';
 const ROLE_CONNECT_COPILOT_MANAGER = 'Connect Copilot Manager';
@@ -123,31 +126,53 @@ const EVENTS = [
     version: 2,
     projectRoles: [PROJECT_ROLE_OWNER, PROJECT_ROLE_COPILOT, PROJECT_ROLE_MANAGER, PROJECT_ROLE_MEMBER],
     toMentionedUsers: true,
+    exclude: {
+      privatePostsForProjectRoles: [PROJECT_ROLE_CUSTOMER],
+    },
   }, {
     type: BUS_API_EVENT.CONNECT.POST.CREATED,
     version: 2,
     projectRoles: [PROJECT_ROLE_OWNER, PROJECT_ROLE_COPILOT, PROJECT_ROLE_MANAGER, PROJECT_ROLE_MEMBER],
     toTopicStarter: true,
     toMentionedUsers: true,
+    exclude: {
+      draftPhasesForProjectRoles: [PROJECT_ROLE_CUSTOMER],
+      privatePostsForProjectRoles: [PROJECT_ROLE_CUSTOMER],
+    },
   }, {
     type: BUS_API_EVENT.CONNECT.POST.UPDATED,
     version: 2,
     projectRoles: [PROJECT_ROLE_OWNER, PROJECT_ROLE_COPILOT, PROJECT_ROLE_MANAGER, PROJECT_ROLE_MEMBER],
     toTopicStarter: true,
     toMentionedUsers: true,
+    exclude: {
+      draftPhasesForProjectRoles: [PROJECT_ROLE_CUSTOMER],
+      privatePostsForProjectRoles: [PROJECT_ROLE_CUSTOMER],
+    },
   }, {
     type: BUS_API_EVENT.CONNECT.POST.MENTION,
+    exclude: {
+      draftPhasesForProjectRoles: [PROJECT_ROLE_CUSTOMER],
+      privatePostsForProjectRoles: [PROJECT_ROLE_CUSTOMER],
+    },
   },
   {
     type: BUS_API_EVENT.CONNECT.TOPIC.DELETED,
     version: 2,
     projectRoles: [PROJECT_ROLE_OWNER, PROJECT_ROLE_COPILOT, PROJECT_ROLE_MANAGER, PROJECT_ROLE_MEMBER],
     toTopicStarter: false,
+    exclude: {
+      privatePostsForProjectRoles: [PROJECT_ROLE_CUSTOMER],
+    },
   },
   {
     type: BUS_API_EVENT.CONNECT.POST.DELETED,
     version: 2,
     projectRoles: [PROJECT_ROLE_OWNER, PROJECT_ROLE_COPILOT, PROJECT_ROLE_MANAGER, PROJECT_ROLE_MEMBER],
+    exclude: {
+      draftPhasesForProjectRoles: [PROJECT_ROLE_CUSTOMER],
+      privatePostsForProjectRoles: [PROJECT_ROLE_CUSTOMER],
+    },
   },
   {
     type: BUS_API_EVENT.CONNECT.PROJECT.LINK_CREATED,

connect/helpers.js

@@ -2,6 +2,9 @@
  * Helper functions
  */
 const Remarkable = require('remarkable');
+const _ = require('lodash');
+
+const PHASE_ID_REGEXP = /phase#(\d+)/;
 
 /**
  * Convert markdown into raw draftjs state
@@ -42,7 +45,20 @@ const sanitizeEmail = (email) => {
   return '';
 };
 
+/**
+ * Helper method to extract phaseId from tag
+ *
+ * @param {Array} tags list of message tags
+ *
+ * @returns {String} phase id
+ */
+const extractPhaseId = (tags) => {
+  const phaseIds = tags.map((tag) => _.get(tag.match(PHASE_ID_REGEXP), '1', null));
+  return _.find(phaseIds, (phaseId) => phaseId !== null);
+};
+
 module.exports = {
   markdownToHTML,
   sanitizeEmail,
+  extractPhaseId,
 };

connect/service.js

@@ -232,10 +232,46 @@ const getTopic = (topicId, logger) => (
     })
 );
 
+/**
+ * Get phase details
+ *
+ * @param  {String} projectId project id
+ * @param  {String} phaseId phase id
+ *
+ * @return {Promise}          promise resolved to phase details
+ */
+const getPhase = (projectId, phaseId) => (
+  M2m.getMachineToken(config.AUTH0_CLIENT_ID, config.AUTH0_CLIENT_SECRET)
+    .then((token) => (
+      request
+        .get(`${config.TC_API_V4_BASE_URL}/projects/${projectId}/phases/${phaseId}`)
+        .set('accept', 'application/json')
+        .set('authorization', `Bearer ${token}`)
+        .then((res) => {
+          if (!_.get(res, 'body.result.success')) {
+            throw new Error(`Failed to get phase details of project id: ${projectId}, phase id: ${phaseId}`);
+          }
+          const project = _.get(res, 'body.result.content');
+          return project;
+        }).catch((err) => {
+          const errorDetails = _.get(err, 'response.body.result.content.message');
+          throw new Error(
+            `Failed to get phase details of project id: ${projectId}, phase id: ${phaseId}.` +
+            (errorDetails ? ' Server response: ' + errorDetails : '')
+          );
+        })
+    ))
+    .catch((err) => {
+      err.message = 'Error generating m2m token: ' + err.message;
+      throw err;
+    })
+);
+
 module.exports = {
   getProject,
   getRoleMembers,
   getUsersById,
   getUsersByHandle,
   getTopic,
+  getPhase,
 };