Merge pull request #54 from topcoder-platform/read-only-cache-issue

Read only cache issue

Author: Gunasekar-K

config/default.js

@@ -18,6 +18,7 @@ module.exports = {
   CREATE_DATA_TOPIC: process.env.CREATE_DATA_TOPIC || 'submission.notification.create',
   UPDATE_DATA_TOPIC: process.env.UPDATE_DATA_TOPIC || 'submission.notification.update',
   DELETE_DATA_TOPIC: process.env.DELETE_DATA_TOPIC || 'submission.notification.delete',
+  AGGREGATE_DATA_TOPIC: process.env.AGGREGATE_DATA_TOPIC || 'submission.notification.aggregate',
 
   LEADERBOARD_API_URL: process.env.LEADERBOARD_API_URL || 'https://api.topcoder-dev.com/v5/leaderboards',
   SUBMISSION_API_URL: process.env.SUBMISSION_API_URL || 'https://api.topcoder-dev.com/v5/submissions',

docker/Dockerfile

@@ -8,4 +8,4 @@ WORKDIR /leaderboard-processor
 
 # Install the dependencies from package.json
 RUN npm install
-CMD npm start
+CMD node src/app.js

src/app.js

@@ -42,7 +42,7 @@ const dataHandler = (messageSet, topic, partition) => Promise.each(messageSet, a
   }
 
   if (messageJSON.payload.resource !== 'review' && messageJSON.payload.resource !== 'reviewSummation') {
-    logger.debug(`Ignoring Non review payloads from topic ${messageJSON.topic}.`)
+    logger.debug(`Ignoring Non review or review summation payloads from topic ${messageJSON.topic}.`)
     // ignore the message
     return
   }
@@ -56,8 +56,10 @@ const dataHandler = (messageSet, topic, partition) => Promise.each(messageSet, a
     }
   }
 
+  const originalTopic = messageJSON.payload.originalTopic
+
   return (async () => {
-    switch (topic) {
+    switch (originalTopic) {
       case config.CREATE_DATA_TOPIC:
         await ProcessorService.upsert(messageJSON)
         break
@@ -90,7 +92,7 @@ function check () {
   return connected
 }
 
-const topics = [config.CREATE_DATA_TOPIC, config.UPDATE_DATA_TOPIC, config.DELETE_DATA_TOPIC]
+const topics = [config.AGGREGATE_DATA_TOPIC]
 
 consumer
   .init([{