Spring/spring-framework
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Suppress deprecation warnings in tests

Browse Source
This commit is contained in:
Sam Brannen
2022-03-29 15:04:58 +02:00
parent c8d0146bcc
commit 7a1421cb0f
12 changed files with 217 additions and 213 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
spring-webflux/src/test/java/org/springframework/web/reactive/function/client/DefaultClientResponseBuilderTests.java
View File

@@ -1,5 +1,5 @@
/*
* Copyright 2002-2020 the original author or authors.
* Copyright 2002-2022 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.
@@ -38,10 +38,10 @@ import static org.assertj.core.api.Assertions.assertThat;
/**
* @author Arjen Poutsma
*/
public class DefaultClientResponseBuilderTests {
class DefaultClientResponseBuilderTests {
@Test
public void normal() {
void normal() {
Flux<DataBuffer> body = Flux.just("baz")
.map(s -> s.getBytes(StandardCharsets.UTF_8))
.map(DefaultDataBufferFactory.sharedInstance::wrap);
@@ -64,7 +64,7 @@ public class DefaultClientResponseBuilderTests {
}
@Test
public void mutate() {
void mutate() {
Flux<DataBuffer> otherBody = Flux.just("foo", "bar")
.map(s -> s.getBytes(StandardCharsets.UTF_8))
.map(DefaultDataBufferFactory.sharedInstance::wrap);
@@ -101,11 +101,13 @@ public class DefaultClientResponseBuilderTests {
}
@Test
public void mutateWithCustomStatus() {
@SuppressWarnings("deprecation")
void mutateWithCustomStatus() {
ClientResponse other = ClientResponse.create(499, ExchangeStrategies.withDefaults()).build();
ClientResponse result = other.mutate().build();
assertThat(result.rawStatusCode()).isEqualTo(499);
assertThat(result.statusCode()).isEqualTo(HttpStatusCode.valueOf(499));
}
}

50
spring-webflux/src/test/java/org/springframework/web/reactive/function/client/DefaultClientResponseTests.java
View File

@@ -1,5 +1,5 @@
/*
* Copyright 2002-2020 the original author or authors.
* Copyright 2002-2022 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.
@@ -59,7 +59,7 @@ import static org.springframework.web.reactive.function.BodyExtractors.toMono;
* @author Arjen Poutsma
* @author Denys Ivano
*/
public class DefaultClientResponseTests {
class DefaultClientResponseTests {
private ClientHttpResponse mockResponse;
@@ -71,7 +71,7 @@ public class DefaultClientResponseTests {
@BeforeEach
public void createMocks() {
void createMocks() {
mockResponse = mock(ClientHttpResponse.class);
given(mockResponse.getHeaders()).willReturn(this.httpHeaders);
mockExchangeStrategies = mock(ExchangeStrategies.class);
@@ -80,7 +80,7 @@ public class DefaultClientResponseTests {
@Test
public void statusCode() {
void statusCode() {
HttpStatus status = HttpStatus.CONTINUE;
given(mockResponse.getStatusCode()).willReturn(status);
@@ -88,7 +88,8 @@ public class DefaultClientResponseTests {
}
@Test
public void rawStatusCode() {
@SuppressWarnings("deprecation")
void rawStatusCode() {
int status = 999;
given(mockResponse.getRawStatusCode()).willReturn(status);
@@ -96,7 +97,7 @@ public class DefaultClientResponseTests {
}
@Test
public void header() {
void header() {
long contentLength = 42L;
httpHeaders.setContentLength(contentLength);
MediaType contentType = MediaType.TEXT_PLAIN;
@@ -115,7 +116,7 @@ public class DefaultClientResponseTests {
}
@Test
public void cookies() {
void cookies() {
ResponseCookie cookie = ResponseCookie.from("foo", "bar").build();
MultiValueMap<String, ResponseCookie> cookies = new LinkedMultiValueMap<>();
cookies.add("foo", cookie);
@@ -127,7 +128,7 @@ public class DefaultClientResponseTests {
@Test
public void body() {
void body() {
byte[] bytes = "foo".getBytes(StandardCharsets.UTF_8);
DefaultDataBuffer dataBuffer = DefaultDataBufferFactory.sharedInstance.wrap(ByteBuffer.wrap(bytes));
Flux<DataBuffer> body = Flux.just(dataBuffer);
@@ -142,7 +143,7 @@ public class DefaultClientResponseTests {
}
@Test
public void bodyToMono() {
void bodyToMono() {
byte[] bytes = "foo".getBytes(StandardCharsets.UTF_8);
DefaultDataBuffer dataBuffer = DefaultDataBufferFactory.sharedInstance.wrap(ByteBuffer.wrap(bytes));
Flux<DataBuffer> body = Flux.just(dataBuffer);
@@ -157,7 +158,7 @@ public class DefaultClientResponseTests {
}
@Test
public void bodyToMonoTypeReference() {
void bodyToMonoTypeReference() {
byte[] bytes = "foo".getBytes(StandardCharsets.UTF_8);
DefaultDataBuffer dataBuffer = DefaultDataBufferFactory.sharedInstance.wrap(ByteBuffer.wrap(bytes));
Flux<DataBuffer> body = Flux.just(dataBuffer);
@@ -174,7 +175,7 @@ public class DefaultClientResponseTests {
}
@Test
public void bodyToFlux() {
void bodyToFlux() {
byte[] bytes = "foo".getBytes(StandardCharsets.UTF_8);
DefaultDataBuffer dataBuffer = DefaultDataBufferFactory.sharedInstance.wrap(ByteBuffer.wrap(bytes));
Flux<DataBuffer> body = Flux.just(dataBuffer);
@@ -190,7 +191,7 @@ public class DefaultClientResponseTests {
}
@Test
public void bodyToFluxTypeReference() {
void bodyToFluxTypeReference() {
byte[] bytes = "foo".getBytes(StandardCharsets.UTF_8);
DefaultDataBuffer dataBuffer = DefaultDataBufferFactory.sharedInstance.wrap(ByteBuffer.wrap(bytes));
Flux<DataBuffer> body = Flux.just(dataBuffer);
@@ -208,7 +209,8 @@ public class DefaultClientResponseTests {
}
@Test
public void toEntity() {
@SuppressWarnings("deprecation")
void toEntity() {
byte[] bytes = "foo".getBytes(StandardCharsets.UTF_8);
DefaultDataBuffer dataBuffer = DefaultDataBufferFactory.sharedInstance.wrap(ByteBuffer.wrap(bytes));
Flux<DataBuffer> body = Flux.just(dataBuffer);
@@ -226,7 +228,8 @@ public class DefaultClientResponseTests {
}
@Test
public void toEntityWithUnknownStatusCode() throws Exception {
@SuppressWarnings("deprecation")
void toEntityWithUnknownStatusCode() throws Exception {
byte[] bytes = "foo".getBytes(StandardCharsets.UTF_8);
DefaultDataBuffer dataBuffer = DefaultDataBufferFactory.sharedInstance.wrap(ByteBuffer.wrap(bytes));
Flux<DataBuffer> body = Flux.just(dataBuffer);
@@ -248,7 +251,8 @@ public class DefaultClientResponseTests {
}
@Test
public void toEntityTypeReference() {
@SuppressWarnings("deprecation")
void toEntityTypeReference() {
byte[] bytes = "foo".getBytes(StandardCharsets.UTF_8);
DefaultDataBuffer dataBuffer = DefaultDataBufferFactory.sharedInstance.wrap(ByteBuffer.wrap(bytes));
Flux<DataBuffer> body = Flux.just(dataBuffer);
@@ -268,7 +272,8 @@ public class DefaultClientResponseTests {
}
@Test
public void toEntityList() {
@SuppressWarnings("deprecation")
void toEntityList() {
byte[] bytes = "foo".getBytes(StandardCharsets.UTF_8);
DefaultDataBuffer dataBuffer = DefaultDataBufferFactory.sharedInstance.wrap(ByteBuffer.wrap(bytes));
Flux<DataBuffer> body = Flux.just(dataBuffer);
@@ -286,7 +291,8 @@ public class DefaultClientResponseTests {
}
@Test
public void toEntityListWithUnknownStatusCode() {
@SuppressWarnings("deprecation")
void toEntityListWithUnknownStatusCode() {
byte[] bytes = "foo".getBytes(StandardCharsets.UTF_8);
DefaultDataBuffer dataBuffer = DefaultDataBufferFactory.sharedInstance.wrap(ByteBuffer.wrap(bytes));
Flux<DataBuffer> body = Flux.just(dataBuffer);
@@ -308,7 +314,8 @@ public class DefaultClientResponseTests {
}
@Test
public void toEntityListTypeReference() {
@SuppressWarnings("deprecation")
void toEntityListTypeReference() {
byte[] bytes = "foo".getBytes(StandardCharsets.UTF_8);
DefaultDataBuffer dataBuffer = DefaultDataBufferFactory.sharedInstance.wrap(ByteBuffer.wrap(bytes));
Flux<DataBuffer> body = Flux.just(dataBuffer);
@@ -328,7 +335,8 @@ public class DefaultClientResponseTests {
}
@Test
public void createException() {
@SuppressWarnings("deprecation")
void createException() {
byte[] bytes = "foo".getBytes(StandardCharsets.UTF_8);
DefaultDataBuffer dataBuffer = DefaultDataBufferFactory.sharedInstance.wrap(ByteBuffer.wrap(bytes));
Flux<DataBuffer> body = Flux.just(dataBuffer);
@@ -351,7 +359,8 @@ public class DefaultClientResponseTests {
}
@Test
public void createError() {
@SuppressWarnings("deprecation")
void createError() {
byte[] bytes = "foo".getBytes(StandardCharsets.UTF_8);
DefaultDataBuffer dataBuffer = DefaultDataBufferFactory.sharedInstance.wrap(ByteBuffer.wrap(bytes));
Flux<DataBuffer> body = Flux.just(dataBuffer);
@@ -380,6 +389,7 @@ public class DefaultClientResponseTests {
}
@SuppressWarnings("deprecation")
private void mockTextPlainResponse(Flux<DataBuffer> body) {
httpHeaders.setContentType(MediaType.TEXT_PLAIN);
given(mockResponse.getStatusCode()).willReturn(HttpStatus.OK);

11
spring-webflux/src/test/java/org/springframework/web/reactive/function/client/WebClientIntegrationTests.java
View File

@@ -529,6 +529,7 @@ class WebClientIntegrationTests {
}
@ParameterizedWebClientTest
@SuppressWarnings("deprecation")
void retrieve500(ClientHttpConnector connector) {
startServer(connector);
@@ -544,7 +545,7 @@ class WebClientIntegrationTests {
StepVerifier.create(result)
.expectErrorSatisfies(throwable -> {
assertThat(throwable instanceof WebClientResponseException).isTrue();
assertThat(throwable).isInstanceOf(WebClientResponseException.class);
WebClientResponseException ex = (WebClientResponseException) throwable;
assertThat(ex.getStatusCode()).isEqualTo(HttpStatus.INTERNAL_SERVER_ERROR);
assertThat(ex.getRawStatusCode()).isEqualTo(HttpStatus.INTERNAL_SERVER_ERROR.value());
@@ -636,11 +637,12 @@ class WebClientIntegrationTests {
}
@ParameterizedWebClientTest
@SuppressWarnings("deprecation")
void retrieve555UnknownStatus(ClientHttpConnector connector) {
startServer(connector);
int errorStatus = 555;
assertThat((Object) HttpStatus.resolve(errorStatus)).isNull();
assertThat(HttpStatus.resolve(errorStatus)).isNull();
String errorMessage = "Something went wrong";
prepareResponse(response -> response.setResponseCode(errorStatus)
.setHeader("Content-Type", "text/plain").setBody(errorMessage));
@@ -652,7 +654,7 @@ class WebClientIntegrationTests {
StepVerifier.create(result)
.expectErrorSatisfies(throwable -> {
assertThat(throwable instanceof UnknownHttpStatusCodeException).isTrue();
assertThat(throwable).isInstanceOf(UnknownHttpStatusCodeException.class);
UnknownHttpStatusCodeException ex = (UnknownHttpStatusCodeException) throwable;
assertThat(ex.getMessage()).isEqualTo(("Unknown status code ["+errorStatus+"]"));
assertThat(ex.getRawStatusCode()).isEqualTo(errorStatus);
@@ -1055,11 +1057,12 @@ class WebClientIntegrationTests {
}
@ParameterizedWebClientTest
@SuppressWarnings("deprecation")
void exchangeForUnknownStatusCode(ClientHttpConnector connector) {
startServer(connector);
int errorStatus = 555;
assertThat((Object) HttpStatus.resolve(errorStatus)).isNull();
assertThat(HttpStatus.resolve(errorStatus)).isNull();
String errorMessage = "Something went wrong";
prepareResponse(response -> response.setResponseCode(errorStatus)
.setHeader("Content-Type", "text/plain").setBody(errorMessage));

43
spring-webflux/src/test/java/org/springframework/web/reactive/function/client/support/ClientResponseWrapperTests.java
View File

@@ -1,5 +1,5 @@
/*
* Copyright 2002-2019 the original author or authors.
* Copyright 2002-2022 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.
@@ -18,7 +18,6 @@ package org.springframework.web.reactive.function.client.support;
import java.util.List;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
@@ -41,25 +40,20 @@ import static org.mockito.Mockito.mock;
/**
* @author Arjen Poutsma
*/
public class ClientResponseWrapperTests {
class ClientResponseWrapperTests {
private ClientResponse mockResponse;
private ClientResponse mockResponse = mock(ClientResponse.class);
private ClientResponseWrapper wrapper;
private ClientResponseWrapper wrapper = new ClientResponseWrapper(mockResponse);
@BeforeEach
public void createWrapper() {
this.mockResponse = mock(ClientResponse.class);
this.wrapper = new ClientResponseWrapper(mockResponse);
}
@Test
public void response() {
void response() {
assertThat(wrapper.response()).isSameAs(mockResponse);
}
@Test
public void statusCode() {
void statusCode() {
HttpStatus status = HttpStatus.BAD_REQUEST;
given(mockResponse.statusCode()).willReturn(status);
@@ -67,7 +61,8 @@ public class ClientResponseWrapperTests {
}
@Test
public void rawStatusCode() {
@SuppressWarnings("deprecation")
void rawStatusCode() {
int status = 999;
given(mockResponse.rawStatusCode()).willReturn(status);
@@ -75,7 +70,7 @@ public class ClientResponseWrapperTests {
}
@Test
public void headers() {
void headers() {
ClientResponse.Headers headers = mock(ClientResponse.Headers.class);
given(mockResponse.headers()).willReturn(headers);
@@ -84,7 +79,7 @@ public class ClientResponseWrapperTests {
@Test
@SuppressWarnings("unchecked")
public void cookies() {
void cookies() {
MultiValueMap<String, ResponseCookie> cookies = mock(MultiValueMap.class);
given(mockResponse.cookies()).willReturn(cookies);
@@ -92,7 +87,7 @@ public class ClientResponseWrapperTests {
}
@Test
public void bodyExtractor() {
void bodyExtractor() {
Mono<String> result = Mono.just("foo");
BodyExtractor<Mono<String>, ReactiveHttpInputMessage> extractor = BodyExtractors.toMono(String.class);
given(mockResponse.body(extractor)).willReturn(result);
@@ -101,7 +96,7 @@ public class ClientResponseWrapperTests {
}
@Test
public void bodyToMonoClass() {
void bodyToMonoClass() {
Mono<String> result = Mono.just("foo");
given(mockResponse.bodyToMono(String.class)).willReturn(result);
@@ -109,7 +104,7 @@ public class ClientResponseWrapperTests {
}
@Test
public void bodyToMonoParameterizedTypeReference() {
void bodyToMonoParameterizedTypeReference() {
Mono<String> result = Mono.just("foo");
ParameterizedTypeReference<String> reference = new ParameterizedTypeReference<>() {};
given(mockResponse.bodyToMono(reference)).willReturn(result);
@@ -118,7 +113,7 @@ public class ClientResponseWrapperTests {
}
@Test
public void bodyToFluxClass() {
void bodyToFluxClass() {
Flux<String> result = Flux.just("foo");
given(mockResponse.bodyToFlux(String.class)).willReturn(result);
@@ -126,7 +121,7 @@ public class ClientResponseWrapperTests {
}
@Test
public void bodyToFluxParameterizedTypeReference() {
void bodyToFluxParameterizedTypeReference() {
Flux<String> result = Flux.just("foo");
ParameterizedTypeReference<String> reference = new ParameterizedTypeReference<>() {};
given(mockResponse.bodyToFlux(reference)).willReturn(result);
@@ -135,7 +130,7 @@ public class ClientResponseWrapperTests {
}
@Test
public void toEntityClass() {
void toEntityClass() {
Mono<ResponseEntity<String>> result = Mono.just(new ResponseEntity<>("foo", HttpStatus.OK));
given(mockResponse.toEntity(String.class)).willReturn(result);
@@ -143,7 +138,7 @@ public class ClientResponseWrapperTests {
}
@Test
public void toEntityParameterizedTypeReference() {
void toEntityParameterizedTypeReference() {
Mono<ResponseEntity<String>> result = Mono.just(new ResponseEntity<>("foo", HttpStatus.OK));
ParameterizedTypeReference<String> reference = new ParameterizedTypeReference<>() {};
given(mockResponse.toEntity(reference)).willReturn(result);
@@ -152,7 +147,7 @@ public class ClientResponseWrapperTests {
}
@Test
public void toEntityListClass() {
void toEntityListClass() {
Mono<ResponseEntity<List<String>>> result = Mono.just(new ResponseEntity<>(singletonList("foo"), HttpStatus.OK));
given(mockResponse.toEntityList(String.class)).willReturn(result);
@@ -160,7 +155,7 @@ public class ClientResponseWrapperTests {
}
@Test
public void toEntityListParameterizedTypeReference() {
void toEntityListParameterizedTypeReference() {
Mono<ResponseEntity<List<String>>> result = Mono.just(new ResponseEntity<>(singletonList("foo"), HttpStatus.OK));
ParameterizedTypeReference<String> reference = new ParameterizedTypeReference<>() {};
given(mockResponse.toEntityList(reference)).willReturn(result);

39
spring-webflux/src/test/java/org/springframework/web/reactive/function/server/DefaultEntityResponseBuilderTests.java
View File

@@ -1,5 +1,5 @@
/*
* Copyright 2002-2020 the original author or authors.
* Copyright 2002-2022 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.
@@ -52,24 +52,24 @@ import static org.assertj.core.api.Assertions.assertThat;
/**
* @author Arjen Poutsma
*/
public class DefaultEntityResponseBuilderTests {
class DefaultEntityResponseBuilderTests {
@Test
public void fromObject() {
void fromObject() {
String body = "foo";
EntityResponse<String> response = EntityResponse.fromObject(body).build().block();
assertThat(response.entity()).isSameAs(body);
}
@Test
public void fromPublisherClass() {
void fromPublisherClass() {
Flux<String> body = Flux.just("foo", "bar");
EntityResponse<Flux<String>> response = EntityResponse.fromPublisher(body, String.class).build().block();
assertThat(response.entity()).isSameAs(body);
}
@Test
public void fromPublisher() {
void fromPublisher() {
Flux<String> body = Flux.just("foo", "bar");
ParameterizedTypeReference<String> typeReference = new ParameterizedTypeReference<>() {};
EntityResponse<Flux<String>> response = EntityResponse.fromPublisher(body, typeReference).build().block();
@@ -77,7 +77,7 @@ public class DefaultEntityResponseBuilderTests {
}
@Test
public void fromProducer() {
void fromProducer() {
Single<String> body = Single.just("foo");
ParameterizedTypeReference<String> typeReference = new ParameterizedTypeReference<>() {};
EntityResponse<Single<String>> response = EntityResponse.fromProducer(body, typeReference).build().block();
@@ -85,7 +85,8 @@ public class DefaultEntityResponseBuilderTests {
}
@Test
public void status() {
@SuppressWarnings("deprecation")
void status() {
String body = "foo";
Mono<EntityResponse<String>> result = EntityResponse.fromObject(body).status(HttpStatus.CREATED).build();
StepVerifier.create(result)
@@ -96,7 +97,7 @@ public class DefaultEntityResponseBuilderTests {
}
@Test
public void allow() {
void allow() {
String body = "foo";
Mono<EntityResponse<String>> result = EntityResponse.fromObject(body).allow(HttpMethod.GET).build();
Set<HttpMethod> expected = Set.of(HttpMethod.GET);
@@ -107,7 +108,7 @@ public class DefaultEntityResponseBuilderTests {
}
@Test
public void contentLength() {
void contentLength() {
String body = "foo";
Mono<EntityResponse<String>> result = EntityResponse.fromObject(body).contentLength(42).build();
StepVerifier.create(result)
@@ -117,7 +118,7 @@ public class DefaultEntityResponseBuilderTests {
}
@Test
public void contentType() {
void contentType() {
String body = "foo";
Mono<EntityResponse<String>>
result = EntityResponse.fromObject(body).contentType(MediaType.APPLICATION_JSON).build();
@@ -128,7 +129,7 @@ public class DefaultEntityResponseBuilderTests {
}
@Test
public void etag() {
void etag() {
String body = "foo";
Mono<EntityResponse<String>> result = EntityResponse.fromObject(body).eTag("foo").build();
StepVerifier.create(result)
@@ -138,7 +139,7 @@ public class DefaultEntityResponseBuilderTests {
}
@Test
public void lastModified() {
void lastModified() {
ZonedDateTime now = ZonedDateTime.now();
String body = "foo";
Mono<EntityResponse<String>> result = EntityResponse.fromObject(body).lastModified(now).build();
@@ -150,7 +151,7 @@ public class DefaultEntityResponseBuilderTests {
}
@Test
public void cacheControlTag() {
void cacheControlTag() {
String body = "foo";
Mono<EntityResponse<String>>
result = EntityResponse.fromObject(body).cacheControl(CacheControl.noCache()).build();
@@ -161,7 +162,7 @@ public class DefaultEntityResponseBuilderTests {
}
@Test
public void varyBy() {
void varyBy() {
String body = "foo";
Mono<EntityResponse<String>> result = EntityResponse.fromObject(body).varyBy("foo").build();
List<String> expected = Collections.singletonList("foo");
@@ -172,7 +173,7 @@ public class DefaultEntityResponseBuilderTests {
}
@Test
public void headers() {
void headers() {
String body = "foo";
HttpHeaders headers = new HttpHeaders();
Mono<EntityResponse<String>> result = EntityResponse.fromObject(body).headers(headers).build();
@@ -183,7 +184,7 @@ public class DefaultEntityResponseBuilderTests {
}
@Test
public void cookies() {
void cookies() {
MultiValueMap<String, ResponseCookie> newCookies = new LinkedMultiValueMap<>();
newCookies.add("name", ResponseCookie.from("name", "value").build());
Mono<EntityResponse<String>> result =
@@ -195,7 +196,7 @@ public class DefaultEntityResponseBuilderTests {
}
@Test
public void bodyInserter() {
void bodyInserter() {
String body = "foo";
Publisher<String> publisher = Mono.just(body);
@@ -229,7 +230,7 @@ public class DefaultEntityResponseBuilderTests {
}
@Test
public void notModifiedEtag() {
void notModifiedEtag() {
String etag = "\"foo\"";
EntityResponse<String> responseMono = EntityResponse.fromObject("bar")
.eTag(etag)
@@ -251,7 +252,7 @@ public class DefaultEntityResponseBuilderTests {
}
@Test
public void notModifiedLastModified() {
void notModifiedLastModified() {
ZonedDateTime now = ZonedDateTime.now();
ZonedDateTime oneMinuteBeforeNow = now.minus(1, ChronoUnit.MINUTES);

76
spring-webflux/src/test/java/org/springframework/web/reactive/function/server/DefaultServerResponseBuilderTests.java
View File

@@ -1,5 +1,5 @@
/*
* Copyright 2002-2019 the original author or authors.
* Copyright 2002-2022 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.
@@ -48,7 +48,7 @@ import static org.assertj.core.api.Assertions.assertThatIllegalArgumentException
/**
* @author Arjen Poutsma
*/
public class DefaultServerResponseBuilderTests {
class DefaultServerResponseBuilderTests {
static final ServerResponse.Context EMPTY_CONTEXT = new ServerResponse.Context() {
@Override
@@ -64,7 +64,7 @@ public class DefaultServerResponseBuilderTests {
@Test
public void from() {
void from() {
ResponseCookie cookie = ResponseCookie.from("foo", "bar").build();
ServerResponse other = ServerResponse.ok().header("foo", "bar")
.cookie(cookie)
@@ -81,7 +81,8 @@ public class DefaultServerResponseBuilderTests {
}
@Test
public void status() {
@SuppressWarnings("deprecation")
void status() {
Mono<ServerResponse> result = ServerResponse.status(HttpStatus.CREATED).build();
StepVerifier.create(result)
.expectNextMatches(response -> HttpStatus.CREATED.equals(response.statusCode()) &&
@@ -91,17 +92,16 @@ public class DefaultServerResponseBuilderTests {
}
@Test
public void ok() {
void ok() {
Mono<ServerResponse> result = ServerResponse.ok().build();
StepVerifier.create(result)
.expectNextMatches(response -> HttpStatus.OK.equals(response.statusCode()))
.expectComplete()
.verify();
}
@Test
public void created() {
void created() {
URI location = URI.create("https://example.com");
Mono<ServerResponse> result = ServerResponse.created(location).build();
StepVerifier.create(result)
@@ -112,27 +112,25 @@ public class DefaultServerResponseBuilderTests {
}
@Test
public void accepted() {
void accepted() {
Mono<ServerResponse> result = ServerResponse.accepted().build();
StepVerifier.create(result)
.expectNextMatches(response -> HttpStatus.ACCEPTED.equals(response.statusCode()))
.expectComplete()
.verify();
}
@Test
public void noContent() {
void noContent() {
Mono<ServerResponse> result = ServerResponse.noContent().build();
StepVerifier.create(result)
.expectNextMatches(response -> HttpStatus.NO_CONTENT.equals(response.statusCode()))
.expectComplete()
.verify();
}
@Test
public void seeOther() {
void seeOther() {
URI location = URI.create("https://example.com");
Mono<ServerResponse> result = ServerResponse.seeOther(location).build();
StepVerifier.create(result)
@@ -143,7 +141,7 @@ public class DefaultServerResponseBuilderTests {
}
@Test
public void temporaryRedirect() {
void temporaryRedirect() {
URI location = URI.create("https://example.com");
Mono<ServerResponse> result = ServerResponse.temporaryRedirect(location).build();
StepVerifier.create(result)
@@ -154,7 +152,7 @@ public class DefaultServerResponseBuilderTests {
}
@Test
public void permanentRedirect() {
void permanentRedirect() {
URI location = URI.create("https://example.com");
Mono<ServerResponse> result = ServerResponse.permanentRedirect(location).build();
StepVerifier.create(result)
@@ -165,58 +163,53 @@ public class DefaultServerResponseBuilderTests {
}
@Test
public void badRequest() {
void badRequest() {
Mono<ServerResponse> result = ServerResponse.badRequest().build();
StepVerifier.create(result)
.expectNextMatches(response -> HttpStatus.BAD_REQUEST.equals(response.statusCode()))
.expectComplete()
.verify();
}
@Test
public void notFound() {
void notFound() {
Mono<ServerResponse> result = ServerResponse.notFound().build();
StepVerifier.create(result)
.expectNextMatches(response -> HttpStatus.NOT_FOUND.equals(response.statusCode()))
.expectComplete()
.verify();
}
@Test
public void unprocessableEntity() {
void unprocessableEntity() {
Mono<ServerResponse> result = ServerResponse.unprocessableEntity().build();
StepVerifier.create(result)
.expectNextMatches(response -> HttpStatus.UNPROCESSABLE_ENTITY.equals(response.statusCode()))
.expectComplete()
.verify();
}
@Test
public void allow() {
void allow() {
Mono<ServerResponse> result = ServerResponse.ok().allow(HttpMethod.GET).build();
Set<HttpMethod> expected = Set.of(HttpMethod.GET);
StepVerifier.create(result)
.expectNextMatches(response -> expected.equals(response.headers().getAllow()))
.expectComplete()
.verify();
}
@Test
public void contentLength() {
void contentLength() {
Mono<ServerResponse> result = ServerResponse.ok().contentLength(42).build();
StepVerifier.create(result)
.expectNextMatches(response -> Long.valueOf(42).equals(response.headers().getContentLength()))
.expectComplete()
.verify();
}
@Test
public void contentType() {
void contentType() {
Mono<ServerResponse>
result = ServerResponse.ok().contentType(MediaType.APPLICATION_JSON).build();
StepVerifier.create(result)
@@ -226,17 +219,16 @@ public class DefaultServerResponseBuilderTests {
}
@Test
public void eTag() {
void eTag() {
Mono<ServerResponse> result = ServerResponse.ok().eTag("foo").build();
StepVerifier.create(result)
.expectNextMatches(response -> "\"foo\"".equals(response.headers().getETag()))
.expectComplete()
.verify();
}
@Test
public void lastModified() {
void lastModified() {
ZonedDateTime now = ZonedDateTime.now();
Mono<ServerResponse> result = ServerResponse.ok().lastModified(now).build();
Long expected = now.toInstant().toEpochMilli() / 1000;
@@ -247,7 +239,7 @@ public class DefaultServerResponseBuilderTests {
}
@Test
public void cacheControlTag() {
void cacheControlTag() {
Mono<ServerResponse>
result = ServerResponse.ok().cacheControl(CacheControl.noCache()).build();
StepVerifier.create(result)
@@ -257,29 +249,27 @@ public class DefaultServerResponseBuilderTests {
}
@Test
public void varyBy() {
void varyBy() {
Mono<ServerResponse> result = ServerResponse.ok().varyBy("foo").build();
List<String> expected = Collections.singletonList("foo");
StepVerifier.create(result)
.expectNextMatches(response -> expected.equals(response.headers().getVary()))
.expectComplete()
.verify();
}
@Test
public void statusCode() {
void statusCode() {
HttpStatus statusCode = HttpStatus.ACCEPTED;
Mono<ServerResponse> result = ServerResponse.status(statusCode).build();
StepVerifier.create(result)
.expectNextMatches(response -> statusCode.equals(response.statusCode()))
.expectComplete()
.verify();
}
@Test
public void headers() {
void headers() {
HttpHeaders newHeaders = new HttpHeaders();
newHeaders.set("foo", "bar");
Mono<ServerResponse> result =
@@ -288,11 +278,10 @@ public class DefaultServerResponseBuilderTests {
.expectNextMatches(response -> newHeaders.equals(response.headers()))
.expectComplete()
.verify();
}
@Test
public void cookies() {
void cookies() {
MultiValueMap<String, ResponseCookie> newCookies = new LinkedMultiValueMap<>();
newCookies.add("name", ResponseCookie.from("name", "value").build());
Mono<ServerResponse> result =
@@ -304,7 +293,7 @@ public class DefaultServerResponseBuilderTests {
}
@Test
public void copyCookies() {
void copyCookies() {
Mono<ServerResponse> serverResponse = ServerResponse.ok()
.cookie(ResponseCookie.from("foo", "bar").build())
.bodyValue("body");
@@ -315,12 +304,11 @@ public class DefaultServerResponseBuilderTests {
.cookie(ResponseCookie.from("foo", "bar").build())
.bodyValue("body");
assertThat(serverResponse.block().cookies().isEmpty()).isFalse();
}
@Test
public void overwriteHeaders() {
void overwriteHeaders() {
ServerResponse serverResponse =
ServerResponse.ok().headers(headers -> headers.set("Foo", "Bar")).build().block();
assertThat(serverResponse).isNotNull();
@@ -338,7 +326,7 @@ public class DefaultServerResponseBuilderTests {
@Test
public void build() {
void build() {
ResponseCookie cookie = ResponseCookie.from("name", "value").build();
Mono<ServerResponse>
result = ServerResponse.status(HttpStatus.CREATED)
@@ -358,7 +346,7 @@ public class DefaultServerResponseBuilderTests {
}
@Test
public void buildVoidPublisher() {
void buildVoidPublisher() {
Mono<Void> mono = Mono.empty();
Mono<ServerResponse> result = ServerResponse.ok().build(mono);
@@ -372,7 +360,7 @@ public class DefaultServerResponseBuilderTests {
}
@Test
public void bodyObjectPublisher() {
void bodyObjectPublisher() {
Mono<Void> mono = Mono.empty();
assertThatIllegalArgumentException().isThrownBy(() ->
@@ -380,7 +368,7 @@ public class DefaultServerResponseBuilderTests {
}
@Test
public void notModifiedEtag() {
void notModifiedEtag() {
String etag = "\"foo\"";
ServerResponse responseMono = ServerResponse.ok()
.eTag(etag)
@@ -402,7 +390,7 @@ public class DefaultServerResponseBuilderTests {
}
@Test
public void notModifiedLastModified() {
void notModifiedLastModified() {
ZonedDateTime now = ZonedDateTime.now();
ZonedDateTime oneMinuteBeforeNow = now.minus(1, ChronoUnit.MINUTES);

30
spring-webflux/src/test/java/org/springframework/web/reactive/function/server/RouterFunctionsTests.java
View File

@@ -1,5 +1,5 @@
/*
* Copyright 2002-2020 the original author or authors.
* Copyright 2002-2022 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.
@@ -48,10 +48,10 @@ import static org.mockito.Mockito.mock;
* @author Arjen Poutsma
* @since 5.0
*/
public class RouterFunctionsTests {
class RouterFunctionsTests {
@Test
public void routeMatch() {
void routeMatch() {
HandlerFunction<ServerResponse> handlerFunction = request -> ServerResponse.ok().build();
MockServerHttpRequest mockRequest = MockServerHttpRequest.get("https://example.com").build();
@@ -72,7 +72,7 @@ public class RouterFunctionsTests {
}
@Test
public void routeNoMatch() {
void routeNoMatch() {
HandlerFunction<ServerResponse> handlerFunction = request -> ServerResponse.ok().build();
MockServerHttpRequest mockRequest = MockServerHttpRequest.get("https://example.com").build();
@@ -90,7 +90,7 @@ public class RouterFunctionsTests {
}
@Test
public void nestMatch() {
void nestMatch() {
HandlerFunction<ServerResponse> handlerFunction = request -> ServerResponse.ok().build();
RouterFunction<ServerResponse> routerFunction = request -> Mono.just(handlerFunction);
@@ -110,7 +110,7 @@ public class RouterFunctionsTests {
}
@Test
public void nestNoMatch() {
void nestNoMatch() {
HandlerFunction<ServerResponse> handlerFunction = request -> ServerResponse.ok().build();
RouterFunction<ServerResponse> routerFunction = request -> Mono.just(handlerFunction);
@@ -129,7 +129,7 @@ public class RouterFunctionsTests {
}
@Test
public void toHttpHandlerNormal() {
void toHttpHandlerNormal() {
HandlerFunction<ServerResponse> handlerFunction = request -> ServerResponse.accepted().build();
RouterFunction<ServerResponse> routerFunction =
RouterFunctions.route(RequestPredicates.all(), handlerFunction);
@@ -144,7 +144,7 @@ public class RouterFunctionsTests {
}
@Test
public void toHttpHandlerHandlerThrowsException() {
void toHttpHandlerHandlerThrowsException() {
HandlerFunction<ServerResponse> handlerFunction =
request -> {
throw new IllegalStateException();
@@ -162,7 +162,7 @@ public class RouterFunctionsTests {
}
@Test
public void toHttpHandlerHandlerReturnsException() {
void toHttpHandlerHandlerReturnsException() {
HandlerFunction<ServerResponse> handlerFunction =
request -> Mono.error(new IllegalStateException());
RouterFunction<ServerResponse> routerFunction =
@@ -178,7 +178,7 @@ public class RouterFunctionsTests {
}
@Test
public void toHttpHandlerHandlerResponseStatusException() {
void toHttpHandlerHandlerResponseStatusException() {
HandlerFunction<ServerResponse> handlerFunction =
request -> Mono.error(new ResponseStatusException(HttpStatus.NOT_FOUND, "Not found"));
RouterFunction<ServerResponse> routerFunction =
@@ -194,7 +194,7 @@ public class RouterFunctionsTests {
}
@Test
public void toHttpHandlerRouteNotFoundReturnsResponseStatusException() {
void toHttpHandlerRouteNotFoundReturnsResponseStatusException() {
HandlerFunction<ServerResponse> handlerFunction = request -> ServerResponse.accepted().build();
RouterFunction<ServerResponse> routerFunction =
RouterFunctions.route(RequestPredicates.GET("/path"), handlerFunction);
@@ -215,7 +215,7 @@ public class RouterFunctionsTests {
}
@Test
public void toHttpHandlerHandlerReturnResponseStatusExceptionInResponseWriteTo() {
void toHttpHandlerHandlerReturnResponseStatusExceptionInResponseWriteTo() {
HandlerFunction<ServerResponse> handlerFunction =
// Mono.<ServerResponse> is required for compilation in Eclipse
request -> Mono.just(new ServerResponse() {
@@ -223,6 +223,7 @@ public class RouterFunctionsTests {
public HttpStatus statusCode() {
return HttpStatus.OK;
}
@SuppressWarnings("deprecation")
@Override
public int rawStatusCode() {
return 200;
@@ -253,7 +254,7 @@ public class RouterFunctionsTests {
}
@Test
public void toHttpHandlerHandlerThrowResponseStatusExceptionInResponseWriteTo() {
void toHttpHandlerHandlerThrowResponseStatusExceptionInResponseWriteTo() {
HandlerFunction<ServerResponse> handlerFunction =
// Mono.<ServerResponse> is required for compilation in Eclipse
request -> Mono.just(new ServerResponse() {
@@ -261,6 +262,7 @@ public class RouterFunctionsTests {
public HttpStatus statusCode() {
return HttpStatus.OK;
}
@SuppressWarnings("deprecation")
@Override
public int rawStatusCode() {
return 200;
@@ -291,7 +293,7 @@ public class RouterFunctionsTests {
}
@Test
public void toHttpHandlerWebFilter() {
void toHttpHandlerWebFilter() {
AtomicBoolean filterInvoked = new AtomicBoolean();
WebFilter webFilter = (exchange, chain) -> {