Commit b6b2fd4c authored by Vedran Pavic's avatar Vedran Pavic Committed by Stephane Nicoll

Make Audit events Web endpoint `after` parameter required

Closes gh-10322
parent dd27682a
...@@ -19,6 +19,7 @@ package org.springframework.boot.actuate.autoconfigure.audit; ...@@ -19,6 +19,7 @@ package org.springframework.boot.actuate.autoconfigure.audit;
import org.springframework.boot.actuate.audit.AuditEventRepository; import org.springframework.boot.actuate.audit.AuditEventRepository;
import org.springframework.boot.actuate.audit.AuditEventsEndpoint; import org.springframework.boot.actuate.audit.AuditEventsEndpoint;
import org.springframework.boot.actuate.audit.AuditEventsJmxEndpointExtension; import org.springframework.boot.actuate.audit.AuditEventsJmxEndpointExtension;
import org.springframework.boot.actuate.audit.AuditEventsWebEndpointExtension;
import org.springframework.boot.actuate.autoconfigure.endpoint.condition.ConditionalOnEnabledEndpoint; import org.springframework.boot.actuate.autoconfigure.endpoint.condition.ConditionalOnEnabledEndpoint;
import org.springframework.boot.actuate.logging.LoggersEndpoint; import org.springframework.boot.actuate.logging.LoggersEndpoint;
import org.springframework.boot.autoconfigure.AutoConfigureAfter; import org.springframework.boot.autoconfigure.AutoConfigureAfter;
...@@ -33,6 +34,7 @@ import org.springframework.context.annotation.Configuration; ...@@ -33,6 +34,7 @@ import org.springframework.context.annotation.Configuration;
* *
* @author Phillip Webb * @author Phillip Webb
* @author Andy Wilkinson * @author Andy Wilkinson
* @author Vedran Pavic
* @since 2.0.0 * @since 2.0.0
*/ */
@Configuration @Configuration
...@@ -57,4 +59,13 @@ public class AuditEventsEndpointAutoConfiguration { ...@@ -57,4 +59,13 @@ public class AuditEventsEndpointAutoConfiguration {
return new AuditEventsJmxEndpointExtension(auditEventsEndpoint); return new AuditEventsJmxEndpointExtension(auditEventsEndpoint);
} }
@Bean
@ConditionalOnMissingBean
@ConditionalOnEnabledEndpoint
@ConditionalOnBean(AuditEventsEndpoint.class)
public AuditEventsWebEndpointExtension auditEventsWebEndpointExtension(
AuditEventsEndpoint auditEventsEndpoint) {
return new AuditEventsWebEndpointExtension(auditEventsEndpoint);
}
} }
...@@ -20,6 +20,7 @@ import org.junit.Test; ...@@ -20,6 +20,7 @@ import org.junit.Test;
import org.springframework.boot.actuate.audit.AuditEventsEndpoint; import org.springframework.boot.actuate.audit.AuditEventsEndpoint;
import org.springframework.boot.actuate.audit.AuditEventsJmxEndpointExtension; import org.springframework.boot.actuate.audit.AuditEventsJmxEndpointExtension;
import org.springframework.boot.actuate.audit.AuditEventsWebEndpointExtension;
import org.springframework.boot.autoconfigure.AutoConfigurations; import org.springframework.boot.autoconfigure.AutoConfigurations;
import org.springframework.boot.test.context.runner.ApplicationContextRunner; import org.springframework.boot.test.context.runner.ApplicationContextRunner;
...@@ -30,6 +31,7 @@ import static org.assertj.core.api.Assertions.assertThat; ...@@ -30,6 +31,7 @@ import static org.assertj.core.api.Assertions.assertThat;
* *
* @author Andy Wilkinson * @author Andy Wilkinson
* @author Phillip Webb * @author Phillip Webb
* @author Vedran Pavic
*/ */
public class AuditEventsEndpointAutoConfigurationTests { public class AuditEventsEndpointAutoConfigurationTests {
...@@ -49,6 +51,12 @@ public class AuditEventsEndpointAutoConfigurationTests { ...@@ -49,6 +51,12 @@ public class AuditEventsEndpointAutoConfigurationTests {
.hasSingleBean(AuditEventsJmxEndpointExtension.class)); .hasSingleBean(AuditEventsJmxEndpointExtension.class));
} }
@Test
public void runShouldHaveWebExtensionBean() {
this.contextRunner.run((context) -> assertThat(context)
.hasSingleBean(AuditEventsWebEndpointExtension.class));
}
@Test @Test
public void runWhenEnabledPropertyIsFalseShouldNotHaveEndpointOrExtensionBean() public void runWhenEnabledPropertyIsFalseShouldNotHaveEndpointOrExtensionBean()
throws Exception { throws Exception {
......
/*
* 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.actuate.audit;
import java.util.Date;
import org.springframework.boot.actuate.audit.AuditEventsEndpoint.AuditEventsDescriptor;
import org.springframework.boot.actuate.endpoint.annotation.ReadOperation;
import org.springframework.boot.actuate.endpoint.web.WebEndpointResponse;
import org.springframework.boot.actuate.endpoint.web.annotation.WebEndpointExtension;
import org.springframework.http.HttpStatus;
/**
* {@link WebEndpointExtension} for the {@link AuditEventsEndpoint}.
*
* @author Vedran Pavic
* @since 2.0.0
*/
@WebEndpointExtension(endpoint = AuditEventsEndpoint.class)
public class AuditEventsWebEndpointExtension {
private final AuditEventsEndpoint delegate;
public AuditEventsWebEndpointExtension(AuditEventsEndpoint delegate) {
this.delegate = delegate;
}
@ReadOperation
public WebEndpointResponse<AuditEventsDescriptor> eventsWithPrincipalDateAfterAndType(
String principal, Date after, String type) {
if (after == null) {
return new WebEndpointResponse<>(HttpStatus.BAD_REQUEST.value());
}
AuditEventsDescriptor auditEvents = this.delegate
.eventsWithPrincipalDateAfterAndType(principal, after, type);
return new WebEndpointResponse<>(auditEvents);
}
}
...@@ -41,6 +41,12 @@ public class AuditEventsEndpointWebIntegrationTests { ...@@ -41,6 +41,12 @@ public class AuditEventsEndpointWebIntegrationTests {
private static WebTestClient client; private static WebTestClient client;
@Test
public void eventsWithoutParams() throws Exception {
client.get().uri((builder) -> builder.path("/application/auditevents").build())
.exchange().expectStatus().isBadRequest();
}
@Test @Test
public void eventsWithDateAfter() throws Exception { public void eventsWithDateAfter() throws Exception {
client.get() client.get()
...@@ -92,6 +98,12 @@ public class AuditEventsEndpointWebIntegrationTests { ...@@ -92,6 +98,12 @@ public class AuditEventsEndpointWebIntegrationTests {
return new AuditEventsEndpoint(auditEventsRepository()); return new AuditEventsEndpoint(auditEventsRepository());
} }
@Bean
public AuditEventsWebEndpointExtension auditEventsWebEndpointExtension(
AuditEventsEndpoint auditEventsEndpoint) {
return new AuditEventsWebEndpointExtension(auditEventsEndpoint);
}
private AuditEvent createEvent(String instant, String principal, String type) { private AuditEvent createEvent(String instant, String principal, String type) {
return new AuditEvent(Date.from(Instant.parse(instant)), principal, type, return new AuditEvent(Date.from(Instant.parse(instant)), principal, type,
Collections.<String, Object>emptyMap()); Collections.<String, Object>emptyMap());
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment