Client.Default - Null pointer exception when receiving an 'empty' res…

…ponse with compression (#2510) * Client.Default - Null pointer exception when receiving an 'empty' response with compression * Apply code style
OpenFeign · Aug 21, 2024 · 9347d2b · 9347d2b
1 parent b86d297
commit 9347d2b
Show file tree

Hide file tree

Showing 2 changed files with 43 additions and 2 deletions.
diff --git a/core/src/main/java/feign/Client.java b/core/src/main/java/feign/Client.java
@@ -137,9 +137,9 @@ Response convertResponse(HttpURLConnection connection, Request request) throws I
       } else {
         stream = connection.getInputStream();
       }
-      if (this.isGzip(headers.get(CONTENT_ENCODING))) {
+      if (stream != null && this.isGzip(headers.get(CONTENT_ENCODING))) {
         stream = new GZIPInputStream(stream);
-      } else if (this.isDeflate(headers.get(CONTENT_ENCODING))) {
+      } else if (stream != null && this.isDeflate(headers.get(CONTENT_ENCODING))) {
         stream = new InflaterInputStream(stream);
       }
       return Response.builder()

diff --git a/core/src/test/java/feign/client/AbstractClientTest.java b/core/src/test/java/feign/client/AbstractClientTest.java
@@ -445,6 +445,26 @@ public void canSupportGzipOnError() throws Exception {
     }
   }
 
+  @Test
+  public void canSupportGzipOnErrorWithoutBody() throws Exception {
+    server.enqueue(new MockResponse().setResponseCode(400).addHeader("Content-Encoding", "gzip"));
+
+    TestInterface api =
+        newBuilder().target(TestInterface.class, "http://localhost:" + server.getPort());
+
+    try {
+      api.get();
+      fail("Expect FeignException");
+    } catch (FeignException e) {
+      /* verify that the response is unzipped */
+      assertThat(e.responseBody())
+          .isNotEmpty()
+          .map(body -> new String(body.array(), StandardCharsets.UTF_8))
+          .get()
+          .isEqualTo("");
+    }
+  }
+
   @Test
   public void canSupportDeflate() throws Exception {
     /* enqueue a zipped response */
@@ -489,6 +509,27 @@ public void canSupportDeflateOnError() throws Exception {
     }
   }
 
+  @Test
+  public void canSupportDeflateOnErrorWithoutBody() throws Exception {
+    server.enqueue(
+        new MockResponse().setResponseCode(400).addHeader("Content-Encoding", "deflate"));
+
+    TestInterface api =
+        newBuilder().target(TestInterface.class, "http://localhost:" + server.getPort());
+
+    try {
+      api.get();
+      fail("Expect FeignException");
+    } catch (FeignException e) {
+      /* verify that the response is unzipped */
+      assertThat(e.responseBody())
+          .isNotEmpty()
+          .map(body -> new String(body.array(), StandardCharsets.UTF_8))
+          .get()
+          .isEqualTo("");
+    }
+  }
+
   @Test
   public void canExceptCaseInsensitiveHeader() throws Exception {
     /* enqueue a zipped response */