refactor: Renamed `ChatRoom` into `ChatRoomData` - Aligned Code

diff --git a/src/main/java/de/juplo/kafka/chat/backend/ChatBackendApplication.java b/src/main/java/de/juplo/kafka/chat/backend/ChatBackendApplication.java
index 9fa675a0e2b8fd816511468ba4732cc446427a7a..15f8ae15dd8021ba9db61f315e3aec7cf375a84f 100644 (file)
--- a/src/main/java/de/juplo/kafka/chat/backend/ChatBackendApplication.java
+++ b/src/main/java/de/juplo/kafka/chat/backend/ChatBackendApplication.java
@@ -32,15 +32,7 @@ public class ChatBackendApplication implements WebFluxConfigurer
        @PreDestroy
        public void onExit()
        {
-               storageStrategy.writeChatRoomInfo(
-                               chatHome
-                                               .getChatRoomInfo()
-                                               .doOnNext(chatRoomInfo ->
-                                                               storageStrategy.writeChatRoomData(
-                                                                               chatRoomInfo.getId(),
-                                                                               chatHome
-                                                                                               .getChatRoomData(chatRoomInfo.getId())
-                                                                                               .flatMapMany(chatRoomData -> chatRoomData.getMessages()))));
+               storageStrategy.write(chatHome);
        }
 
        public static void main(String[] args)

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 c39869cc19e9f5caa6aae654f0ffaaa03e82ba84..e2fe714b295c490ed65386a6187d1078c0284f5a 100644 (file)
--- a/src/main/java/de/juplo/kafka/chat/backend/api/ChatBackendController.java
+++ b/src/main/java/de/juplo/kafka/chat/backend/api/ChatBackendController.java
@@ -131,14 +131,6 @@ public class ChatBackendController
   @PostMapping("/store")
   public void store()
   {
-    storageStrategy.writeChatRoomInfo(
-        chatHome
-            .getChatRoomInfo()
-            .doOnNext(chatRoomInfo ->
-                storageStrategy.writeChatRoomData(
-                    chatRoomInfo.getId(),
-                    chatHome
-                        .getChatRoomData(chatRoomInfo.getId())
-                        .flatMapMany(chatRoomData -> chatRoomData.getMessages()))));
+    storageStrategy.write(chatHome);
   }
 }

diff --git a/src/main/java/de/juplo/kafka/chat/backend/persistence/StorageStrategy.java b/src/main/java/de/juplo/kafka/chat/backend/persistence/StorageStrategy.java
index c4ab80a4f5504f7dfe66c7e3f761d0402c9cc8d6..7d0f66d4b47c033848803dea348b57422cc78ba0 100644 (file)
--- a/src/main/java/de/juplo/kafka/chat/backend/persistence/StorageStrategy.java
+++ b/src/main/java/de/juplo/kafka/chat/backend/persistence/StorageStrategy.java
@@ -1,5 +1,6 @@
 package de.juplo.kafka.chat.backend.persistence;
 
+import de.juplo.kafka.chat.backend.domain.ChatHome;
 import de.juplo.kafka.chat.backend.domain.ChatRoomInfo;
 import de.juplo.kafka.chat.backend.domain.Message;
 import reactor.core.publisher.Flux;
@@ -9,6 +10,19 @@ import java.util.UUID;
 
 public interface StorageStrategy
 {
+  default void write(ChatHome chatHome)
+  {
+    writeChatRoomInfo(
+        chatHome
+            .getChatRoomInfo()
+            .doOnNext(chatRoomInfo ->
+                writeChatRoomData(
+                    chatRoomInfo.getId(),
+                    chatHome
+                        .getChatRoomData(chatRoomInfo.getId())
+                        .flatMapMany(chatRoomData -> chatRoomData.getMessages()))));
+  }
+
   void writeChatRoomInfo(Flux<ChatRoomInfo> chatRoomInfoFlux);
   Flux<ChatRoomInfo> readChatRoomInfo();
   void writeChatRoomData(UUID chatRoomId, Flux<Message> messageFlux);