Add support for activating/closing a challenge

Author: ThomasKranitsas

config/default.js

@@ -38,5 +38,8 @@ module.exports = {
   // PHASE IDs
   REGISTRATION_PHASE_ID: process.env.REGISTRATION_PHASE_ID || 'a93544bc-c165-4af4-b55e-18f3593b457a',
   SUBMISSION_PHASE_ID: process.env.SUBMISSION_PHASE_ID || '6950164f-3c5e-4bdc-abc8-22aaf5a1bd49',
-  CHECKPOINT_SUBMISSION_PHASE_ID: process.env.CHECKPOINT_SUBMISSION_PHASE_ID || 'd8a2cdbe-84d1-4687-ab75-78a6a7efdcc8'
+  CHECKPOINT_SUBMISSION_PHASE_ID: process.env.CHECKPOINT_SUBMISSION_PHASE_ID || 'd8a2cdbe-84d1-4687-ab75-78a6a7efdcc8',
+
+  // Challenge Type IDs
+  TASK_TYPE_ID: process.env.TASK_TYPE_ID || 'e885273d-aeda-42c0-917d-bfbf979afbba'
 }

src/services/ProcessorService.js

@@ -176,6 +176,25 @@ async function parsePayload (payload, m2mToken, isCreated = true) {
   }
 }
 
+/**
+ * Activate challenge
+ * @param {Number} challengeId the challenge ID
+ */
+async function activateChallenge (challengeId) {
+  const m2mToken = await helper.getM2MToken()
+  return helper.postRequest(`${config.V4_CHALLENGE_API_URL}/${challengeId}/activate`, null, m2mToken)
+}
+
+/**
+ * Close challenge
+ * @param {Number} challengeId the challenge ID
+ * @param {Number} winnerId the winner ID
+ */
+async function closeChallenge (challengeId, winnerId) {
+  const m2mToken = await helper.getM2MToken()
+  return helper.postRequest(`${config.V4_CHALLENGE_API_URL}/${challengeId}/close?winnerId=${winnerId}`, null, m2mToken)
+}
+
 /**
  * Process create challenge message
  * @param {Object} message the kafka message
@@ -269,6 +288,22 @@ async function processUpdate (message) {
     if (!challenge) {
       throw new Error(`Could not find challenge ${message.payload.legacyId}`)
     }
+    if (message.payload.status) {
+      if (message.payload.status === constants.challengeStatuses.Active && challenge.status !== constants.challengeStatuses.Active) {
+        await activateChallenge(message.payload.legacyId)
+      }
+      if (message.payload.status === constants.challengeStatuses.Completed && challenge.status !== constants.challengeStatuses.Completed) {
+        const challengeUuid = message.payload.id
+        const v5Challenge = await helper.getRequest(`${config.V5_CHALLENGE_API_URL}/${challengeUuid}`, m2mToken)
+        if (v5Challenge.typeId === config.TASK_TYPE_ID) {
+          if (!message.payload.winners || message.payload.winners.length === 0) {
+            throw new Error('Cannot close challenge without winners')
+          }
+          const winnerId = _.find(message.payload.winners, winner => winner.placement === 1).userId
+          await closeChallenge(message.payload.legacyId, winnerId)
+        }
+      }
+    }
     // we can't switch the challenge type
     // TODO: track is missing from the response.
     // if (message.payload.legacy.track) {