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,13 +125,9 @@ 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 );
130+
134131 assertTrue (document .hasField ("name" ));
135132 assertTrue (document .hasField ("address" ));
136133 assertTrue (document .hasField ("address.street" ));
@@ -142,7 +139,7 @@ public void testKeepFields() throws Exception {
142139 assertTrue (document .hasField ("_version_type" ));
143140 }
144141
145- public void testShouldKeep (String a , String b ) {
142+ public void testShouldKeep () {
146143 Map <String , Object > address = new HashMap <>();
147144 address .put ("street" , "Ipiranga Street" );
148145 address .put ("number" , 123 );
@@ -153,37 +150,18 @@ public void testShouldKeep(String a, String b) {
153150
154151 IngestDocument document = RandomDocumentPicks .randomIngestDocument (random (), source );
155152
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 ));
187162 }
188163
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+ }
189167}
0 commit comments