Trying to force the v4 es feeder on create/update

Author: rootelement

config/default.js

@@ -56,6 +56,7 @@ module.exports = {
   V4_PLATFORMS_API_URL: process.env.V4_PLATFORMS_API_URL || 'http://localhost:4000/v4/platforms',
   V5_PROJECTS_API_URL: process.env.V5_PROJECTS_API_URL || 'https://api.topcoder-dev.com/v5/projects',
   V5_CHALLENGE_MIGRATION_API_URL: process.env.V5_CHALLENGE_MIGRATION_API_URL || 'https://api.topcoder-dev.com/v5/challenge-migration',
+  V4_ES_FEEDER_API_URL: process.env.V4_ES_FEEDER_API_URL || 'https://api.topcoder-dev.com/v4/esfeeder/challenges',
 
   V5_GROUPS_API_URL: process.env.V5_GROUPS_API_URL || 'https://api.topcoder-dev.com/v5/groups',
 

src/common/helper.js

@@ -150,6 +150,16 @@ async function postBusEvent (topic, payload) {
   })
 }
 
+async function forceV4ESFeeder (legacyId) {
+  const token = await getM2MToken()
+  const body = {
+    param: {
+      challengeIds: [legacyId]
+    }
+  }
+  await request.put(`${config.V4_ES_FEEDER_API_URL}`).send(body).set({ Authorization: `Bearer ${token}` })
+}
+
 module.exports = {
   getInformixConnection,
   getKafkaOptions,
@@ -158,5 +168,6 @@ module.exports = {
   getRequest,
   putRequest,
   postRequest,
-  postBusEvent
+  postBusEvent,
+  forceV4ESFeeder
 }

src/services/ProcessorService.js

@@ -291,6 +291,7 @@ async function processCreate (message) {
   logger.debug('processCreate :: beforeTry')
   try {
     const newChallenge = await helper.postRequest(`${config.V4_CHALLENGE_API_URL}`, { param: _.omit(saveDraftContestDTO, ['groupsToBeAdded', 'groupsToBeDeleted']) }, m2mToken)
+    await helper.forceV4ESFeeder(newChallenge.body.result.content.id)
     await associateChallengeGroups(saveDraftContestDTO.groupsToBeAdded, saveDraftContestDTO.groupsToBeDeleted, newChallenge.body.result.content.id)
     await helper.patchRequest(`${config.V5_CHALLENGE_API_URL}/${challengeUuid}`, {
       legacy: {
@@ -435,16 +436,7 @@ async function processUpdate (message) {
         }
       }
     }
-    // we can't switch the challenge type
-    // TODO: track is missing from the response.
-    // if (message.payload.legacy.track) {
-    //   const newTrack = message.payload.legacy.track
-    //   // track information is stored in subTrack of V4 API
-    //   if (challenge.track !== newTrack) {
-    //     // refer ContestDirectManager.prepare in ap-challenge-microservice
-    //     throw new Error('You can\'t change challenge track')
-    //   }
-    // }
+    await helper.forceV4ESFeeder(message.payload.legacyId)
   } catch (e) {
     logger.error('processUpdate Catch', e)
     throw e