Merge branch 'develop'

Author: rootelement

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/constants.js

@@ -14,15 +14,33 @@ const EVENT_MIME_TYPE = 'application/json'
 const createChallengeStatusesMap = {
   Active: 1,
   Draft: 2,
-  New: 2
+  New: 2,
+  Cancelled: 9,
+  Completed: 7,
+  Deleted: 3,
+  CancelledFailedReview: 4,
+  CancelledFailedScreening: 5,
+  CancelledZeroSubmissions: 6,
+  CancelledWinnerUnresponsive: 8,
+  CancelledClientRequest: 9,
+  CancelledRequirementsInfeasible: 10,
+  CancelledZeroRegistrations: 11
 }
 
 const challengeStatuses = {
   New: 'New',
   Draft: 'Draft',
   Canceled: 'Canceled',
   Active: 'Active',
-  Completed: 'Completed'
+  Completed: 'Completed',
+  Deleted: 'Deleted',
+  CancelledFailedReview: 'Cancelled - Failed Review',
+  CancelledFailedScreening: 'Cancelled - Failed Screening',
+  CancelledZeroSubmissions: 'Cancelled - Zero Submissions',
+  CancelledWinnerUnresponsive: 'Cancelled - Winner Unresponsive',
+  CancelledClientRequest: 'Cancelled - Client Request',
+  CancelledRequirementsInfeasible: 'Cancelled - Requirements Infeasible',
+  CancelledZeroRegistrations: 'Cancelled - Zero Registrations'
 }
 
 module.exports = {

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) {