@@ -699,6 +699,28 @@ async function processMessage (message) {
699
699
throw new Error ( `Error getting challenge by id - Error: ${ JSON . stringify ( e ) } ` )
700
700
}
701
701
702
+ // If iterative review is open
703
+ if ( _ . find ( _ . get ( message . payload , 'phases' ) , p => p . isOpen && p . name === 'Iterative Review' ) ) {
704
+ // Try to read reviews and insert them into informix DB
705
+ if ( message . payload . metadata && message . payload . legacy . reviewScorecardId ) {
706
+ let orReviewFeedback = _ . find ( message . payload . metadata , meta => meta . name === 'or_review_feedback' )
707
+ let orReviewScore = _ . find ( message . payload . metadata , meta => meta . name === 'or_review_score' )
708
+ if ( ! _ . isUndefined ( orReviewFeedback ) && ! _ . isUndefined ( orReviewScore ) ) {
709
+ orReviewFeedback = JSON . parse ( orReviewFeedback )
710
+ const reviewResponses = [ ]
711
+ _ . each ( orReviewFeedback , ( value , key ) => {
712
+ const questionId = _ . get ( _ . find ( constants . scorecardQuestionMapping [ message . payload . legacy . reviewScorecardId ] , item => _ . toString ( item . questionId ) === _ . toString ( key ) || _ . toLower ( item . description ) === _ . toLower ( key ) ) , 'questionId' )
713
+ reviewResponses . push ( {
714
+ questionId,
715
+ answer : value
716
+ } )
717
+ } )
718
+ orReviewScore = _ . toNumber ( orReviewFeedback )
719
+ await legacyChallengeReviewService . insertReview ( legacyId , message . payload . legacy . reviewScorecardId , orReviewScore , reviewResponses , createdByUserId )
720
+ }
721
+ }
722
+ }
723
+
702
724
if ( message . payload . status && challenge ) {
703
725
// Whether we need to sync v4 ES again
704
726
let needSyncV4ES = false
@@ -714,24 +736,6 @@ async function processMessage (message) {
714
736
needSyncV4ES = true
715
737
}
716
738
if ( message . payload . status === constants . challengeStatuses . Completed && challenge . currentStatus !== constants . challengeStatuses . Completed ) {
717
- // Try to read reviews and insert them into informix DB
718
- if ( message . payload . metadata && message . payload . legacy . reviewScorecardId ) {
719
- let orReviewFeedback = _ . find ( message . payload . metadata , meta => meta . name === 'or_review_feedback' )
720
- let orReviewScore = _ . find ( message . payload . metadata , meta => meta . name === 'or_review_score' )
721
- if ( ! _ . isUndefined ( orReviewFeedback ) && ! _ . isUndefined ( orReviewScore ) ) {
722
- orReviewFeedback = JSON . parse ( orReviewFeedback )
723
- const reviewResponses = [ ]
724
- _ . each ( orReviewFeedback , ( value , key ) => {
725
- const questionId = _ . get ( _ . find ( constants . scorecardQuestionMapping [ message . payload . legacy . reviewScorecardId ] , item => _ . toString ( item . questionId ) === _ . toString ( key ) || _ . toLower ( item . description ) === _ . toLower ( key ) ) , 'questionId' )
726
- reviewResponses . push ( {
727
- questionId,
728
- answer : value
729
- } )
730
- } )
731
- orReviewScore = _ . toNumber ( orReviewFeedback )
732
- await legacyChallengeReviewService . insertReview ( legacyId , message . payload . legacy . reviewScorecardId , orReviewScore , reviewResponses , createdByUserId )
733
- }
734
- }
735
739
if ( message . payload . task . isTask ) {
736
740
logger . info ( 'Challenge is a TASK' )
737
741
if ( ! message . payload . winners || message . payload . winners . length === 0 ) {
0 commit comments