Add test for GCS fixture (#118737)

Relates: ES-5679

Author: nicktindall

server/src/main/java/org/elasticsearch/rest/RestUtils.java

@@ -15,6 +15,7 @@
 import org.elasticsearch.core.Nullable;
 import org.elasticsearch.core.TimeValue;
 
+import java.net.URI;
 import java.nio.charset.Charset;
 import java.nio.charset.StandardCharsets;
 import java.util.Arrays;
@@ -35,6 +36,13 @@ public class RestUtils {
 
     public static final UnaryOperator<String> REST_DECODER = RestUtils::decodeComponent;
 
+    public static void decodeQueryString(URI uri, Map<String, String> params) {
+        final var rawQuery = uri.getRawQuery();
+        if (Strings.hasLength(rawQuery)) {
+            decodeQueryString(rawQuery, 0, params);
+        }
+    }
+
     public static void decodeQueryString(String s, int fromIndex, Map<String, String> params) {
         if (fromIndex < 0) {
             return;

test/fixtures/gcs-fixture/build.gradle

@@ -9,7 +9,6 @@
 apply plugin: 'elasticsearch.java'
 
 description = 'Fixture for Google Cloud Storage service'
-tasks.named("test").configure { enabled = false }
 
 dependencies {
   api project(':server')

test/fixtures/gcs-fixture/src/main/java/fixture/gcs/GoogleCloudStorageHttpHandler.java

@@ -95,7 +95,7 @@ public void handle(final HttpExchange exchange) throws IOException {
             } else if (Regex.simpleMatch("GET /storage/v1/b/" + bucket + "/o*", request)) {
                 // List Objects https://cloud.google.com/storage/docs/json_api/v1/objects/list
                 final Map<String, String> params = new HashMap<>();
-                RestUtils.decodeQueryString(exchange.getRequestURI().getQuery(), 0, params);
+                RestUtils.decodeQueryString(exchange.getRequestURI(), params);
                 final String prefix = params.getOrDefault("prefix", "");
                 final String delimiter = params.get("delimiter");
 
@@ -212,7 +212,7 @@ public void handle(final HttpExchange exchange) throws IOException {
             } else if (Regex.simpleMatch("POST /upload/storage/v1/b/" + bucket + "/*uploadType=resumable*", request)) {
                 // Resumable upload initialization https://cloud.google.com/storage/docs/json_api/v1/how-tos/resumable-upload
                 final Map<String, String> params = new HashMap<>();
-                RestUtils.decodeQueryString(exchange.getRequestURI().getQuery(), 0, params);
+                RestUtils.decodeQueryString(exchange.getRequestURI(), params);
                 final String blobName = params.get("name");
                 blobs.put(blobName, BytesArray.EMPTY);
 
@@ -237,7 +237,7 @@ public void handle(final HttpExchange exchange) throws IOException {
             } else if (Regex.simpleMatch("PUT /upload/storage/v1/b/" + bucket + "/o?*uploadType=resumable*", request)) {
                 // Resumable upload https://cloud.google.com/storage/docs/json_api/v1/how-tos/resumable-upload
                 final Map<String, String> params = new HashMap<>();
-                RestUtils.decodeQueryString(exchange.getRequestURI().getQuery(), 0, params);
+                RestUtils.decodeQueryString(exchange.getRequestURI(), params);
 
                 final String blobName = params.get("test_blob_name");
                 if (blobs.containsKey(blobName) == false) {
@@ -269,8 +269,6 @@ public void handle(final HttpExchange exchange) throws IOException {
                 exchange.sendResponseHeaders(RestStatus.NOT_FOUND.getStatus(), -1);
             }
         } finally {
-            int read = exchange.getRequestBody().read();
-            assert read == -1 : "Request body should have been fully read here but saw [" + read + "]";
             exchange.close();
         }
     }