Ignore messages from configured originators

Author: ThomasKranitsas

config/default.js

@@ -35,5 +35,7 @@ module.exports = {
   GET_PROJECT_API_BASE: process.env.GET_PROJECT_API_BASE || 'http://localhost:4000/v5/projects',
   SEARCH_MEMBERS_API_BASE: process.env.SEARCH_MEMBERS_API_BASE || 'https://api.topcoder-dev.com/v3/members/_search',
   RESOURCES_API: process.env.RESOURCES_API || 'http://localhost:4000/v5/resources',
-  CHALLENGE_API: process.env.CHALLENGE_API || 'http://localhost:4000/v5/challenges'
+  CHALLENGE_API: process.env.CHALLENGE_API || 'http://localhost:4000/v5/challenges',
+
+  IGNORED_ORIGINATORS: process.env.IGNORED_ORIGINATORS ? process.env.IGNORED_ORIGINATORS.split(',') : ['legacy-migration-script']
 }

src/app.js

@@ -5,6 +5,7 @@
 global.Promise = require('bluebird')
 const config = require('config')
 const Kafka = require('no-kafka')
+const _ = require('lodash')
 const healthcheck = require('topcoder-healthcheck-dropin')
 const logger = require('./common/logger')
 const helper = require('./common/helper')
@@ -34,14 +35,18 @@ const dataHandler = (messageSet, topic, partition) => Promise.each(messageSet, (
   }
 
   return (async () => {
-    if (topic === config.CHALLENGE_CREATE_TOPIC) {
-      await ProcessorService.handleChallengeCreate(messageJSON)
-    } else if (topic === config.PROJECT_MEMBER_ADDED_TOPIC) {
-      await ProcessorService.handleMemberAdded(messageJSON)
-    } else if (topic === config.PROJECT_MEMBER_REMOVED_TOPIC) {
-      await ProcessorService.handleMemberRemoved(messageJSON)
+    if (_.includes(config.IGNORED_ORIGINATORS, messageJSON.originator)) {
+      logger.error(`The message originator is in the ignored list. Originator: ${messageJSON.originator}`)
+    } else {
+      if (topic === config.CHALLENGE_CREATE_TOPIC) {
+        await ProcessorService.handleChallengeCreate(messageJSON)
+      } else if (topic === config.PROJECT_MEMBER_ADDED_TOPIC) {
+        await ProcessorService.handleMemberAdded(messageJSON)
+      } else if (topic === config.PROJECT_MEMBER_REMOVED_TOPIC) {
+        await ProcessorService.handleMemberRemoved(messageJSON)
+      }
+      logger.debug('Successfully processed message')
     }
-    logger.debug('Successfully processed message')
   })()
     // commit offset
     .then(() => consumer.commitOffset({ topic, partition, offset: m.offset }))