X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fchat%2Fbackend%2Fapi%2FChatBackendController.java;h=6c7cff7de38056ea93f7804f9da26499a72fb3cc;hb=7107fd0b4795d95b6c7f49cf4e765b82c16d016e;hp=12f8d67f9a2d302c50bb3bdb668f272c80de57f4;hpb=97984a15c5c2e62bb92ba8cfc4b06166f7586c41;p=demos%2Fkafka%2Fchat diff --git a/src/main/java/de/juplo/kafka/chat/backend/api/ChatBackendController.java b/src/main/java/de/juplo/kafka/chat/backend/api/ChatBackendController.java index 12f8d67f..6c7cff7d 100644 --- a/src/main/java/de/juplo/kafka/chat/backend/api/ChatBackendController.java +++ b/src/main/java/de/juplo/kafka/chat/backend/api/ChatBackendController.java @@ -1,129 +1,142 @@ package de.juplo.kafka.chat.backend.api; -import de.juplo.kafka.chat.backend.domain.ChatHome; -import de.juplo.kafka.chat.backend.domain.Chatroom; -import de.juplo.kafka.chat.backend.persistence.StorageStrategy; -import lombok.RequiredArgsConstructor; -import org.springframework.http.MediaType; +import de.juplo.kafka.chat.backend.ChatBackendProperties; +import de.juplo.kafka.chat.backend.domain.ChatHomeService; +import de.juplo.kafka.chat.backend.domain.ChatRoomData; +import de.juplo.kafka.chat.backend.implementation.StorageStrategy; import org.springframework.http.codec.ServerSentEvent; import org.springframework.web.bind.annotation.*; import reactor.core.publisher.Flux; import reactor.core.publisher.Mono; -import java.time.Clock; -import java.time.LocalDateTime; -import java.util.Optional; import java.util.UUID; -import java.util.stream.Stream; +import java.util.logging.Level; @RestController -@RequiredArgsConstructor public class ChatBackendController { - private final ChatHome chatHome; - private final Clock clock; + private final ChatHomeService chatHomeService; private final StorageStrategy storageStrategy; + private final String loggingCategory = ChatBackendController.class.getSimpleName(); + private final Level loggingLevel; + private final boolean showOperatorLine; + + + public ChatBackendController( + ChatHomeService chatHomeService, + StorageStrategy storageStrategy, + ChatBackendProperties properties) + { + this.chatHomeService = chatHomeService; + this.storageStrategy = storageStrategy; + this.loggingLevel = properties.getProjectreactor().getLoggingLevel(); + this.showOperatorLine = properties.getProjectreactor().isShowOperatorLine(); + } @PostMapping("create") - public ChatroomTo create(@RequestBody String name) + public Mono create(@RequestBody String name) { - return ChatroomTo.from(chatHome.createChatroom(name)); + UUID chatRoomId = UUID.randomUUID(); + return chatHomeService + .createChatRoom(chatRoomId, name) + .map(ChatRoomInfoTo::from); } @GetMapping("list") - public Stream list() + public Flux list() { - return chatHome.list().map(chatroom -> ChatroomTo.from(chatroom)); + return chatHomeService + .getChatRoomInfo() + .map(chatroomInfo -> ChatRoomInfoTo.from(chatroomInfo)); } - @GetMapping("list/{chatroomId}") - public Flux list(@PathVariable UUID chatroomId) + @GetMapping("{chatRoomId}/list") + public Flux list(@PathVariable UUID chatRoomId) { - return chatHome - .getChatroom(chatroomId) - .map(chatroom -> chatroom + return chatHomeService + .getChatRoomData(chatRoomId) + .flatMapMany(chatRoomData -> chatRoomData .getMessages() - .map(MessageTo::from)) - .get(); + .map(MessageTo::from)); } - @GetMapping("get/{chatroomId}") - public Optional get(@PathVariable UUID chatroomId) + @GetMapping("{chatRoomId}") + public Mono get(@PathVariable UUID chatRoomId) { - return chatHome.getChatroom(chatroomId).map(chatroom -> ChatroomTo.from(chatroom)); + return chatHomeService + .getChatRoomInfo(chatRoomId) + .map(chatRoomInfo -> ChatRoomInfoTo.from(chatRoomInfo)); } - @PutMapping("put/{chatroomId}/{username}/{messageId}") + @PutMapping("{chatRoomId}/{username}/{messageId}") public Mono put( - @PathVariable UUID chatroomId, + @PathVariable UUID chatRoomId, @PathVariable String username, @PathVariable Long messageId, @RequestBody String text) { return - chatHome - .getChatroom(chatroomId) - .map(chatroom -> put(chatroom, username, messageId, text)) - .orElseThrow(() -> new UnknownChatroomException(chatroomId)); + chatHomeService + .getChatRoomData(chatRoomId) + .flatMap(chatRoomData -> put(chatRoomData, username, messageId, text)); } - public Mono put( - Chatroom chatroom, + private Mono put( + ChatRoomData chatRoomData, String username, Long messageId, String text) { return - chatroom + chatRoomData .addMessage( messageId, - LocalDateTime.now(clock), username, text) - .switchIfEmpty(chatroom.getMessage(username, messageId)) .map(message -> MessageTo.from(message)); } - @GetMapping("get/{chatroomId}/{username}/{messageId}") + @GetMapping("{chatRoomId}/{username}/{messageId}") public Mono get( - @PathVariable UUID chatroomId, + @PathVariable UUID chatRoomId, @PathVariable String username, @PathVariable Long messageId) { return - chatHome - .getChatroom(chatroomId) - .map(chatroom -> get(chatroom, username, messageId)) - .orElseThrow(() -> new UnknownChatroomException(chatroomId)); + chatHomeService + .getChatRoomData(chatRoomId) + .flatMap(chatRoomData -> get(chatRoomData, username, messageId)); } private Mono get( - Chatroom chatroom, + ChatRoomData chatRoomData, String username, Long messageId) { return - chatroom + chatRoomData .getMessage(username, messageId) .map(message -> MessageTo.from(message)); } - @GetMapping(path = "listen/{chatroomId}") - public Flux> listen(@PathVariable UUID chatroomId) + @GetMapping(path = "{chatRoomId}/listen") + public Flux> listen(@PathVariable UUID chatRoomId) { - return chatHome - .getChatroom(chatroomId) - .map(chatroom -> listen(chatroom)) - .orElseThrow(() -> new UnknownChatroomException(chatroomId)); + return chatHomeService + .getChatRoomData(chatRoomId) + .flatMapMany(chatRoomData -> listen(chatRoomData)); } - private Flux> listen(Chatroom chatroom) + private Flux> listen(ChatRoomData chatRoomData) { - return chatroom + return chatRoomData .listen() - .log() + .log( + loggingCategory, + loggingLevel, + showOperatorLine) .map(message -> MessageTo.from(message)) .map(messageTo -> ServerSentEvent @@ -133,9 +146,17 @@ public class ChatBackendController .build()); } + @GetMapping("/shards") + public Mono getShardOwners() + { + return chatHomeService.getShardOwners(); + } + @PostMapping("/store") public void store() { - storageStrategy.writeChatrooms(Flux.fromStream(chatHome.list())); + storageStrategy + .write(chatHomeService) + .subscribe(); } }