1 package de.juplo.kafka.chat.backend.persistence.storage.mongodb;
3 import de.juplo.kafka.chat.backend.domain.Message;
5 import org.springframework.data.mongodb.core.index.Indexed;
6 import org.springframework.data.mongodb.core.mapping.Document;
7 import org.springframework.data.mongodb.core.mapping.Field;
9 import java.time.LocalDateTime;
10 import java.util.UUID;
15 @Getter(AccessLevel.PACKAGE)
16 @Setter(AccessLevel.PACKAGE)
17 @EqualsAndHashCode(of = { "chatRoomId", "user", "id" })
18 @ToString(of = { "chatRoomId", "user", "id" })
23 private String chatRoomId;
37 Message.MessageKey.of(user, id),
39 LocalDateTime.parse(time),
43 static MessageTo from(UUID chatRoomId, Message message)
47 chatRoomId.toString(),
48 message.getUsername(),
50 message.getSerialNumber(),
51 message.getTimestamp().toString(),
52 message.getMessageText());