From ddf5d35ceef43e3bf275fec8f0453d69f7c283f3 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Sat, 27 Jan 2024 16:08:06 +0100
Subject: [PATCH] WIP

---
 .../chat/backend/AbstractConfigurationIT.java | 98 +++++++++++--------
 1 file changed, 57 insertions(+), 41 deletions(-)

diff --git a/src/test/java/de/juplo/kafka/chat/backend/AbstractConfigurationIT.java b/src/test/java/de/juplo/kafka/chat/backend/AbstractConfigurationIT.java
index e1e87c59..c357f780 100644
--- a/src/test/java/de/juplo/kafka/chat/backend/AbstractConfigurationIT.java
+++ b/src/test/java/de/juplo/kafka/chat/backend/AbstractConfigurationIT.java
@@ -55,65 +55,81 @@ public abstract class AbstractConfigurationIT
   @DisplayName("Restored chat-rooms can be listed")
   void testRestoredChatRoomsCanBeListed()
   {
-    webTestClient
-        .get()
-        .uri(
-            "http://localhost:{port}/list",
-            port)
-        .accept(MediaType.APPLICATION_JSON)
-        .exchange()
-        .expectStatus().isOk()
-        .expectBody()
-        .jsonPath("$.length()").isEqualTo(1)
-        .jsonPath("$[0].name").isEqualTo("FOO");
+    Awaitility
+        .await()
+        .atMost(Duration.ofSeconds(15))
+        .untilAsserted(() ->
+            webTestClient
+                .get()
+                .uri(
+                    "http://localhost:{port}/list",
+                    port)
+                .accept(MediaType.APPLICATION_JSON)
+                .exchange()
+                .expectStatus().isOk()
+                .expectBody()
+                .jsonPath("$.length()").isEqualTo(1)
+                .jsonPath("$[0].name").isEqualTo("FOO"));
   }
 
   @Test
   @DisplayName("Details as expected for restored chat-room")
   void testRestoredChatRoomHasExpectedDetails()
   {
-    webTestClient
-        .get()
-        .uri(
-            "http://localhost:{port}/{chatRoomId}",
-            port,
-            EXISTING_CHATROOM)
-        .accept(MediaType.APPLICATION_JSON)
-        .exchange()
-        .expectStatus().isOk()
-        .expectBody().jsonPath("$.name").isEqualTo("FOO");
+    Awaitility
+        .await()
+        .atMost(Duration.ofSeconds(15))
+        .untilAsserted(() ->
+            webTestClient
+                .get()
+                .uri(
+                    "http://localhost:{port}/{chatRoomId}",
+                    port,
+                    EXISTING_CHATROOM)
+                .accept(MediaType.APPLICATION_JSON)
+                .exchange()
+                .expectStatus().isOk()
+                .expectBody().jsonPath("$.name").isEqualTo("FOO"));
   }
 
   @Test
   @DisplayName("Restored message from Ute has expected Text")
   void testRestoredMessageForUteHasExpectedText()
   {
-    webTestClient
-        .get()
-        .uri(
-            "http://localhost:{port}/{chatRoomId}/ute/1",
-            port,
-            EXISTING_CHATROOM)
-        .accept(MediaType.APPLICATION_JSON)
-        .exchange()
-        .expectStatus().isOk()
-        .expectBody().jsonPath("$.text").isEqualTo("Ich bin Ute...");
+    Awaitility
+        .await()
+        .atMost(Duration.ofSeconds(15))
+        .untilAsserted(() ->
+            webTestClient
+                .get()
+                .uri(
+                    "http://localhost:{port}/{chatRoomId}/ute/1",
+                    port,
+                    EXISTING_CHATROOM)
+                .accept(MediaType.APPLICATION_JSON)
+                .exchange()
+                .expectStatus().isOk()
+                .expectBody().jsonPath("$.text").isEqualTo("Ich bin Ute..."));
   }
 
   @Test
   @DisplayName("Restored message from Peter has expected Text")
   void testRestoredMessageForPeterHasExpectedText()
   {
-    webTestClient
-        .get()
-        .uri(
-            "http://localhost:{port}/{chatRoomId}/peter/1",
-            port,
-            EXISTING_CHATROOM)
-        .accept(MediaType.APPLICATION_JSON)
-        .exchange()
-        .expectStatus().isOk()
-        .expectBody().jsonPath("$.text").isEqualTo("Hallo, ich heiße Peter!");
+    Awaitility
+        .await()
+        .atMost(Duration.ofSeconds(15))
+        .untilAsserted(() ->
+            webTestClient
+                .get()
+                .uri(
+                    "http://localhost:{port}/{chatRoomId}/peter/1",
+                    port,
+                    EXISTING_CHATROOM)
+                .accept(MediaType.APPLICATION_JSON)
+                .exchange()
+                .expectStatus().isOk()
+                .expectBody().jsonPath("$.text").isEqualTo("Hallo, ich heiße Peter!"));
   }
 
   @Test
-- 
2.20.1