Spring/spring-aot-smoke-tests
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix session-redis-webflux integration tests

Browse Source
This commit is contained in:
Moritz Halbritter
2022-08-04 16:13:02 +02:00
parent 7a39bc5dda
commit 68b45c69c0
3 changed files with 9 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
session-redis-webflux/src/aotTest/java/com/example/session/redis/webflux/SessionRedisWebfluxApplicationTests.java
View File

@@ -13,12 +13,12 @@ public class SessionRedisWebfluxApplicationTests {
@Test
void shouldIncreaseCounter(WebTestClient client) {
AtomicReference<String> sessionId = new AtomicReference<>();
client.get().uri("/counter").exchange().expectCookie().value("SESSION", sessionId::set).expectBody()
.jsonPath("$.counter").isEqualTo(1);
client.get().uri("/counter").cookie("SESSION", sessionId.get()).exchange().expectBody().jsonPath("$.counter")
.isEqualTo(2);
client.get().uri("/counter").cookie("SESSION", sessionId.get()).exchange().expectBody().jsonPath("$.counter")
.isEqualTo(3);
client.get().uri("/counter").exchange().expectStatus().isOk().expectCookie().value("SESSION", sessionId::set)
.expectBody().jsonPath("$.counter").isEqualTo(1);
client.get().uri("/counter").cookie("SESSION", sessionId.get()).exchange().expectStatus().isOk().expectBody()
.jsonPath("$.counter").isEqualTo(2);
client.get().uri("/counter").cookie("SESSION", sessionId.get()).exchange().expectStatus().isOk().expectBody()
.jsonPath("$.counter").isEqualTo(3);
}
}

4
session-redis-webflux/src/main/java/com/example/session/redis/webflux/SessionConfig.java
View File

@@ -15,7 +15,9 @@ class SessionConfig {
@Bean
LettuceConnectionFactory redisConnectionFactory() {
return new LettuceConnectionFactory();
String redisHost = System.getenv().getOrDefault("REDIS_HOST", "localhost");
String port = System.getenv().getOrDefault("REDIS_PORT_6379", "6379");
return new LettuceConnectionFactory(redisHost, Integer.parseInt(port));
}
@Bean

2
session-redis-webflux/src/main/resources/application.properties
View File

@@ -1,2 +0,0 @@
spring.redis.host=${REDIS_HOST:localhost}
spring.redis.port=${REDIS_PORT_6379:6379}