import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.web.server.LocalServerPort;
import org.springframework.http.MediaType;
+import org.springframework.test.annotation.DirtiesContext;
import org.springframework.test.web.reactive.server.WebTestClient;
import org.testcontainers.shaded.org.awaitility.Awaitility;
@Slf4j
+@DirtiesContext
public abstract class AbstractConfigurationIT
{
final static String EXISTING_CHATROOM = "5c73531c-6fc4-426c-adcb-afc5c140a0f7";
@DisplayName("A message can be put into a newly created chat-room")
void testPutMessageInNewChatRoom() throws IOException
{
+ ChatRoomInfoTo chatRoomInfo;
+ do
+ {
+ // The first request creates a new chat-room
+ // It must be repeated, until a chat-room was created,
+ // that is owned by the instance
+ chatRoomInfo = webTestClient
+ .post()
+ .uri("http://localhost:{port}/create", port)
+ .contentType(MediaType.TEXT_PLAIN)
+ .bodyValue("bar")
+ .accept(MediaType.APPLICATION_JSON)
+ .exchange()
+ .returnResult(ChatRoomInfoTo.class)
+ .getResponseBody()
+ .retry(30)
+ .blockFirst();
+ }
+ while(!(chatRoomInfo.getShard() == null || chatRoomInfo.getShard().intValue() == 2));
+
+ UUID chatRoomId = chatRoomInfo.getId();
+
Awaitility
.await()
.atMost(Duration.ofSeconds(15))
.untilAsserted(() ->
{
- byte[] result = webTestClient
- .post()
- .uri("http://localhost:{port}/create", port)
- .contentType(MediaType.TEXT_PLAIN)
- .bodyValue("bar")
- .accept(MediaType.APPLICATION_JSON)
- .exchange()
- .expectStatus().isOk()
- .expectBody()
- .jsonPath("$.id").exists()
- .jsonPath("$.name").isEqualTo("bar")
- // The hard must not be asserted, because not all implementations ar aware of it
- // .jsonPath("$.shard").isEqualTo(Integer.valueOf(2))
- .returnResult()
- .getResponseBody();
- ChatRoomInfoTo chatRoomInfo = objectMapper.readValue(result, ChatRoomInfoTo.class);
- UUID chatRoomId = chatRoomInfo.getId();
webTestClient
.put()
.uri(