add additional unit test

Signed-off-by: georgi-l95 <[email protected]>
hashgraph · Dec 13, 2024 · 79073e7 · 79073e7
1 parent c685271
commit 79073e7
Show file tree

Hide file tree

Showing 3 changed files with 14 additions and 4 deletions.
diff --git a/simulator/src/main/java/com/hedera/block/simulator/config/data/BlockStreamConfig.java b/simulator/src/main/java/com/hedera/block/simulator/config/data/BlockStreamConfig.java
@@ -38,7 +38,7 @@ public record BlockStreamConfig(
         @ConfigProperty(defaultValue = "1_500_000") int delayBetweenBlockItems,
         @ConfigProperty(defaultValue = "100_000") int maxBlockItemsToStream,
         @ConfigProperty(defaultValue = "MILLIS_PER_BLOCK") StreamingMode streamingMode,
-        @ConfigProperty(defaultValue = "1000") int millisecondsPerBlock,
+        @ConfigProperty(defaultValue = "10") int millisecondsPerBlock,
         @ConfigProperty(defaultValue = "1000") int blockItemsBatchSize) {
 
     /**

diff --git a/simulator/src/main/resources/app.properties b/simulator/src/main/resources/app.properties
@@ -8,7 +8,7 @@ grpc.port=8080
 # ----------------------------------------------
 # BlockStreamConfig
 # ----------------------------------------------
-blockStream.simulatorMode=PUBLISHER
+blockStream.simulatorMode=CONSUMER
 # ----------------------------------------------
 # Prometheus Config
 # ----------------------------------------------
@@ -19,8 +19,8 @@ blockStream.simulatorMode=PUBLISHER
 # We might consider enabling this on a different
 # port to track simulator metrics from a
 # dashboard.
-prometheus.endpointEnabled=false
-prometheus.endpointPortNumber=9998
+prometheus.endpointEnabled=true
+prometheus.endpointPortNumber=9997
 # ----------------------------------------------
 # BlockAsFileLargeDataSets config
 # ----------------------------------------------

diff --git a/simulator/src/test/java/com/hedera/block/simulator/config/data/BlockStreamConfigTest.java b/simulator/src/test/java/com/hedera/block/simulator/config/data/BlockStreamConfigTest.java
@@ -78,6 +78,16 @@ void testSimulatorMode() {
         assertEquals(SimulatorMode.PUBLISHER, config.simulatorMode());
     }
 
+    @Test
+    void testLastKnownStatusesCapacity() {
+        final int capacity = 20;
+        BlockStreamConfig config = getBlockStreamConfigBuilder()
+                .lastKnownStatusesCapacity(capacity)
+                .build();
+
+        assertEquals(capacity, config.lastKnownStatusesCapacity());
+    }
+
     @Test
     void testValidAbsolutePath() {
         // Setup valid folder path and generation mode