api/handler/delete.go

@@ -150,15 +150,18 @@ func (h *handler) DeleteMultipleObjectsHandler(w http.ResponseWriter, r *http.Re
 		return
 	}
 
-	removed := make(map[string]*layer.VersionedObject)
+	unique := make(map[string]struct{})
 	toRemove := make([]*layer.VersionedObject, 0, len(requested.Objects))
 	for _, obj := range requested.Objects {
 		versionedObj := &layer.VersionedObject{
 			Name:      obj.ObjectName,
 			VersionID: obj.VersionID,
 		}
-		toRemove = append(toRemove, versionedObj)
-		removed[versionedObj.String()] = versionedObj
+		key := versionedObj.String()
+		if _, ok := unique[key]; !ok {
+			toRemove = append(toRemove, versionedObj)
+			unique[key] = struct{}{}
+		}
 	}
 
 	response := &DeleteObjectsResponse{

api/handler/delete_test.go

@@ -85,6 +85,19 @@ func TestDeleteBucketOnNotFoundError(t *testing.T) {
 	deleteBucket(t, hc, bktName, http.StatusNoContent)
 }
 
+func TestDeleteMultipleObjectCheckUniqueness(t *testing.T) {
+	hc := prepareHandlerContext(t)
+
+	bktName, objName := "bucket", "object"
+	createTestBucket(hc, bktName)
+
+	putObject(hc, bktName, objName)
+
+	resp := deleteObjects(t, hc, bktName, [][2]string{{objName, emptyVersion}, {objName, emptyVersion}})
+	require.Empty(t, resp.Errors)
+	require.Len(t, resp.DeletedObjects, 1)
+}
+
 func TestDeleteObjectsError(t *testing.T) {
 	hc := prepareHandlerContext(t)
 

api/middleware/policy.go

@@ -32,7 +32,9 @@ const (
 	amzTagging     = "x-amz-tagging"
 )
 
-// At the beginning of these operations resources haven't yet been created.
+// In these operations we don't check resource tags because
+// * they haven't been created yet
+// * resource tags shouldn't be checked by AWS spec.
 var withoutResourceOps = []string{
 	CreateBucketOperation,
 	CreateMultipartUploadOperation,
@@ -43,6 +45,8 @@ var withoutResourceOps = []string{
 	ListPartsOperation,
 	PutObjectOperation,
 	CopyObjectOperation,
+	DeleteObjectOperation,
+	DeleteMultipleObjectsOperation,
 }
 
 type PolicySettings interface {