Creating default topic for phase when phase is created via new project

Fixed data type for template id when indexing in ES

Author: Vikas Agarwal

src/events/projectPhases/index.js

@@ -191,4 +191,5 @@ module.exports = {
   projectPhaseAddedHandler,
   projectPhaseRemovedHandler,
   projectPhaseUpdatedHandler,
+  createPhaseTopic,
 };

src/events/projects/index.js

@@ -5,19 +5,16 @@ import _ from 'lodash';
 import Promise from 'bluebird';
 import config from 'config';
 import util from '../../util';
+import { createPhaseTopic } from '../projectPhases';
 
 const ES_PROJECT_INDEX = config.get('elasticsearchConfig.indexName');
 const ES_PROJECT_TYPE = config.get('elasticsearchConfig.docType');
 const eClient = util.getElasticSearchClient();
 
-/**
- * Handler for project creation event
- * @param  {Object} logger  logger to log along with trace id
- * @param  {Object} msg     event payload
- * @param  {Object} channel channel to ack, nack
- * @returns {undefined}
- */
-const projectCreatedHandler = Promise.coroutine(function* (logger, msg, channel) { // eslint-disable-line func-names
+
+
+
+const indexProject = Promise.coroutine(function* (logger, msg) {
   const data = JSON.parse(msg.content.toString());
   const userIds = data.members ? data.members.map(single => `userId:${single.userId}`) : [];
   try {
@@ -42,9 +39,26 @@ const projectCreatedHandler = Promise.coroutine(function* (logger, msg, channel)
       body: data,
     });
     logger.debug(`project indexed successfully (projectId: ${data.id})`, result);
-    channel.ack(msg);
     return undefined;
   } catch (error) {
+    logger.error(`Error indexing project (projectId: ${data.id})`, error);
+    throw error;
+  }
+});
+
+/**
+ * Handler for project creation event
+ * @param  {Object} logger  logger to log along with trace id
+ * @param  {Object} msg     event payload
+ * @param  {Object} channel channel to ack, nack
+ * @returns {undefined}
+ */
+const projectCreatedHandler = Promise.coroutine(function* (logger, msg, channel) { // eslint-disable-line func-names
+  try {
+    indexProject(logger, msg);
+    createPhaseTopic(logger, msg);
+    channel.ack(msg);
+  } catch(error) {
     logger.error(`Error processing event (projectId: ${data.id})`, error);
     channel.nack(msg, false, !msg.fields.redelivered);
     return undefined;

src/routes/projects/create.js

@@ -115,7 +115,7 @@ function createProjectAndPhases(req, project, projectTemplate) {
               _.assign(_.omit(product, ['id', 'productKey']), {
                 phaseId: newPhase.id,
                 projectId: newProject.id,
-                templateId: product.id,
+                templateId: Integer.parseInt(product.id),
                 updatedBy: req.authUser.userId,
                 createdBy: req.authUser.userId,
               })), { returning: true })