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

diff --git a/src/main/java/de/juplo/kafka/chat/backend/persistence/inmemory/InMemoryServicesConfiguration.java b/src/main/java/de/juplo/kafka/chat/backend/persistence/inmemory/InMemoryServicesConfiguration.java
index 47c223e8dcb5a7826e1dfcfc337446b75b4300d9..1611582529560c5b73727e867abe54a206a986d9 100644 (file)
--- a/src/main/java/de/juplo/kafka/chat/backend/persistence/inmemory/InMemoryServicesConfiguration.java
+++ b/src/main/java/de/juplo/kafka/chat/backend/persistence/inmemory/InMemoryServicesConfiguration.java
@@ -29,12 +29,10 @@ public class InMemoryServicesConfiguration
   ChatHome noneShardingChatHome(
       ChatBackendProperties properties,
       StorageStrategy storageStrategy,
-      ChatRoomServiceFactory chatRoomServiceFactory,
       Clock clock)
   {
     return new SimpleChatHome(
         storageStrategy,
-        chatRoomServiceFactory,
         clock,
         properties.getChatroomBufferSize());
   }
@@ -57,7 +55,6 @@ public class InMemoryServicesConfiguration
         .forEach(shard -> chatHomes[shard] = new SimpleChatHome(
             shard,
             storageStrategy,
-            chatRoomServiceFactory,
             clock,
             properties.getChatroomBufferSize()));
     ShardingStrategy strategy = new KafkaLikeShardingStrategy(numShards);

diff --git a/src/main/java/de/juplo/kafka/chat/backend/persistence/inmemory/SimpleChatHome.java b/src/main/java/de/juplo/kafka/chat/backend/persistence/inmemory/SimpleChatHome.java
index 51147c5136824665b3f6ff0625f7bf0f8fa2765f..c6f337782d9ebb2e0360a429fbd4984d127f2b3c 100644 (file)
--- a/src/main/java/de/juplo/kafka/chat/backend/persistence/inmemory/SimpleChatHome.java
+++ b/src/main/java/de/juplo/kafka/chat/backend/persistence/inmemory/SimpleChatHome.java
@@ -24,14 +24,12 @@ public class SimpleChatHome implements ChatHome
 
   public SimpleChatHome(
       StorageStrategy storageStrategy,
-      ChatRoomServiceFactory chatRoomServiceFactory,
       Clock clock,
       int bufferSize)
   {
     this(
         null,
         storageStrategy,
-        chatRoomServiceFactory,
         clock,
         bufferSize);
   }
@@ -39,7 +37,6 @@ public class SimpleChatHome implements ChatHome
   public SimpleChatHome(
       Integer shard,
       StorageStrategy storageStrategy,
-      ChatRoomServiceFactory chatRoomServiceFactory,
       Clock clock,
       int bufferSize)
   {
@@ -76,7 +73,7 @@ public class SimpleChatHome implements ChatHome
               info.getId(),
               new ChatRoomData(
                   clock,
-                  chatRoomServiceFactory.create(messageFlux),
+                  new InMemoryChatRoomService(messageFlux),
                   bufferSize));
         });
     this.clock = clock;

diff --git a/src/test/java/de/juplo/kafka/chat/backend/persistence/AbstractInMemoryStorageIT.java b/src/test/java/de/juplo/kafka/chat/backend/persistence/AbstractInMemoryStorageIT.java
index b5d0cd42bcb9adf47c94e96d1cdc55f6003dab0e..d984db3ae47997f5aca99993c57788e51ba610de 100644 (file)
--- a/src/test/java/de/juplo/kafka/chat/backend/persistence/AbstractInMemoryStorageIT.java
+++ b/src/test/java/de/juplo/kafka/chat/backend/persistence/AbstractInMemoryStorageIT.java
@@ -2,6 +2,7 @@ package de.juplo.kafka.chat.backend.persistence;
 
 import de.juplo.kafka.chat.backend.domain.ChatHome;
 import de.juplo.kafka.chat.backend.persistence.inmemory.SimpleChatHome;
+import de.juplo.kafka.chat.backend.persistence.storage.files.ChatRoomServiceFactory;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 
@@ -22,7 +23,7 @@ public abstract class AbstractInMemoryStorageIT extends AbstractStorageStrategyI
       int bufferSize = 8;
 
       SimpleChatHome simpleChatHome = new SimpleChatHome(
-          getStorageStrategy().readChatRoomData(),
+          getStorageStrategy(),
           clock,
           bufferSize);
 

diff --git a/src/test/java/de/juplo/kafka/chat/backend/persistence/AbstractStorageStrategyIT.java b/src/test/java/de/juplo/kafka/chat/backend/persistence/AbstractStorageStrategyIT.java
index f9cd11f14ca2e1865155c3656bd79eadf3dce220..5132c65605774ccd51bb79a5b84bc19034f711fe 100644 (file)
--- a/src/test/java/de/juplo/kafka/chat/backend/persistence/AbstractStorageStrategyIT.java
+++ b/src/test/java/de/juplo/kafka/chat/backend/persistence/AbstractStorageStrategyIT.java
@@ -27,7 +27,7 @@ public abstract class AbstractStorageStrategyIT
 
   protected void stop()
   {
-    getStorageStrategy().writeChatRoomData(chathome.getChatRoomData());
+    getStorageStrategy().write(chathome);
   }
 
   @Test

diff --git a/src/test/java/de/juplo/kafka/chat/backend/persistence/inmemory/ShardedChatHomeTest.java b/src/test/java/de/juplo/kafka/chat/backend/persistence/inmemory/ShardedChatHomeTest.java
index 22c37d186d9a08ed37b3fe7ba96861c2c1242ab7..652ade843443ff8f6b7d525cb39713d3457c1294 100644 (file)
--- a/src/test/java/de/juplo/kafka/chat/backend/persistence/inmemory/ShardedChatHomeTest.java
+++ b/src/test/java/de/juplo/kafka/chat/backend/persistence/inmemory/ShardedChatHomeTest.java
@@ -27,7 +27,7 @@ public class ShardedChatHomeTest extends ChatHomeWithShardsTest
           .of(ownedShards())
           .forEach(shard -> chatHomes[shard] = new SimpleChatHome(
               shard,
-              storageStrategy.readChatRoomData(),
+              storageStrategy,
               clock,
               bufferSize()));
 

diff --git a/src/test/java/de/juplo/kafka/chat/backend/persistence/inmemory/SimpleChatHomeTest.java b/src/test/java/de/juplo/kafka/chat/backend/persistence/inmemory/SimpleChatHomeTest.java
index 1140f69b1e2b84d7985c4c26870bd15c792a1675..7103bb67006b6ba0263c2feb31b20a9b745ef719 100644 (file)
--- a/src/test/java/de/juplo/kafka/chat/backend/persistence/inmemory/SimpleChatHomeTest.java
+++ b/src/test/java/de/juplo/kafka/chat/backend/persistence/inmemory/SimpleChatHomeTest.java
@@ -22,7 +22,7 @@ public class SimpleChatHomeTest extends ChatHomeTest
         Clock clock)
     {
       return new SimpleChatHome(
-          storageStrategy.readChatRoomData(),
+          storageStrategy,
           clock,
           bufferSize());
     }