Merge pull request #21 from imcaizheng/include-id-field-when-index

Include the `id` field inside the body of a document

Author: maxceem

src/services/JobCandidateProcessorService.js

@@ -80,7 +80,7 @@ async function processCreate (message, transactionId) {
     index: config.get('esConfig.ES_INDEX_JOB_CANDIDATE'),
     id: jobcandidate.id,
     transactionId,
-    body: _.omit(jobcandidate, 'id'),
+    body: jobcandidate,
     refresh: constants.esRefreshOption
   })
 }
@@ -117,7 +117,7 @@ async function processUpdate (message, transactionId) {
     id: data.id,
     transactionId,
     body: {
-      doc: _.omit(data, ['id'])
+      doc: data
     },
     refresh: constants.esRefreshOption
   })

src/services/JobProcessorService.js

@@ -51,7 +51,7 @@ async function processCreate (message, transactionId) {
     index: config.get('esConfig.ES_INDEX_JOB'),
     id: job.id,
     transactionId,
-    body: _.omit(job, 'id'),
+    body: job,
     refresh: constants.esRefreshOption
   })
   await postMessageToZapier({
@@ -99,7 +99,7 @@ async function processUpdate (message, transactionId) {
     id: data.id,
     transactionId,
     body: {
-      doc: _.omit(data, ['id'])
+      doc: data
     },
     refresh: constants.esRefreshOption
   })

src/services/ResourceBookingProcessorService.js

@@ -22,7 +22,7 @@ async function processCreate (message, transactionId) {
     index: config.get('esConfig.ES_INDEX_RESOURCE_BOOKING'),
     id: resourcebooking.id,
     transactionId,
-    body: _.omit(resourcebooking, 'id'),
+    body: resourcebooking,
     refresh: constants.esRefreshOption
   })
 }
@@ -63,7 +63,7 @@ async function processUpdate (message, transactionId) {
     id: data.id,
     transactionId,
     body: {
-      doc: _.omit(data, ['id'])
+      doc: data
     },
     refresh: constants.esRefreshOption
   })