1 package de.juplo.kafka.chat.backend;
3 import org.junit.jupiter.api.Test;
4 import org.springframework.beans.factory.annotation.Autowired;
5 import org.springframework.boot.test.context.SpringBootTest;
6 import org.springframework.boot.test.web.server.LocalServerPort;
7 import org.springframework.http.MediaType;
8 import org.springframework.test.web.reactive.server.WebTestClient;
9 import org.testcontainers.shaded.org.awaitility.Awaitility;
11 import java.time.Duration;
15 webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT,
16 properties = "chat.backend.storage-directory=target/test-classes/data/files")
17 class InMemoryWithFilesStorageIT
22 private WebTestClient webTestClient;
29 .atMost(Duration.ofSeconds(15))
34 .uri("http://localhost:{port}/actuator/health", port)
36 .expectStatus().isOk()
37 .expectBody().jsonPath("$.status").isEqualTo("UP");
40 .uri("http://localhost:{port}/618e89ae-fdc0-4c65-8055-f49908295e8f", port)
41 .accept(MediaType.APPLICATION_JSON)
43 .expectStatus().isOk()
44 .expectBody().jsonPath("$.name").isEqualTo("Peter's Chat-Room");
47 .uri("http://localhost:{port}/618e89ae-fdc0-4c65-8055-f49908295e8f/ute/1478", port)
48 .accept(MediaType.APPLICATION_JSON)
50 .expectStatus().isOk()
51 .expectBody().jsonPath("$.text").isEqualTo("Nachricht Nr. 1478");