5151import java .nio .channels .SeekableByteChannel ;
5252import java .nio .charset .Charset ;
5353import java .nio .file .*;
54- import java .util .ArrayList ;
55- import java .util .List ;
56- import java .util .Map ;
57- import java .util .UUID ;
54+ import java .util .*;
5855import java .util .concurrent .CountDownLatch ;
5956import java .util .concurrent .TimeUnit ;
6057import java .util .concurrent .atomic .AtomicBoolean ;
@@ -378,6 +375,14 @@ final public SeekableByteChannel buildChannel(final String key) throws IOExcepti
378375 }
379376 }
380377
378+ private Map < String , Set < UUID >> objectsToMap (final Iterable <Contents > objs ) {
379+ Map <String , Set <UUID >> objMap = new HashMap <>();
380+ for (Contents next : objs ) {
381+ objMap .put (next .getKey (), null );
382+ }
383+ return objMap ;
384+ }
385+
381386 @ Test
382387 public void multiObjectDeleteNotQuiet () throws IOException , URISyntaxException {
383388 final String bucketName = "multi_object_delete" ;
@@ -388,7 +393,7 @@ public void multiObjectDeleteNotQuiet() throws IOException, URISyntaxException {
388393
389394 final Iterable <Contents > objs = HELPERS .listObjects (bucketName );
390395 final DeleteObjectsResponse response = client
391- .deleteObjects (new DeleteObjectsRequest (bucketName , objs ).withQuiet (false ));
396+ .deleteObjects (new DeleteObjectsRequest (bucketName , objectsToMap ( objs ) ).withQuiet (false ));
392397 assertThat (response , is (notNullValue ()));
393398 assertThat (response .getDeleteResult (), is (notNullValue ()));
394399 assertThat (response .getDeleteResult ().getDeletedObjects ().size (), is (4 ));
@@ -410,7 +415,7 @@ public void multiObjectDeleteQuiet() throws IOException, URISyntaxException {
410415
411416 final Iterable <Contents > objs = HELPERS .listObjects (bucketName );
412417 final DeleteObjectsResponse response = client
413- .deleteObjects (new DeleteObjectsRequest (bucketName , objs ).withQuiet (true ));
418+ .deleteObjects (new DeleteObjectsRequest (bucketName , objectsToMap ( objs ) ).withQuiet (true ));
414419 assertThat (response , is (notNullValue ()));
415420 assertThat (response .getDeleteResult (), is (notNullValue ()));
416421 assertThat (response .getDeleteResult ().getDeletedObjects ().size (), is (0 ));
@@ -429,7 +434,11 @@ public void multiObjectDeleteOfUnknownObjects() throws IOException {
429434 try {
430435 HELPERS .ensureBucketExists (bucketName , envDataPolicyId );
431436
432- final List <String > objList = Lists .newArrayList ("badObj1.txt" , "badObj2.txt" , "badObj3.txt" );
437+ final Map <String , Set <UUID >> objList = new HashMap <>();
438+ objList .put ("badObj1.txt" , null );
439+ objList .put ("badObj2.txt" , null );
440+ objList .put ("badObj3.txt" , null );
441+
433442 final DeleteObjectsResponse response = client
434443 .deleteObjects (new DeleteObjectsRequest (bucketName , objList ));
435444 assertThat (response , is (notNullValue ()));
0 commit comments