Merge branch '1.5.x'

pull/8889/head
Phillip Webb 8 years ago
commit c4cba6b0ea

@ -68,17 +68,19 @@ public class LoggersMvcEndpoint extends EndpointMvcAdapter {
// disabled // disabled
return getDisabledResponse(); return getDisabledResponse();
} }
LogLevel logLevel;
try { try {
String level = configuration.get("configuredLevel"); LogLevel logLevel = getLogLevel(configuration);
logLevel = level == null ? null : LogLevel.valueOf(level.toUpperCase()); this.delegate.setLogLevel(name, logLevel);
return ResponseEntity.ok().build();
} }
catch (IllegalArgumentException ex) { catch (IllegalArgumentException ex) {
return ResponseEntity.badRequest().build(); return ResponseEntity.badRequest().build();
} }
}
this.delegate.setLogLevel(name, logLevel); private LogLevel getLogLevel(Map<String, String> configuration) {
return ResponseEntity.ok().build(); String level = configuration.get("configuredLevel");
return (level == null ? null : LogLevel.valueOf(level.toUpperCase()));
} }
} }

@ -41,13 +41,10 @@ public class SolrHealthIndicator extends AbstractHealthIndicator {
CoreAdminRequest request = new CoreAdminRequest(); CoreAdminRequest request = new CoreAdminRequest();
request.setAction(CoreAdminParams.CoreAdminAction.STATUS); request.setAction(CoreAdminParams.CoreAdminAction.STATUS);
CoreAdminResponse response = request.process(this.solrClient); CoreAdminResponse response = request.process(this.solrClient);
int status = response.getStatus(); int statusCode = response.getStatus();
if (status == 0) { Status status = (statusCode == 0 ? Status.UP : Status.DOWN);
builder.up().withDetail("solrStatus", "OK"); builder.status(status).withDetail("solrStatus",
} (statusCode == 0 ? "OK" : statusCode));
else {
builder.down().withDetail("solrStatus", status);
}
} }
} }

@ -138,7 +138,7 @@ public class WebRequestTraceFilter extends OncePerRequestFilter implements Order
add(trace, Include.USER_PRINCIPAL, "userPrincipal", add(trace, Include.USER_PRINCIPAL, "userPrincipal",
(userPrincipal == null ? null : userPrincipal.getName())); (userPrincipal == null ? null : userPrincipal.getName()));
if (isIncluded(Include.PARAMETERS)) { if (isIncluded(Include.PARAMETERS)) {
trace.put("parameters", getParameterMap(request)); trace.put("parameters", getParameterMapCopy(request));
} }
add(trace, Include.QUERY_STRING, "query", request.getQueryString()); add(trace, Include.QUERY_STRING, "query", request.getQueryString());
add(trace, Include.AUTH_TYPE, "authType", request.getAuthType()); add(trace, Include.AUTH_TYPE, "authType", request.getAuthType());
@ -190,10 +190,8 @@ public class WebRequestTraceFilter extends OncePerRequestFilter implements Order
return value; return value;
} }
private Map<String, String[]> getParameterMap(HttpServletRequest request) { private Map<String, String[]> getParameterMapCopy(HttpServletRequest request) {
Map<String, String[]> map = new LinkedHashMap<String, String[]>(); return new LinkedHashMap<String, String[]>(request.getParameterMap());
map.putAll(request.getParameterMap());
return map;
} }
/** /**

@ -66,7 +66,7 @@ public class TraceWebFilterAutoConfigurationTests {
public void skipsFilterIfPropertyDisabled() throws Exception { public void skipsFilterIfPropertyDisabled() throws Exception {
load("endpoints.trace.filter.enabled:false"); load("endpoints.trace.filter.enabled:false");
assertThat(this.context.getBeansOfType(WebRequestTraceFilter.class).size()) assertThat(this.context.getBeansOfType(WebRequestTraceFilter.class).size())
.isEqualTo(0); .isEqualTo(0);
} }
private void load(String... environment) { private void load(String... environment) {
@ -74,16 +74,16 @@ public class TraceWebFilterAutoConfigurationTests {
} }
private void load(Class<?> config, String... environment) { private void load(Class<?> config, String... environment) {
AnnotationConfigApplicationContext ctx = new AnnotationConfigApplicationContext(); AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext();
EnvironmentTestUtils.addEnvironment(ctx, environment); EnvironmentTestUtils.addEnvironment(context, environment);
if (config != null) { if (config != null) {
ctx.register(config); context.register(config);
} }
ctx.register(PropertyPlaceholderAutoConfiguration.class, context.register(PropertyPlaceholderAutoConfiguration.class,
TraceRepositoryAutoConfiguration.class, TraceRepositoryAutoConfiguration.class,
TraceWebFilterAutoConfiguration.class); TraceWebFilterAutoConfiguration.class);
ctx.refresh(); context.refresh();
this.context = ctx; this.context = context;
} }
@Configuration @Configuration

@ -31,9 +31,9 @@ import org.springframework.boot.autoconfigure.solr.SolrAutoConfiguration;
import org.springframework.context.annotation.AnnotationConfigApplicationContext; import org.springframework.context.annotation.AnnotationConfigApplicationContext;
import static org.assertj.core.api.Assertions.assertThat; import static org.assertj.core.api.Assertions.assertThat;
import static org.mockito.ArgumentMatchers.any;
import static org.mockito.ArgumentMatchers.isNull;
import static org.mockito.BDDMockito.given; import static org.mockito.BDDMockito.given;
import static org.mockito.Matchers.any;
import static org.mockito.Matchers.isNull;
import static org.mockito.Mockito.mock; import static org.mockito.Mockito.mock;
/** /**
@ -68,7 +68,7 @@ public class SolrHealthIndicatorTests {
public void solrIsUp() throws Exception { public void solrIsUp() throws Exception {
SolrClient solrClient = mock(SolrClient.class); SolrClient solrClient = mock(SolrClient.class);
given(solrClient.request(any(CoreAdminRequest.class), isNull())) given(solrClient.request(any(CoreAdminRequest.class), isNull()))
.willReturn(mockResponse(0)); .willReturn(mockResponse(0));
SolrHealthIndicator healthIndicator = new SolrHealthIndicator(solrClient); SolrHealthIndicator healthIndicator = new SolrHealthIndicator(solrClient);
Health health = healthIndicator.health(); Health health = healthIndicator.health();
assertThat(health.getStatus()).isEqualTo(Status.UP); assertThat(health.getStatus()).isEqualTo(Status.UP);
@ -79,7 +79,7 @@ public class SolrHealthIndicatorTests {
public void solrIsUpAndRequestFailed() throws Exception { public void solrIsUpAndRequestFailed() throws Exception {
SolrClient solrClient = mock(SolrClient.class); SolrClient solrClient = mock(SolrClient.class);
given(solrClient.request(any(CoreAdminRequest.class), isNull())) given(solrClient.request(any(CoreAdminRequest.class), isNull()))
.willReturn(mockResponse(400)); .willReturn(mockResponse(400));
SolrHealthIndicator healthIndicator = new SolrHealthIndicator(solrClient); SolrHealthIndicator healthIndicator = new SolrHealthIndicator(solrClient);
Health health = healthIndicator.health(); Health health = healthIndicator.health();
assertThat(health.getStatus()).isEqualTo(Status.DOWN); assertThat(health.getStatus()).isEqualTo(Status.DOWN);
@ -90,7 +90,7 @@ public class SolrHealthIndicatorTests {
public void solrIsDown() throws Exception { public void solrIsDown() throws Exception {
SolrClient solrClient = mock(SolrClient.class); SolrClient solrClient = mock(SolrClient.class);
given(solrClient.request(any(CoreAdminRequest.class), isNull())) given(solrClient.request(any(CoreAdminRequest.class), isNull()))
.willThrow(new IOException("Connection failed")); .willThrow(new IOException("Connection failed"));
SolrHealthIndicator healthIndicator = new SolrHealthIndicator(solrClient); SolrHealthIndicator healthIndicator = new SolrHealthIndicator(solrClient);
Health health = healthIndicator.health(); Health health = healthIndicator.health();
assertThat(health.getStatus()).isEqualTo(Status.DOWN); assertThat(health.getStatus()).isEqualTo(Status.DOWN);

@ -20,13 +20,8 @@ import java.util.ArrayList;
import java.util.Arrays; import java.util.Arrays;
import java.util.List; import java.util.List;
import org.springframework.boot.autoconfigure.template.AbstractTemplateAvailabilityProvider;
import org.springframework.boot.autoconfigure.template.TemplateAvailabilityProvider; import org.springframework.boot.autoconfigure.template.TemplateAvailabilityProvider;
import org.springframework.boot.bind.PropertySourcesPropertyValues;
import org.springframework.boot.bind.RelaxedDataBinder;
import org.springframework.core.env.ConfigurableEnvironment;
import org.springframework.core.env.Environment;
import org.springframework.core.io.ResourceLoader;
import org.springframework.util.ClassUtils;
/** /**
* {@link TemplateAvailabilityProvider} that provides availability information for * {@link TemplateAvailabilityProvider} that provides availability information for
@ -36,35 +31,28 @@ import org.springframework.util.ClassUtils;
* @since 1.1.0 * @since 1.1.0
*/ */
public class FreeMarkerTemplateAvailabilityProvider public class FreeMarkerTemplateAvailabilityProvider
implements TemplateAvailabilityProvider { extends AbstractTemplateAvailabilityProvider {
@Override public FreeMarkerTemplateAvailabilityProvider() {
public boolean isTemplateAvailable(String view, Environment environment, super("freemarker.template.Configuration",
ClassLoader classLoader, ResourceLoader resourceLoader) { FreeMarkerTemplateAvailabilityProperties.class, "spring.freemarker");
if (ClassUtils.isPresent("freemarker.template.Configuration", classLoader)) {
FreeMarkerTemplateAvailabilityProperties properties = new FreeMarkerTemplateAvailabilityProperties();
RelaxedDataBinder binder = new RelaxedDataBinder(properties,
"spring.freemarker");
binder.bind(new PropertySourcesPropertyValues(
((ConfigurableEnvironment) environment).getPropertySources()));
for (String loaderPath : properties.getTemplateLoaderPath()) {
if (resourceLoader.getResource(loaderPath + properties.getPrefix() + view
+ properties.getSuffix()).exists()) {
return true;
}
}
}
return false;
} }
static final class FreeMarkerTemplateAvailabilityProperties { static final class FreeMarkerTemplateAvailabilityProperties
extends TemplateAvailabilityProperties {
private List<String> templateLoaderPath = new ArrayList<String>( private List<String> templateLoaderPath = new ArrayList<String>(
Arrays.asList(FreeMarkerProperties.DEFAULT_TEMPLATE_LOADER_PATH)); Arrays.asList(FreeMarkerProperties.DEFAULT_TEMPLATE_LOADER_PATH));
private String prefix = FreeMarkerProperties.DEFAULT_PREFIX; FreeMarkerTemplateAvailabilityProperties() {
super(FreeMarkerProperties.DEFAULT_PREFIX,
FreeMarkerProperties.DEFAULT_SUFFIX);
}
private String suffix = FreeMarkerProperties.DEFAULT_SUFFIX; @Override
protected List<String> getLoaderPath() {
return this.templateLoaderPath;
}
public List<String> getTemplateLoaderPath() { public List<String> getTemplateLoaderPath() {
return this.templateLoaderPath; return this.templateLoaderPath;
@ -74,22 +62,6 @@ public class FreeMarkerTemplateAvailabilityProvider
this.templateLoaderPath = templateLoaderPath; this.templateLoaderPath = templateLoaderPath;
} }
public String getPrefix() {
return this.prefix;
}
public void setPrefix(String prefix) {
this.prefix = prefix;
}
public String getSuffix() {
return this.suffix;
}
public void setSuffix(String suffix) {
this.suffix = suffix;
}
} }
} }

@ -20,13 +20,8 @@ import java.util.ArrayList;
import java.util.Arrays; import java.util.Arrays;
import java.util.List; import java.util.List;
import org.springframework.boot.autoconfigure.template.AbstractTemplateAvailabilityProvider;
import org.springframework.boot.autoconfigure.template.TemplateAvailabilityProvider; import org.springframework.boot.autoconfigure.template.TemplateAvailabilityProvider;
import org.springframework.boot.bind.PropertySourcesPropertyValues;
import org.springframework.boot.bind.RelaxedDataBinder;
import org.springframework.core.env.ConfigurableEnvironment;
import org.springframework.core.env.Environment;
import org.springframework.core.io.ResourceLoader;
import org.springframework.util.ClassUtils;
/** /**
* {@link TemplateAvailabilityProvider} that provides availability information for Groovy * {@link TemplateAvailabilityProvider} that provides availability information for Groovy
@ -35,35 +30,29 @@ import org.springframework.util.ClassUtils;
* @author Dave Syer * @author Dave Syer
* @since 1.1.0 * @since 1.1.0
*/ */
public class GroovyTemplateAvailabilityProvider implements TemplateAvailabilityProvider { public class GroovyTemplateAvailabilityProvider
extends AbstractTemplateAvailabilityProvider {
@Override public GroovyTemplateAvailabilityProvider() {
public boolean isTemplateAvailable(String view, Environment environment, super("groovy.text.TemplateEngine", GroovyTemplateAvailabilityProperties.class,
ClassLoader classLoader, ResourceLoader resourceLoader) { "spring.groovy.template");
if (ClassUtils.isPresent("groovy.text.TemplateEngine", classLoader)) {
GroovyTemplateAvailabilityProperties properties = new GroovyTemplateAvailabilityProperties();
RelaxedDataBinder binder = new RelaxedDataBinder(properties,
"spring.groovy.template");
binder.bind(new PropertySourcesPropertyValues(
((ConfigurableEnvironment) environment).getPropertySources()));
for (String loaderPath : properties.getResourceLoaderPath()) {
if (resourceLoader.getResource(loaderPath + properties.getPrefix() + view
+ properties.getSuffix()).exists()) {
return true;
}
}
}
return false;
} }
static final class GroovyTemplateAvailabilityProperties { static final class GroovyTemplateAvailabilityProperties
extends TemplateAvailabilityProperties {
private List<String> resourceLoaderPath = new ArrayList<String>( private List<String> resourceLoaderPath = new ArrayList<String>(
Arrays.asList(GroovyTemplateProperties.DEFAULT_RESOURCE_LOADER_PATH)); Arrays.asList(GroovyTemplateProperties.DEFAULT_RESOURCE_LOADER_PATH));
private String prefix = GroovyTemplateProperties.DEFAULT_PREFIX; GroovyTemplateAvailabilityProperties() {
super(GroovyTemplateProperties.DEFAULT_PREFIX,
GroovyTemplateProperties.DEFAULT_SUFFIX);
}
private String suffix = GroovyTemplateProperties.DEFAULT_SUFFIX; @Override
protected List<String> getLoaderPath() {
return this.resourceLoaderPath;
}
public List<String> getResourceLoaderPath() { public List<String> getResourceLoaderPath() {
return this.resourceLoaderPath; return this.resourceLoaderPath;
@ -73,22 +62,6 @@ public class GroovyTemplateAvailabilityProvider implements TemplateAvailabilityP
this.resourceLoaderPath = resourceLoaderPath; this.resourceLoaderPath = resourceLoaderPath;
} }
public String getPrefix() {
return this.prefix;
}
public void setPrefix(String prefix) {
this.prefix = prefix;
}
public String getSuffix() {
return this.suffix;
}
public void setSuffix(String suffix) {
this.suffix = suffix;
}
} }
} }

@ -0,0 +1,110 @@
/*
* Copyright 2012-2017 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.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.springframework.boot.autoconfigure.template;
import java.util.List;
import org.springframework.beans.BeanUtils;
import org.springframework.boot.bind.PropertySourcesPropertyValues;
import org.springframework.boot.bind.RelaxedDataBinder;
import org.springframework.core.env.ConfigurableEnvironment;
import org.springframework.core.env.Environment;
import org.springframework.core.io.ResourceLoader;
import org.springframework.util.ClassUtils;
/**
* Abstract base class for {@link TemplateAvailabilityProvider} implementations.
*
* @author Andy Wilkinson
* @author Phillip Webb
* @since 1.4.6
*/
public abstract class AbstractTemplateAvailabilityProvider
implements TemplateAvailabilityProvider {
private final String className;
private final Class<? extends TemplateAvailabilityProperties> propertiesClass;
private final String propertyPrefix;
public AbstractTemplateAvailabilityProvider(String className,
Class<? extends TemplateAvailabilityProperties> propertiesClass,
String propertyPrefix) {
this.className = className;
this.propertiesClass = propertiesClass;
this.propertyPrefix = propertyPrefix;
}
@Override
public boolean isTemplateAvailable(String view, Environment environment,
ClassLoader classLoader, ResourceLoader resourceLoader) {
if (ClassUtils.isPresent(this.className, classLoader)) {
TemplateAvailabilityProperties properties = BeanUtils
.instantiateClass(this.propertiesClass);
RelaxedDataBinder binder = new RelaxedDataBinder(properties,
this.propertyPrefix);
binder.bind(new PropertySourcesPropertyValues(
((ConfigurableEnvironment) environment).getPropertySources()));
return isTemplateAvailable(view, resourceLoader, properties);
}
return false;
}
private boolean isTemplateAvailable(String view, ResourceLoader resourceLoader,
TemplateAvailabilityProperties properties) {
String location = properties.getPrefix() + view + properties.getSuffix();
for (String path : properties.getLoaderPath()) {
if (resourceLoader.getResource(path + location).exists()) {
return true;
}
}
return false;
}
protected static abstract class TemplateAvailabilityProperties {
private String prefix;
private String suffix;
protected TemplateAvailabilityProperties(String prefix, String suffix) {
this.prefix = prefix;
this.suffix = suffix;
}
protected abstract List<String> getLoaderPath();
public String getPrefix() {
return this.prefix;
}
public void setPrefix(String prefix) {
this.prefix = prefix;
}
public String getSuffix() {
return this.suffix;
}
public void setSuffix(String suffix) {
this.suffix = suffix;
}
}
}

@ -66,8 +66,8 @@ public class ValidationAutoConfiguration {
} }
private static boolean determineProxyTargetClass(Environment environment) { private static boolean determineProxyTargetClass(Environment environment) {
RelaxedPropertyResolver resolver = new RelaxedPropertyResolver( RelaxedPropertyResolver resolver = new RelaxedPropertyResolver(environment,
environment, "spring.aop."); "spring.aop.");
Boolean value = resolver.getProperty("proxyTargetClass", Boolean.class); Boolean value = resolver.getProperty("proxyTargetClass", Boolean.class);
return (value != null ? value : true); return (value != null ? value : true);
} }

@ -78,12 +78,12 @@ public class ValidationAutoConfigurationTests {
@Test @Test
public void validationCanBeConfiguredToUseJdkProxy() { public void validationCanBeConfiguredToUseJdkProxy() {
load(AnotherSampleServiceConfiguration.class, "spring.aop.proxy-target-class=false"); load(AnotherSampleServiceConfiguration.class,
"spring.aop.proxy-target-class=false");
assertThat(this.context.getBeansOfType(Validator.class)).hasSize(1); assertThat(this.context.getBeansOfType(Validator.class)).hasSize(1);
assertThat(this.context.getBeansOfType(DefaultAnotherSampleService.class)) assertThat(this.context.getBeansOfType(DefaultAnotherSampleService.class))
.isEmpty(); .isEmpty();
AnotherSampleService service = this.context AnotherSampleService service = this.context.getBean(AnotherSampleService.class);
.getBean(AnotherSampleService.class);
service.doSomething(42); service.doSomething(42);
this.thrown.expect(ConstraintViolationException.class); this.thrown.expect(ConstraintViolationException.class);
service.doSomething(2); service.doSomething(2);

@ -726,52 +726,52 @@ Sample summarized HTTP response (default for anonymous request):
[source,indent=0] [source,indent=0]
---- ----
$ curl -i localhost:8080/health $ curl -i localhost:8080/health
HTTP/1.1 200 HTTP/1.1 200
X-Application-Context: application X-Application-Context: application
Content-Type: application/vnd.spring-boot.actuator.v2+json;charset=UTF-8 Content-Type: application/vnd.spring-boot.actuator.v2+json;charset=UTF-8
Content-Length: 15 Content-Length: 15
{"status":"UP"} {"status":"UP"}
---- ----
Sample summarized HTTP response for status "DOWN" (notice the 503 status code): Sample summarized HTTP response for status "DOWN" (notice the 503 status code):
[source,indent=0] [source,indent=0]
---- ----
$ curl -i localhost:8080/health $ curl -i localhost:8080/health
HTTP/1.1 503 HTTP/1.1 503
X-Application-Context: application X-Application-Context: application
Content-Type: application/vnd.spring-boot.actuator.v2+json;charset=UTF-8 Content-Type: application/vnd.spring-boot.actuator.v2+json;charset=UTF-8
Content-Length: 17 Content-Length: 17
{"status":"DOWN"} {"status":"DOWN"}
---- ----
Sample detailed HTTP response: Sample detailed HTTP response:
[source,indent=0] [source,indent=0]
---- ----
$ curl -i localhost:8080/health $ curl -i localhost:8080/health
HTTP/1.1 200 OK HTTP/1.1 200 OK
X-Application-Context: application X-Application-Context: application
Content-Type: application/vnd.spring-boot.actuator.v2+json;charset=UTF-8 Content-Type: application/vnd.spring-boot.actuator.v2+json;charset=UTF-8
Content-Length: 221 Content-Length: 221
{ {
"status" : "UP", "status" : "UP",
"diskSpace" : { "diskSpace" : {
"status" : "UP", "status" : "UP",
"total" : 63251804160, "total" : 63251804160,
"free" : 31316164608, "free" : 31316164608,
"threshold" : 10485760 "threshold" : 10485760
}, },
"db" : { "db" : {
"status" : "UP", "status" : "UP",
"database" : "H2", "database" : "H2",
"hello" : 1 "hello" : 1
} }
} }
---- ----
The above-described restrictions can be enhanced, thereby allowing only authenticated The above-described restrictions can be enhanced, thereby allowing only authenticated

@ -1,5 +1,5 @@
/* /*
* Copyright 2012-2016 the original author or authors. * Copyright 2012-2017 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.
@ -198,7 +198,7 @@ public class SampleActuatorApplicationTests {
List<Map<String, Object>> list = entity.getBody(); List<Map<String, Object>> list = entity.getBody();
Map<String, Object> trace = list.get(0); Map<String, Object> trace = list.get(0);
@SuppressWarnings("unchecked") @SuppressWarnings("unchecked")
Map<String, Object> map = (Map<String, Object>) ((Map<String, Object>)trace Map<String, Object> map = (Map<String, Object>) ((Map<String, Object>) trace
.get("info")).get("parameters"); .get("info")).get("parameters");
assertThat(map.get("param1")).isNotNull(); assertThat(map.get("param1")).isNotNull();
} }

Loading…
Cancel
Save