package de.juplo.kafka.chat.backend.persistence.storage.mongodb;
import de.juplo.kafka.chat.backend.domain.ChatRoom;
+import de.juplo.kafka.chat.backend.domain.ChatRoomInfo;
import lombok.*;
import org.springframework.data.annotation.Id;
import org.springframework.data.mongodb.core.mapping.Document;
@Id
private String id;
private String name;
- private int shard;
private List<MessageTo> messages;
- public static ChatRoomTo from(ChatRoom chatroom)
+ public static ChatRoomTo from(ChatRoomInfo chatroom)
{
return new ChatRoomTo(
chatroom.getId().toString(),
chatroom.getName(),
- chatroom.getShard(),
chatroom
.getMessages()
.map(MessageTo::from)