Added logic for the plan ready event.

Author: architectt1

src/constants.js

@@ -84,7 +84,6 @@ export const BUS_API_EVENT = {
   // 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

src/events/busApi.js

@@ -177,6 +177,34 @@ module.exports = (app, logger) => {
       }).catch(err => null);    // eslint-disable-line no-unused-vars
   });
 
+  /**
+   * If the project is in draft status and the phase is in reviewed status, and it's the
+   * only phase in the project with that status, then send the plan ready event.
+   *
+   * @param req
+   * @param project
+   * @param phase
+   * @returns {Promise<void>}
+   */
+  async function sendPlanReadyEventIfNeeded(req, project, phase) {
+    if (project.status === PROJECT_STATUS.DRAFT &&
+      phase.status === PROJECT_PHASE_STATUS.REVIEWED) {
+      models.ProjectPhase.count({
+        where: { projectId: project.id, status: PROJECT_PHASE_STATUS.REVIEWED }
+      }).then((count => {
+        // only send the plan ready event when this is the only reviewed phase in the project
+        if (count !== 1) { return; }
+        createEvent(BUS_API_EVENT.PROJECT_PLAN_READY, {
+          projectId: project.id,
+          phaseId: phase.id,
+          projectName: project.name,
+          userId: req.authUser.userId,
+          initiatorUserId: req.authUser.userId,
+        }, logger)
+      }));
+    }
+  }
+
   /**
    * PROJECT_PHASE_ADDED
    */
@@ -195,6 +223,8 @@ module.exports = (app, logger) => {
           userId: req.authUser.userId,
           initiatorUserId: req.authUser.userId,
         }, logger);
+
+        return sendPlanReadyEventIfNeeded(req, project, created);
       }).catch(err => null);    // eslint-disable-line no-unused-vars
   });
 
@@ -261,6 +291,8 @@ module.exports = (app, logger) => {
             }, logger));
           }
         });
+
+        return sendPlanReadyEventIfNeeded(req, project, updated);
       }).catch(err => null);    // eslint-disable-line no-unused-vars
   });