fix: rename impl class

Signed-off-by: Matt Peterson <[email protected]>

Author: mattp-swirldslabs

server/src/main/java/com/hedera/block/server/Server.java

@@ -20,7 +20,7 @@
 import static com.hedera.block.server.Constants.*;
 
 import com.hedera.block.server.mediator.LiveStreamMediatorImpl;
-import com.hedera.block.server.persistence.WriteThroughCacheHandler;
+import com.hedera.block.server.persistence.FileSystemPersistenceHandler;
 import com.hedera.block.server.persistence.storage.*;
 import com.hedera.block.server.producer.ItemAckBuilder;
 import io.grpc.stub.ServerCalls;
@@ -77,7 +77,7 @@ public static void main(final String[] args) {
                             consumerTimeoutThreshold,
                             new ItemAckBuilder(),
                             new LiveStreamMediatorImpl(
-                                    new WriteThroughCacheHandler(blockReader, blockWriter),
+                                    new FileSystemPersistenceHandler(blockReader, blockWriter),
                                     (streamMediator) -> {
                                         LOGGER.log(
                                                 System.Logger.Level.ERROR,

server/src/main/java/com/hedera/block/server/persistence/FileSystemPersistenceHandler.java

@@ -30,13 +30,13 @@
  * Write-Through cache handler coordinates between the block storage and the block cache to ensure
  * the block is persisted to the storage before being cached.
  */
-public class WriteThroughCacheHandler implements BlockPersistenceHandler<BlockItem, Block> {
+public class FileSystemPersistenceHandler implements BlockPersistenceHandler<BlockItem, Block> {
 
     private final BlockReader<Block> blockReader;
     private final BlockWriter<BlockItem> blockWriter;
 
     /** Constructor for the WriteThroughCacheHandler class. */
-    public WriteThroughCacheHandler(
+    public FileSystemPersistenceHandler(
             final BlockReader<Block> blockReader, final BlockWriter<BlockItem> blockWriter) {
         this.blockReader = blockReader;
         this.blockWriter = blockWriter;

server/src/test/java/com/hedera/block/server/BlockStreamServiceIT.java

@@ -26,7 +26,7 @@
 import com.hedera.block.server.data.ObjectEvent;
 import com.hedera.block.server.mediator.LiveStreamMediatorImpl;
 import com.hedera.block.server.mediator.StreamMediator;
-import com.hedera.block.server.persistence.WriteThroughCacheHandler;
+import com.hedera.block.server.persistence.FileSystemPersistenceHandler;
 import com.hedera.block.server.persistence.storage.BlockAsDirReader;
 import com.hedera.block.server.persistence.storage.BlockAsDirWriter;
 import com.hedera.block.server.persistence.storage.BlockReader;
@@ -147,7 +147,7 @@ public void testSubscribeBlockStream() throws InterruptedException {
         final var streamMediator =
                 new LiveStreamMediatorImpl(
                         new HashMap<>(),
-                        new WriteThroughCacheHandler(blockReader, blockWriter),
+                        new FileSystemPersistenceHandler(blockReader, blockWriter),
                         testCallback);
 
         // Build the BlockStreamService
@@ -426,7 +426,7 @@ private StreamMediator<ObjectEvent<BlockItem>, BlockItem> buildStreamMediator(
         final BlockReader<Block> blockReader = new BlockAsDirReader(JUNIT, testConfig);
         final BlockWriter<BlockItem> blockWriter = new BlockAsDirWriter(JUNIT, testConfig);
         return new LiveStreamMediatorImpl(
-                subscribers, new WriteThroughCacheHandler(blockReader, blockWriter), testCallback);
+                subscribers, new FileSystemPersistenceHandler(blockReader, blockWriter), testCallback);
     }
 
     private StreamMediator<ObjectEvent<BlockItem>, BlockItem> buildStreamMediator()

server/src/test/java/com/hedera/block/server/mediator/LiveStreamMediatorImplTest.java

@@ -26,7 +26,7 @@
 import com.hedera.block.server.consumer.ConsumerBlockItemObserver;
 import com.hedera.block.server.data.ObjectEvent;
 import com.hedera.block.server.persistence.BlockPersistenceHandler;
-import com.hedera.block.server.persistence.WriteThroughCacheHandler;
+import com.hedera.block.server.persistence.FileSystemPersistenceHandler;
 import com.hedera.block.server.persistence.storage.BlockReader;
 import com.hedera.block.server.persistence.storage.BlockWriter;
 import io.grpc.stub.StreamObserver;
@@ -61,7 +61,7 @@ public void testUnsubscribeEach() {
 
         final var streamMediator =
                 new LiveStreamMediatorImpl(
-                        new WriteThroughCacheHandler(blockReader, blockWriter), testCallback);
+                        new FileSystemPersistenceHandler(blockReader, blockWriter), testCallback);
 
         // Set up the subscribers
         streamMediator.subscribe(observer1);
@@ -99,7 +99,7 @@ public void testMediatorPersistenceWithoutSubscribers() throws IOException {
 
         final var streamMediator =
                 new LiveStreamMediatorImpl(
-                        new WriteThroughCacheHandler(blockReader, blockWriter), testCallback);
+                        new FileSystemPersistenceHandler(blockReader, blockWriter), testCallback);
 
         final BlockItem blockItem = BlockItem.newBuilder().build();
 
@@ -118,7 +118,7 @@ public void testMediatorPublishEventToSubscribers() throws IOException, Interrup
         final long TEST_TIME = 1_719_427_664_950L;
         final var streamMediator =
                 new LiveStreamMediatorImpl(
-                        new WriteThroughCacheHandler(blockReader, blockWriter), testCallback);
+                        new FileSystemPersistenceHandler(blockReader, blockWriter), testCallback);
 
         final var concreteObserver1 =
                 new ConsumerBlockItemObserver(
@@ -200,7 +200,7 @@ public void testSubAndUnsubHandling() {
         final long TEST_TIME = 1_719_427_664_950L;
         final var streamMediator =
                 new LiveStreamMediatorImpl(
-                        new WriteThroughCacheHandler(blockReader, blockWriter), testCallback);
+                        new FileSystemPersistenceHandler(blockReader, blockWriter), testCallback);
 
         final var concreteObserver1 =
                 new ConsumerBlockItemObserver(

server/src/test/java/com/hedera/block/server/persistence/FileSystemPersistenceHandlerTest.java

@@ -40,7 +40,7 @@
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
 
-public class WriteThroughCacheHandlerTest {
+public class FileSystemPersistenceHandlerTest {
 
     private final System.Logger LOGGER = System.getLogger(getClass().getName());
 
@@ -73,7 +73,7 @@ public void testMaxEntriesGreaterThanBlocks() throws IOException {
         BlockReader<Block> blockReader = new BlockAsDirReader(JUNIT, testConfig);
         BlockWriter<BlockItem> blockWriter = new BlockAsDirWriter(JUNIT, testConfig);
         BlockPersistenceHandler<BlockItem, Block> blockPersistenceHandler =
-                new WriteThroughCacheHandler(blockReader, blockWriter);
+                new FileSystemPersistenceHandler(blockReader, blockWriter);
 
         List<BlockItem> blockItems = generateBlockItems(numOfBlocks);
         persistBlockItems(blockItems, blockPersistenceHandler);

server/src/test/java/com/hedera/block/server/persistence/RangeTest.java

@@ -101,7 +101,7 @@ private static void verifyReadRange(
 
         // Mock up a simple, in-memory persistence handler
         NoOpTestBlockStorage noOpTestBlockStorage = new NoOpTestBlockStorage();
-        return new WriteThroughCacheHandler(noOpTestBlockStorage, noOpTestBlockStorage);
+        return new FileSystemPersistenceHandler(noOpTestBlockStorage, noOpTestBlockStorage);
     }
 
     private static class NoOpTestBlockStorage

server/src/test/java/com/hedera/block/server/producer/ProducerBlockItemObserverTest.java

@@ -30,7 +30,7 @@
 import com.hedera.block.server.data.ObjectEvent;
 import com.hedera.block.server.mediator.LiveStreamMediatorImpl;
 import com.hedera.block.server.mediator.StreamMediator;
-import com.hedera.block.server.persistence.WriteThroughCacheHandler;
+import com.hedera.block.server.persistence.FileSystemPersistenceHandler;
 import com.hedera.block.server.persistence.storage.BlockReader;
 import com.hedera.block.server.persistence.storage.BlockWriter;
 import io.grpc.stub.StreamObserver;
@@ -103,7 +103,7 @@ public void testProducerToManyConsumers() throws IOException, InterruptedExcepti
         final long TEST_TIME = 1_719_427_664_950L;
         final var streamMediator =
                 new LiveStreamMediatorImpl(
-                        new WriteThroughCacheHandler(blockReader, blockWriter), testCallback);
+                        new FileSystemPersistenceHandler(blockReader, blockWriter), testCallback);
 
         final var concreteObserver1 =
                 new ConsumerBlockItemObserver(