1 package de.juplo.kafka.chat.backend.persistence.kafka;
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;
9 import static org.assertj.core.api.AssertionsForInterfaceTypes.assertThat;
12 public class ChatRoomInfoToTest
14 final String json = """
16 "id": "5c73531c-6fc4-426c-adcb-afc5c140a0f7",
26 mapper = new ObjectMapper();
27 mapper.registerModule(new JavaTimeModule());
28 mapper.disable(SerializationFeature.WRITE_DATES_AS_TIMESTAMPS);
32 public void testDeserialization() throws Exception
34 ChatRoomInfoTo message = mapper.readValue(json, ChatRoomInfoTo.class);
35 assertThat(message.getId()).isEqualTo("5c73531c-6fc4-426c-adcb-afc5c140a0f7");
36 assertThat(message.getName()).isEqualTo("Foo-Room!");
37 assertThat(message.getShard()).isEqualTo(666);