Update helper.js

nkumar-topcoder · web-flow · commit e36a53e85f0c · 2021-06-09T16:30:32.000+05:30
diff --git a/src/common/helper.js b/src/common/helper.js
@@ -952,7 +952,9 @@ async function postEvent (topic, payload, options = {}) {
     'mime-type': 'application/json',
     payload
   }
-  _.merge(message,options)
+  if (options.key) {
+   message.key = options.key
+   }
   await client.postEvent(message)
   await eventDispatcher.handleEvent(topic, { value: payload, options })
 }

Original file line number	Diff line number	Diff line change
`@@ -952,7 +952,9 @@ async function postEvent (topic, payload, options = {}) {`
`952`	`952`	`'mime-type': 'application/json',`
`953`	`953`	`payload`
`954`	`954`	`}`
`955`		`- _.merge(message,options)`
	`955`	`+ if (options.key) {`
	`956`	`+ message.key = options.key`
	`957`	`+ }`
`956`	`958`	`await client.postEvent(message)`
`957`	`959`	`await eventDispatcher.handleEvent(topic, { value: payload, options })`
`958`	`960`	`}`