re post resources on kafka after activation

Author: ThomasKranitsas

src/services/ProcessorService.js

@@ -467,6 +467,18 @@ async function closeChallenge (challengeId, winnerId) {
   return helper.postRequest(`${config.V4_CHALLENGE_API_URL}/${challengeId}/close?winnerId=${winnerId}`, null, m2mToken)
 }
 
+/**
+ * Repost challenge resources on kafka
+ * @param {String} challengeUuid the V5 challenge UUID
+ * @param {String} m2mToken the m2m token
+ */
+async function rePostResourcesOnKafka (challengeUuid, m2mToken) {
+  const challengeResourcesResponse = await helper.getRequest(`${config.V5_RESOURCES_API_URL}?challengeId=${challengeUuid}&perPage=100`, m2mToken)
+  for (const resource of (challengeResourcesResponse.body || [])) {
+    await helper.postBusEvent(config.RESOURCE_CREATE_TOPIC, _.pick(resource, ['id', 'challengeId', 'memberId', 'memberHandle', 'roleId', 'created', 'createdBy', 'updated', 'updatedBy', 'legacyId']))
+  }
+}
+
 /**
  * Process create challenge message
  * @param {Object} message the kafka message
@@ -515,10 +527,7 @@ async function processCreate (message) {
       legacyId: newChallenge.body.result.content.id
     }, m2mToken)
     // Repost all challenge resource on Kafka so they will get created on legacy by the legacy-challenge-resource-processor
-    const challengeResourcesResponse = await helper.getRequest(`${config.V5_RESOURCES_API_URL}?challengeId=${challengeUuid}&perPage=100`, m2mToken)
-    for (const resource of (challengeResourcesResponse.body || [])) {
-      await helper.postBusEvent(config.RESOURCE_CREATE_TOPIC, _.pick(resource, ['id', 'challengeId', 'memberId', 'memberHandle', 'roleId', 'created', 'createdBy', 'updated', 'updatedBy', 'legacyId']))
-    }
+    await rePostResourcesOnKafka(challengeUuid, m2mToken)
     await timelineService.enableTimelineNotifications(newChallenge.body.result.content.id, _.get(message, 'payload.createdBy'))
     logger.debug('End of processCreate')
     return newChallenge.body.result.content.id
@@ -672,6 +681,8 @@ async function processUpdate (message) {
         logger.info('Activating challenge...')
         await activateChallenge(legacyId)
         logger.info('Activated!')
+        // Repost all challenge resource on Kafka so they will get created on legacy by the legacy-challenge-resource-processor
+        await rePostResourcesOnKafka(message.payload.id, m2mToken)
       }
       if (message.payload.status === constants.challengeStatuses.Completed && challenge.currentStatus !== constants.challengeStatuses.Completed) {
         if (message.payload.task.isTask) {