testing done

Author: Sachin Maheshwari

src/common/helper.js

@@ -167,7 +167,6 @@ async function postEvent (topic, payload) {
  * @params {String} action for which operation error occurred
  */
  async function publishError (topic, payload, action) {
-  logger.debug(`Publish error to Kafka topic ${topic}, ${JSON.stringify(payload, null, 2)}`)
   _.set(payload, 'apiAction', action)
   const message = {
     topic,
@@ -176,7 +175,7 @@ async function postEvent (topic, payload) {
     'mime-type': 'application/json',
     payload
   }
-  logger.debug(`Final message, ${JSON.stringify(message, null, 2)}`)
+  logger.debug(`Publish error to Kafka topic ${topic}, ${JSON.stringify(message, null, 2)}`)
   await busApiClient.postEvent(message)
 }
 

src/common/service-helper.js

@@ -65,8 +65,7 @@ async function createRecordInEs (resource, entity, toEs) {
 async function patchRecordInEs (resource, entity, toEs) {
   try {
     if (toEs) {
-      //await esHelper.processUpdate(resource, entity)
-      throw "throwing error"
+      await esHelper.processUpdate(resource, entity)
     }
   } catch (err) {
     logger.logFullError(err)