51
51
import java .nio .channels .SeekableByteChannel ;
52
52
import java .nio .charset .Charset ;
53
53
import 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 .*;
58
55
import java .util .concurrent .CountDownLatch ;
59
56
import java .util .concurrent .TimeUnit ;
60
57
import java .util .concurrent .atomic .AtomicBoolean ;
@@ -378,6 +375,14 @@ final public SeekableByteChannel buildChannel(final String key) throws IOExcepti
378
375
}
379
376
}
380
377
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
+
381
386
@ Test
382
387
public void multiObjectDeleteNotQuiet () throws IOException , URISyntaxException {
383
388
final String bucketName = "multi_object_delete" ;
@@ -388,7 +393,7 @@ public void multiObjectDeleteNotQuiet() throws IOException, URISyntaxException {
388
393
389
394
final Iterable <Contents > objs = HELPERS .listObjects (bucketName );
390
395
final DeleteObjectsResponse response = client
391
- .deleteObjects (new DeleteObjectsRequest (bucketName , objs ).withQuiet (false ));
396
+ .deleteObjects (new DeleteObjectsRequest (bucketName , objectsToMap ( objs ) ).withQuiet (false ));
392
397
assertThat (response , is (notNullValue ()));
393
398
assertThat (response .getDeleteResult (), is (notNullValue ()));
394
399
assertThat (response .getDeleteResult ().getDeletedObjects ().size (), is (4 ));
@@ -410,7 +415,7 @@ public void multiObjectDeleteQuiet() throws IOException, URISyntaxException {
410
415
411
416
final Iterable <Contents > objs = HELPERS .listObjects (bucketName );
412
417
final DeleteObjectsResponse response = client
413
- .deleteObjects (new DeleteObjectsRequest (bucketName , objs ).withQuiet (true ));
418
+ .deleteObjects (new DeleteObjectsRequest (bucketName , objectsToMap ( objs ) ).withQuiet (true ));
414
419
assertThat (response , is (notNullValue ()));
415
420
assertThat (response .getDeleteResult (), is (notNullValue ()));
416
421
assertThat (response .getDeleteResult ().getDeletedObjects ().size (), is (0 ));
@@ -429,7 +434,11 @@ public void multiObjectDeleteOfUnknownObjects() throws IOException {
429
434
try {
430
435
HELPERS .ensureBucketExists (bucketName , envDataPolicyId );
431
436
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
+
433
442
final DeleteObjectsResponse response = client
434
443
.deleteObjects (new DeleteObjectsRequest (bucketName , objList ));
435
444
assertThat (response , is (notNullValue ()));
0 commit comments