3
3
*/
4
4
5
5
const config = require ( 'config' )
6
- const _ = require ( 'lodash' )
7
6
const stringcase = require ( 'stringcase' )
8
7
const app = require ( '../../src/app' )
9
8
const request = require ( 'superagent' )
@@ -89,14 +88,14 @@ describe('Taas ES Processor E2E Test', () => {
89
88
index,
90
89
id : testData . messages [ model ] . create . message . payload . id
91
90
} )
92
- should . deepEqual ( doc . body . _source , _ . omit ( testData . messages [ model ] . create . message . payload , [ 'id' ] ) )
91
+ should . deepEqual ( doc . body . _source , testData . messages [ model ] . create . message . payload , [ 'id' ] )
93
92
} )
94
93
95
94
it ( `Should handle ${ modelInSpaceCase } updating message` , async ( ) => {
96
95
await testHelper . esClient . create ( {
97
96
index,
98
97
id : testData . messages [ model ] . create . message . payload . id ,
99
- body : _ . omit ( testData . messages [ model ] . create . message . payload , [ 'id' ] ) ,
98
+ body : testData . messages [ model ] . create . message . payload ,
100
99
refresh : 'true'
101
100
} )
102
101
await testHelper . sendMessage ( testData . messages [ model ] . update . message )
@@ -105,14 +104,14 @@ describe('Taas ES Processor E2E Test', () => {
105
104
index,
106
105
id : testData . messages [ model ] . update . message . payload . id
107
106
} )
108
- should . deepEqual ( _ . omit ( doc . body . _source , [ 'createdAt' , 'createdBy' ] ) , _ . omit ( testData . messages [ model ] . update . message . payload , [ 'id' ] ) )
107
+ should . deepEqual ( doc . body . _source , testData . messages [ model ] . update . message . payload )
109
108
} )
110
109
111
110
it ( `Should handle ${ modelInSpaceCase } deletion message` , async ( ) => {
112
111
await testHelper . esClient . create ( {
113
112
index,
114
113
id : testData . messages [ model ] . create . message . payload . id ,
115
- body : _ . omit ( testData . messages [ model ] . create . message . payload , [ 'id' ] ) ,
114
+ body : testData . messages [ model ] . create . message . payload ,
116
115
refresh : 'true'
117
116
} )
118
117
await testHelper . sendMessage ( testData . messages [ model ] . delete . message )
@@ -133,7 +132,7 @@ describe('Taas ES Processor E2E Test', () => {
133
132
await testHelper . esClient . create ( {
134
133
index,
135
134
id : testData . messages [ model ] . create . message . payload . id ,
136
- body : _ . omit ( testData . messages [ model ] . create . message . payload , [ 'id' ] ) ,
135
+ body : testData . messages [ model ] . create . message . payload ,
137
136
refresh : 'true'
138
137
} )
139
138
await testHelper . sendMessage ( testData . messages [ model ] . create . message )
0 commit comments