16
16
import org .elasticsearch .script .TemplateScript ;
17
17
import org .elasticsearch .test .ESTestCase ;
18
18
19
- import java .util .ArrayList ;
19
+ import java .util .Arrays ;
20
20
import java .util .HashMap ;
21
21
import java .util .List ;
22
22
import java .util .Map ;
23
23
24
+ import static org .elasticsearch .ingest .common .RemoveProcessor .shouldKeep ;
24
25
import static org .hamcrest .Matchers .containsString ;
25
26
import static org .hamcrest .Matchers .is ;
26
27
@@ -124,13 +125,9 @@ public void testKeepFields() throws Exception {
124
125
125
126
IngestDocument document = RandomDocumentPicks .randomIngestDocument (random (), source );
126
127
127
- List <TemplateScript .Factory > fieldsToKeep = List .of (
128
- new TestTemplateService .MockTemplateScript .Factory ("name" ),
129
- new TestTemplateService .MockTemplateScript .Factory ("address.street" )
130
- );
131
-
132
- Processor processor = new RemoveProcessor (randomAlphaOfLength (10 ), null , new ArrayList <>(), fieldsToKeep , false );
128
+ Processor processor = new RemoveProcessor (null , null , List .of (), templates ("name" , "address.street" ), false );
133
129
processor .execute (document );
130
+
134
131
assertTrue (document .hasField ("name" ));
135
132
assertTrue (document .hasField ("address" ));
136
133
assertTrue (document .hasField ("address.street" ));
@@ -142,7 +139,7 @@ public void testKeepFields() throws Exception {
142
139
assertTrue (document .hasField ("_version_type" ));
143
140
}
144
141
145
- public void testShouldKeep (String a , String b ) {
142
+ public void testShouldKeep () {
146
143
Map <String , Object > address = new HashMap <>();
147
144
address .put ("street" , "Ipiranga Street" );
148
145
address .put ("number" , 123 );
@@ -153,37 +150,18 @@ public void testShouldKeep(String a, String b) {
153
150
154
151
IngestDocument document = RandomDocumentPicks .randomIngestDocument (random (), source );
155
152
156
- assertTrue (RemoveProcessor .shouldKeep ("name" , List .of (new TestTemplateService .MockTemplateScript .Factory ("name" )), document ));
157
-
158
- assertTrue (RemoveProcessor .shouldKeep ("age" , List .of (new TestTemplateService .MockTemplateScript .Factory ("age" )), document ));
159
-
160
- assertFalse (RemoveProcessor .shouldKeep ("name" , List .of (new TestTemplateService .MockTemplateScript .Factory ("age" )), document ));
161
-
162
- assertTrue (
163
- RemoveProcessor .shouldKeep ("address" , List .of (new TestTemplateService .MockTemplateScript .Factory ("address.street" )), document )
164
- );
165
-
166
- assertTrue (
167
- RemoveProcessor .shouldKeep ("address" , List .of (new TestTemplateService .MockTemplateScript .Factory ("address.number" )), document )
168
- );
169
-
170
- assertTrue (
171
- RemoveProcessor .shouldKeep ("address.street" , List .of (new TestTemplateService .MockTemplateScript .Factory ("address" )), document )
172
- );
173
-
174
- assertTrue (
175
- RemoveProcessor .shouldKeep ("address.number" , List .of (new TestTemplateService .MockTemplateScript .Factory ("address" )), document )
176
- );
177
-
178
- assertTrue (RemoveProcessor .shouldKeep ("address" , List .of (new TestTemplateService .MockTemplateScript .Factory ("address" )), document ));
179
-
180
- assertFalse (
181
- RemoveProcessor .shouldKeep (
182
- "address.street" ,
183
- List .of (new TestTemplateService .MockTemplateScript .Factory ("address.number" )),
184
- document
185
- )
186
- );
153
+ assertTrue (shouldKeep ("name" , templates ("name" ), document ));
154
+ assertTrue (shouldKeep ("age" , templates ("age" ), document ));
155
+ assertFalse (shouldKeep ("name" , templates ("age" ), document ));
156
+ assertTrue (shouldKeep ("address" , templates ("address.street" ), document ));
157
+ assertTrue (shouldKeep ("address" , templates ("address.number" ), document ));
158
+ assertTrue (shouldKeep ("address.street" , templates ("address" ), document ));
159
+ assertTrue (shouldKeep ("address.number" , templates ("address" ), document ));
160
+ assertTrue (shouldKeep ("address" , templates ("address" ), document ));
161
+ assertFalse (shouldKeep ("address.street" , templates ("address.number" ), document ));
187
162
}
188
163
164
+ private static List <TemplateScript .Factory > templates (String ... fields ) {
165
+ return Arrays .stream (fields ).map (f -> (TemplateScript .Factory ) new TestTemplateService .MockTemplateScript .Factory (f )).toList ();
166
+ }
189
167
}
0 commit comments