Added most needed events.

Author: architectt1

src/constants.js

@@ -61,6 +61,12 @@ export const BUS_API_EVENT = {
   PROJECT_CANCELED: 'notifications.connect.project.canceled',
   PROJECT_ACTIVE: 'notifications.connect.project.active',
 
+  PROJECT_PHASE_TRANSITION_ACTIVE: 'project.phase.transition.active',
+  PROJECT_PHASE_TRANSITION_COMPLETED: 'project.phase.transition.completed',
+  PROJECT_PHASE_UPDATE_PAYMENT: 'project.phase.update.payment',
+  PROJECT_PHASE_UPDATE_PROGRESS: 'project.phase.update.progress',
+  PROJECT_PHASE_UPDATE_SCOPE: 'project.phase.update.scope',
+
   MEMBER_JOINED: 'notifications.connect.project.member.joined',
   MEMBER_LEFT: 'notifications.connect.project.member.left',
   MEMBER_REMOVED: 'notifications.connect.project.member.removed',
@@ -71,12 +77,16 @@ export const BUS_API_EVENT = {
   PROJECT_LINK_CREATED: 'notifications.connect.project.linkCreated',
   PROJECT_FILE_UPLOADED: 'notifications.connect.project.fileUploaded',
   PROJECT_SPECIFICATION_MODIFIED: 'notifications.connect.project.specificationModified',
+  PROJECT_PROGRESS_MODIFIED: 'notifications.connect.project.progressModified',
 
   // When phase is added/updated/deleted from the project,
   // When product is added/deleted from a phase
   // When product is updated on any field other than specification
   PROJECT_PLAN_MODIFIED: 'notifications.connect.project.planModified',
 
+  // TODO: add logic to send this event
+  PROJECT_PLAN_READY: 'notifications.connect.project.planReady',
+
   // When specification of a product is modified
   PROJECT_PRODUCT_SPECIFICATION_MODIFIED: 'notifications.connect.project.productSpecificationModified',
 };

src/events/busApi.js

@@ -1,6 +1,6 @@
 import _ from 'lodash';
 import 'config';
-import { EVENT, BUS_API_EVENT, PROJECT_STATUS, PROJECT_MEMBER_ROLE } from '../constants';
+import { EVENT, BUS_API_EVENT, PROJECT_STATUS, PROJECT_PHASE_STATUS, PROJECT_MEMBER_ROLE } from '../constants';
 import { createEvent } from '../services/busApi';
 import models from '../models';
 
@@ -226,6 +226,7 @@ module.exports = (app, logger) => {
     logger.debug('receive PROJECT_PHASE_UPDATED event');
 
     const projectId = _.parseInt(req.params.projectId);
+    const phaseId = _.parseInt(req.params.phaseId);
 
     models.Project.findOne({
       where: { id: projectId },
@@ -237,6 +238,29 @@ module.exports = (app, logger) => {
           userId: req.authUser.userId,
           initiatorUserId: req.authUser.userId,
         }, logger);
+
+        [
+          ['spentBudget', BUS_API_EVENT.PROJECT_PHASE_UPDATE_PAYMENT],
+          ['progress', [BUS_API_EVENT.PROJECT_PHASE_UPDATE_PROGRESS, BUS_API_EVENT.PROJECT_PROGRESS_MODIFIED]],
+          ['details', BUS_API_EVENT.PROJECT_PHASE_UPDATE_SCOPE],
+          ['status', BUS_API_EVENT.PROJECT_PHASE_TRANSITION_ACTIVE, PROJECT_PHASE_STATUS.ACTIVE],
+          ['status', BUS_API_EVENT.PROJECT_PHASE_TRANSITION_COMPLETED, PROJECT_PHASE_STATUS.COMPLETED],
+        ].forEach(([key, events, sendIfEqual]) => {
+          // eslint-disable-next-line no-param-reassign
+          events = Array.isArray(events) ? events : [events];
+          
+          // send event(s) only if the target field's value was updated, or when an update matches a "sendIfEqual" value
+          if ((!sendIfEqual && !_.isEqual(original[key], updated[key])) ||
+            (original[key] !== sendIfEqual && updated[key] === sendIfEqual)) {
+            events.forEach(event => createEvent(event, {
+              projectId,
+              phaseId,
+              projectName: project.name,
+              userId: req.authUser.userId,
+              initiatorUserId: req.authUser.userId,
+            }, logger));
+          }
+        });
       }).catch(err => null);    // eslint-disable-line no-unused-vars
   });