Browse Source

DefaultResponseErrorHandler shows full error details

Closes gh-27552
pull/28694/head
Rossen Stoyanchev 4 years ago
parent
commit
26af506441
  1. 8
      spring-core/src/main/java/org/springframework/core/log/LogFormatUtils.java
  2. 29
      spring-web/src/main/java/org/springframework/web/client/DefaultResponseErrorHandler.java
  3. 24
      spring-web/src/test/java/org/springframework/web/client/DefaultResponseErrorHandlerTests.java

8
spring-core/src/main/java/org/springframework/core/log/LogFormatUtils.java

@ -60,23 +60,21 @@ public abstract class LogFormatUtils {
return ""; return "";
} }
String result; String result;
if (value instanceof CharSequence) {
result = "\"" + value + "\"";
}
else {
try { try {
result = value.toString(); result = value.toString();
} }
catch (Throwable ex) { catch (Throwable ex) {
result = ex.toString(); result = ex.toString();
} }
}
if (maxLength != -1) { if (maxLength != -1) {
result = (result.length() > maxLength ? result.substring(0, maxLength) + " (truncated)..." : result); result = (result.length() > maxLength ? result.substring(0, maxLength) + " (truncated)..." : result);
} }
if (replaceNewlines) { if (replaceNewlines) {
result = result.replace("\n", "<LF>").replace("\r", "<CR>"); result = result.replace("\n", "<LF>").replace("\r", "<CR>");
} }
if (value instanceof CharSequence) {
result = "\"" + result + "\"";
}
return result; return result;
} }

29
spring-web/src/main/java/org/springframework/web/client/DefaultResponseErrorHandler.java

@ -1,5 +1,5 @@
/* /*
* Copyright 2002-2020 the original author or authors. * Copyright 2002-2021 the original author or authors.
* *
* Licensed under the Apache License, Version 2.0 (the "License"); * Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License. * you may not use this file except in compliance with the License.
@ -16,14 +16,11 @@
package org.springframework.web.client; package org.springframework.web.client;
import java.io.ByteArrayInputStream;
import java.io.IOException; import java.io.IOException;
import java.io.InputStreamReader;
import java.io.Reader;
import java.nio.CharBuffer;
import java.nio.charset.Charset; import java.nio.charset.Charset;
import java.nio.charset.StandardCharsets; import java.nio.charset.StandardCharsets;
import org.springframework.core.log.LogFormatUtils;
import org.springframework.http.HttpHeaders; import org.springframework.http.HttpHeaders;
import org.springframework.http.HttpStatus; import org.springframework.http.HttpStatus;
import org.springframework.http.MediaType; import org.springframework.http.MediaType;
@ -135,29 +132,17 @@ public class DefaultResponseErrorHandler implements ResponseErrorHandler {
int rawStatusCode, String statusText, @Nullable byte[] responseBody, @Nullable Charset charset) { int rawStatusCode, String statusText, @Nullable byte[] responseBody, @Nullable Charset charset) {
String preface = rawStatusCode + " " + statusText + ": "; String preface = rawStatusCode + " " + statusText + ": ";
if (ObjectUtils.isEmpty(responseBody)) { if (ObjectUtils.isEmpty(responseBody)) {
return preface + "[no body]"; return preface + "[no body]";
} }
charset = charset == null ? StandardCharsets.UTF_8 : charset; charset = (charset != null ? charset : StandardCharsets.UTF_8);
int maxChars = 200;
if (responseBody.length < maxChars * 2) { String bodyText = new String(responseBody, charset);
return preface + "[" + new String(responseBody, charset) + "]"; bodyText = LogFormatUtils.formatValue(bodyText, -1, true);
}
try { return preface + bodyText;
Reader reader = new InputStreamReader(new ByteArrayInputStream(responseBody), charset);
CharBuffer buffer = CharBuffer.allocate(maxChars);
reader.read(buffer);
reader.close();
buffer.flip();
return preface + "[" + buffer.toString() + "... (" + responseBody.length + " bytes)]";
}
catch (IOException ex) {
// should never happen
throw new IllegalStateException(ex);
}
} }
/** /**

24
spring-web/src/test/java/org/springframework/web/client/DefaultResponseErrorHandlerTests.java

@ -1,5 +1,5 @@
/* /*
* Copyright 2002-2020 the original author or authors. * Copyright 2002-2021 the original author or authors.
* *
* Licensed under the Apache License, Version 2.0 (the "License"); * Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License. * you may not use this file except in compliance with the License.
@ -19,10 +19,8 @@ package org.springframework.web.client;
import java.io.ByteArrayInputStream; import java.io.ByteArrayInputStream;
import java.io.IOException; import java.io.IOException;
import java.nio.charset.StandardCharsets; import java.nio.charset.StandardCharsets;
import java.util.function.Function;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
import reactor.core.publisher.Flux;
import org.springframework.http.HttpHeaders; import org.springframework.http.HttpHeaders;
import org.springframework.http.HttpStatus; import org.springframework.http.HttpStatus;
@ -75,25 +73,7 @@ public class DefaultResponseErrorHandlerTests {
assertThatExceptionOfType(HttpClientErrorException.class) assertThatExceptionOfType(HttpClientErrorException.class)
.isThrownBy(() -> handler.handleError(response)) .isThrownBy(() -> handler.handleError(response))
.satisfies(ex -> assertThat(ex.getResponseHeaders()).isSameAs(headers)) .satisfies(ex -> assertThat(ex.getResponseHeaders()).isSameAs(headers))
.satisfies(ex -> assertThat(ex.getMessage()).isEqualTo("404 Not Found: [Hello World]")); .withMessage("404 Not Found: \"Hello World\"");
}
@Test
public void handleErrorWithLongBody() throws Exception {
Function<Integer, String> bodyGenerator =
size -> Flux.just("a").repeat(size-1).reduce((s, s2) -> s + s2).block();
given(response.getRawStatusCode()).willReturn(HttpStatus.NOT_FOUND.value());
given(response.getStatusText()).willReturn("Not Found");
given(response.getHeaders()).willReturn(new HttpHeaders());
given(response.getBody()).willReturn(
new ByteArrayInputStream(bodyGenerator.apply(500).getBytes(StandardCharsets.UTF_8)));
assertThatExceptionOfType(HttpClientErrorException.class)
.isThrownBy(() -> handler.handleError(response))
.satisfies(ex -> assertThat(ex.getMessage()).isEqualTo(
"404 Not Found: [" + bodyGenerator.apply(200) + "... (500 bytes)]"));
} }
@Test @Test

Loading…
Cancel
Save