1616import org .elasticsearch .script .TemplateScript ;
1717import org .elasticsearch .test .ESTestCase ;
1818
19- import java .util .ArrayList ;
19+ import java .util .Arrays ;
2020import java .util .HashMap ;
2121import java .util .List ;
2222import java .util .Map ;
2323
24+ import static org .elasticsearch .ingest .common .RemoveProcessor .shouldKeep ;
2425import static org .hamcrest .Matchers .containsString ;
2526import static org .hamcrest .Matchers .is ;
2627
@@ -124,12 +125,7 @@ public void testKeepFields() throws Exception {
124125
125126 IngestDocument document = RandomDocumentPicks .randomIngestDocument (random (), source );
126127
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 );
133129 processor .execute (document );
134130 assertTrue (document .hasField ("name" ));
135131 assertTrue (document .hasField ("address" ));
@@ -153,37 +149,26 @@ public void testShouldKeep(String a, String b) {
153149
154150 IngestDocument document = RandomDocumentPicks .randomIngestDocument (random (), source );
155151
156- assertTrue (RemoveProcessor . shouldKeep ("name" , List . of ( new TestTemplateService . MockTemplateScript . Factory ( "name" ) ), document ));
152+ assertTrue (shouldKeep ("name" , templates ( "name" ), document ));
157153
158- assertTrue (RemoveProcessor . shouldKeep ("age" , List . of ( new TestTemplateService . MockTemplateScript . Factory ( "age" ) ), document ));
154+ assertTrue (shouldKeep ("age" , templates ( "age" ), document ));
159155
160- assertFalse (RemoveProcessor . shouldKeep ("name" , List . of ( new TestTemplateService . MockTemplateScript . Factory ( "age" ) ), document ));
156+ assertFalse (shouldKeep ("name" , templates ( "age" ), document ));
161157
162- assertTrue (
163- RemoveProcessor .shouldKeep ("address" , List .of (new TestTemplateService .MockTemplateScript .Factory ("address.street" )), document )
164- );
158+ assertTrue (shouldKeep ("address" , templates ("address.street" ), document ));
165159
166- assertTrue (
167- RemoveProcessor .shouldKeep ("address" , List .of (new TestTemplateService .MockTemplateScript .Factory ("address.number" )), document )
168- );
160+ assertTrue (shouldKeep ("address" , templates ("address.number" ), document ));
169161
170- assertTrue (
171- RemoveProcessor .shouldKeep ("address.street" , List .of (new TestTemplateService .MockTemplateScript .Factory ("address" )), document )
172- );
162+ assertTrue (shouldKeep ("address.street" , templates ("address" ), document ));
173163
174- assertTrue (
175- RemoveProcessor .shouldKeep ("address.number" , List .of (new TestTemplateService .MockTemplateScript .Factory ("address" )), document )
176- );
164+ assertTrue (shouldKeep ("address.number" , templates ("address" ), document ));
177165
178- assertTrue (RemoveProcessor . shouldKeep ("address" , List . of ( new TestTemplateService . MockTemplateScript . Factory ( "address" ) ), document ));
166+ assertTrue (shouldKeep ("address" , templates ( "address" ), document ));
179167
180- assertFalse (
181- RemoveProcessor .shouldKeep (
182- "address.street" ,
183- List .of (new TestTemplateService .MockTemplateScript .Factory ("address.number" )),
184- document
185- )
186- );
168+ assertFalse (shouldKeep ("address.street" , templates ("address.number" ), document ));
187169 }
188170
171+ private static List <TemplateScript .Factory > templates (String ... fields ) {
172+ return Arrays .stream (fields ).map (f -> (TemplateScript .Factory ) new TestTemplateService .MockTemplateScript .Factory (f )).toList ();
173+ }
189174}
0 commit comments