chore: apply formatting and checkstyle

Author: SteKoe

spring-boot-admin-server/src/main/java/de/codecentric/boot/admin/server/web/servlet/InstancesProxyController.java

@@ -87,37 +87,42 @@ public InstancesProxyController(String adminContextPath, Set<String> ignoredHead
 			RequestMethod.PUT, RequestMethod.PATCH, RequestMethod.DELETE, RequestMethod.OPTIONS })
 	public void instanceProxy(@PathVariable("instanceId") String instanceId, HttpServletRequest servletRequest) {
 		// start async because we will commit from different thread.
-		// otherwise incorrect thread local objects (session and security context) will be stored.
-		// check for example org.springframework.security.web.context.HttpSessionSecurityContextRepository.SaveToSessionRequestWrapper.startAsync()
+		// otherwise incorrect thread local objects (session and security context) will be
+		// stored.
+		// check for example
+		// org.springframework.security.web.context.HttpSessionSecurityContextRepository.SaveToSessionRequestWrapper.startAsync()
 		AsyncContext asyncContext = servletRequest.startAsync();
-		asyncContext.setTimeout(-1); // no timeout because instanceWebProxy will handle it for us
+		asyncContext.setTimeout(-1); // no timeout because instanceWebProxy will handle it
+										// for us
 		try {
-			ServletServerHttpRequest request = new ServletServerHttpRequest((HttpServletRequest) asyncContext.getRequest());
+			ServletServerHttpRequest request = new ServletServerHttpRequest(
+					(HttpServletRequest) asyncContext.getRequest());
 			Flux<DataBuffer> requestBody = DataBufferUtils.readInputStream(request::getBody, this.bufferFactory, 4096);
 			InstanceWebProxy.ForwardRequest fwdRequest = createForwardRequest(request, requestBody,
-				this.adminContextPath + INSTANCE_MAPPED_PATH);
-
+					this.adminContextPath + INSTANCE_MAPPED_PATH);
 
 			this.instanceWebProxy
-				.forward(this.registry.getInstance(InstanceId.of(instanceId)), fwdRequest, (clientResponse) -> {
-					ServerHttpResponse response = new ServletServerHttpResponse((HttpServletResponse) asyncContext.getResponse());
-					response.setStatusCode(clientResponse.statusCode());
-					response.getHeaders()
-						.addAll(this.httpHeadersFilter.filterHeaders(clientResponse.headers().asHttpHeaders()));
-					try {
-						OutputStream responseBody = response.getBody();
-						response.flush();
-						return clientResponse.body(BodyExtractors.toDataBuffers()).window(1)
-							.concatMap((body) -> writeAndFlush(body, responseBody)).then();
-					}
-					catch (IOException ex) {
-						return Mono.error(ex);
-					}
-				})
-				// We need to explicitly block so the headers are recieved and written
-				// before any async dispatch otherwise the FrameworkServlet will add wrong
-				// Allow header for OPTIONS request
-				.block();
+					.forward(this.registry.getInstance(InstanceId.of(instanceId)), fwdRequest, (clientResponse) -> {
+						ServerHttpResponse response = new ServletServerHttpResponse(
+								(HttpServletResponse) asyncContext.getResponse());
+						response.setStatusCode(clientResponse.statusCode());
+						response.getHeaders()
+								.addAll(this.httpHeadersFilter.filterHeaders(clientResponse.headers().asHttpHeaders()));
+						try {
+							OutputStream responseBody = response.getBody();
+							response.flush();
+							return clientResponse.body(BodyExtractors.toDataBuffers()).window(1)
+									.concatMap((body) -> writeAndFlush(body, responseBody)).then();
+						}
+						catch (IOException ex) {
+							return Mono.error(ex);
+						}
+					})
+					// We need to explicitly block so the headers are recieved and written
+					// before any async dispatch otherwise the FrameworkServlet will add
+					// wrong
+					// Allow header for OPTIONS request
+					.block();
 		}
 		finally {
 			asyncContext.complete();

spring-boot-admin-server/src/test/java/de/codecentric/boot/admin/server/web/AbstractInstancesProxyControllerIntegrationTest.java

@@ -126,8 +126,8 @@ public void should_return_status_502() {
 	public void should_return_status_504() {
 		// 504 on read timeout
 		this.client.get().uri("/instances/{instanceId}/actuator/timeout", this.instanceId)
-    .accept(new MediaType(ApiVersion.LATEST.getProducedMimeType()))
-		.exchange().expectStatus().isEqualTo(HttpStatus.GATEWAY_TIMEOUT);
+				.accept(new MediaType(ApiVersion.LATEST.getProducedMimeType())).exchange().expectStatus()
+				.isEqualTo(HttpStatus.GATEWAY_TIMEOUT);
 	}
 
 	@Test
@@ -197,13 +197,13 @@ private void stubForInstance(String managementPath) {
 
 		//@formatter:off
 		String actuatorIndex = "{ \"_links\": { " +
-							"\"env\": { \"href\": \"" + managementUrl + "/env\", \"templated\": false }," +
-							"\"test\": { \"href\": \"" + managementUrl + "/test\", \"templated\": false }," +
-							"\"post\": { \"href\": \"" + managementUrl + "/post\", \"templated\": false }," +
-							"\"delete\": { \"href\": \"" + managementUrl + "/delete\", \"templated\": false }," +
-							"\"invalid\": { \"href\": \"" + managementUrl + "/invalid\", \"templated\": false }," +
-							"\"timeout\": { \"href\": \"" + managementUrl + "/timeout\", \"templated\": false }" +
-							" } }";
+			"\"env\": { \"href\": \"" + managementUrl + "/env\", \"templated\": false }," +
+			"\"test\": { \"href\": \"" + managementUrl + "/test\", \"templated\": false }," +
+			"\"post\": { \"href\": \"" + managementUrl + "/post\", \"templated\": false }," +
+			"\"delete\": { \"href\": \"" + managementUrl + "/delete\", \"templated\": false }," +
+			"\"invalid\": { \"href\": \"" + managementUrl + "/invalid\", \"templated\": false }," +
+			"\"timeout\": { \"href\": \"" + managementUrl + "/timeout\", \"templated\": false }" +
+			" } }";
 		//@formatter:on
 		this.wireMock.stubFor(get(urlEqualTo(managementPath + "/health")).willReturn(ok("{ \"status\" : \"UP\" }")
 				.withHeader(CONTENT_TYPE, ApiVersion.LATEST.getProducedMimeType().toString())));
@@ -242,17 +242,17 @@ private String sendRegistration(String managementPath) {
 
 		//@formatter:off
 		String registration = "{ \"name\": \"test\", " +
-							"\"healthUrl\": \"" + managementUrl + "/health\", " +
-							"\"managementUrl\": \"" + managementUrl + "\" }";
+			"\"healthUrl\": \"" + managementUrl + "/health\", " +
+			"\"managementUrl\": \"" + managementUrl + "\" }";
 
 		EntityExchangeResult<Map<String, Object>> result = this.client.post()
-																.uri("/instances")
-																.accept(MediaType.APPLICATION_JSON).contentType(MediaType.APPLICATION_JSON)
-																.bodyValue(registration)
-																.exchange()
-																.expectStatus().isCreated()
-																.expectBody(RESPONSE_TYPE)
-																.returnResult();
+			.uri("/instances")
+			.accept(MediaType.APPLICATION_JSON).contentType(MediaType.APPLICATION_JSON)
+			.bodyValue(registration)
+			.exchange()
+			.expectStatus().isCreated()
+			.expectBody(RESPONSE_TYPE)
+			.returnResult();
 		//@formatter:on
 		assertThat(result.getResponseBody()).containsKeys("id");
 		return result.getResponseBody().get("id").toString();
@@ -261,9 +261,9 @@ private String sendRegistration(String managementPath) {
 	private Flux<Map<String, Object>> getEventStream() {
 		//@formatter:off
 		return this.client.get().uri("/instances/events").accept(MediaType.TEXT_EVENT_STREAM)
-						.exchange()
-						.expectStatus().isOk()
-						.returnResult(RESPONSE_TYPE).getResponseBody();
+			.exchange()
+			.expectStatus().isOk()
+			.returnResult(RESPONSE_TYPE).getResponseBody();
 		//@formatter:on
 	}