feat: Added API for list all buckets.

Author: ShreyasSinha

google-cloud-storage/src/main/java/com/google/cloud/storage/MultipartUploadClient.java

@@ -24,6 +24,8 @@
 import com.google.cloud.storage.multipartupload.model.CompleteMultipartUploadResponse;
 import com.google.cloud.storage.multipartupload.model.CreateMultipartUploadRequest;
 import com.google.cloud.storage.multipartupload.model.CreateMultipartUploadResponse;
+import com.google.cloud.storage.multipartupload.model.ListMultipartUploadsRequest;
+import com.google.cloud.storage.multipartupload.model.ListMultipartUploadsResponse;
 import com.google.cloud.storage.multipartupload.model.ListPartsRequest;
 import com.google.cloud.storage.multipartupload.model.ListPartsResponse;
 import com.google.cloud.storage.multipartupload.model.UploadPartRequest;
@@ -100,6 +102,17 @@ public abstract CompleteMultipartUploadResponse completeMultipartUpload(
   @BetaApi
   public abstract UploadPartResponse uploadPart(UploadPartRequest request, RequestBody requestBody);
 
+  /**
+   * Lists all multipart uploads in a bucket.
+   *
+   * @param request The request object containing the details for listing the multipart uploads.
+   * @return A {@link ListMultipartUploadsResponse} object containing the list of multipart uploads.
+   * @since 2.60.0 This new api is in preview and is subject to breaking changes.
+   */
+  @BetaApi
+  public abstract ListMultipartUploadsResponse listMultipartUploads(
+      ListMultipartUploadsRequest request);
+
   /**
    * Creates a new instance of {@link MultipartUploadClient}.
    *
@@ -116,4 +129,4 @@ public static MultipartUploadClient create(MultipartUploadSettings config) {
         MultipartUploadHttpRequestManager.createFrom(options),
         options.getRetryAlgorithmManager());
   }
-}
+}

google-cloud-storage/src/main/java/com/google/cloud/storage/MultipartUploadClientImpl.java

@@ -23,6 +23,8 @@
 import com.google.cloud.storage.multipartupload.model.CompleteMultipartUploadResponse;
 import com.google.cloud.storage.multipartupload.model.CreateMultipartUploadRequest;
 import com.google.cloud.storage.multipartupload.model.CreateMultipartUploadResponse;
+import com.google.cloud.storage.multipartupload.model.ListMultipartUploadsRequest;
+import com.google.cloud.storage.multipartupload.model.ListMultipartUploadsResponse;
 import com.google.cloud.storage.multipartupload.model.ListPartsRequest;
 import com.google.cloud.storage.multipartupload.model.ListPartsResponse;
 import com.google.cloud.storage.multipartupload.model.UploadPartRequest;
@@ -100,4 +102,12 @@ public UploadPartResponse uploadPart(UploadPartRequest request, RequestBody requ
         },
         Decoder.identity());
   }
+
+  @Override
+  public ListMultipartUploadsResponse listMultipartUploads(ListMultipartUploadsRequest request) {
+    return retrier.run(
+        retryAlgorithmManager.idempotent(),
+        () -> httpRequestManager.sendListMultipartUploadsRequest(uri, request),
+        Decoder.identity());
+  }
 }

google-cloud-storage/src/main/java/com/google/cloud/storage/MultipartUploadHttpRequestManager.java

@@ -36,6 +36,8 @@
 import com.google.cloud.storage.multipartupload.model.CompleteMultipartUploadResponse;
 import com.google.cloud.storage.multipartupload.model.CreateMultipartUploadRequest;
 import com.google.cloud.storage.multipartupload.model.CreateMultipartUploadResponse;
+import com.google.cloud.storage.multipartupload.model.ListMultipartUploadsRequest;
+import com.google.cloud.storage.multipartupload.model.ListMultipartUploadsResponse;
 import com.google.cloud.storage.multipartupload.model.ListPartsRequest;
 import com.google.cloud.storage.multipartupload.model.ListPartsResponse;
 import com.google.cloud.storage.multipartupload.model.UploadPartRequest;
@@ -111,6 +113,43 @@ ListPartsResponse sendListPartsRequest(URI uri, ListPartsRequest request) throws
     return httpRequest.execute().parseAs(ListPartsResponse.class);
   }
 
+  ListMultipartUploadsResponse sendListMultipartUploadsRequest(
+      URI uri, ListMultipartUploadsRequest request) throws IOException {
+
+    ImmutableMap.Builder<String, Object> params =
+        ImmutableMap.<String, Object>builder()
+            .put("bucket", request.bucket());
+    if(request.delimiter() != null){
+      params.put("delimiter", request.delimiter());
+    }
+    if(request.encodingType() != null){
+      params.put("encoding-type", request.encodingType());
+    }
+    if(request.keyMarker() != null){
+      params.put("key-marker", request.keyMarker());
+    }
+    if(request.maxUploads() != null){
+      params.put("max-uploads", request.maxUploads());
+    }
+    if(request.prefix() != null){
+      params.put("prefix", request.prefix());
+    }
+    if(request.uploadIdMarker() != null){
+      params.put("upload-id-marker", request.uploadIdMarker());
+    }
+    String listUri =
+        UriTemplate.expand(
+            uri.toString() + "{bucket}?uploads{delimiter,encoding-type,key-marker,max-uploads,prefix,upload-id-marker}",
+            params,
+            false);
+    System.out.println(listUri);
+    HttpRequest httpRequest = requestFactory.buildGetRequest(new GenericUrl(listUri));
+    httpRequest.getHeaders().putAll(headerProvider.getHeaders());
+    httpRequest.setParser(objectParser);
+    httpRequest.setThrowExceptionOnExecuteError(true);
+    return httpRequest.execute().parseAs(ListMultipartUploadsResponse.class);
+  }
+
   AbortMultipartUploadResponse sendAbortMultipartUploadRequest(
       URI uri, AbortMultipartUploadRequest request) throws IOException {
 
@@ -248,7 +287,7 @@ private static String urlEncode(String value) {
    */
   private static String formatName(String name) {
     // Only lowercase letters, digits, and "-" are allowed
-    return name.toLowerCase().replaceAll("[^\\w\\d\\-]", "-");
+    return name.toLowerCase().replaceAll("[^\\w-]", "-");
   }
 
   private static String formatSemver(String version) {