chore: Merge develop to main

README.md

@@ -55,7 +55,7 @@ Build docker image
 
 
 ```shell
-docker build -t cardanofoundation/ledger-sync:<version> .
+docker build  --target ledger-sync -t cardanofoundation/ledger-sync:<version> .
 ```
 
 ### Docker Run

application/build.gradle

@@ -1,13 +1,14 @@
 plugins {
-    id 'org.springframework.boot' version '3.1.4'
-    id 'nu.studer.jooq' version '8.2'
+    id 'org.springframework.boot' version '3.2.2'
+    id 'nu.studer.jooq' version '8.2.3'
 }
 
 dependencies {
     implementation 'org.springframework.boot:spring-boot-starter'
     implementation 'org.springframework.boot:spring-boot-starter-validation'
     implementation 'org.springframework.boot:spring-boot-starter-data-jpa'
     implementation 'org.springframework.boot:spring-boot-starter-webflux'
+    implementation 'org.springframework.boot:spring-boot-starter-web'
     implementation 'org.springframework.boot:spring-boot-configuration-processor'
     implementation 'org.springframework.boot:spring-boot-starter-actuator'
     implementation 'org.springframework.boot:spring-boot-starter-jooq'
@@ -57,6 +58,7 @@ ext {
 }
 
 jooq {
+    version = '3.18.9'
     configurations {
         main {
             generateSchemaSourceOnCompilation = false

application/src/main/java/org/cardanofoundation/ledgersync/explorerconsumer/ExplorerConsumerApplication.java → application/src/main/java/org/cardanofoundation/ledgersync/LedgerSyncApplication.java

@@ -1,5 +1,6 @@
-package org.cardanofoundation.ledgersync.explorerconsumer;
+package org.cardanofoundation.ledgersync;
 
+import jakarta.annotation.PostConstruct;
 import lombok.AccessLevel;
 import lombok.RequiredArgsConstructor;
 import lombok.experimental.FieldDefaults;
@@ -17,15 +18,21 @@
 @ComponentScan(basePackages = "org.cardanofoundation.*")
 @EntityScan("org.cardanofoundation.*")
 @EnableJpaRepositories("org.cardanofoundation.*")
-public class ExplorerConsumerApplication {
+public class LedgerSyncApplication {
 
     static {
         System.setProperty("org.jooq.no-logo", "true");
         System.setProperty("org.jooq.no-tips", "true");
     }
 
     public static void main(String[] args) {
-        SpringApplication.run(ExplorerConsumerApplication.class, args);
+        SpringApplication.run(LedgerSyncApplication.class, args);
+    }
+
+    @PostConstruct
+    public void postConstruct() {
+        long maxMemory = Runtime.getRuntime().maxMemory();
+        log.info("<< Max JVM heap memory: {} MB", maxMemory / (1024 * 1024) + " >>");
     }
 
 }

application/src/main/java/org/cardanofoundation/ledgersync/explorerconsumer/aggregate/AggregatedAddress.java → application/src/main/java/org/cardanofoundation/ledgersync/aggregate/AggregatedAddress.java

@@ -1,4 +1,4 @@
-package org.cardanofoundation.ledgersync.explorerconsumer.aggregate;
+package org.cardanofoundation.ledgersync.aggregate;
 
 import com.bloxbean.cardano.client.crypto.Base58;
 import lombok.AccessLevel;
@@ -8,7 +8,7 @@
 import lombok.experimental.FieldDefaults;
 import org.cardanofoundation.ledgersync.common.common.address.ShelleyAddress;
 import org.cardanofoundation.ledgersync.common.util.HexUtil;
-import org.cardanofoundation.ledgersync.explorerconsumer.constant.ConsumerConstant;
+import org.cardanofoundation.ledgersync.constant.ConsumerConstant;
 
 import java.util.Arrays;
 

application/src/main/java/org/cardanofoundation/ledgersync/explorerconsumer/aggregate/AggregatedAddressBalance.java → application/src/main/java/org/cardanofoundation/ledgersync/aggregate/AggregatedAddressBalance.java

@@ -1,4 +1,4 @@
-package org.cardanofoundation.ledgersync.explorerconsumer.aggregate;
+package org.cardanofoundation.ledgersync.aggregate;
 
 import lombok.AccessLevel;
 import lombok.AllArgsConstructor;

application/src/main/java/org/cardanofoundation/ledgersync/explorerconsumer/aggregate/AggregatedBatchBlockData.java → application/src/main/java/org/cardanofoundation/ledgersync/aggregate/AggregatedBatchBlockData.java

@@ -1,4 +1,4 @@
-package org.cardanofoundation.ledgersync.explorerconsumer.aggregate;
+package org.cardanofoundation.ledgersync.aggregate;
 
 import lombok.AccessLevel;
 import lombok.Getter;

application/src/main/java/org/cardanofoundation/ledgersync/explorerconsumer/aggregate/AggregatedBlock.java → application/src/main/java/org/cardanofoundation/ledgersync/aggregate/AggregatedBlock.java

@@ -1,4 +1,4 @@
-package org.cardanofoundation.ledgersync.explorerconsumer.aggregate;
+package org.cardanofoundation.ledgersync.aggregate;
 
 //import org.cardanofoundation.ledgersync.common.common.AuxData;
 

application/src/main/java/org/cardanofoundation/ledgersync/explorerconsumer/aggregate/AggregatedSlotLeader.java → application/src/main/java/org/cardanofoundation/ledgersync/aggregate/AggregatedSlotLeader.java

@@ -1,4 +1,4 @@
-package org.cardanofoundation.ledgersync.explorerconsumer.aggregate;
+package org.cardanofoundation.ledgersync.aggregate;
 
 import lombok.AccessLevel;
 import lombok.AllArgsConstructor;

application/src/main/java/org/cardanofoundation/ledgersync/explorerconsumer/aggregate/AggregatedTx.java → application/src/main/java/org/cardanofoundation/ledgersync/aggregate/AggregatedTx.java

@@ -1,4 +1,4 @@
-package org.cardanofoundation.ledgersync.explorerconsumer.aggregate;
+package org.cardanofoundation.ledgersync.aggregate;
 
 import com.bloxbean.cardano.yaci.core.model.Amount;
 import com.bloxbean.cardano.yaci.core.model.Update;

application/src/main/java/org/cardanofoundation/ledgersync/explorerconsumer/aggregate/AggregatedTxIn.java → application/src/main/java/org/cardanofoundation/ledgersync/aggregate/AggregatedTxIn.java

@@ -1,4 +1,4 @@
-package org.cardanofoundation.ledgersync.explorerconsumer.aggregate;
+package org.cardanofoundation.ledgersync.aggregate;
 
 import com.bloxbean.cardano.yaci.core.model.TransactionInput;
 import com.bloxbean.cardano.yaci.core.model.byron.ByronTxIn;

application/src/main/java/org/cardanofoundation/ledgersync/explorerconsumer/aggregate/AggregatedTxOut.java → application/src/main/java/org/cardanofoundation/ledgersync/aggregate/AggregatedTxOut.java

@@ -1,4 +1,4 @@
-package org.cardanofoundation.ledgersync.explorerconsumer.aggregate;
+package org.cardanofoundation.ledgersync.aggregate;
 
 //import org.cardanofoundation.ledgersync.common.common.Amount;
 //import org.cardanofoundation.ledgersync.common.common.Datum;

application/src/main/java/org/cardanofoundation/ledgersync/explorerconsumer/configuration/ExceptionHandlerConfiguration.java → application/src/main/java/org/cardanofoundation/ledgersync/configuration/ExceptionHandlerConfiguration.java

@@ -1,4 +1,4 @@
-package org.cardanofoundation.ledgersync.explorerconsumer.configuration;
+package org.cardanofoundation.ledgersync.configuration;
 
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;

application/src/main/java/org/cardanofoundation/ledgersync/explorerconsumer/configuration/JooqConfigurationCustomizer.java → application/src/main/java/org/cardanofoundation/ledgersync/configuration/JooqConfigurationCustomizer.java

@@ -1,4 +1,4 @@
-package org.cardanofoundation.ledgersync.explorerconsumer.configuration;
+package org.cardanofoundation.ledgersync.configuration;
 
 import org.jooq.conf.MappedSchema;
 import org.jooq.conf.RenderMapping;

application/src/main/java/org/cardanofoundation/ledgersync/explorerconsumer/configuration/MicrometerConfig.java → application/src/main/java/org/cardanofoundation/ledgersync/configuration/MicrometerConfig.java

@@ -1,4 +1,4 @@
-package org.cardanofoundation.ledgersync.explorerconsumer.configuration;
+package org.cardanofoundation.ledgersync.configuration;
 
 import io.micrometer.core.aop.TimedAspect;
 import io.micrometer.core.instrument.MeterRegistry;

application/src/main/java/org/cardanofoundation/ledgersync/explorerconsumer/constant/ConsumerConstant.java → application/src/main/java/org/cardanofoundation/ledgersync/constant/ConsumerConstant.java

@@ -1,4 +1,4 @@
-package org.cardanofoundation.ledgersync.explorerconsumer.constant;
+package org.cardanofoundation.ledgersync.constant;
 
 import org.cardanofoundation.ledgersync.common.common.constant.Constant;
 

application/src/main/java/org/cardanofoundation/ledgersync/explorerconsumer/converter/AvvmAddressConverter.java → application/src/main/java/org/cardanofoundation/ledgersync/converter/AvvmAddressConverter.java

@@ -1,4 +1,4 @@
-package org.cardanofoundation.ledgersync.explorerconsumer.converter;
+package org.cardanofoundation.ledgersync.converter;
 
 import co.nstant.in.cbor.model.Array;
 import co.nstant.in.cbor.model.ByteString;

application/src/main/java/org/cardanofoundation/ledgersync/explorerconsumer/converter/CostModelConverter.java → application/src/main/java/org/cardanofoundation/ledgersync/converter/CostModelConverter.java

@@ -1,4 +1,4 @@
-package org.cardanofoundation.ledgersync.explorerconsumer.converter;
+package org.cardanofoundation.ledgersync.converter;
 
 import co.nstant.in.cbor.model.Array;
 import co.nstant.in.cbor.model.Map;
@@ -14,7 +14,7 @@
 import java.util.List;
 import java.util.stream.IntStream;
 
-import static org.cardanofoundation.ledgersync.explorerconsumer.service.impl.genesis.GenesisDataServiceImpl.convertObjecToBigInteger;
+import static org.cardanofoundation.ledgersync.service.impl.genesis.GenesisDataServiceImpl.convertObjecToBigInteger;
 
 @UtilityClass
 public class CostModelConverter {

application/src/main/java/org/cardanofoundation/ledgersync/explorerconsumer/dto/BlockMessage.java → application/src/main/java/org/cardanofoundation/ledgersync/dto/BlockMessage.java

@@ -1,4 +1,4 @@
-package org.cardanofoundation.ledgersync.explorerconsumer.dto;
+package org.cardanofoundation.ledgersync.dto;
 
 import lombok.AllArgsConstructor;
 import lombok.Builder;

application/src/main/java/org/cardanofoundation/ledgersync/explorerconsumer/dto/EUTXOWrapper.java → application/src/main/java/org/cardanofoundation/ledgersync/dto/EUTXOWrapper.java

@@ -1,11 +1,11 @@
-package org.cardanofoundation.ledgersync.explorerconsumer.dto;
+package org.cardanofoundation.ledgersync.dto;
 
 import lombok.AccessLevel;
 import lombok.AllArgsConstructor;
 import lombok.Getter;
 import lombok.experimental.FieldDefaults;
-import org.cardanofoundation.explorer.consumercommon.entity.MaTxOut;
-import org.cardanofoundation.explorer.consumercommon.entity.TxOut;
+import org.cardanofoundation.ledgersync.consumercommon.entity.MaTxOut;
+import org.cardanofoundation.ledgersync.consumercommon.entity.TxOut;
 import org.springframework.util.CollectionUtils;
 
 import java.util.Collection;

application/src/main/java/org/cardanofoundation/ledgersync/explorerconsumer/dto/GenesisData.java → application/src/main/java/org/cardanofoundation/ledgersync/dto/GenesisData.java

@@ -1,11 +1,11 @@
-package org.cardanofoundation.ledgersync.explorerconsumer.dto;
+package org.cardanofoundation.ledgersync.dto;
 
 
 import lombok.AllArgsConstructor;
 import lombok.Builder;
 import lombok.Data;
 import lombok.NoArgsConstructor;
-import org.cardanofoundation.explorer.consumercommon.entity.*;
+import org.cardanofoundation.ledgersync.consumercommon.entity.*;
 
 import java.sql.Timestamp;
 import java.util.List;

application/src/main/java/org/cardanofoundation/ledgersync/explorerconsumer/dto/TransactionOutMultiAssets.java → application/src/main/java/org/cardanofoundation/ledgersync/dto/TransactionOutMultiAssets.java

@@ -1,12 +1,12 @@
-package org.cardanofoundation.ledgersync.explorerconsumer.dto;
+package org.cardanofoundation.ledgersync.dto;
 
 import lombok.AccessLevel;
 import lombok.AllArgsConstructor;
 import lombok.Builder;
 import lombok.Getter;
 import lombok.experimental.FieldDefaults;
-import org.cardanofoundation.explorer.consumercommon.entity.MaTxOut;
-import org.cardanofoundation.explorer.consumercommon.entity.TxOut;
+import org.cardanofoundation.ledgersync.consumercommon.entity.MaTxOut;
+import org.cardanofoundation.ledgersync.consumercommon.entity.TxOut;
 import org.springframework.util.MultiValueMap;
 
 

application/src/main/java/org/cardanofoundation/ledgersync/explorerconsumer/dto/cache/CurrentEpochObject.java → application/src/main/java/org/cardanofoundation/ledgersync/dto/cache/CurrentEpochObject.java

@@ -1,4 +1,4 @@
-package org.cardanofoundation.ledgersync.explorerconsumer.dto.cache;
+package org.cardanofoundation.ledgersync.dto.cache;
 
 import lombok.*;
 import lombok.experimental.FieldDefaults;

application/src/main/java/org/cardanofoundation/ledgersync/explorerconsumer/dto/cache/LatestTxObject.java → application/src/main/java/org/cardanofoundation/ledgersync/dto/cache/LatestTxObject.java

@@ -1,4 +1,4 @@
-package org.cardanofoundation.ledgersync.explorerconsumer.dto.cache;
+package org.cardanofoundation.ledgersync.dto.cache;
 
 import lombok.*;
 import lombok.experimental.FieldDefaults;

application/src/main/java/org/cardanofoundation/ledgersync/dto/healthcheck/HealthStatus.java

@@ -0,0 +1,18 @@
+package org.cardanofoundation.ledgersync.dto.healthcheck;
+
+import lombok.*;
+
+import java.time.LocalDateTime;
+
+@Getter
+@Setter
+@AllArgsConstructor
+@NoArgsConstructor
+@Builder
+public class HealthStatus {
+    Boolean isHealthy;
+    String messageCode;
+    String messageDesc;
+    LocalDateTime latestBlockInsertTime;
+    Boolean hasStopSlot;
+}

application/src/main/java/org/cardanofoundation/ledgersync/dto/healthcheck/Message.java

@@ -0,0 +1,22 @@
+package org.cardanofoundation.ledgersync.dto.healthcheck;
+
+import lombok.Getter;
+
+@Getter
+public enum Message {
+    READY_TO_SERVE("READY_TO_SERVE", "Data is ready to serve"),
+    IS_NOT_SYNCING("IS_NOT_SYNCING", "Connection to node is not healthy, data is not being synchronized"),
+    SYNCING_BUT_NOT_READY("SYNCING_BUT_NOT_READY", "Data is being synchronized, but it isn't ready to serve yet"),
+    CONNECTION_HEALTHY_BUT_BLOCK_CONSUMING_NOT_HEALTHY("CONNECTION_HEALTHY_BUT_BLOCK_CONSUMING_NOT_HEALTHY",
+            "Connection to node is healthy, but the latest block insertion time has exceeded the threshold"),
+    SYNCING_HAS_FINISHED("SYNCING_HAS_FINISHED",
+            "Connection to node is healthy, but the latest block insertion time has exceeded the threshold");
+
+    private final String code;
+    private final String desc;
+
+    Message(String code, String desc) {
+        this.code = code;
+        this.desc = desc;
+    }
+}

application/src/main/java/org/cardanofoundation/ledgersync/explorerconsumer/exception/HashScriptException.java → application/src/main/java/org/cardanofoundation/ledgersync/exception/HashScriptException.java

@@ -1,4 +1,4 @@
-package org.cardanofoundation.ledgersync.explorerconsumer.exception;
+package org.cardanofoundation.ledgersync.exception;
 
 public class HashScriptException extends RuntimeException {
     public HashScriptException(Exception e) {