@@ -726,6 +726,15 @@ async function processUpdate (message) {
726726 // logger.warn('Failed to update the challenge via the V4 API')
727727 // logger.error(e)
728728 // }
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 )
729738
730739 if ( message . payload . status && challenge ) {
731740 // logger.info(`The status has changed from ${challenge.currentStatus} to ${message.payload.status}`)
@@ -750,15 +759,6 @@ async function processUpdate (message) {
750759 }
751760 }
752761 }
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 )
762762
763763 try {
764764 await helper . forceV4ESFeeder ( legacyId )
0 commit comments