fix email notification Kafka message payload format

maxceem · maxceem · commit 94632a477774 · 2021-08-04T17:00:37.000+03:00
diff --git a/local/kafka-client/topics.txt b/local/kafka-client/topics.txt
@@ -21,3 +21,4 @@ taas.interview.update
 taas.interview.bulkUpdate
 external.action.email
 taas.action.retry
+notifications.action.create
diff --git a/src/services/EmailNotificationService.js b/src/services/EmailNotificationService.js
@@ -499,7 +499,9 @@ async function sendEmail (currentUser, data) {
       version: 'v3'
     }
   }
-  await helper.postEvent(config.NOTIFICATIONS_CREATE_TOPIC, emailData)
+  await helper.postEvent(config.NOTIFICATIONS_CREATE_TOPIC, {
+    notifications: [emailData]
+  })
 }
 
 module.exports = {

Original file line number	Diff line number	Diff line change
`@@ -499,7 +499,9 @@ async function sendEmail (currentUser, data) {`
`499`	`499`	`version: 'v3'`
`500`	`500`	`}`
`501`	`501`	`}`
`502`		`- await helper.postEvent(config.NOTIFICATIONS_CREATE_TOPIC, emailData)`
	`502`	`+ await helper.postEvent(config.NOTIFICATIONS_CREATE_TOPIC, {`
	`503`	`+ notifications: [emailData]`
	`504`	`+ })`
`503`	`505`	`}`
`504`	`506`
`505`	`507`	`module.exports = {`