fix #5041: adding raw methods

Author: shawkins

CHANGELOG.md

@@ -36,6 +36,7 @@
 
 #### New Features
 * Fix #5037: OkHttp-specific logging interceptor replacement. Introducing a generic HTTP interceptor to log HTTP and WS requests.
+* Fix #5041: exposed Client.raw methods for arbitrary calls
 
 #### _**Note**_: Breaking changes
 * Fix #4875: Removed unused options from the java-generator

kubernetes-client-api/src/main/java/io/fabric8/kubernetes/client/Client.java

@@ -189,4 +189,23 @@ default <T extends HasMetadata, L extends KubernetesResourceList<T>> MixedOperat
 
   Config getConfiguration();
 
+  /**
+   * GET the response from the given uri as a String
+   *
+   * @param uri must start with / if relative
+   * @return the response, or null if a 404 code
+   */
+  default String raw(String uri) {
+    return raw(uri, "GET", null);
+  }
+
+  /**
+   * The response from the given uri as a String
+   *
+   * @param uri must start with / if relative
+   * @param method an http method verb such as GET, DELETE, PUT, POST
+   * @param payload a non-String value will be converted to json
+   * @return the response
+   */
+  String raw(String uri, String method, Object payload);
 }

kubernetes-client-api/src/main/java/io/fabric8/kubernetes/client/NamespacedKubernetesClientAdapter.java

@@ -420,4 +420,9 @@ public void visitResources(ApiVisitor visitor) {
     getClient().visitResources(visitor);
   }
 
+  @Override
+  public String raw(String uri, String method, Object payload) {
+    return getClient().raw(uri, method, payload);
+  }
+
 }

kubernetes-client-api/src/main/java/io/fabric8/kubernetes/client/extension/ClientAdapter.java

@@ -153,4 +153,9 @@ public Client newClient(RequestConfig requestConfig) {
 
   public abstract C newInstance();
 
+  @Override
+  public String raw(String uri, String method, Object payload) {
+    return client.raw(uri, method, payload);
+  }
+
 }

kubernetes-client-api/src/main/java/io/fabric8/kubernetes/client/http/StandardHttpRequest.java

@@ -218,7 +218,9 @@ public HttpRequest.Builder method(String method, String contentType, String body
       this.method = method;
       this.contentType = contentType;
       this.bodyAsString = body;
-      this.body = new StringBodyContent(body);
+      if (body != null) {
+        this.body = new StringBodyContent(body);
+      }
       return this;
     }
 

kubernetes-client-api/src/test/java/io/fabric8/kubernetes/client/http/TestHttpResponse.java

@@ -15,6 +15,8 @@
  */
 package io.fabric8.kubernetes.client.http;
 
+import java.io.ByteArrayInputStream;
+import java.io.InputStream;
 import java.nio.charset.StandardCharsets;
 import java.util.Optional;
 
@@ -82,7 +84,8 @@ public HttpResponse<T> withPreviousResponse(HttpResponse<T> previousResponse) {
     return this;
   }
 
-  public static TestHttpResponse<byte[]> from(int code, String body) {
-    return new TestHttpResponse<byte[]>().withCode(code).withBody(body.getBytes(StandardCharsets.UTF_8));
+  public static TestHttpResponse<InputStream> from(int code, String body) {
+    return new TestHttpResponse<InputStream>().withCode(code)
+        .withBody(new ByteArrayInputStream(body.getBytes(StandardCharsets.UTF_8)));
   }
 }

kubernetes-client/src/main/java/io/fabric8/kubernetes/client/dsl/internal/OperationSupport.java

@@ -44,7 +44,6 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import java.io.ByteArrayInputStream;
 import java.io.IOException;
 import java.io.InputStream;
 import java.io.InterruptedIOException;
@@ -488,11 +487,7 @@ protected <T> T handleGet(URL resourceUrl, Class<T> type) throws InterruptedExce
    * Send a raw get - where the type should be one of String, Reader, InputStream
    */
   protected <T> T handleRawGet(URL resourceUrl, Class<T> type) throws IOException {
-    HttpRequest.Builder requestBuilder = httpClient.newHttpRequestBuilder().url(resourceUrl);
-    HttpRequest request = requestBuilder.build();
-    HttpResponse<T> response = waitForResult(httpClient.sendAsync(request, type));
-    assertResponseCode(request, response);
-    return response.body();
+    return handleRaw(type, resourceUrl.toString(), "GET", null);
   }
 
   /**
@@ -569,11 +564,11 @@ protected <T> CompletableFuture<T> handleResponse(HttpClient client, HttpRequest
     VersionUsageUtils.log(this.resourceT, this.apiGroupVersion);
     HttpRequest request = requestBuilder.build();
 
-    return client.sendAsync(request, byte[].class).thenApply(response -> {
+    return client.sendAsync(request, InputStream.class).thenApply(response -> {
       try {
         assertResponseCode(request, response);
         if (type != null && type.getType() != null) {
-          return Serialization.unmarshal(new ByteArrayInputStream(response.body()), type);
+          return Serialization.unmarshal(response.body(), type);
         } else {
           return null;
         }
@@ -760,4 +755,28 @@ public <R1> R1 restCall(Class<R1> result, String... path) {
     }
   }
 
+  /**
+   * Send a raw request - where the type should be one of String, Reader, InputStream
+   */
+  public <R1> R1 handleRaw(Class<R1> result, String uri, String method, Object payload) {
+    try {
+      if (uri.startsWith("/")) {
+        // master ends with slash
+        uri = config.getMasterUrl() + uri.substring(1, uri.length());
+      }
+      String body = null;
+      if (payload instanceof String) {
+        body = (String) payload;
+      } else if (payload != null) {
+        body = Serialization.asJson(payload);
+      }
+      HttpRequest request = httpClient.newHttpRequestBuilder().uri(uri).method(method, JSON, body).build();
+      HttpResponse<R1> response = waitForResult(httpClient.sendAsync(request, result));
+      assertResponseCode(request, response);
+      return response.body();
+    } catch (IOException e) {
+      throw KubernetesClientException.launderThrowable(e);
+    }
+  }
+
 }

kubernetes-client/src/main/java/io/fabric8/kubernetes/client/impl/BaseClient.java

@@ -41,6 +41,7 @@
 import io.fabric8.kubernetes.client.utils.ApiVersionUtil;
 import io.fabric8.kubernetes.client.utils.Utils;
 
+import java.net.HttpURLConnection;
 import java.net.MalformedURLException;
 import java.net.URL;
 import java.util.List;
@@ -354,4 +355,21 @@ public Executor getExecutor() {
     return executor;
   }
 
+  @Override
+  public String raw(String uri) {
+    try {
+      return raw(uri, "GET", null);
+    } catch (KubernetesClientException e) {
+      if (e.getCode() != HttpURLConnection.HTTP_NOT_FOUND) {
+        throw e;
+      }
+      return null;
+    }
+  }
+
+  @Override
+  public String raw(String uri, String method, Object payload) {
+    return this.getOperationSupport().handleRaw(String.class, uri, method, payload);
+  }
+
 }

kubernetes-client/src/test/java/io/fabric8/kubernetes/client/dsl/internal/BaseOperationTest.java

@@ -250,7 +250,7 @@ private HttpClient newHttpClientWithSomeFailures(final AtomicInteger httpExecuti
     HttpRequest.Builder mockRequestBuilder = mock(HttpRequest.Builder.class, Mockito.RETURNS_SELF);
     when(mockClient.newHttpRequestBuilder()).thenReturn(mockRequestBuilder);
     when(mockRequestBuilder.build()).thenReturn(new StandardHttpRequest.Builder().uri("https://k8s.example.com").build());
-    when(mockClient.sendAsync(Mockito.any(), Mockito.eq(byte[].class))).thenAnswer(
+    when(mockClient.sendAsync(Mockito.any(), Mockito.eq(InputStream.class))).thenAnswer(
         invocation -> {
           int count = httpExecutionCounter.getAndIncrement();
           if (count < numFailures) {

kubernetes-client/src/test/java/io/fabric8/kubernetes/client/impl/DryRunTest.java

@@ -35,6 +35,7 @@
 import org.mockito.Mockito;
 
 import java.io.IOException;
+import java.io.InputStream;
 import java.net.URL;
 import java.util.ArrayList;
 import java.util.List;
@@ -58,7 +59,7 @@ public void setUp() throws IOException {
     builders = new ArrayList<>();
     this.mockClient = Mockito.mock(HttpClient.class, Mockito.RETURNS_DEEP_STUBS);
     Config config = new ConfigBuilder().withMasterUrl("https://localhost:8443/").build();
-    when(mockClient.sendAsync(any(), Mockito.eq(byte[].class)))
+    when(mockClient.sendAsync(any(), Mockito.eq(InputStream.class)))
         .thenReturn(CompletableFuture.completedFuture(TestHttpResponse.from(200,
             "{\"kind\":\"Pod\", \"apiVersion\":\"v1\"}")));
     kubernetesClient = new KubernetesClientImpl(mockClient, config);