import com.google.gcloud.storage.BatchRequest;

private static abstract class BlobsAction extends StorageAction<Blob[]> {

@Override

Blob[] parse(String... args) {

if (args.length < 2) {

throw new IllegalArgumentException();

}

Blob[] blobs = new Blob[args.length - 1];

for (int i = 1; i < args.length; i++) {

blobs[i - 1] = Blob.of(args[0], args[i]);

}

return blobs;

}

@Override

public String params() {

return "<bucket> <path>+";

}

}

private static class DeleteAction extends BlobsAction {

public void run(StorageService storage, Blob... blobs) {

if (blobs.length == 1) {

System.out.println("Calling delete");

System.out.println(storage.delete(blobs[0]));

} else {

BatchRequest batch = new BatchRequest();

for (Blob blob : blobs) {

batch.delete(blob);

}

System.out.println("Calling batch.delete");

storage.apply(batch);

}

/* * Copyright 2015 Google Inc. All Rights Reserved. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */package com.google.gcloud.spi;import com.google.api.services.storage.model.Bucket;import com.google.api.services.storage.model.StorageObject;import com.google.gcloud.storage.BlobReadChannel;import com.google.gcloud.storage.BlobWriteChannel;import com.google.gcloud.storage.StorageServiceException;import java.util.Map;public interface StorageRpc { enum Option { PREDEFINED_ACL("predefinedAcl"), PREDEFINED_DEFAULT_OBJECT_ACL("predefinedDefaultObjectAcl"), IF_METAGENERATION_MATCH("ifMetagenerationMatch"), IF_METAGENERATION_NOT_MATCH("ifMetagenerationNotMatch"), IF_GENERATION_NOT_MATCH("ifGenerationMatch"), IF_GENERATION_MATCH("ifGenerationNotMatch"), IF_SOURCE_METAGENERATION_MATCH("ifSourceMetagenerationMatch"), IF_SOURCE_METAGENERATION_NOT_MATCH("ifSourceMetagenerationNotMatch"), IF_SOURCE_GENERATION_MATCH("ifSourceGenerationMatch"), IF_SOURCE_GENERATION_NOT_MATCH("ifSourceGenerationNotMatch"), PREFIX("prefix"), MAX_RESULTS("maxResults"), PAGE_TOKEN("pageToken"), DELIMITER("delimiter"), VERSIONS("versions"); private final String value; Option(String value) { this.value = value; } public String value() { return value; } @SuppressWarnings("unchecked") <T> T get(Map<Option, ?> options) { return (T) options.get(this); } String getString(Map<Option, ?> options) { return get(options); } Long getLong(Map<Option, ?> options) { return get(options); } Boolean getBoolean(Map<Option, ?> options) { return get(options); } } class Tuple<X, Y> { private final X x; private final Y y; private Tuple(X x, Y y) { this.x = x; this.y = y; } public static <X, Y> Tuple<X, Y> of(X x, Y y) { return new Tuple<>(x, y); } public X x() { return x; } public Y y() { return y; } } Bucket create(Bucket bucket, Map<Option, ?> options) throws StorageServiceException; StorageObject create(StorageObject object, byte[] content, Map<Option, ?> options) throws StorageServiceException; Tuple<String, Iterable<Bucket>> list(Map<Option, ?> options) throws StorageServiceException; Tuple<String, Iterable<StorageObject>> list(String bucket, Map<Option, ?> options) throws StorageServiceException; Bucket get(Bucket bucket, Map<Option, ?> options) throws StorageServiceException; StorageObject get(StorageObject object, Map<Option, ?> options) throws StorageServiceException; Bucket patch(Bucket bucket, Map<Option, ?> options) throws StorageServiceException; StorageObject patch(StorageObject storageObject, Map<Option, ?> options) throws StorageServiceException; boolean delete(Bucket bucket, Map<Option, ?> options) throws StorageServiceException; boolean delete(StorageObject object, Map<Option, ?> options) throws StorageServiceException; void batch(Iterable<Tuple<StorageObject, Map<Option, ?>>> toDelete) throws StorageServiceException; StorageObject compose(Iterable<StorageObject> sources, StorageObject target, Map<Option, ?> targetOptions) throws StorageServiceException; StorageObject copy(StorageObject source, Map<Option, ?> sourceOptions, StorageObject target, Map<Option, ?> targetOptions) throws StorageServiceException; byte[] load(StorageObject storageObject, Map<Option, ?> options) throws StorageServiceException; BlobReadChannel reader(StorageObject from, Map<Option, ?> options) throws StorageServiceException; BlobWriteChannel writer(StorageObject to, Map<Option, ?> options) throws StorageServiceException;}

package com.google.gcloud.storage;

import com.google.gcloud.storage.StorageService.BlobSourceOption;

import java.util.LinkedHashMap;

import java.util.Map;

public class BatchRequest {

Map<Blob, BlobSourceOption[]> toDelete = new LinkedHashMap<>();

public void delete(Blob blob, BlobSourceOption... options) {

toDelete.put(blob, options);

}

}

package com.google.gcloud.storage;

public class BatchResponse {

}

boolean delete(Bucket bucket, BucketSourceOption... options);

boolean delete(Blob blob, BlobSourceOption... options);

BatchResponse apply(BatchRequest batchRequest);

public boolean delete(Bucket bucket, BucketSourceOption... options) {

return runWithRetries(new Callable<Boolean>() {

public Boolean call() {

return storageRpc.delete(bucketPb, optionsMap);

public boolean delete(Blob blob, BlobSourceOption... options) {

return runWithRetries(new Callable<Boolean>() {

public Boolean call() {

return storageRpc.delete(storageObject, optionsMap);

@Override

public BatchResponse apply(BatchRequest batchRequest) {

BatchResponse response = new BatchResponse();

List<Tuple<StorageObject, Map<StorageRpc.Option, ?>>> request =

Lists.newArrayListWithCapacity(batchRequest.toDelete.size());

for (Map.Entry<Blob, BlobSourceOption[]> entry : batchRequest.toDelete.entrySet()) {

Blob blob = entry.getKey();

Map<StorageRpc.Option, ?> optionsMap = optionMap(blob, entry.getValue());

request.add(Tuple.<StorageObject, Map<StorageRpc.Option, ?>>of(blob.toPb(), optionsMap));

}

storageRpc.batch(request);

return response;

}