import org.junit.jupiter.api.DisplayName;
import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.ExtendWith;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.test.context.junit.jupiter.SpringExtension;
import reactor.core.publisher.Mono;
+import reactor.util.retry.Retry;
-import java.time.Clock;
+import java.time.Duration;
import java.util.UUID;
-import static org.mockito.ArgumentMatchers.any;
-import static org.mockito.ArgumentMatchers.anyInt;
-import static org.mockito.Mockito.mock;
-import static org.mockito.Mockito.when;
import static pl.rzrz.assertj.reactor.Assertions.assertThat;
-public class ChatHomeTest
+@ExtendWith(SpringExtension.class)
+public abstract class ChatHomeTest
{
+ @Autowired
+ ChatHome chatHome;
+
+
@Test
@DisplayName("Assert chatroom is delivered, if it exists")
void testGetExistingChatroom()
{
// Given
- ChatHomeService chatHomeService = mock(ChatHomeService.class);
- ChatRoom chatRoom = new ChatRoom(
- UUID.randomUUID(),
- "Foo",
- 0,
- Clock.systemDefaultZone(),
- mock(ChatRoomService.class),
- 8);
- when(chatHomeService.getChatRoom(anyInt(), any(UUID.class))).thenReturn(Mono.just(chatRoom));
- ChatHome chatHome = new ChatHome(chatHomeService, 0);
+ UUID chatRoomId = UUID.fromString("5c73531c-6fc4-426c-adcb-afc5c140a0f7");
// When
- Mono<ChatRoom> mono = chatHome.getChatRoom(chatRoom.getId());
+ Mono<ChatRoom> mono = Mono
+ .defer(() -> chatHome.getChatRoom(chatRoomId))
+ .log("testGetExistingChatroom")
+ .retryWhen(Retry
+ .backoff(5, Duration.ofSeconds(1))
+ .filter(throwable -> throwable instanceof LoadInProgressException));
// Then
- assertThat(mono).emitsExactly(chatRoom);
+ assertThat(mono).emitsCount(1);
}
@Test
void testGetNonExistentChatroom()
{
// Given
- ChatHomeService chatHomeService = mock(ChatHomeService.class);
- when(chatHomeService.getChatRoom(anyInt(), any(UUID.class))).thenReturn(Mono.empty());
- ChatHome chatHome = new ChatHome(chatHomeService, 0);
+ UUID chatRoomId = UUID.fromString("7f59ec77-832e-4a17-8d22-55ef46242c17");
// When
- Mono<ChatRoom> mono = chatHome.getChatRoom(UUID.randomUUID());
+ Mono<ChatRoom> mono = Mono
+ .defer(() -> chatHome.getChatRoom(chatRoomId))
+ .log("testGetNonExistentChatroom")
+ .retryWhen(Retry
+ .backoff(5, Duration.ofSeconds(1))
+ .filter(throwable -> throwable instanceof LoadInProgressException));
// Then
- assertThat(mono).sendsError();
+ assertThat(mono).sendsError(e ->
+ {
+ assertThat(e).isInstanceOf(UnknownChatroomException.class);
+ UnknownChatroomException unknownChatroomException = (UnknownChatroomException) e;
+ assertThat(unknownChatroomException.getChatroomId()).isEqualTo(chatRoomId);
+ });
}
}