Merge pull request #16 from topcoder-platform/Issue_210

Swap challenge id to correctly store details in elasticsearch
topcoder-platform · Feb 11, 2021 · 225cbac · 225cbac
2 parents ad87263 + 5e44278
commit 225cbac
Showing 1 changed file with 12 additions and 0 deletions.
diff --git a/src/services/ProcessorService.js b/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'),
@@ -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'),