Skip to content

Commit 96bcad1

Browse files
committed
Include the id field inside the body of a document
1 parent 6ffb3e0 commit 96bcad1

File tree

3 files changed

+6
-6
lines changed

3 files changed

+6
-6
lines changed

src/services/JobCandidateProcessorService.js

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -80,7 +80,7 @@ async function processCreate (message, transactionId) {
8080
index: config.get('esConfig.ES_INDEX_JOB_CANDIDATE'),
8181
id: jobcandidate.id,
8282
transactionId,
83-
body: _.omit(jobcandidate, 'id'),
83+
body: jobcandidate,
8484
refresh: constants.esRefreshOption
8585
})
8686
}
@@ -117,7 +117,7 @@ async function processUpdate (message, transactionId) {
117117
id: data.id,
118118
transactionId,
119119
body: {
120-
doc: _.omit(data, ['id'])
120+
doc: data
121121
},
122122
refresh: constants.esRefreshOption
123123
})

src/services/JobProcessorService.js

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -51,7 +51,7 @@ async function processCreate (message, transactionId) {
5151
index: config.get('esConfig.ES_INDEX_JOB'),
5252
id: job.id,
5353
transactionId,
54-
body: _.omit(job, 'id'),
54+
body: job,
5555
refresh: constants.esRefreshOption
5656
})
5757
await postMessageToZapier({
@@ -99,7 +99,7 @@ async function processUpdate (message, transactionId) {
9999
id: data.id,
100100
transactionId,
101101
body: {
102-
doc: _.omit(data, ['id'])
102+
doc: data
103103
},
104104
refresh: constants.esRefreshOption
105105
})

src/services/ResourceBookingProcessorService.js

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@ async function processCreate (message, transactionId) {
2222
index: config.get('esConfig.ES_INDEX_RESOURCE_BOOKING'),
2323
id: resourcebooking.id,
2424
transactionId,
25-
body: _.omit(resourcebooking, 'id'),
25+
body: resourcebooking,
2626
refresh: constants.esRefreshOption
2727
})
2828
}
@@ -63,7 +63,7 @@ async function processUpdate (message, transactionId) {
6363
id: data.id,
6464
transactionId,
6565
body: {
66-
doc: _.omit(data, ['id'])
66+
doc: data
6767
},
6868
refresh: constants.esRefreshOption
6969
})

0 commit comments

Comments
 (0)