From e36a53e85f0c40e9b58e651bf1d8ce45b2216309 Mon Sep 17 00:00:00 2001
From: nkumar-topcoder <33625707+nkumar-topcoder@users.noreply.github.com>
Date: Wed, 9 Jun 2021 16:30:32 +0530
Subject: [PATCH 1/2] Update helper.js

---
 src/common/helper.js | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/src/common/helper.js b/src/common/helper.js
index 506a60f7..60f398c2 100644
--- 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 })
 }

From 7c8021465956f52274af03c842b8074f098a834b Mon Sep 17 00:00:00 2001
From: nkumar-topcoder <33625707+nkumar-topcoder@users.noreply.github.com>
Date: Wed, 9 Jun 2021 16:35:41 +0530
Subject: [PATCH 2/2] Update WorkPeriodService.js

---
 src/services/WorkPeriodService.js | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/services/WorkPeriodService.js b/src/services/WorkPeriodService.js
index cd149a36..e16ce290 100644
--- a/src/services/WorkPeriodService.js
+++ b/src/services/WorkPeriodService.js
@@ -290,7 +290,7 @@ async function updateWorkPeriod (currentUser, id, data) {
   }
 
   //await helper.postEvent(config.TAAS_WORK_PERIOD_UPDATE_TOPIC, updated.toJSON(), { oldValue: oldValue })
-  await helper.postEvent(config.TAAS_WORK_PERIOD_UPDATE_TOPIC, updated.toJSON(), {"key":data.resourceBookingId})
+  await helper.postEvent(config.TAAS_WORK_PERIOD_UPDATE_TOPIC, updated.toJSON(), {oldValue: oldValue, "key":data.resourceBookingId})
   return updated.dataValues
 }