test: refactored OpenShiftOAuthInterceptorTest to not rely on mocks

Signed-off-by: Marc Nuri <[email protected]>
adietish · Oct 30, 2024 · badd7c8 · badd7c8
1 parent 75d30c7
commit badd7c8
Show file tree

Hide file tree

Showing 3 changed files with 185 additions and 207 deletions.
diff --git a/kubernetes-client-api/src/test/java/io/fabric8/kubernetes/client/http/TestHttpResponse.java b/kubernetes-client-api/src/test/java/io/fabric8/kubernetes/client/http/TestHttpResponse.java
@@ -16,6 +16,7 @@
 package io.fabric8.kubernetes.client.http;
 
 import java.nio.charset.StandardCharsets;
+import java.util.LinkedHashMap;
 import java.util.List;
 import java.util.Map;
 import java.util.Optional;
@@ -27,17 +28,19 @@
  */
 public class TestHttpResponse<T> extends StandardHttpHeaders implements HttpResponse<T> {
 
+  private final Map<String, List<String>> headers;
   private int code;
   private T body;
   private HttpRequest request;
   private HttpResponse<T> previousResponse;
 
   public TestHttpResponse() {
-    super();
+    this(new LinkedHashMap<>());
   }
 
   public TestHttpResponse(Map<String, List<String>> headers) {
     super(headers);
+    this.headers = headers;
   }
 
   @Override
@@ -78,7 +81,7 @@ public TestHttpResponse<T> withBody(T body) {
     return this;
   }
 
-  public HttpResponse<T> withRequest(HttpRequest request) {
+  public TestHttpResponse<T> withRequest(HttpRequest request) {
     this.request = request;
     return this;
   }
@@ -87,11 +90,22 @@ public HttpResponse<T> getPreviousResponse() {
     return previousResponse;
   }
 
-  public HttpResponse<T> withPreviousResponse(HttpResponse<T> previousResponse) {
+  public TestHttpResponse<T> withPreviousResponse(HttpResponse<T> previousResponse) {
     this.previousResponse = previousResponse;
     return this;
   }
 
+  public TestHttpResponse<T> withHeader(String name, String value) {
+    headers.compute(name, (k, v) -> {
+      if (v == null) {
+        v = new java.util.ArrayList<>();
+      }
+      v.add(value);
+      return v;
+    });
+    return this;
+  }
+
   public static TestHttpResponse<byte[]> from(int code, String body) {
     return new TestHttpResponse<byte[]>().withCode(code)
         .withBody(body.getBytes(StandardCharsets.UTF_8));

diff --git a/...nt-api/src/test/java/io/fabric8/kubernetes/client/http/TestStandardHttpClientFactory.java b/...nt-api/src/test/java/io/fabric8/kubernetes/client/http/TestStandardHttpClientFactory.java
@@ -17,6 +17,7 @@
 
 import lombok.Getter;
 
+import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.ConcurrentLinkedQueue;
 import java.util.stream.IntStream;
 import java.util.stream.Stream;
@@ -77,4 +78,8 @@ public final void expect(String pathRegex, int statusCode, byte[] body) {
     instances.forEach(c -> c.expect(pathRegex, statusCode, body));
   }
 
+  public final void expect(String pathRegex, CompletableFuture<HttpResponse<AsyncBody>> future) {
+    instances.forEach(c -> c.expect(pathRegex, future));
+  }
+
 }