X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fchat%2Fbackend%2Fapi%2FChatBackendControllerTest.java;h=8947a03cd0579227d81d4482e92d92ccb0fff4f9;hb=972a1f2c248a51740091c1fdf3526f0eb676639e;hp=404fab2560279052f94e08eefc1c057257a9845f;hpb=f9b0d9a71a85741983a451a51fdbd1c38632be87;p=demos%2Fkafka%2Fchat diff --git a/src/test/java/de/juplo/kafka/chat/backend/api/ChatBackendControllerTest.java b/src/test/java/de/juplo/kafka/chat/backend/api/ChatBackendControllerTest.java index 404fab25..8947a03c 100644 --- a/src/test/java/de/juplo/kafka/chat/backend/api/ChatBackendControllerTest.java +++ b/src/test/java/de/juplo/kafka/chat/backend/api/ChatBackendControllerTest.java @@ -13,7 +13,6 @@ import org.springframework.test.web.reactive.server.WebTestClient; import reactor.core.publisher.Mono; import java.time.LocalDateTime; -import java.util.Optional; import java.util.UUID; import static org.mockito.ArgumentMatchers.any; @@ -167,10 +166,9 @@ public class ChatBackendControllerTest .thenReturn(Mono.just(chatRoom)); Message.MessageKey key = Message.MessageKey.of("foo", 1l); LocalDateTime timestamp = LocalDateTime.now(); - Message mutated = new Message(key, 0l, timestamp, "Mutated!"); Message existing = new Message(key, 0l, timestamp, "Existing"); when(chatRoom.addMessage(any(Long.class), any(String.class), any(String.class))) - .thenThrow(new MessageMutationException(mutated, existing)); + .thenReturn(Mono.error(() -> new MessageMutationException(existing, "Mutated!"))); // When client @@ -187,7 +185,7 @@ public class ChatBackendControllerTest .expectStatus().is4xxClientError() .expectBody() .jsonPath("$.type").isEqualTo("/problem/message-mutation") - .jsonPath("$.mutatedMessage.text").isEqualTo("Mutated!") - .jsonPath("$.existingMessage.text").isEqualTo("Existing"); + .jsonPath("$.existingMessage.text").isEqualTo("Existing") + .jsonPath("$.mutatedText").isEqualTo("Mutated!"); } }