import de.juplo.kafka.chat.backend.domain.ChatHome;
import de.juplo.kafka.chat.backend.domain.ChatRoom;
-import de.juplo.kafka.chat.backend.domain.ChatRoomFactory;
import de.juplo.kafka.chat.backend.persistence.StorageStrategy;
import lombok.RequiredArgsConstructor;
import org.springframework.http.codec.ServerSentEvent;
public class ChatBackendController
{
private final ChatHome chatHome;
- private final ChatRoomFactory factory;
private final StorageStrategy storageStrategy;
public Mono<ChatRoomInfoTo> create(@RequestBody String name)
{
UUID chatRoomId = UUID.randomUUID();
- return factory
+ return chatHome
.createChatRoom(chatRoomId, name)
.map(ChatRoomInfoTo::from);
}