Merge pull request #155 from cardano-foundation/health_check

feat: #153 create healthcheck component and use it in main app, streamer app, aggregation app

aggregation-app/build.gradle

@@ -14,6 +14,7 @@ dependencies {
     implementation(libs.yaci.store.utxo.starter)
     implementation(libs.yaci.store.account.starter)
 
+    implementation project(':components:healthcheck')
     implementation project(':aggregates:account')
     runtimeOnly 'org.postgresql:postgresql'
 

aggregation-app/src/main/resources/application.yml

@@ -50,3 +50,24 @@ store:
     blocks-partition-size: 10
     use-virtual-thread-for-batch-processing: false
     use-virtual-thread-for-event-processing: true
+
+ledger-sync:
+  healthcheck:
+    enabled: ${HEALTH_CHECK_ENABLED:true}
+    event-time-threshold: ${EVENT_TIME_THRESHOLD_IN_SECOND:600}
+    block-time-check-enabled: ${BLOCK_TIME_CHECK_ENABLED:true}
+    block-time-threshold: ${BLOCK_TIME_THRESHOLD_IN_SECOND:180}
+
+management:
+  endpoints:
+    enabled-by-default: false
+    web:
+      exposure:
+        include: "health,prometheus,health-status"
+  endpoint:
+    health:
+      enabled: true
+    prometheus:
+      enabled: true
+    health-status:
+      enabled: ${HEALTH_CHECK_ENABLED:true}

application/build.gradle

@@ -17,6 +17,7 @@ dependencies {
     implementation project(':components:common')
     implementation project(':components:consumer-common')
     implementation project(':components:scheduler')
+    implementation project(':components:healthcheck')
 
     implementation(libs.yaci.store.starter)
 

application/src/main/java/org/cardanofoundation/ledgersync/listeners/BlockEventListener.java

@@ -5,6 +5,7 @@
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.cardanofoundation.ledgersync.aggregate.AggregatedBlock;
+import org.cardanofoundation.ledgersync.healthcheck.service.HealthCheckCachingService;
 import org.cardanofoundation.ledgersync.repository.BlockRepository;
 import org.cardanofoundation.ledgersync.service.*;
 import org.cardanofoundation.ledgersync.service.impl.block.BlockAggregatorServiceImpl;
@@ -38,7 +39,6 @@ public class BlockEventListener {
 
     private final BlockRepository blockRepository;
     private final MetricCollectorService metricCollectorService;
-    private final HealthCheckCachingService healthCheckCachingService;
     private final AtomicInteger blockCount = new AtomicInteger(0);
 
     @Value("${blocks.batch-size}")
@@ -95,10 +95,6 @@ public void handleGenesisBlock(GenesisBlockEvent genesisBlockEvent) {
         }
 
         genesisDataService.setupData(genesisHash);
-        healthCheckCachingService.saveLatestBlockSlot(genesisBlockEvent.getSlot());
-        healthCheckCachingService.saveLatestBlockInsertTime(LocalDateTime.now(ZoneOffset.UTC));
-        healthCheckCachingService.saveLatestBlockTime(
-                LocalDateTime.ofInstant(Instant.ofEpochSecond(genesisBlockEvent.getBlockTime()), ZoneId.of("UTC")));
     }
 
     @EventListener
@@ -121,10 +117,6 @@ public void handleRollback(RollbackEvent rollbackEvent) {
         rollbackService.rollBackFrom(rollbackBlockNo);
         metricCollectorService.collectRollbackMetric();
         blockCount.set(0);
-
-        healthCheckCachingService.saveLatestBlockSlot(rollbackEvent.getRollbackTo().getSlot());
-        healthCheckCachingService.saveLatestBlockInsertTime(LocalDateTime.now(ZoneOffset.UTC));
-        healthCheckCachingService.saveLatestBlockTime(rollBackBlock.get().getTime().toLocalDateTime());
     }
 
     private boolean checkIfBlockExists(EventMetadata metadata) {
@@ -182,13 +174,6 @@ private void handleAggregateBlock(EventMetadata eventMetadata, AggregatedBlock a
             int currentBlockCount = blockCount.incrementAndGet();
             if (currentBlockCount % batchSize == 0 || lastReceivedTimeElapsed >= commitThreshold || eventMetadata.isSyncMode()) {
                 blockSyncService.startBlockSyncing();
-
-                healthCheckCachingService.saveLatestBlockInsertTime(LocalDateTime.now(ZoneOffset.UTC));
-                healthCheckCachingService.saveLatestBlockTime(LocalDateTime.ofEpochSecond(
-                        eventMetadata.getBlockTime(), 0, ZoneOffset.ofHours(0)));
-                healthCheckCachingService.saveIsSyncMode(eventMetadata.isSyncMode());
-                healthCheckCachingService.saveLatestBlockSlot(eventMetadata.getSlot());
-
                 blockCount.set(0);
             }