fix: keep seedElasticsearchIndex.js working

- we change the previous fix and keep projectCreatedHandler as it is, as `seedElasticsearchIndex.js` relies on it
- for out needs we create a copy of `projectCreatedHandler` called `projectCreatedHandlerForPhases` which only take care about topics for phases

Author: maxceem

src/events/index.js

@@ -1,6 +1,7 @@
 
 import { EVENT, CONNECT_NOTIFICATION_EVENT } from '../constants';
 import { projectCreatedHandler,
+  projectCreatedHandlerForPhases,
   projectUpdatedKafkaHandler } from './projects';
 import { projectPhaseAddedHandler, projectPhaseRemovedHandler,
   projectPhaseUpdatedHandler } from './projectPhases';
@@ -39,7 +40,7 @@ const voidRabbitHandler = (logger, msg, channel) => {
 //       we should completely remove the handlers for this events.
 export const rabbitHandlers = {
   'project.initial': projectCreatedHandler, // is only used `seedElasticsearchIndex.js` and can be removed
-  [EVENT.ROUTING_KEY.PROJECT_DRAFT_CREATED]: projectCreatedHandler, // we have to call it, because it triggers topics creating for phases
+  [EVENT.ROUTING_KEY.PROJECT_DRAFT_CREATED]: projectCreatedHandlerForPhases, // we have to call it, because it triggers topics creating for phases
   [EVENT.ROUTING_KEY.PROJECT_UPDATED]: voidRabbitHandler, // DISABLED
   [EVENT.ROUTING_KEY.PROJECT_DELETED]: voidRabbitHandler, // DISABLED
   [EVENT.ROUTING_KEY.PROJECT_MEMBER_ADDED]: voidRabbitHandler, // DISABLED

src/events/projects/index.js

@@ -65,9 +65,32 @@ const indexProject = Promise.coroutine(function* (logger, msg) { // eslint-disab
 const projectCreatedHandler = Promise.coroutine(function* (logger, msg, channel) { // eslint-disable-line func-names
   const project = JSON.parse(msg.content.toString());
   try {
-    // we don't have to call indexing, as it's now handled by `project-processor-es`
-    // yield indexProject(logger, msg);
-    // we call this handle only for the sake of creating topics for the phases
+    yield indexProject(logger, msg);
+    if (project.phases && project.phases.length > 0) {
+      logger.debug('Phases found for the project, trying to create topics for each phase.');
+      const topicPromises = _.map(project.phases, phase => createPhaseTopic(logger, phase));
+      yield Promise.all(topicPromises);
+    }
+    channel.ack(msg);
+  } catch (error) {
+    logger.error(`Error processing event (projectId: ${project.id})`, error);
+    channel.nack(msg, false, !msg.fields.redelivered);
+  }
+});
+
+/**
+ * Handler for project creation event
+ *
+ * we call this handle only for the sake of creating topics for the phases
+ *
+ * @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 projectCreatedHandlerForPhases = Promise.coroutine(function* (logger, msg, channel) { // eslint-disable-line func-names
+  const project = JSON.parse(msg.content.toString());
+  try {
     if (project.phases && project.phases.length > 0) {
       logger.debug('Phases found for the project, trying to create topics for each phase.');
       const topicPromises = _.map(project.phases, phase => createPhaseTopic(logger, phase));
@@ -192,6 +215,7 @@ async function projectUpdatedKafkaHandler(app, topic, payload) {
 
 module.exports = {
   projectCreatedHandler,
+  projectCreatedHandlerForPhases,
   projectUpdatedHandler,
   projectDeletedHandler,
   projectUpdatedKafkaHandler,