juplo.de Git - demos/kafka/chat/blob - src/main/java/de/juplo/kafka/chat/backend/domain/ChatHome.java

   1 package de.juplo.kafka.chat.backend.domain;
   2
   3 import lombok.RequiredArgsConstructor;
   4 import lombok.extern.slf4j.Slf4j;
   5 import reactor.core.publisher.Flux;
   6 import reactor.core.publisher.Mono;
   7
   8 import java.util.*;
   9
  10
  11 @Slf4j
  12 @RequiredArgsConstructor
  13 public class ChatHome
  14 {
  15   private final ChatHomeService service;
  16
  17   public Mono<ChatRoom> createChatroom(String name)
  18   {
  19     return service.createChatRoom(UUID.randomUUID(), name);
  20   }
  21
  22   public Mono<ChatRoom> getChatRoom(UUID id)
  23   {
  24     return service
  25         .getChatRoom(id)
  26         .switchIfEmpty(Mono.error(() -> new UnknownChatroomException(id)));
  27   }
  28
  29   public Flux<ChatRoom> getChatRooms()
  30   {
  31     return service.getChatRooms();
  32   }
  33 }