import de.juplo.kafka.chat.backend.ChatBackendProperties;
import de.juplo.kafka.chat.backend.domain.*;
import de.juplo.kafka.chat.backend.ChatBackendProperties;
import de.juplo.kafka.chat.backend.domain.*;
import lombok.extern.slf4j.Slf4j;
import org.junit.jupiter.api.DisplayName;
import org.junit.jupiter.api.Test;
import lombok.extern.slf4j.Slf4j;
import org.junit.jupiter.api.DisplayName;
import org.junit.jupiter.api.Test;
String textMutatedMessage = "Mutated!";
ChatRoomData chatRoomData = new ChatRoomData(
Clock.systemDefaultZone(),
String textMutatedMessage = "Mutated!";
ChatRoomData chatRoomData = new ChatRoomData(
Clock.systemDefaultZone(),
Message existingMessage = new Message(
key,
serialNumberExistingMessage,
timeExistingMessage,
textExistingMessage);
Message existingMessage = new Message(
key,
serialNumberExistingMessage,
timeExistingMessage,
textExistingMessage);
.thenReturn(Mono.just(existingMessage));
// Needed for readable error-reports, in case of a bug that leads to according unwanted call
.thenReturn(Mono.just(existingMessage));
// Needed for readable error-reports, in case of a bug that leads to according unwanted call
- when(chatRoomService.persistMessage(any(Message.MessageKey.class), any(LocalDateTime.class), any(String.class)))
+ when(chatMessageService.persistMessage(any(Message.MessageKey.class), any(LocalDateTime.class), any(String.class)))
.jsonPath("$.existingMessage.user").isEqualTo(user)
.jsonPath("$.existingMessage.text").isEqualTo(textExistingMessage)
.jsonPath("$.mutatedText").isEqualTo(textMutatedMessage);
.jsonPath("$.existingMessage.user").isEqualTo(user)
.jsonPath("$.existingMessage.text").isEqualTo(textExistingMessage)
.jsonPath("$.mutatedText").isEqualTo(textMutatedMessage);
- verify(chatRoomService, never()).persistMessage(eq(key), any(LocalDateTime.class), any(String.class));
+ verify(chatMessageService, never()).persistMessage(eq(key), any(LocalDateTime.class), any(String.class));
String textMessage = "Hallo Welt";
ChatRoomData chatRoomData = new ChatRoomData(
Clock.systemDefaultZone(),
String textMessage = "Hallo Welt";
ChatRoomData chatRoomData = new ChatRoomData(
Clock.systemDefaultZone(),
.thenReturn(Mono.empty());
// Needed for readable error-reports, in case of a bug that leads to according unwanted call
.thenReturn(Mono.empty());
// Needed for readable error-reports, in case of a bug that leads to according unwanted call
- when(chatRoomService.persistMessage(any(Message.MessageKey.class), any(LocalDateTime.class), any(String.class)))
+ when(chatMessageService.persistMessage(any(Message.MessageKey.class), any(LocalDateTime.class), any(String.class)))
- verify(chatRoomService, never()).persistMessage(eq(key), any(LocalDateTime.class), any(String.class));
+ verify(chatMessageService, never()).persistMessage(eq(key), any(LocalDateTime.class), any(String.class));