juplo.de Git - demos/kafka/chat/blob - src/test/java/de/juplo/kafka/chat/backend/domain/ChatHomeWithShardsTestBase.java

   1 package de.juplo.kafka.chat.backend.domain;
   2
   3 import org.junit.jupiter.api.DisplayName;
   4 import org.junit.jupiter.api.Test;
   5 import reactor.core.publisher.Mono;
   6
   7 import java.util.UUID;
   8
   9 import static pl.rzrz.assertj.reactor.Assertions.assertThat;
  10
  11
  12 public class ChatHomeWithShardsTestBase extends ChatHomeTestBase
  13 {
  14   @Test
  15   @DisplayName("Assert ShardNotOwnedException is thrown, if the shard for the chatroom is not owned")
  16   void testGetChatroomForNotOwnedShard()
  17   {
  18     // Given
  19     UUID chatRoomId = UUID.fromString("4e7246a6-29ae-43ea-b56f-669c3481ac19");
  20
  21     // When
  22     Mono<ChatRoom> mono = chatHome.getChatRoom(chatRoomId);
  23
  24     // Then
  25     assertThat(mono).sendsError(e ->
  26     {
  27       assertThat(e).isInstanceOf(UnknownChatroomException.class);
  28       UnknownChatroomException unknownChatroomException = (UnknownChatroomException) e;
  29       assertThat(unknownChatroomException.getChatroomId()).isEqualTo(chatRoomId);
  30     });
  31   }
  32 }