Polish

spring-boot-project/spring-boot-actuator/src/main/java/org/springframework/boot/actuate/endpoint/web/reactive/ControllerEndpointHandlerMapping.java

@@ -95,8 +95,7 @@ public class ControllerEndpointHandlerMapping extends RequestMappingHandlerMappi
 			ExposableControllerEndpoint endpoint, RequestMappingInfo mapping) {
 		Set<PathPattern> patterns = mapping.getPatternsCondition().getPatterns();
 		if (patterns.isEmpty()) {
-			patterns = new HashSet<>(
-					Arrays.asList(getPathPatternParser().parse("")));
+			patterns = new HashSet<>(Arrays.asList(getPathPatternParser().parse("")));
 		}
 		PathPattern[] endpointMappedPatterns = patterns.stream()
 				.map((pattern) -> getEndpointMappedPattern(endpoint, pattern))

spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/jdbc/DataSourceJmxConfiguration.java

@@ -64,8 +64,8 @@ class DataSourceJmxConfiguration {
 		public void validateMBeans() {
 			HikariDataSource hikariDataSource = unwrapHikariDataSource();
 			if (hikariDataSource != null && hikariDataSource.isRegisterMbeans()) {
-				this.mBeanExporter.ifUnique((exporter) ->
-						exporter.addExcludedBean("dataSource"));
+				this.mBeanExporter
+						.ifUnique((exporter) -> exporter.addExcludedBean("dataSource"));
 			}
 		}
 

spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/ldap/embedded/EmbeddedLdapAutoConfiguration.java

@@ -218,12 +218,10 @@ public class EmbeddedLdapAutoConfiguration {
 				AnnotatedTypeMetadata metadata) {
 			Builder message = ConditionMessage.forCondition("Embedded LDAP");
 			Environment environment = context.getEnvironment();
-			if (environment != null
-					&& !Binder.get(environment)
+			if (environment != null && !Binder.get(environment)
 					.bind("spring.ldap.embedded.base-dn", STRING_LIST)
 					.orElseGet(Collections::emptyList).isEmpty()) {
-				return ConditionOutcome
-						.match(message.because("Found base-dn property"));
+				return ConditionOutcome.match(message.because("Found base-dn property"));
 			}
 			return ConditionOutcome.noMatch(message.because("No base-dn property found"));
 		}

spring-boot-project/spring-boot-autoconfigure/src/test/java/org/springframework/boot/autoconfigure/jdbc/DataSourceJmxConfigurationTests.java

@@ -49,18 +49,20 @@ import static org.assertj.core.api.Assertions.assertThat;
 public class DataSourceJmxConfigurationTests {
 
 	private final ApplicationContextRunner contextRunner = new ApplicationContextRunner()
-			.withPropertyValues("spring.datasource.url="
-					+ "jdbc:hsqldb:mem:test-" + UUID.randomUUID())
+			.withPropertyValues("spring.datasource.url=" + "jdbc:hsqldb:mem:test-"
+					+ UUID.randomUUID())
 			.withConfiguration(AutoConfigurations.of(JmxAutoConfiguration.class,
 					DataSourceAutoConfiguration.class));
 
 	@Test
 	public void hikariAutoConfiguredCanUseRegisterMBeans() {
 		String poolName = UUID.randomUUID().toString();
-		this.contextRunner.withPropertyValues(
+		this.contextRunner
+				.withPropertyValues(
 						"spring.datasource.type=" + HikariDataSource.class.getName(),
 						"spring.datasource.name=" + poolName,
-				"spring.datasource.hikari.register-mbeans=true").run((context) -> {
+						"spring.datasource.hikari.register-mbeans=true")
+				.run((context) -> {
 					assertThat(context).hasSingleBean(HikariDataSource.class);
 					assertThat(context.getBean(HikariDataSource.class).isRegisterMbeans())
 							.isTrue();
@@ -75,33 +77,38 @@ public class DataSourceJmxConfigurationTests {
 		MBeanServer mBeanServer = ManagementFactory.getPlatformMBeanServer();
 		Set<ObjectInstance> existingInstances = mBeanServer
 				.queryMBeans(new ObjectName("com.zaxxer.hikari:type=*"), null);
-		this.contextRunner.withPropertyValues(
+		this.contextRunner
+				.withPropertyValues(
 						"spring.datasource.type=" + HikariDataSource.class.getName(),
-				"spring.datasource.hikari.register-mbeans=true").run((context) -> {
+						"spring.datasource.hikari.register-mbeans=true")
+				.run((context) -> {
 					assertThat(context).hasSingleBean(HikariDataSource.class);
 					assertThat(context.getBean(HikariDataSource.class).isRegisterMbeans())
 							.isTrue();
-			// We can't rely on the number of MBeans so we're checking that the pool and pool
+					// We can't rely on the number of MBeans so we're checking that the
+					// pool and pool
 					// config MBeans were registered
 					assertThat(mBeanServer
-					.queryMBeans(new ObjectName("com.zaxxer.hikari:type=*"), null).size())
-					.isEqualTo(existingInstances.size() + 2);
+							.queryMBeans(new ObjectName("com.zaxxer.hikari:type=*"), null)
+							.size()).isEqualTo(existingInstances.size() + 2);
 				});
 	}
 
 	@Test
 	public void hikariAutoConfiguredUsesJmsFlag() {
 		String poolName = UUID.randomUUID().toString();
-		this.contextRunner.withPropertyValues(
+		this.contextRunner
+				.withPropertyValues(
 						"spring.datasource.type=" + HikariDataSource.class.getName(),
 						"spring.jmx.enabled=false", "spring.datasource.name=" + poolName,
-				"spring.datasource.hikari.register-mbeans=true").run((context) -> {
+						"spring.datasource.hikari.register-mbeans=true")
+				.run((context) -> {
 					assertThat(context).hasSingleBean(HikariDataSource.class);
 					assertThat(context.getBean(HikariDataSource.class).isRegisterMbeans())
 							.isTrue();
 					// Hikari can still register mBeans
-			validateHikariMBeansRegistration(ManagementFactory.getPlatformMBeanServer(),
-					poolName, true);
+					validateHikariMBeansRegistration(
+							ManagementFactory.getPlatformMBeanServer(), poolName, true);
 				});
 	}
 
@@ -115,8 +122,9 @@ public class DataSourceJmxConfigurationTests {
 						"spring.datasource.hikari.register-mbeans=true")
 				.run((context) -> {
 					assertThat(context).hasSingleBean(javax.sql.DataSource.class);
-					HikariDataSource hikariDataSource = context.getBean(
-							javax.sql.DataSource.class).unwrap(HikariDataSource.class);
+					HikariDataSource hikariDataSource = context
+							.getBean(javax.sql.DataSource.class)
+							.unwrap(HikariDataSource.class);
 					assertThat(hikariDataSource.isRegisterMbeans()).isTrue();
 					MBeanServer mBeanServer = context.getBean(MBeanServer.class);
 					validateHikariMBeansRegistration(mBeanServer, poolName, true);
@@ -136,9 +144,10 @@ public class DataSourceJmxConfigurationTests {
 	@Test
 	public void tomcatDoesNotExposeMBeanPoolByDefault() {
 		this.contextRunner
-				.withPropertyValues("spring.datasource.type=" + DataSource.class.getName())
-				.run((context) ->
-						assertThat(context).doesNotHaveBean(ConnectionPool.class));
+				.withPropertyValues(
+						"spring.datasource.type=" + DataSource.class.getName())
+				.run((context) -> assertThat(context)
+						.doesNotHaveBean(ConnectionPool.class));
 	}
 
 	@Test
@@ -147,7 +156,8 @@ public class DataSourceJmxConfigurationTests {
 				"spring.datasource.type=" + DataSource.class.getName(),
 				"spring.datasource.jmx-enabled=true").run((context) -> {
 					assertThat(context).hasSingleBean(ConnectionPool.class);
-			assertThat(context.getBean(DataSourceProxy.class).createPool().getJmxPool())
+					assertThat(context.getBean(DataSourceProxy.class).createPool()
+							.getJmxPool())
 									.isSameAs(context.getBean(ConnectionPool.class));
 				});
 	}
@@ -162,7 +172,6 @@ public class DataSourceJmxConfigurationTests {
 
 	}
 
-
 	private static class DataSourceBeanPostProcessor implements BeanPostProcessor {
 
 		@Override

spring-boot-project/spring-boot-test-autoconfigure/src/main/java/org/springframework/boot/test/autoconfigure/web/servlet/WebMvcTypeExcludeFilter.java

 /*
- * Copyright 2012-2017 the original author or authors.
+ * Copyright 2012-2018 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-test-autoconfigure/src/test/java/org/springframework/boot/test/autoconfigure/web/servlet/WebMvcTypeExcludeFilterTests.java

 /*
- * Copyright 2012-2017 the original author or authors.
+ * Copyright 2012-2018 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-tools/spring-boot-gradle-plugin/src/test/java/org/springframework/boot/gradle/tasks/bundling/PomCondition.java

 /*
- * Copyright 2012-2017 the original author or authors.
+ * Copyright 2012-2018 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.
@@ -22,8 +22,6 @@ import java.io.IOException;
 import java.util.HashSet;
 import java.util.Set;
 
-import org.assertj.core.api.Condition;
-import org.assertj.core.description.Description;
 import org.assertj.core.description.TextDescription;
 
 import org.springframework.util.FileCopyUtils;

spring-boot-project/spring-boot-tools/spring-boot-loader/src/main/java/org/springframework/boot/loader/jar/JarURLConnection.java

@@ -266,8 +266,7 @@ final class JarURLConnection extends java.net.JarURLConnection {
 			index = separator + SEPARATOR.length();
 		}
 		JarEntryName jarEntryName = JarEntryName.get(spec, index);
-		if (Boolean.TRUE.equals(useFastExceptions.get())
-				&& !jarEntryName.isEmpty()
+		if (Boolean.TRUE.equals(useFastExceptions.get()) && !jarEntryName.isEmpty()
 				&& !jarFile.containsEntry(jarEntryName.toString())) {
 			return NOT_FOUND_CONNECTION;
 		}

spring-boot-project/spring-boot-tools/spring-boot-maven-plugin/src/main/java/org/springframework/boot/maven/BuildInfoMojo.java

 /*
- * Copyright 2012-2017 the original author or authors.
+ * Copyright 2012-2018 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/src/main/java/org/springframework/boot/context/ApplicationPidFileWriter.java

@@ -142,8 +142,7 @@ public class ApplicationPidFileWriter
 				writePidFile(event);
 			}
 			catch (Exception ex) {
-				String message = String.format("Cannot create pid file %s",
-						this.file);
+				String message = String.format("Cannot create pid file %s", this.file);
 				if (failOnWriteError(event)) {
 					throw new IllegalStateException(message, ex);
 				}

spring-boot-project/spring-boot/src/main/java/org/springframework/boot/web/embedded/netty/CompressionCustomizer.java

@@ -16,9 +16,11 @@
 
 package org.springframework.boot.web.embedded.netty;
 
+import java.util.Arrays;
 import java.util.function.BiPredicate;
 
 import io.netty.handler.codec.http.HttpHeaderNames;
+import io.netty.handler.codec.http.HttpHeaders;
 import reactor.ipc.netty.http.server.HttpServerOptions;
 import reactor.ipc.netty.http.server.HttpServerRequest;
 import reactor.ipc.netty.http.server.HttpServerResponse;
@@ -26,11 +28,14 @@ import reactor.ipc.netty.http.server.HttpServerResponse;
 import org.springframework.boot.web.server.Compression;
 import org.springframework.util.MimeType;
 import org.springframework.util.MimeTypeUtils;
+import org.springframework.util.ObjectUtils;
+import org.springframework.util.StringUtils;
 
 /**
  * Configure the HTTP compression on an Reactor Netty request/response handler.
  *
  * @author Stephane Maldini
+ * @author Phillip Webb
  */
 final class CompressionCustomizer implements NettyServerCustomizer {
 
@@ -45,71 +50,46 @@ final class CompressionCustomizer implements NettyServerCustomizer {
 		if (this.compression.getMinResponseSize() >= 0) {
 			builder.compression(this.compression.getMinResponseSize());
 		}
-		BiPredicate<HttpServerRequest, HttpServerResponse> compressPredicate = null;
-		if (this.compression.getMimeTypes() != null &&
-				this.compression.getMimeTypes().length > 0) {
-			compressPredicate = new CompressibleMimeTypePredicate(this.compression.getMimeTypes());
-		}
-		if (this.compression.getExcludedUserAgents() != null &&
-				this.compression.getExcludedUserAgents().length > 0) {
-			BiPredicate<HttpServerRequest, HttpServerResponse> agentCompressPredicate =
-					new CompressibleAgentPredicate(this.compression.getExcludedUserAgents());
-			compressPredicate = compressPredicate == null ?
-					agentCompressPredicate :
-					compressPredicate.and(agentCompressPredicate);
-		}
-		if (compressPredicate != null) {
-			builder.compression(compressPredicate);
-		}
+		CompressionPredicate mimeTypes = getMimeTypesPredicate(
+				this.compression.getMimeTypes());
+		CompressionPredicate excludedUserAgents = getExcludedUserAgentsPredicate(
+				this.compression.getExcludedUserAgents());
+		builder.compression(mimeTypes.and(excludedUserAgents));
 	}
 
-	private static class CompressibleAgentPredicate
-			implements BiPredicate<HttpServerRequest, HttpServerResponse> {
-
-		private final String[] excludedAgents;
-
-		CompressibleAgentPredicate(String[] excludedAgents) {
-			this.excludedAgents = new String[excludedAgents.length];
-			System.arraycopy(excludedAgents, 0, this.excludedAgents, 0, excludedAgents.length);
+	private CompressionPredicate getMimeTypesPredicate(String[] mimeTypes) {
+		if (ObjectUtils.isEmpty(mimeTypes)) {
+			return CompressionPredicate.ALWAYS;
 		}
-
-		@Override
-		public boolean test(HttpServerRequest request, HttpServerResponse response) {
-			for (String excludedAgent : this.excludedAgents) {
-				if (request.requestHeaders()
-						.contains(HttpHeaderNames.USER_AGENT, excludedAgent, true)) {
+		return (request, response) -> {
+			String contentType = response.responseHeaders()
+					.get(HttpHeaderNames.CONTENT_TYPE);
+			if (StringUtils.isEmpty(contentType)) {
 				return false;
 			}
+			MimeType contentMimeType = MimeTypeUtils.parseMimeType(contentType);
+			return Arrays.stream(mimeTypes).map(MimeTypeUtils::parseMimeType)
+					.anyMatch((candidate) -> candidate.isCompatibleWith(contentMimeType));
+		};
 	}
-			return true;
+
+	private CompressionPredicate getExcludedUserAgentsPredicate(
+			String[] excludedUserAgents) {
+		if (ObjectUtils.isEmpty(excludedUserAgents)) {
+			return CompressionPredicate.ALWAYS;
 		}
+		return (request, response) -> {
+			HttpHeaders headers = request.requestHeaders();
+			return Arrays.stream(excludedUserAgents).noneMatch((candidate) -> headers
+					.contains(HttpHeaderNames.USER_AGENT, candidate, true));
+		};
 	}
 
-	private static class CompressibleMimeTypePredicate
-			implements BiPredicate<HttpServerRequest, HttpServerResponse> {
+	private interface CompressionPredicate
+			extends BiPredicate<HttpServerRequest, HttpServerResponse> {
 
-		private final MimeType[] mimeTypes;
+		static final CompressionPredicate ALWAYS = (request, response) -> true;
 
-		CompressibleMimeTypePredicate(String[] mimeTypes) {
-			this.mimeTypes = new MimeType[mimeTypes.length];
-			for (int i = 0; i < mimeTypes.length; i++) {
-				this.mimeTypes[i] = MimeTypeUtils.parseMimeType(mimeTypes[i]);
-			}
 	}
 
-		@Override
-		public boolean test(HttpServerRequest request, HttpServerResponse response) {
-			String contentType = response.responseHeaders()
-					.get(HttpHeaderNames.CONTENT_TYPE);
-			if (contentType != null) {
-				for (MimeType mimeType : this.mimeTypes) {
-					if (mimeType.isCompatibleWith(MimeTypeUtils.parseMimeType(contentType))) {
-						return true;
-					}
-				}
-			}
-			return false;
-		}
-
-	}
 }

spring-boot-project/spring-boot/src/test/java/org/springframework/boot/web/reactive/server/AbstractReactiveWebServerFactoryTests.java

@@ -286,7 +286,7 @@ public abstract class AbstractReactiveWebServerFactoryTests {
 	@Test
 	public void noCompressionForMimeType() {
 		Compression compression = new Compression();
-		compression.setMimeTypes(new String[] {"application/json"});
+		compression.setMimeTypes(new String[] { "application/json" });
 		WebClient client = prepareCompressionTest(compression);
 		ResponseEntity<Void> response = client.get().exchange()
 				.flatMap((res) -> res.toEntity(Void.class)).block();
@@ -297,7 +297,7 @@ public abstract class AbstractReactiveWebServerFactoryTests {
 	public void noCompressionForUserAgent() {
 		Compression compression = new Compression();
 		compression.setEnabled(true);
-		compression.setExcludedUserAgents(new String[] {"testUserAgent"});
+		compression.setExcludedUserAgents(new String[] { "testUserAgent" });
 		WebClient client = prepareCompressionTest(compression);
 		ResponseEntity<Void> response = client.get().header("User-Agent", "testUserAgent")
 				.exchange().flatMap((res) -> res.toEntity(Void.class)).block();