import de.juplo.kafka.chat.backend.api.ChatroomTo;
import de.juplo.kafka.chat.backend.api.MessageTo;
import de.juplo.kafka.chat.backend.domain.Chatroom;
-import de.juplo.kafka.chat.backend.domain.ChatroomFactory;
import de.juplo.kafka.chat.backend.domain.Message;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
private final Path storagePath;
private final ObjectMapper mapper;
- private final ChatroomFactory chatroomFactory;
+ private final InMemoryChatHomeService service;
@Override
.log()
.map(chatroomTo ->
{
- InMemoryPersistenceStrategy strategy =
- new InMemoryPersistenceStrategy(readMessages(chatroomTo));
- return chatroomFactory.restoreChatroom(chatroomTo.getId(), chatroomTo.getName(), strategy);
+ InMemoryChatroomService chatroomService =
+ new InMemoryChatroomService(readMessages(chatroomTo));
+ return service.restoreChatroom(
+ chatroomTo.getId(),
+ chatroomTo.getName(),
+ chatroomService);
});
}