added asynchronous methods and context propagation

Author: ssayyaparaj

src/main/java/com/intuit/springwebclient/client/CommonSpringWebClient.java

@@ -29,20 +29,20 @@
 @Slf4j
 @Component
 public class CommonSpringWebClient {
-    private final WebClient webClient;
+	private final WebClient webClient;
 
 	public CommonSpringWebClient(@Qualifier("RWebPulseClient") WebClient webClient) {
 		this.webClient = webClient;
 	}
 
 	/**
-     * Execute Blocking http request.
-     * @param httpRequest
-     * @return
-     * @param <REQUEST>
-     * @param <RESPONSE>
-     */
-    public <REQUEST, RESPONSE> ClientHttpResponse<RESPONSE> syncHttpResponse(ClientHttpRequest<REQUEST, RESPONSE> httpRequest) {
+	 * Execute Blocking http request.
+	 * @param httpRequest
+	 * @return
+	 * @param <REQUEST>
+	 * @param <RESPONSE>
+	 */
+	public <REQUEST, RESPONSE> ClientHttpResponse<RESPONSE> syncHttpResponse(ClientHttpRequest<REQUEST, RESPONSE> httpRequest) {
 		try {
 			log.info("Executing http request for request={}, method={}", httpRequest.getRequest(),
 					httpRequest.getHttpMethod());
@@ -73,9 +73,9 @@ public <REQUEST, RESPONSE> ClientHttpResponse<RESPONSE> syncHttpResponse(ClientH
 		}
 	}
 
-    /**
+	/**
 	 * Generate Web Client Response spec from http request.
-	 * 
+	 *
 	 * @param httpRequest
 	 * @return
 	 */
@@ -96,11 +96,11 @@ private <REQUEST, RESPONSE> WebClient.ResponseSpec generateResponseSpec(
 
 	}
 
-    /**
-     * Generates retry spec for the request based on config provided.
-     * @param httpRequest
-     * @return
-     */
+	/**
+	 * Generates retry spec for the request based on config provided.
+	 * @param httpRequest
+	 * @return
+	 */
 	private <REQUEST, RESPONSE> Retry generateRetrySpec(ClientHttpRequest<REQUEST, RESPONSE> httpRequest) {
 		return Retry
 				.fixedDelay(httpRequest.getClientRetryConfig().getMaxAttempts(),
@@ -112,7 +112,7 @@ private <REQUEST, RESPONSE> Retry generateRetrySpec(ClientHttpRequest<REQUEST, R
 
 	/**
 	 * Handle Success response.
-	 * 
+	 *
 	 * @param response
 	 * @return
 	 * @param <RESPONSE>
@@ -122,24 +122,24 @@ private <RESPONSE> ClientHttpResponse<RESPONSE> generateResponse(ResponseEntity<
 				.isSuccess2xx(response.getStatusCode().is2xxSuccessful()).build();
 	}
 
-    /**
-     * Handle Exception and send back response.
-     * @param exception
-     * @param errorMessage
-     * @param httpStatus
-     * @param httpRequest
-     * @return
-     * @param <RESPONSE>
-     */
-    private <REQUEST, RESPONSE> ClientHttpResponse<RESPONSE> handleException(
-            final Exception exception,
-            final String errorMessage,
-            final String responseBody,
-            final HttpStatus httpStatus,
-            final ClientHttpRequest<REQUEST, RESPONSE> httpRequest) {
-        log.error("Exception while executing http request for requestUrl={}, status={}, errorMessage={}", httpRequest.getUrl(), httpStatus, errorMessage);
-        httpRequest.getRetryHandlers()
-                .forEach(handlerId -> RetryHandlerFactory.getHandler(handlerId.toString()).checkAndThrowRetriableException(exception));
-        return ClientHttpResponse.<RESPONSE>builder().error(responseBody).status(httpStatus).build();
-    }
+	/**
+	 * Handle Exception and send back response.
+	 * @param exception
+	 * @param errorMessage
+	 * @param httpStatus
+	 * @param httpRequest
+	 * @return
+	 * @param <RESPONSE>
+	 */
+	private <REQUEST, RESPONSE> ClientHttpResponse<RESPONSE> handleException(
+			final Exception exception,
+			final String errorMessage,
+			final String responseBody,
+			final HttpStatus httpStatus,
+			final ClientHttpRequest<REQUEST, RESPONSE> httpRequest) {
+		log.error("Exception while executing http request for requestUrl={}, status={}, errorMessage={}", httpRequest.getUrl(), httpStatus, errorMessage);
+		httpRequest.getRetryHandlers()
+				.forEach(handlerId -> RetryHandlerFactory.getHandler(handlerId.toString()).checkAndThrowRetriableException(exception));
+		return ClientHttpResponse.<RESPONSE>builder().error(responseBody).status(httpStatus).build();
+	}
 }

src/test/java/com/intuit/springwebclient/client/CommonSpringWebClientTest.java

@@ -52,16 +52,16 @@ public void testSyncHttpResponseSuccess() {
 
         commonSpringWebClient.syncHttpResponse(clientHttpRequest);
     }
-    
-	@Test
-	public void testSyncHttpResponseSuccessNoRequestBody() {
-		ClientHttpRequest clientHttpRequest = createClientHttpRequest().request(null).requestType(null).build();
-		Mockito.when(webClient.method(HttpMethod.GET)).thenReturn(requestBodyUriSpec);
-	    Mockito.doReturn(requestBodyUriSpec).when(requestBodyUriSpec).uri("test-url");
-	    Mockito.when(requestBodyUriSpec.headers(Mockito.any())).thenReturn(requestBodySpec);
 
-		commonSpringWebClient.syncHttpResponse(clientHttpRequest);
-	}
+    @Test
+    public void testSyncHttpResponseSuccessNoRequestBody() {
+        ClientHttpRequest clientHttpRequest = createClientHttpRequest().request(null).requestType(null).build();
+        Mockito.when(webClient.method(HttpMethod.GET)).thenReturn(requestBodyUriSpec);
+        Mockito.doReturn(requestBodyUriSpec).when(requestBodyUriSpec).uri("test-url");
+        Mockito.when(requestBodyUriSpec.headers(Mockito.any())).thenReturn(requestBodySpec);
+
+        commonSpringWebClient.syncHttpResponse(clientHttpRequest);
+    }
 
     @Test
     public void testHttpStatusCodeException() {
@@ -115,12 +115,12 @@ public void accept(HttpHeaders httpHeaders) {
         httpHeadersConsumer.accept(httpHeadersMock);
 
         return ClientHttpRequest.builder()
-                .httpMethod(HttpMethod.GET)
-                .url("test-url")
-                .requestHeaders(httpHeadersMock)
-                .requestType(ParameterizedTypeReference.forType(String.class))
-                .request("hello")
-                .responseType(ParameterizedTypeReference.forType(String.class));
+            .httpMethod(HttpMethod.GET)
+            .url("test-url")
+            .requestHeaders(httpHeadersMock)
+            .requestType(ParameterizedTypeReference.forType(String.class))
+            .request("hello")
+            .responseType(ParameterizedTypeReference.forType(String.class));
     }
 
     private void mockRequestBody() {