From 14680d839e2b30f6a37426b7855f41cf65378359 Mon Sep 17 00:00:00 2001
From: Samir Gondzetovic <gondzo@gmail.com>
Date: Tue, 26 Jun 2018 15:53:43 +0100
Subject: [PATCH] upgrade message bus format

---
 src/services/busApi.js | 16 +++++++++-------
 1 file changed, 9 insertions(+), 7 deletions(-)

diff --git a/src/services/busApi.js b/src/services/busApi.js
index 3962dd0f..5d3aa07d 100644
--- a/src/services/busApi.js
+++ b/src/services/busApi.js
@@ -37,19 +37,21 @@ async function getClient() {
 /**
  * Creates a new event in Bus API
  * Any errors will be simply ignored
- * @param {String} type the event type, should be a dot separated fully qualitied name
- * @param {Object} message the message, should be a JSON object
+ * @param {String} topic the event topic, should be a dot separated fully qualitied name
+ * @param {Object} payload the payload, should be a JSON object
  * @param {Object} logger object
  * @return {Promise} new event promise
  */
-function createEvent(type, message, logger) {
-  const body = JSON.stringify(message);
-  logger.debug(`Sending message: ${JSON.stringify(message)}`);
+function createEvent(topic, payload, logger) {
+  logger.debug(`Sending message: ${JSON.stringify(payload)}`);
   return getClient().then((busClient) => {
     logger.debug('calling bus-api');
     return busClient.post('/bus/events', {
-      type,
-      message: body,
+      topic,
+      originator: 'tc-project-service',
+      timestamp: (new Date()).toISOString(),
+      'mime-type': 'application/json',
+      payload,
     }).then((resp) => {
       logger.debug('Sent event to bus-api');
       logger.debug(`Sent event to bus-api [data]: ${resp.data}`);