@@ -726,6 +726,15 @@ async function processUpdate (message) {
726
726
// logger.warn('Failed to update the challenge via the V4 API')
727
727
// logger.error(e)
728
728
// }
729
+ if ( ! _ . get ( message . payload , 'task.isTask' ) ) {
730
+ await syncChallengePhases ( legacyId , message . payload . phases )
731
+ } else {
732
+ logger . info ( 'Will skip syncing phases as the challenge is a task...' )
733
+ }
734
+ await updateMemberPayments ( legacyId , message . payload . prizeSets , updatedByUserId )
735
+ await associateChallengeGroups ( saveDraftContestDTO . groupsToBeAdded , saveDraftContestDTO . groupsToBeDeleted , legacyId )
736
+ await associateChallengeTerms ( message . payload . terms , legacyId , createdByUserId , updatedByUserId )
737
+ await setCopilotPayment ( message . payload . id , legacyId , _ . get ( message , 'payload.prizeSets' ) , createdByUserId , updatedByUserId , m2mToken )
729
738
730
739
if ( message . payload . status && challenge ) {
731
740
// logger.info(`The status has changed from ${challenge.currentStatus} to ${message.payload.status}`)
@@ -750,15 +759,6 @@ async function processUpdate (message) {
750
759
}
751
760
}
752
761
}
753
- if ( ! _ . get ( message . payload , 'task.isTask' ) ) {
754
- await syncChallengePhases ( legacyId , message . payload . phases )
755
- } else {
756
- logger . info ( 'Will skip syncing phases as the challenge is a task...' )
757
- }
758
- await updateMemberPayments ( legacyId , message . payload . prizeSets , updatedByUserId )
759
- await associateChallengeGroups ( saveDraftContestDTO . groupsToBeAdded , saveDraftContestDTO . groupsToBeDeleted , legacyId )
760
- await associateChallengeTerms ( message . payload . terms , legacyId , createdByUserId , updatedByUserId )
761
- await setCopilotPayment ( message . payload . id , legacyId , _ . get ( message , 'payload.prizeSets' ) , createdByUserId , updatedByUserId , m2mToken )
762
762
763
763
try {
764
764
await helper . forceV4ESFeeder ( legacyId )
0 commit comments