Merge pull request #138 from cardano-foundation/develop

chore: Merge develop to main
cardano-foundation · Mar 4, 2024 · 5b2da38 · 5b2da38
2 parents c79af01 + affdc6e
commit 5b2da38
Show file tree

Hide file tree

Showing 429 changed files with 2,676 additions and 1,689 deletions.
diff --git a/README.md b/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

diff --git a/application/build.gradle b/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

diff --git a/...consumer/ExplorerConsumerApplication.java → ...ion/ledgersync/LedgerSyncApplication.java b/...consumer/ExplorerConsumerApplication.java → ...ion/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) + " >>");
     }
 
 }
diff --git a/...consumer/aggregate/AggregatedAddress.java → ...dgersync/aggregate/AggregatedAddress.java b/...consumer/aggregate/AggregatedAddress.java → ...dgersync/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;
 

diff --git a/...r/aggregate/AggregatedAddressBalance.java → ...c/aggregate/AggregatedAddressBalance.java b/...r/aggregate/AggregatedAddressBalance.java → ...c/aggregate/AggregatedAddressBalance.java
@@ -1,4 +1,4 @@
-package org.cardanofoundation.ledgersync.explorerconsumer.aggregate;
+package org.cardanofoundation.ledgersync.aggregate;
 
 import lombok.AccessLevel;
 import lombok.AllArgsConstructor;

diff --git a/...r/aggregate/AggregatedBatchBlockData.java → ...c/aggregate/AggregatedBatchBlockData.java b/...r/aggregate/AggregatedBatchBlockData.java → ...c/aggregate/AggregatedBatchBlockData.java
@@ -1,4 +1,4 @@
-package org.cardanofoundation.ledgersync.explorerconsumer.aggregate;
+package org.cardanofoundation.ledgersync.aggregate;
 
 import lombok.AccessLevel;
 import lombok.Getter;

diff --git a/...erconsumer/aggregate/AggregatedBlock.java → ...ledgersync/aggregate/AggregatedBlock.java b/...erconsumer/aggregate/AggregatedBlock.java → ...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;
 

diff --git a/...sumer/aggregate/AggregatedSlotLeader.java → ...rsync/aggregate/AggregatedSlotLeader.java b/...sumer/aggregate/AggregatedSlotLeader.java → ...rsync/aggregate/AggregatedSlotLeader.java
@@ -1,4 +1,4 @@
-package org.cardanofoundation.ledgersync.explorerconsumer.aggregate;
+package org.cardanofoundation.ledgersync.aggregate;
 
 import lombok.AccessLevel;
 import lombok.AllArgsConstructor;

diff --git a/...lorerconsumer/aggregate/AggregatedTx.java → ...on/ledgersync/aggregate/AggregatedTx.java b/...lorerconsumer/aggregate/AggregatedTx.java → ...on/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;

diff --git a/...rerconsumer/aggregate/AggregatedTxIn.java → .../ledgersync/aggregate/AggregatedTxIn.java b/...rerconsumer/aggregate/AggregatedTxIn.java → .../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;

diff --git a/...erconsumer/aggregate/AggregatedTxOut.java → ...ledgersync/aggregate/AggregatedTxOut.java b/...erconsumer/aggregate/AggregatedTxOut.java → ...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;

diff --git a/...ration/ExceptionHandlerConfiguration.java → ...ration/ExceptionHandlerConfiguration.java b/...ration/ExceptionHandlerConfiguration.java → ...ration/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;

diff --git a/...guration/JooqConfigurationCustomizer.java → ...guration/JooqConfigurationCustomizer.java b/...guration/JooqConfigurationCustomizer.java → ...guration/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;

diff --git a/...sumer/configuration/MicrometerConfig.java → ...rsync/configuration/MicrometerConfig.java b/...sumer/configuration/MicrometerConfig.java → ...rsync/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;

diff --git a/...erconsumer/constant/ConsumerConstant.java → ...ledgersync/constant/ConsumerConstant.java b/...erconsumer/constant/ConsumerConstant.java → ...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;
 

diff --git a/...sumer/converter/AvvmAddressConverter.java → ...rsync/converter/AvvmAddressConverter.java b/...sumer/converter/AvvmAddressConverter.java → ...rsync/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;

diff --git a/...onsumer/converter/CostModelConverter.java → ...gersync/converter/CostModelConverter.java b/...onsumer/converter/CostModelConverter.java → ...gersync/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 {

diff --git a/...nc/explorerconsumer/dto/BlockMessage.java → ...undation/ledgersync/dto/BlockMessage.java b/...nc/explorerconsumer/dto/BlockMessage.java → ...undation/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;

diff --git a/...nc/explorerconsumer/dto/EUTXOWrapper.java → ...undation/ledgersync/dto/EUTXOWrapper.java b/...nc/explorerconsumer/dto/EUTXOWrapper.java → ...undation/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;

diff --git a/...ync/explorerconsumer/dto/GenesisData.java → ...oundation/ledgersync/dto/GenesisData.java b/...ync/explorerconsumer/dto/GenesisData.java → ...oundation/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;

diff --git a/...nsumer/dto/TransactionOutMultiAssets.java → ...ersync/dto/TransactionOutMultiAssets.java b/...nsumer/dto/TransactionOutMultiAssets.java → ...ersync/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;
 
 

diff --git a/...onsumer/dto/cache/CurrentEpochObject.java → ...gersync/dto/cache/CurrentEpochObject.java b/...onsumer/dto/cache/CurrentEpochObject.java → ...gersync/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;

diff --git a/...rerconsumer/dto/cache/LatestTxObject.java → .../ledgersync/dto/cache/LatestTxObject.java b/...rerconsumer/dto/cache/LatestTxObject.java → .../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;

diff --git a/application/src/main/java/org/cardanofoundation/ledgersync/dto/healthcheck/HealthStatus.java b/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;
+}
diff --git a/application/src/main/java/org/cardanofoundation/ledgersync/dto/healthcheck/Message.java b/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;
+    }
+}
diff --git a/...nsumer/exception/HashScriptException.java → ...ersync/exception/HashScriptException.java b/...nsumer/exception/HashScriptException.java → ...ersync/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) {

diff --git a/...rdanofoundation/ledgersync/explorerconsumer/repository/AddressTokenBalanceRepository.java b/...rdanofoundation/ledgersync/explorerconsumer/repository/AddressTokenBalanceRepository.java
diff --git a/...on/ledgersync/explorerconsumer/repository/custom/CustomAddressTokenBalanceRepository.java b/...on/ledgersync/explorerconsumer/repository/custom/CustomAddressTokenBalanceRepository.java