import de.juplo.kafka.chat.backend.domain.ChatRoom;
import de.juplo.kafka.chat.backend.domain.ChatRoomService;
-import de.juplo.kafka.chat.backend.persistence.inmemory.ChatHomeService;
-import de.juplo.kafka.chat.backend.persistence.inmemory.SimpleChatHome;
import org.junit.jupiter.api.DisplayName;
import org.junit.jupiter.api.Test;
import reactor.core.publisher.Mono;
void testGetExistingChatroom()
{
// Given
- ChatHomeService chatHomeService = mock(ChatHomeService.class);
+ InMemoryChatHomeService chatHomeService = mock(InMemoryChatHomeService.class);
ChatRoom chatRoom = new ChatRoom(
UUID.randomUUID(),
"Foo",
void testGetNonExistentChatroom()
{
// Given
- ChatHomeService chatHomeService = mock(ChatHomeService.class);
+ InMemoryChatHomeService chatHomeService = mock(InMemoryChatHomeService.class);
when(chatHomeService.getChatRoom(anyInt(), any(UUID.class))).thenReturn(Mono.empty());
SimpleChatHome chatHome = new SimpleChatHome(chatHomeService);