feat: add preview MultipartUploadClient#listMultipartUploads

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

@@ -22,19 +22,25 @@
 import java.io.IOException;
 import java.util.Arrays;
 import java.util.Collections;
+import java.util.List;
 import java.util.Map;
-import java.util.Optional;
 import java.util.stream.Collectors;
 
-/** A utility class to parse {@link HttpResponse} and create a {@link UploadPartResponse}. */
+/** A utility class to parse checksums from an {@link HttpResponse}. */
 final class ChecksumResponseParser {
 
+  private static final String X_GOOG_HASH = "x-goog-hash";
+
   private ChecksumResponseParser() {}
 
   static UploadPartResponse parseUploadResponse(HttpResponse response) {
     String eTag = response.getHeaders().getETag();
     Map<String, String> hashes = extractHashesFromHeader(response);
-    return UploadPartResponse.builder().eTag(eTag).md5(hashes.get("md5")).build();
+    return UploadPartResponse.builder()
+        .eTag(eTag)
+        .md5(hashes.get("md5"))
+        .crc32c(hashes.get("crc32c"))
+        .build();
   }
 
   static CompleteMultipartUploadResponse parseCompleteResponse(HttpResponse response)
@@ -52,14 +58,18 @@ static CompleteMultipartUploadResponse parseCompleteResponse(HttpResponse respon
   }
 
   static Map<String, String> extractHashesFromHeader(HttpResponse response) {
-    return Optional.ofNullable(response.getHeaders().getFirstHeaderStringValue("x-goog-hash"))
-        .map(
-            h ->
-                Arrays.stream(h.split(","))
-                    .map(s -> s.trim().split("=", 2))
-                    .filter(a -> a.length == 2)
-                    .filter(a -> "crc32c".equalsIgnoreCase(a[0]) || "md5".equalsIgnoreCase(a[0]))
-                    .collect(Collectors.toMap(a -> a[0].toLowerCase(), a -> a[1], (v1, v2) -> v1)))
-        .orElse(Collections.emptyMap());
+    List<String> hashHeaders = response.getHeaders().getHeaderStringValues(X_GOOG_HASH);
+    if (hashHeaders == null || hashHeaders.isEmpty()) {
+      return Collections.emptyMap();
+    }
+
+    return hashHeaders.stream()
+        .flatMap(h -> Arrays.stream(h.split(",")))
+        .map(String::trim)
+        .filter(s -> !s.isEmpty())
+        .map(s -> s.split("=", 2))
+        .filter(a -> a.length == 2)
+        .filter(a -> "crc32c".equalsIgnoreCase(a[0]) || "md5".equalsIgnoreCase(a[0]))
+        .collect(Collectors.toMap(a -> a[0].toLowerCase(), a -> a[1], (v1, v2) -> v1));
   }
 }

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,18 @@ 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.61.0 This new api is in preview and is subject to breaking changes.
+   */
+  @BetaApi
+  public ListMultipartUploadsResponse listMultipartUploads(ListMultipartUploadsRequest request) {
+    throw new UnsupportedOperationException("This operation is not yet implemented.");
+  }
+
   /**
    * Creates a new instance of {@link MultipartUploadClient}.
    *

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.build(),
+            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) {