Merge pull request #474 from topcoder-platform/issue_dup

Resolving duplicate payment issue

Author: LieutenantRoger

src/common/helper.js

@@ -764,16 +764,21 @@ function getBusApiClient () {
  * Post bus event.
  * @param {String} topic the event topic
  * @param {Object} payload the event payload
+ * @param {Object} options the extra options to the message
  */
-async function postBusEvent (topic, payload) {
+async function postBusEvent (topic, payload, options = {}) {
   const client = getBusApiClient()
-  await client.postEvent({
+  const message = {
     topic,
     originator: constants.EVENT_ORIGINATOR,
     timestamp: new Date().toISOString(),
     'mime-type': constants.EVENT_MIME_TYPE,
     payload
-  })
+  }
+  if (options.key) {
+    message.key = options.key
+  }
+  await client.postEvent(message)
 }
 
 /**

src/services/ChallengeService.js

@@ -1951,7 +1951,11 @@ async function update (currentUser, challengeId, data, isFull) {
 
   // post bus event
   logger.debug(`Post Bus Event: ${constants.Topics.ChallengeUpdated} ${JSON.stringify(challenge)}`)
-  await helper.postBusEvent(constants.Topics.ChallengeUpdated, challenge)
+  const options = {}
+  if (challenge.status == 'Completed') {
+    options.key = `${challenge.id}:${challenge.status}`
+  }
+  await helper.postBusEvent(constants.Topics.ChallengeUpdated, challenge, options)
   if (phasesHaveBeenModified === true && _.get(challenge, 'legacy.useSchedulingAPI')) {
     await helper.postBusEvent(config.SCHEDULING_TOPIC, { id: challengeId })
   }