juplo.de Git - demos/kafka/chat/blob - src/test/java/de/juplo/kafka/chat/backend/persistence/kafka/CreateChatRoomRequestToTest.java

   1 package de.juplo.kafka.chat.backend.persistence.kafka;
   2
   3 import com.fasterxml.jackson.databind.ObjectMapper;
   4 import com.fasterxml.jackson.databind.SerializationFeature;
   5 import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule;
   6 import org.junit.jupiter.api.BeforeEach;
   7 import org.junit.jupiter.api.Test;
   8
   9 import static org.assertj.core.api.AssertionsForInterfaceTypes.assertThat;
  10
  11
  12 public class CreateChatRoomRequestToTest
  13 {
  14   final String json = """
  15   {
  16     "id": "5c73531c-6fc4-426c-adcb-afc5c140a0f7",
  17     "name": "Foo-Room!",
  18     "shard": 666
  19   }""";
  20
  21   ObjectMapper mapper;
  22
  23   @BeforeEach
  24   public void setUp()
  25   {
  26     mapper = new ObjectMapper();
  27     mapper.registerModule(new JavaTimeModule());
  28     mapper.disable(SerializationFeature.WRITE_DATES_AS_TIMESTAMPS);
  29   }
  30
  31   @Test
  32   public void testDeserialization() throws Exception
  33   {
  34     CreateChatRoomRequestTo message = mapper.readValue(json, CreateChatRoomRequestTo.class);
  35     assertThat(message.getId()).isEqualTo("5c73531c-6fc4-426c-adcb-afc5c140a0f7");
  36     assertThat(message.getName()).isEqualTo("Foo-Room!");
  37     assertThat(message.getShard()).isEqualTo(666);
  38   }
  39 }