Skip to content
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,6 @@
import org.assertj.core.api.AbstractCharSequenceAssert;
import org.assertj.core.api.AbstractObjectAssert;
import org.assertj.core.api.Assert;
import org.assertj.core.api.Assertions;
import org.assertj.core.api.ListAssert;
import org.assertj.core.api.MapAssert;
import org.jspecify.annotations.Nullable;
Expand All @@ -45,6 +44,8 @@
import org.springframework.util.StringUtils;
import org.springframework.util.function.ThrowingFunction;

import static org.assertj.core.api.Assertions.assertThat;

/**
* AssertJ {@link Assert} for {@link JsonContent}.
*
Expand Down Expand Up @@ -920,7 +921,7 @@ public JsonContentAssert doesNotHaveEmptyJsonPathValue(CharSequence expression,
*/
@CheckReturnValue
public AbstractObjectAssert<?, Object> extractingJsonPathValue(CharSequence expression, Object... args) {
return Assertions.assertThat(new JsonPathValue(expression, args).getValue(false));
return assertThat(new JsonPathValue(expression, args).getValue(false));
}

/**
Expand All @@ -934,7 +935,7 @@ public AbstractObjectAssert<?, Object> extractingJsonPathValue(CharSequence expr
@CheckReturnValue
public AbstractCharSequenceAssert<?, String> extractingJsonPathStringValue(CharSequence expression,
Object... args) {
return Assertions.assertThat(extractingJsonPathValue(expression, args, String.class, "a string"));
return assertThat(extractingJsonPathValue(expression, args, String.class, "a string"));
}

/**
Expand All @@ -947,7 +948,7 @@ public AbstractCharSequenceAssert<?, String> extractingJsonPathStringValue(CharS
*/
@CheckReturnValue
public AbstractObjectAssert<?, Number> extractingJsonPathNumberValue(CharSequence expression, Object... args) {
return Assertions.assertThat(extractingJsonPathValue(expression, args, Number.class, "a number"));
return assertThat(extractingJsonPathValue(expression, args, Number.class, "a number"));
}

/**
Expand All @@ -960,7 +961,7 @@ public AbstractObjectAssert<?, Number> extractingJsonPathNumberValue(CharSequenc
*/
@CheckReturnValue
public AbstractBooleanAssert<?> extractingJsonPathBooleanValue(CharSequence expression, Object... args) {
return Assertions.assertThat(extractingJsonPathValue(expression, args, Boolean.class, "a boolean"));
return assertThat(extractingJsonPathValue(expression, args, Boolean.class, "a boolean"));
}

/**
Expand All @@ -975,7 +976,7 @@ public AbstractBooleanAssert<?> extractingJsonPathBooleanValue(CharSequence expr
@SuppressWarnings("unchecked")
@CheckReturnValue
public <E> ListAssert<E> extractingJsonPathArrayValue(CharSequence expression, Object... args) {
return Assertions.assertThat(extractingJsonPathValue(expression, args, List.class, "an array"));
return assertThat(extractingJsonPathValue(expression, args, List.class, "an array"));
}

/**
Expand All @@ -991,7 +992,7 @@ public <E> ListAssert<E> extractingJsonPathArrayValue(CharSequence expression, O
@SuppressWarnings("unchecked")
@CheckReturnValue
public <K, V> MapAssert<K, V> extractingJsonPathMapValue(CharSequence expression, Object... args) {
return Assertions.assertThat(extractingJsonPathValue(expression, args, Map.class, "a map"));
return assertThat(extractingJsonPathValue(expression, args, Map.class, "a map"));
}

@SuppressWarnings("unchecked")
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,6 @@
import io.micrometer.core.instrument.MeterRegistry;
import io.micrometer.core.instrument.Tags;
import io.micrometer.core.instrument.simple.SimpleMeterRegistry;
import org.assertj.core.api.Assertions;
import org.junit.jupiter.api.Test;

import org.springframework.boot.SpringApplication;
Expand Down Expand Up @@ -63,7 +62,7 @@ void autoConfiguresThreadPoolMetricsWithEmbeddedServletJetty() {
context.publishEvent(createApplicationStartedEvent(context.getSourceApplicationContext()));
assertThat(context).hasSingleBean(JettyServerThreadPoolMetricsBinder.class);
SimpleMeterRegistry registry = context.getBean(SimpleMeterRegistry.class);
Assertions.assertThat(registry.find("jetty.threads.config.min").meter()).isNotNull();
assertThat(registry.find("jetty.threads.config.min").meter()).isNotNull();
});
}

Expand All @@ -76,7 +75,7 @@ void autoConfiguresThreadPoolMetricsWithEmbeddedReactiveJetty() {
.run((context) -> {
context.publishEvent(createApplicationStartedEvent(context.getSourceApplicationContext()));
SimpleMeterRegistry registry = context.getBean(SimpleMeterRegistry.class);
Assertions.assertThat(registry.find("jetty.threads.config.min").meter()).isNotNull();
assertThat(registry.find("jetty.threads.config.min").meter()).isNotNull();
});
}

Expand All @@ -98,7 +97,7 @@ void autoConfiguresConnectionMetricsWithEmbeddedServletJetty() {
context.publishEvent(createApplicationStartedEvent(context.getSourceApplicationContext()));
assertThat(context).hasSingleBean(JettyConnectionMetricsBinder.class);
SimpleMeterRegistry registry = context.getBean(SimpleMeterRegistry.class);
Assertions.assertThat(registry.find("jetty.connections.messages.in").meter()).isNotNull();
assertThat(registry.find("jetty.connections.messages.in").meter()).isNotNull();
});
}

Expand All @@ -111,7 +110,7 @@ void autoConfiguresConnectionMetricsWithEmbeddedReactiveJetty() {
.run((context) -> {
context.publishEvent(createApplicationStartedEvent(context.getSourceApplicationContext()));
SimpleMeterRegistry registry = context.getBean(SimpleMeterRegistry.class);
Assertions.assertThat(registry.find("jetty.connections.messages.in").meter()).isNotNull();
assertThat(registry.find("jetty.connections.messages.in").meter()).isNotNull();
});
}

Expand All @@ -127,11 +126,9 @@ void allowsCustomJettyConnectionMetricsBinderToBeUsed() {
assertThat(context).hasSingleBean(JettyConnectionMetricsBinder.class)
.hasBean("customJettyConnectionMetricsBinder");
SimpleMeterRegistry registry = context.getBean(SimpleMeterRegistry.class);
Assertions
.assertThat(registry.find("jetty.connections.messages.in")
.tag("custom-tag-name", "custom-tag-value")
.meter())
.isNotNull();
assertThat(registry.find("jetty.connections.messages.in")
.tag("custom-tag-name", "custom-tag-value")
.meter()).isNotNull();
});
}

Expand All @@ -148,7 +145,7 @@ void autoConfiguresSslHandshakeMetricsWithEmbeddedServletJetty() {
context.publishEvent(createApplicationStartedEvent(context.getSourceApplicationContext()));
assertThat(context).hasSingleBean(JettySslHandshakeMetricsBinder.class);
SimpleMeterRegistry registry = context.getBean(SimpleMeterRegistry.class);
Assertions.assertThat(registry.find("jetty.ssl.handshakes").meter()).isNotNull();
assertThat(registry.find("jetty.ssl.handshakes").meter()).isNotNull();
});
}

Expand All @@ -164,7 +161,7 @@ void autoConfiguresSslHandshakeMetricsWithEmbeddedReactiveJetty() {
.run((context) -> {
context.publishEvent(createApplicationStartedEvent(context.getSourceApplicationContext()));
SimpleMeterRegistry registry = context.getBean(SimpleMeterRegistry.class);
Assertions.assertThat(registry.find("jetty.ssl.handshakes").meter()).isNotNull();
assertThat(registry.find("jetty.ssl.handshakes").meter()).isNotNull();
});
}

Expand All @@ -183,9 +180,7 @@ void allowsCustomJettySslHandshakeMetricsBinderToBeUsed() {
assertThat(context).hasSingleBean(JettySslHandshakeMetricsBinder.class)
.hasBean("customJettySslHandshakeMetricsBinder");
SimpleMeterRegistry registry = context.getBean(SimpleMeterRegistry.class);
Assertions
.assertThat(
registry.find("jetty.ssl.handshakes").tag("custom-tag-name", "custom-tag-value").meter())
assertThat(registry.find("jetty.ssl.handshakes").tag("custom-tag-name", "custom-tag-value").meter())
.isNotNull();
});

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -21,13 +21,14 @@
import java.util.function.Function;

import io.opentelemetry.context.ContextStorage;
import org.assertj.core.api.Assertions;
import org.junit.jupiter.api.Test;
import org.mockito.Mockito;

import org.springframework.boot.micrometer.tracing.opentelemetry.autoconfigure.OpenTelemetryEventPublisherBeansApplicationListener.Wrapper.Storage;
import org.springframework.boot.testsupport.classpath.ForkedClassPath;

import static org.assertj.core.api.Assertions.assertThat;

/**
* Integration tests for {@link OpenTelemetryEventPublisherBeansTestExecutionListener}.
*
Expand All @@ -45,7 +46,7 @@ void wrapperIsInstalled() throws Exception {
Method getWrappersMethod = wrappersClass.getDeclaredMethod("getWrappers");
getWrappersMethod.setAccessible(true);
List<Function> wrappers = (List<Function>) getWrappersMethod.invoke(null);
Assertions.assertThat(wrappers).anyMatch((function) -> function.apply(this.parent) instanceof Storage);
assertThat(wrappers).anyMatch((function) -> function.apply(this.parent) instanceof Storage);
}

}
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,6 @@
import okhttp3.mockwebserver.RecordedRequest;
import okio.Buffer;
import okio.GzipSource;
import org.assertj.core.api.Assertions;
import org.eclipse.jetty.http.HttpFields;
import org.eclipse.jetty.http2.server.HTTP2CServerConnectionFactory;
import org.eclipse.jetty.io.Content;
Expand Down Expand Up @@ -99,13 +98,13 @@ void httpSpanExporterShouldUseProtobufAndNoCompressionByDefault() {
assertThat(context.getBean(OtlpHttpSpanExporter.class).flush())
.isSameAs(CompletableResultCode.ofSuccess());
RecordedRequest request = this.mockWebServer.takeRequest(10, TimeUnit.SECONDS);
Assertions.assertThat(request).isNotNull();
Assertions.assertThat(request.getRequestLine()).contains("/v1/traces");
Assertions.assertThat(request.getHeader("Content-Type")).isEqualTo("application/x-protobuf");
Assertions.assertThat(request.getHeader("custom")).isEqualTo("42");
Assertions.assertThat(request.getBodySize()).isPositive();
assertThat(request).isNotNull();
assertThat(request.getRequestLine()).contains("/v1/traces");
assertThat(request.getHeader("Content-Type")).isEqualTo("application/x-protobuf");
assertThat(request.getHeader("custom")).isEqualTo("42");
assertThat(request.getBodySize()).isPositive();
try (Buffer body = request.getBody()) {
Assertions.assertThat(body.readString(StandardCharsets.UTF_8)).contains("org.springframework.boot");
assertThat(body.readString(StandardCharsets.UTF_8)).contains("org.springframework.boot");
}
});
}
Expand All @@ -123,15 +122,14 @@ void httpSpanExporterCanBeConfiguredToUseGzipCompression() {
assertThat(context.getBean(OtlpHttpSpanExporter.class).flush())
.isSameAs(CompletableResultCode.ofSuccess());
RecordedRequest request = this.mockWebServer.takeRequest(10, TimeUnit.SECONDS);
Assertions.assertThat(request).isNotNull();
Assertions.assertThat(request.getRequestLine()).contains("/test");
Assertions.assertThat(request.getHeader("Content-Type")).isEqualTo("application/x-protobuf");
Assertions.assertThat(request.getHeader("Content-Encoding")).isEqualTo("gzip");
Assertions.assertThat(request.getBodySize()).isPositive();
assertThat(request).isNotNull();
assertThat(request.getRequestLine()).contains("/test");
assertThat(request.getHeader("Content-Type")).isEqualTo("application/x-protobuf");
assertThat(request.getHeader("Content-Encoding")).isEqualTo("gzip");
assertThat(request.getBodySize()).isPositive();
try (Buffer uncompressed = new Buffer(); Buffer body = request.getBody()) {
uncompressed.writeAll(new GzipSource(body));
Assertions.assertThat(uncompressed.readString(StandardCharsets.UTF_8))
.contains("org.springframework.boot");
assertThat(uncompressed.readString(StandardCharsets.UTF_8)).contains("org.springframework.boot");
}
});
}
Expand All @@ -150,8 +148,8 @@ void grpcSpanExporterShouldExportSpans() {
.isSameAs(CompletableResultCode.ofSuccess());
RecordedGrpcRequest request = this.mockGrpcServer.takeRequest(10, TimeUnit.SECONDS);
assertThat(request).isNotNull();
Assertions.assertThat(request.headers().get("Content-Type")).isEqualTo("application/grpc");
Assertions.assertThat(request.headers().get("custom")).isEqualTo("42");
assertThat(request.headers().get("Content-Type")).isEqualTo("application/grpc");
assertThat(request.headers().get("custom")).isEqualTo("42");
assertThat(request.bodyAsString()).contains("org.springframework.boot");
});
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,6 @@

import com.samskivert.mustache.Mustache;
import com.samskivert.mustache.Template;
import org.assertj.core.api.Assertions;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;

Expand Down Expand Up @@ -75,7 +74,7 @@ void shouldRenderTemplate() {
Template tmpl = Mustache.compiler().compile(source);
Map<String, String> context = new HashMap<>();
context.put("arg", "world");
Assertions.assertThat(tmpl.execute(context)).isEqualTo("Hello world!");
assertThat(tmpl.execute(context)).isEqualTo("Hello world!");
}

@Test
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,6 @@
import java.util.function.Supplier;

import com.samskivert.mustache.Mustache;
import org.assertj.core.api.Assertions;
import org.assertj.core.api.InstanceOfAssertFactories;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.params.ParameterizedTest;
Expand Down Expand Up @@ -62,7 +61,7 @@ void registerCompilerForServletApp() {
assertThat(context).hasSingleBean(Mustache.Compiler.class);
assertThat(context).hasSingleBean(MustacheResourceTemplateLoader.class);
assertThat(context).hasSingleBean(MustacheViewResolver.class);
Assertions.assertThat(context.getBean(Mustache.Compiler.class).standardsMode).isTrue();
assertThat(context.getBean(Mustache.Compiler.class).standardsMode).isTrue();
});
}

Expand All @@ -86,7 +85,7 @@ void registerCompilerForReactiveApp() {
assertThat(context).doesNotHaveBean(MustacheViewResolver.class);
assertThat(context)
.hasSingleBean(org.springframework.boot.mustache.reactive.view.MustacheViewResolver.class);
Assertions.assertThat(context.getBean(Mustache.Compiler.class).standardsMode).isTrue();
assertThat(context.getBean(Mustache.Compiler.class).standardsMode).isTrue();
});
}

Expand Down Expand Up @@ -117,7 +116,7 @@ void defaultReactiveViewResolverConfiguration() {
assertThat(viewResolver).extracting("prefix").isEqualTo("classpath:/templates/");
assertThat(viewResolver).extracting("requestContextAttribute").isNull();
assertThat(viewResolver).extracting("suffix").isEqualTo(".mustache");
Assertions.assertThat(viewResolver.getSupportedMediaTypes())
assertThat(viewResolver.getSupportedMediaTypes())
.containsExactly(MediaType.parseMediaType("text/html;charset=UTF-8"));
});
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,6 @@
import java.util.Collections;

import com.samskivert.mustache.Mustache;
import org.assertj.core.api.Assertions;
import org.junit.jupiter.api.Test;
import reactor.test.StepVerifier;

Expand All @@ -31,6 +30,8 @@
import org.springframework.mock.http.server.reactive.MockServerHttpRequest;
import org.springframework.mock.web.server.MockServerWebExchange;

import static org.assertj.core.api.Assertions.assertThat;

/**
* Tests for {@link MustacheView}.
*
Expand All @@ -52,7 +53,7 @@ void viewResolvesHandlebars() {
view.render(Collections.singletonMap("World", "Spring"), MediaType.TEXT_HTML, exchange)
.block(Duration.ofSeconds(30));
StepVerifier.create(exchange.getResponse().getBodyAsString())
.assertNext((body) -> Assertions.assertThat(body).isEqualToIgnoringWhitespace("Hello Spring"))
.assertNext((body) -> assertThat(body).isEqualToIgnoringWhitespace("Hello Spring"))
.expectComplete()
.verify(Duration.ofSeconds(30));
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,6 @@

import java.util.Locale;

import org.assertj.core.api.Assertions;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;

Expand Down Expand Up @@ -66,7 +65,7 @@ void setsContentType() throws Exception {
this.resolver.setContentType("application/octet-stream");
View view = this.resolver.resolveViewName("template", Locale.ROOT);
assertThat(view).isNotNull();
Assertions.assertThat(view.getContentType()).isEqualTo("application/octet-stream");
assertThat(view.getContentType()).isEqualTo("application/octet-stream");

}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,6 @@

import nz.net.ultraq.thymeleaf.layoutdialect.LayoutDialect;
import nz.net.ultraq.thymeleaf.layoutdialect.decorators.strategies.GroupingStrategy;
import org.assertj.core.api.Assertions;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith;
import org.junit.jupiter.api.io.TempDir;
Expand Down Expand Up @@ -90,27 +89,26 @@ void overrideCharacterEncoding() {
assertThat(resolver).isInstanceOf(SpringResourceTemplateResolver.class);
assertThat(((SpringResourceTemplateResolver) resolver).getCharacterEncoding()).isEqualTo("UTF-16");
ThymeleafReactiveViewResolver views = context.getBean(ThymeleafReactiveViewResolver.class);
Assertions.assertThat(views.getDefaultCharset().name()).isEqualTo("UTF-16");
assertThat(views.getDefaultCharset().name()).isEqualTo("UTF-16");
});
}

@Test
void defaultMediaTypes() {
this.contextRunner.run((context) -> Assertions
.assertThat(context.getBean(ThymeleafReactiveViewResolver.class).getSupportedMediaTypes())
.containsExactly(MediaType.TEXT_HTML, MediaType.APPLICATION_XHTML_XML, MediaType.APPLICATION_XML,
MediaType.TEXT_XML, MediaType.APPLICATION_RSS_XML, MediaType.APPLICATION_ATOM_XML,
new MediaType("application", "javascript"), new MediaType("application", "ecmascript"),
new MediaType("text", "javascript"), new MediaType("text", "ecmascript"),
MediaType.APPLICATION_JSON, new MediaType("text", "css"), MediaType.TEXT_PLAIN,
MediaType.TEXT_EVENT_STREAM));
this.contextRunner
.run((context) -> assertThat(context.getBean(ThymeleafReactiveViewResolver.class).getSupportedMediaTypes())
.containsExactly(MediaType.TEXT_HTML, MediaType.APPLICATION_XHTML_XML, MediaType.APPLICATION_XML,
MediaType.TEXT_XML, MediaType.APPLICATION_RSS_XML, MediaType.APPLICATION_ATOM_XML,
new MediaType("application", "javascript"), new MediaType("application", "ecmascript"),
new MediaType("text", "javascript"), new MediaType("text", "ecmascript"),
MediaType.APPLICATION_JSON, new MediaType("text", "css"), MediaType.TEXT_PLAIN,
MediaType.TEXT_EVENT_STREAM));
}

@Test
void overrideMediaTypes() {
this.contextRunner.withPropertyValues("spring.thymeleaf.reactive.media-types:text/html,text/plain")
.run((context) -> Assertions
.assertThat(context.getBean(ThymeleafReactiveViewResolver.class).getSupportedMediaTypes())
.run((context) -> assertThat(context.getBean(ThymeleafReactiveViewResolver.class).getSupportedMediaTypes())
.containsExactly(MediaType.TEXT_HTML, MediaType.TEXT_PLAIN));
}

Expand Down
Loading
Loading