Merge pull request #17 from topcoder-platform/develop

Shapeup-Pure-V5-task

.circleci/config.yml

@@ -18,7 +18,6 @@ install_deploysuite: &install_deploysuite
             cp ./../buildscript/master_deploy.sh .
             cp ./../buildscript/buildenv.sh .
             cp ./../buildscript/awsconfiguration.sh .
-
 run_build: &run_build
           name: Installation of build dependencies.
           command: ./build.sh            
@@ -61,7 +60,6 @@ jobs:
             ./buildenv.sh -e PROD -b submission-processor-es_deployvar
             source buildenvvar
             ./master_deploy.sh -d ECS -e PROD -t latest -s prod-global-appvar,submission-processor-es_appvar -i submission-processor-es
-
 workflows:
   version: 2
   build:
@@ -76,4 +74,4 @@ workflows:
           context : org-global
           filters:
             branches:
-              only: master        
+              only: master

README.md

@@ -227,4 +227,4 @@ npm run view-data a12a4180-65aa-42ec-a945-5fd21dec0501
 
 ```
 { "topic":"submission.notification.delete", "originator":"submission-api", "timestamp":"2018-08-06T15:46:05.575Z", "mime-type":"application/json", "payload":{ "resource":"review", "id": "d34d4180-65aa-42ec-a945-5fd21dec0503" } }
-```
+```

src/services/ProcessorService.js

@@ -28,6 +28,11 @@ function * getESData (id) {
  * @param {Object} message the message
  */
 function * create (message) {
+  if (message.payload.resource === 'submission') {
+    message.payload.challengeId = message.payload.v5ChallengeId
+    delete message.payload.v5ChallengeId
+  }
+
   yield client.create({
     index: config.get('esConfig.ES_INDEX'),
     type: config.get('esConfig.ES_TYPE'),
@@ -53,8 +58,8 @@ function * create (message) {
     const submission = yield getESData(message.payload.submissionId)
     let reviewSummationArr = []
     reviewSummationArr.push(_.omit(message.payload, ['resource']))
-    if (submission.reviewSummationArr) {
-      reviewSummationArr = reviewSummationArr.concat(submission.review)
+    if (submission.reviewSummation) {
+      reviewSummationArr = reviewSummationArr.concat(submission.reviewSummation)
     }
     yield client.update({
       index: config.get('esConfig.ES_INDEX'),
@@ -83,6 +88,13 @@ create.schema = {
  * @param {Object} message the message
  */
 function * update (message) {
+  if (message.payload.resource === 'submission') {
+    const legacyChallengeId = message.payload.challengeId
+    message.payload.challengeId = message.payload.v5ChallengeId
+    message.payload.legacyChallengeId = legacyChallengeId
+    delete message.payload.v5ChallengeId
+  }
+
   yield client.update({
     index: config.get('esConfig.ES_INDEX'),
     type: config.get('esConfig.ES_TYPE'),