1 package de.juplo.kafka.chat.backend.domain;
3 import org.junit.jupiter.api.BeforeEach;
4 import org.junit.jupiter.api.DisplayName;
5 import org.junit.jupiter.api.Test;
6 import reactor.core.publisher.Mono;
8 import java.time.Clock;
9 import java.time.Instant;
10 import java.time.LocalDateTime;
11 import java.time.ZoneId;
13 import static org.mockito.Mockito.*;
14 import static pl.rzrz.assertj.reactor.Assertions.assertThat;
17 public class ChatRoomDataTest
20 ChatMessageService chatMessageService;
21 ChatRoomData chatRoomData;
25 Message.MessageKey key;
26 LocalDateTime timestamp;
32 now = Clock.fixed(Instant.now(), ZoneId.systemDefault());
33 chatMessageService = mock(ChatMessageService.class);
34 chatRoomData = new ChatRoomData(
41 key = Message.MessageKey.of(user, messageId);
42 timestamp = LocalDateTime.now(now);
47 @DisplayName("Assert, that Mono emits expected message, if it exists")
48 void testGetExistingMessage()
51 when(chatMessageService.getMessage(any(Message.MessageKey.class)))
52 .thenReturn(Mono.just(someMessage()));
55 Mono<Message> mono = chatRoomData.getMessage(user, messageId);
58 assertThat(mono).emitsExactly(someMessage());
62 @DisplayName("Assert, that Mono is empty, if message does not exists")
63 void testGetNonExistentMessage()
66 when(chatMessageService.getMessage(any(Message.MessageKey.class)))
67 .thenReturn(Mono.empty());
70 Mono<Message> mono = chatRoomData.getMessage(user, messageId);
73 assertThat(mono).emitsCount(0);
77 @DisplayName("Assert, that Mono emits the persisted message, if a new message is added")
78 void testAddNewMessageEmitsPersistedMessage()
81 when(chatMessageService.getMessage(any(Message.MessageKey.class)))
82 .thenReturn(Mono.empty());
83 when(chatMessageService.persistMessage(any(Message.MessageKey.class), any(LocalDateTime.class), any(String.class)))
84 .thenReturn(Mono.just(someMessage()));
87 Mono<Message> mono = chatRoomData.addMessage(messageId, user, "Some Text");
90 assertThat(mono).emitsExactly(someMessage());
94 @DisplayName("Assert, that ChatMessageService.persistMessage() is called correctly, if a new message is added")
95 void testAddNewMessageTriggersPersistence()
98 String messageText = "Bar";
99 when(chatMessageService.getMessage(any(Message.MessageKey.class)))
100 .thenReturn(Mono.empty());
101 when(chatMessageService.persistMessage(any(Message.MessageKey.class), any(LocalDateTime.class), any(String.class)))
102 .thenReturn(Mono.just(someMessage()));
106 .addMessage(messageId, user, messageText)
110 verify(chatMessageService, times(1)).persistMessage(eq(key), eq(timestamp), eq(messageText));
114 @DisplayName("Assert, that Mono emits the already persisted message, if an unchanged message is added")
115 void testAddUnchangedMessageEmitsAlreadyPersistedMessage()
118 String messageText = "Bar";
119 Message existingMessage = new Message(key, 0l, timestamp, messageText);
120 when(chatMessageService.getMessage(any(Message.MessageKey.class)))
121 .thenReturn(Mono.just(existingMessage));
124 Mono<Message> mono = chatRoomData.addMessage(messageId, user, messageText);
127 assertThat(mono).emitsExactly(existingMessage);
131 @DisplayName("Assert, that ChatMessageService.persistMessage() is not called, if an unchanged message is added")
132 void testAddUnchangedMessageDoesNotTriggerPersistence()
135 String messageText = "Bar";
136 Message existingMessage = new Message(key, 0l, timestamp, messageText);
137 when(chatMessageService.getMessage(any(Message.MessageKey.class)))
138 .thenReturn(Mono.just(existingMessage));
142 .addMessage(messageId, user, messageText)
146 verify(chatMessageService, never()).persistMessage(any(), any(), any());
150 @DisplayName("Assert, that Mono sends an error, if a message is added again with mutated text")
151 void testAddMutatedMessageSendsError()
154 String messageText = "Bar";
155 String mutatedText = "Boom!";
156 Message existingMessage = new Message(key, 0l, timestamp, messageText);
157 when(chatMessageService.getMessage(any(Message.MessageKey.class)))
158 .thenReturn(Mono.just(existingMessage));
161 Mono<Message> mono = chatRoomData.addMessage(messageId, user, mutatedText);
164 assertThat(mono).sendsError();
168 @DisplayName("Assert, that ChatMessageService.persistMessage() is not called, if a message is added again with mutated text")
169 void testAddMutatedDoesNotTriggerPersistence()
172 String messageText = "Bar";
173 String mutatedText = "Boom!";
174 Message existingMessage = new Message(key, 0l, timestamp, messageText);
175 when(chatMessageService.getMessage(any(Message.MessageKey.class)))
176 .thenReturn(Mono.just(existingMessage));
180 .addMessage(messageId, user, mutatedText)
181 .onErrorResume((throwable) -> Mono.empty())
185 verify(chatMessageService, never()).persistMessage(any(), any(), any());
190 * This message is used, when methods of {@link ChatMessageService} are mocked,
191 * that return a {@link Message}.
192 * The contents of the message are set to arbitrary values, in order to underline
193 * the fact, that the test can only assert, that the message that was returned
194 * by {@link ChatMessageService} is handed on by {@link ChatRoomData} correctly.
197 private Message someMessage()
200 Message.MessageKey.of("FOO", 666l),
202 LocalDateTime.of(2024, 3, 8, 12, 13, 00),
203 "Just some message...");