Pass transactionId during create and delete operations too

Author: callmekatootie

Diff for: src/common/helper.js

@@ -8,7 +8,6 @@ const elasticsearch = require('elasticsearch')
 const _ = require('lodash')
 const Joi = require('@hapi/joi')
 const { Mutex } = require('async-mutex')
-const logger = require('./logger')
 
 AWS.config.region = config.ES.AWS_REGION
 

Diff for: src/services/ProcessorService.js

@@ -28,6 +28,7 @@ async function processCreate (message, transactionId) {
       index: topResources[resource].index,
       type: topResources[resource].type,
       id: message.payload.id,
+      transactionId,
       body: _.omit(message.payload, ['resource', 'originalTopic']),
       refresh: 'wait_for'
     })
@@ -186,6 +187,7 @@ async function processDelete (message, transactionId) {
       index: topResources[resource].index,
       type: topResources[resource].type,
       id: message.payload.id,
+      transactionId,
       refresh: 'wait_for'
     })
   } else if (_.includes(_.keys(userResources), resource)) {