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

---
 src/common/helper.js | 1 +
 1 file changed, 1 insertion(+)

diff --git a/src/common/helper.js b/src/common/helper.js
index e35c661e..506a60f7 100644
--- a/src/common/helper.js
+++ b/src/common/helper.js
@@ -952,6 +952,7 @@ async function postEvent (topic, payload, options = {}) {
     'mime-type': 'application/json',
     payload
   }
+  _.merge(message,options)
   await client.postEvent(message)
   await eventDispatcher.handleEvent(topic, { value: payload, options })
 }

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

---
 src/services/WorkPeriodService.js | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/src/services/WorkPeriodService.js b/src/services/WorkPeriodService.js
index fc750bd7..cd149a36 100644
--- a/src/services/WorkPeriodService.js
+++ b/src/services/WorkPeriodService.js
@@ -235,7 +235,7 @@ async function createWorkPeriod (currentUser, workPeriod) {
     }
   }
 
-  await helper.postEvent(config.TAAS_WORK_PERIOD_CREATE_TOPIC, created.toJSON())
+  await helper.postEvent(config.TAAS_WORK_PERIOD_CREATE_TOPIC, created.toJSON(),{"key":workPeriod.resourceBookingId})
   return created.dataValues
 }
 
@@ -289,7 +289,8 @@ 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(), { oldValue: oldValue })
+  await helper.postEvent(config.TAAS_WORK_PERIOD_UPDATE_TOPIC, updated.toJSON(), {"key":data.resourceBookingId})
   return updated.dataValues
 }