From 0959e0b38fb92d9125a1ce744651dabda11b9177 Mon Sep 17 00:00:00 2001
From: Justin Gasper <jmgasper@gmail.com>
Date: Fri, 9 Sep 2022 15:40:10 +1000
Subject: [PATCH] Test for phase syncing for multi-round challenges

---
 src/constants.js                 | 7 +++++++
 src/services/ProcessorService.js | 5 +++++
 2 files changed, 12 insertions(+)

diff --git a/src/constants.js b/src/constants.js
index 0e848a1..422afb0 100644
--- a/src/constants.js
+++ b/src/constants.js
@@ -71,6 +71,12 @@ const PhaseStatusTypes = {
   Closed: 3
 }
 
+const CheckpointPhaseTypes = {
+  Submission: 'Checkpoint Submission',
+  Screening: 'Checkpoint Screening',
+  Review: 'Checkpoint Review',
+}
+
 const prizeTypesIds = {
   Contest: 15,
   Checkpoint: 14
@@ -166,6 +172,7 @@ module.exports = {
   createChallengeStatusesMap,
   challengeStatuses,
   PhaseStatusTypes,
+  CheckpointPhaseTypes,
   prizeTypesIds,
   supportedMetadata,
   scorecardQuestionMapping
diff --git a/src/services/ProcessorService.js b/src/services/ProcessorService.js
index 8a75f06..1051d22 100644
--- a/src/services/ProcessorService.js
+++ b/src/services/ProcessorService.js
@@ -658,6 +658,11 @@ async function processMessage (message) {
     if (_.get(message, 'payload.legacy.selfService')) {
       await disableTimelineNotifications(legacyId, createdByUserId) // disable
     }
+  } else {
+    const v5PhaseType = _.find(message.payload.phases, p => p.name === constants.CheckpointPhaseTypes.Submission)
+    if (v5PhaseType) {
+      await recreatePhases(legacyId, message.payload.phases, updatedByUserId)
+    }
   }
 
   logger.debug('Result from parsePayload:')