Polish

Closes gh-15594

spring-boot-project/spring-boot-actuator/src/main/java/org/springframework/boot/actuate/metrics/web/client/DefaultRestTemplateExchangeTagsProvider.java

 /*
- * Copyright 2012-2018 the original author or authors.
+ * Copyright 2012-2019 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

spring-boot-project/spring-boot-actuator/src/main/java/org/springframework/boot/actuate/metrics/web/client/RestTemplateExchangeTags.java

 /*
- * Copyright 2012-2018 the original author or authors.
+ * Copyright 2012-2019 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -35,6 +35,7 @@ import org.springframework.web.client.RestTemplate;
  * @author Andy Wilkinson
  * @author Jon Schneider
  * @author Nishant Raut
+ * @author Brian Clozel
  * @since 2.0.0
  */
 public final class RestTemplateExchangeTags {
@@ -137,36 +138,37 @@ public final class RestTemplateExchangeTags {
 	 * @since 2.2.0
 	 */
 	public static Tag outcome(ClientHttpResponse response) {
-		if (response != null) {
-			HttpStatus status = extractStatus(response);
-			if (status != null) {
-				if (status.is1xxInformational()) {
-					return OUTCOME_INFORMATIONAL;
-				}
-				if (status.is2xxSuccessful()) {
-					return OUTCOME_SUCCESS;
-				}
-				if (status.is3xxRedirection()) {
-					return OUTCOME_REDIRECTION;
-				}
-				if (status.is4xxClientError()) {
-					return OUTCOME_CLIENT_ERROR;
-				}
+		HttpStatus status = extractStatus(response);
+		if (status != null) {
+			if (status.is1xxInformational()) {
+				return OUTCOME_INFORMATIONAL;
+			}
+			if (status.is2xxSuccessful()) {
+				return OUTCOME_SUCCESS;
+			}
+			if (status.is3xxRedirection()) {
+				return OUTCOME_REDIRECTION;
+			}
+			if (status.is4xxClientError()) {
+				return OUTCOME_CLIENT_ERROR;
+			}
+			if (status.is5xxServerError()) {
+				return OUTCOME_SERVER_ERROR;
 			}
-			return OUTCOME_SERVER_ERROR;
 		}
 		return OUTCOME_UNKNOWN;
 	}
 
 	private static HttpStatus extractStatus(ClientHttpResponse response) {
-
 		try {
-			return response.getStatusCode();
+			if (response != null) {
+				return response.getStatusCode();
+			}
+			return null;
 		}
-		catch (IOException ex) {
+		catch (IOException | IllegalArgumentException exc) {
 			return null;
 		}
-
 	}
 
 }

spring-boot-project/spring-boot-actuator/src/main/java/org/springframework/boot/actuate/metrics/web/reactive/client/DefaultWebClientExchangeTagsProvider.java

 /*
- * Copyright 2012-2018 the original author or authors.
+ * Copyright 2012-2019 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

spring-boot-project/spring-boot-actuator/src/main/java/org/springframework/boot/actuate/metrics/web/reactive/client/WebClientExchangeTags.java

 /*
- * Copyright 2012-2018 the original author or authors.
+ * Copyright 2012-2019 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -133,9 +133,9 @@ public final class WebClientExchangeTags {
 	 * @since 2.2.0
 	 */
 	public static Tag outcome(ClientResponse response) {
-		if (response != null) {
-			HttpStatus status = response.statusCode();
-			if (status != null) {
+		try {
+			if (response != null) {
+				HttpStatus status = response.statusCode();
 				if (status.is1xxInformational()) {
 					return OUTCOME_INFORMATIONAL;
 				}
@@ -148,10 +148,15 @@ public final class WebClientExchangeTags {
 				if (status.is4xxClientError()) {
 					return OUTCOME_CLIENT_ERROR;
 				}
+				if (status.is5xxServerError()) {
+					return OUTCOME_SERVER_ERROR;
+				}
 			}
-			return OUTCOME_SERVER_ERROR;
+			return OUTCOME_UNKNOWN;
+		}
+		catch (IllegalArgumentException exc) {
+			return OUTCOME_UNKNOWN;
 		}
-		return OUTCOME_UNKNOWN;
 	}
 
 }

spring-boot-project/spring-boot-actuator/src/test/java/org/springframework/boot/actuate/metrics/web/client/RestTemplateExchangeTagsTests.java

 /*
- * Copyright 2012-2018 the original author or authors.
+ * Copyright 2012-2019 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -16,23 +16,28 @@
 
 package org.springframework.boot.actuate.metrics.web.client;
 
+import java.io.IOException;
+
 import io.micrometer.core.instrument.Tag;
 import org.junit.Test;
 
 import org.springframework.http.HttpStatus;
+import org.springframework.http.client.ClientHttpResponse;
 import org.springframework.mock.http.client.MockClientHttpResponse;
 
 import static org.assertj.core.api.Assertions.assertThat;
+import static org.mockito.BDDMockito.given;
+import static org.mockito.Mockito.mock;
 
 /**
  * Tests for {@link RestTemplateExchangeTags}.
  *
  * @author Nishant Raut
+ * @author Brian Clozel
+ * @author Brian Clozel
  */
 public class RestTemplateExchangeTagsTests {
 
-	private MockClientHttpResponse response;
-
 	@Test
 	public void outcomeTagIsUnknownWhenResponseStatusIsNull() {
 		Tag tag = RestTemplateExchangeTags.outcome(null);
@@ -41,40 +46,58 @@ public class RestTemplateExchangeTagsTests {
 
 	@Test
 	public void outcomeTagIsInformationalWhenResponseIs1xx() {
-		this.response = new MockClientHttpResponse("foo".getBytes(), HttpStatus.CONTINUE);
-		Tag tag = RestTemplateExchangeTags.outcome(this.response);
+		ClientHttpResponse response = new MockClientHttpResponse("foo".getBytes(),
+				HttpStatus.CONTINUE);
+		Tag tag = RestTemplateExchangeTags.outcome(response);
 		assertThat(tag.getValue()).isEqualTo("INFORMATIONAL");
 	}
 
 	@Test
 	public void outcomeTagIsSuccessWhenResponseIs2xx() {
-		this.response = new MockClientHttpResponse("foo".getBytes(), HttpStatus.OK);
-		Tag tag = RestTemplateExchangeTags.outcome(this.response);
+		ClientHttpResponse response = new MockClientHttpResponse("foo".getBytes(),
+				HttpStatus.OK);
+		Tag tag = RestTemplateExchangeTags.outcome(response);
 		assertThat(tag.getValue()).isEqualTo("SUCCESS");
 	}
 
 	@Test
 	public void outcomeTagIsRedirectionWhenResponseIs3xx() {
-		this.response = new MockClientHttpResponse("foo".getBytes(),
+		ClientHttpResponse response = new MockClientHttpResponse("foo".getBytes(),
 				HttpStatus.MOVED_PERMANENTLY);
-		Tag tag = RestTemplateExchangeTags.outcome(this.response);
+		Tag tag = RestTemplateExchangeTags.outcome(response);
 		assertThat(tag.getValue()).isEqualTo("REDIRECTION");
 	}
 
 	@Test
 	public void outcomeTagIsClientErrorWhenResponseIs4xx() {
-		this.response = new MockClientHttpResponse("foo".getBytes(),
+		ClientHttpResponse response = new MockClientHttpResponse("foo".getBytes(),
 				HttpStatus.BAD_REQUEST);
-		Tag tag = RestTemplateExchangeTags.outcome(this.response);
+		Tag tag = RestTemplateExchangeTags.outcome(response);
 		assertThat(tag.getValue()).isEqualTo("CLIENT_ERROR");
 	}
 
 	@Test
 	public void outcomeTagIsServerErrorWhenResponseIs5xx() {
-		this.response = new MockClientHttpResponse("foo".getBytes(),
+		ClientHttpResponse response = new MockClientHttpResponse("foo".getBytes(),
 				HttpStatus.BAD_GATEWAY);
-		Tag tag = RestTemplateExchangeTags.outcome(this.response);
+		Tag tag = RestTemplateExchangeTags.outcome(response);
 		assertThat(tag.getValue()).isEqualTo("SERVER_ERROR");
 	}
 
+	@Test
+	public void outcomeTagIsUnknownWhenResponseThrowsIOException() throws Exception {
+		ClientHttpResponse response = mock(ClientHttpResponse.class);
+		given(response.getStatusCode()).willThrow(IOException.class);
+		Tag tag = RestTemplateExchangeTags.outcome(response);
+		assertThat(tag.getValue()).isEqualTo("UNKNOWN");
+	}
+
+	@Test
+	public void outcomeTagIsUnknownForCustomResponseStatus() throws Exception {
+		ClientHttpResponse response = mock(ClientHttpResponse.class);
+		given(response.getStatusCode()).willThrow(IllegalArgumentException.class);
+		Tag tag = RestTemplateExchangeTags.outcome(response);
+		assertThat(tag.getValue()).isEqualTo("UNKNOWN");
+	}
+
 }

spring-boot-project/spring-boot-actuator/src/test/java/org/springframework/boot/actuate/metrics/web/reactive/client/DefaultWebClientExchangeTagsProviderTests.java

 /*
- * Copyright 2012-2018 the original author or authors.
+ * Copyright 2012-2019 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

spring-boot-project/spring-boot-actuator/src/test/java/org/springframework/boot/actuate/metrics/web/reactive/client/WebClientExchangeTagsTests.java

 /*
- * Copyright 2012-2018 the original author or authors.
+ * Copyright 2012-2019 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -155,4 +155,11 @@ public class WebClientExchangeTagsTests {
 		assertThat(tag.getValue()).isEqualTo("SERVER_ERROR");
 	}
 
+	@Test
+	public void outcomeTagIsUknownWhenResponseStatusIsUknown() {
+		given(this.response.statusCode()).willThrow(IllegalArgumentException.class);
+		Tag tag = WebClientExchangeTags.outcome(this.response);
+		assertThat(tag.getValue()).isEqualTo("UNKNOWN");
+	}
+
 }