chore: compare data of ada_pots table

verifier-data-app/build.gradle

@@ -2,6 +2,7 @@ plugins {
     id 'java'
     id 'org.springframework.boot' version '3.2.2'
     id 'io.spring.dependency-management' version '1.1.4'
+    id 'io.freefair.lombok' version '8.6'
 }
 
 group = 'org.cardanofoundation.ledgersync'
@@ -24,6 +25,7 @@ repositories {
 dependencies {
     implementation 'org.springframework.boot:spring-boot-starter-data-jpa'
     implementation 'org.springframework.boot:spring-boot-starter-web'
+    implementation 'org.springframework.boot:spring-boot-starter-validation'
     implementation 'io.github.cardano-community:koios-java-client:1.18.1'
     compileOnly 'org.projectlombok:lombok'
     runtimeOnly 'org.postgresql:postgresql'

verifier-data-app/src/main/java/org/cardanofoundation/ledgersync/verifier/data/app/config/DbSyncDatasourceConfig.java

@@ -1,51 +1,51 @@
-//package org.cardanofoundation.ledgersync.verifier.data.app.config;
-//
-//import lombok.RequiredArgsConstructor;
-//import org.springframework.beans.factory.annotation.Qualifier;
-//import org.springframework.boot.orm.jpa.EntityManagerFactoryBuilder;
-//import org.springframework.context.annotation.Bean;
-//import org.springframework.context.annotation.Configuration;
-//import org.springframework.data.jpa.repository.config.EnableJpaRepositories;
-//import org.springframework.orm.jpa.JpaTransactionManager;
-//import org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean;
-//import org.springframework.transaction.PlatformTransactionManager;
-//import org.springframework.transaction.annotation.EnableTransactionManagement;
-//
-//import javax.sql.DataSource;
-//import java.util.Objects;
-//
-//@Configuration
-//@EnableTransactionManagement
-//@EnableJpaRepositories(
-//        entityManagerFactoryRef = "dbSyncEntityManagerFactory",
-//        transactionManagerRef = "dbSyncTransactionManager",
-//        basePackages = {"org.cardanofoundation.ledgersync.verifier.data.app.repository.dbsync"})
-//@RequiredArgsConstructor
-//public class DbSyncDatasourceConfig {
-//
-//    private final MultiDataSourceProperties multiDataSourceProperties;
-//
-//    @Bean(name = "dbSyncDataSource")
-//    public DataSource ledgerSyncDataSource() {
-//        return multiDataSourceProperties.buildDataSource(
-//                multiDataSourceProperties.getDatasourceDbSync());
-//    }
-//
-//    @Bean(name = "dbSyncEntityManagerFactory")
-//    public LocalContainerEntityManagerFactoryBean entityManagerFactoryBean(
-//            EntityManagerFactoryBuilder builder, @Qualifier("dbSyncDataSource") DataSource dataSource) {
-//        return builder
-//                .dataSource(dataSource)
-//                .packages(
-//                        "org.cardanofoundation.ledgersync.verifier.data.app.entity.dbsync")
-//                .build();
-//    }
-//
-//    @Bean(name = "dbSyncTransactionManager")
-//    public PlatformTransactionManager dbSyncTransactionManager(
-//            @Qualifier("dbSyncEntityManagerFactory")
-//            LocalContainerEntityManagerFactoryBean ledgerSyncEntityManagerFactory) {
-//        return new JpaTransactionManager(
-//                Objects.requireNonNull(ledgerSyncEntityManagerFactory.getObject()));
-//    }
-//}
+package org.cardanofoundation.ledgersync.verifier.data.app.config;
+
+import lombok.RequiredArgsConstructor;
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.boot.orm.jpa.EntityManagerFactoryBuilder;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.jpa.repository.config.EnableJpaRepositories;
+import org.springframework.orm.jpa.JpaTransactionManager;
+import org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean;
+import org.springframework.transaction.PlatformTransactionManager;
+import org.springframework.transaction.annotation.EnableTransactionManagement;
+
+import javax.sql.DataSource;
+import java.util.Objects;
+
+@Configuration
+@EnableTransactionManagement
+@EnableJpaRepositories(
+        entityManagerFactoryRef = "dbSyncEntityManagerFactory",
+        transactionManagerRef = "dbSyncTransactionManager",
+        basePackages = {"org.cardanofoundation.ledgersync.verifier.data.app.repository.dbsync"})
+@RequiredArgsConstructor
+public class DbSyncDatasourceConfig {
+
+    private final MultiDataSourceProperties multiDataSourceProperties;
+
+    @Bean(name = "dbSyncDataSource")
+    public DataSource ledgerSyncDataSource() {
+        return multiDataSourceProperties.buildDataSource(
+                multiDataSourceProperties.getDatasourceDbSync());
+    }
+
+    @Bean(name = "dbSyncEntityManagerFactory")
+    public LocalContainerEntityManagerFactoryBean entityManagerFactoryBean(
+            EntityManagerFactoryBuilder builder, @Qualifier("dbSyncDataSource") DataSource dataSource) {
+        return builder
+                .dataSource(dataSource)
+                .packages(
+                        "org.cardanofoundation.ledgersync.verifier.data.app.entity.dbsync")
+                .build();
+    }
+
+    @Bean(name = "dbSyncTransactionManager")
+    public PlatformTransactionManager dbSyncTransactionManager(
+            @Qualifier("dbSyncEntityManagerFactory")
+            LocalContainerEntityManagerFactoryBean ledgerSyncEntityManagerFactory) {
+        return new JpaTransactionManager(
+                Objects.requireNonNull(ledgerSyncEntityManagerFactory.getObject()));
+    }
+}

verifier-data-app/src/main/java/org/cardanofoundation/ledgersync/verifier/data/app/entity/dbsync/AdaPot.java

@@ -0,0 +1,49 @@
+package org.cardanofoundation.ledgersync.verifier.data.app.entity.dbsync;
+
+import jakarta.persistence.*;
+import jakarta.validation.constraints.NotNull;
+import lombok.*;
+
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+@Builder
+@Getter
+@Setter
+@Entity
+@Table(name = "ada_pots")
+public class AdaPot {
+    @Id
+    @Column(name = "id", nullable = false)
+    private Long id;
+
+    @NotNull
+    @Column(name = "slot_no", nullable = false)
+    private Long slotNo;
+
+    @Column(name = "epoch_no", columnDefinition = "word31type(0, 0) not null")
+    private Long epochNo;
+
+    @Column(name = "treasury", columnDefinition = "lovelace(0, 0) not null")
+    private Long treasury;
+
+    @Column(name = "reserves", columnDefinition = "lovelace(0, 0) not null")
+    private Long reserves;
+
+    @Column(name = "rewards", columnDefinition = "lovelace(0, 0) not null")
+    private Long rewards;
+
+    @Column(name = "utxo", columnDefinition = "lovelace(0, 0) not null")
+    private Long utxo;
+
+    @Column(name = "deposits", columnDefinition = "lovelace(0, 0) not null")
+    private Long deposits;
+
+    @Column(name = "fees", columnDefinition = "lovelace(0, 0) not null")
+    private Long fees;
+
+    @NotNull
+    @Column(name = "block_id", nullable = false)
+    private Long blockId;
+
+}

verifier-data-app/src/main/java/org/cardanofoundation/ledgersync/verifier/data/app/mapper/AdaPotsComparisonMapper.java

@@ -0,0 +1,18 @@
+package org.cardanofoundation.ledgersync.verifier.data.app.mapper;
+
+import org.cardanofoundation.ledgersync.verifier.data.app.model.AdaPotsComparison;
+import org.cardanofoundation.ledgersync.verifier.data.app.model.AdaPotsComparisonKey;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+import java.util.Map;
+
+@Component
+public interface AdaPotsComparisonMapper<T> {
+    /**
+     * Builds a map of Ada pots comparisons.
+     * @param source The source data list.
+     * @return A map of Ada pots comparisons.
+     */
+    Map<AdaPotsComparisonKey, AdaPotsComparison> buildMap(List<T> source);
+}

verifier-data-app/src/main/java/org/cardanofoundation/ledgersync/verifier/data/app/mapper/impl/AdaPotsComparisonMapperDbSync.java

@@ -0,0 +1,37 @@
+package org.cardanofoundation.ledgersync.verifier.data.app.mapper.impl;
+
+import org.cardanofoundation.ledgersync.verifier.data.app.mapper.AdaPotsComparisonMapper;
+import org.cardanofoundation.ledgersync.verifier.data.app.model.AdaPotsComparison;
+import org.cardanofoundation.ledgersync.verifier.data.app.model.AdaPotsComparisonKey;
+import org.cardanofoundation.ledgersync.verifier.data.app.projection.AdaPotsProjection;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * Ada pots comparison mapper for the db sync implementation.
+ */
+public class AdaPotsComparisonMapperDbSync implements AdaPotsComparisonMapper<AdaPotsProjection> {
+
+    @Override
+    public Map<AdaPotsComparisonKey, AdaPotsComparison> buildMap(List<AdaPotsProjection> source) {
+        Map<AdaPotsComparisonKey, AdaPotsComparison> map = new HashMap<>();
+
+        source.forEach(adaPotsProjection -> {
+            AdaPotsComparisonKey adaPotsComparisonKey = AdaPotsComparisonKey.builder()
+                    .epochNo(adaPotsProjection.getEpochNo())
+                    .slotNo(adaPotsProjection.getSlotNo())
+                    .build();
+
+            AdaPotsComparison adaPotsComparison = AdaPotsComparison.builder()
+                    .adaPotsComparisonKey(adaPotsComparisonKey)
+                    .treasury(adaPotsProjection.getTreasury())
+                    .reserves(adaPotsProjection.getReserves())
+                    .rewards(adaPotsProjection.getRewards())
+                    .build();
+            map.put(adaPotsComparisonKey, adaPotsComparison);
+        });
+        return map;
+    }
+}

verifier-data-app/src/main/java/org/cardanofoundation/ledgersync/verifier/data/app/mapper/impl/AdaPotsComparisonMapperLS.java

@@ -0,0 +1,36 @@
+package org.cardanofoundation.ledgersync.verifier.data.app.mapper.impl;
+
+import org.cardanofoundation.ledgersync.verifier.data.app.mapper.AdaPotsComparisonMapper;
+import org.cardanofoundation.ledgersync.verifier.data.app.model.AdaPotsComparison;
+import org.cardanofoundation.ledgersync.verifier.data.app.model.AdaPotsComparisonKey;
+import org.cardanofoundation.ledgersync.verifier.data.app.projection.AdaPotsProjection;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * Ada pots comparison mapper for the ledger sync implementation.
+ */
+public class AdaPotsComparisonMapperLS implements AdaPotsComparisonMapper<AdaPotsProjection> {
+
+    @Override
+    public Map<AdaPotsComparisonKey, AdaPotsComparison> buildMap(List<AdaPotsProjection> source) {
+        Map<AdaPotsComparisonKey, AdaPotsComparison> map = new HashMap<>();
+
+        source.forEach(adaPotsProjection -> {
+            AdaPotsComparisonKey adaPotsComparisonKey = AdaPotsComparisonKey.builder()
+                    .epochNo(adaPotsProjection.getEpochNo())
+                    .slotNo(adaPotsProjection.getSlotNo())
+                    .build();
+
+            AdaPotsComparison adaPotsComparison = AdaPotsComparison.builder()
+                    .adaPotsComparisonKey(adaPotsComparisonKey)
+                    .reserves(adaPotsProjection.getReserves())
+                    .rewards(adaPotsProjection.getRewards())
+                    .build();
+            map.put(adaPotsComparisonKey, adaPotsComparison);
+        });
+        return map;
+    }
+}

verifier-data-app/src/main/java/org/cardanofoundation/ledgersync/verifier/data/app/model/AdaPotsComparison.java

@@ -0,0 +1,20 @@
+package org.cardanofoundation.ledgersync.verifier.data.app.model;
+
+import lombok.AccessLevel;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.Setter;
+import lombok.experimental.FieldDefaults;
+
+import java.math.BigInteger;
+
+@Builder
+@Setter
+@Getter
+@FieldDefaults(level = AccessLevel.PRIVATE)
+public class AdaPotsComparison {
+    AdaPotsComparisonKey adaPotsComparisonKey;
+    BigInteger treasury;
+    BigInteger reserves;
+    BigInteger rewards;
+}

verifier-data-app/src/main/java/org/cardanofoundation/ledgersync/verifier/data/app/model/AdaPotsComparisonKey.java

@@ -0,0 +1,31 @@
+package org.cardanofoundation.ledgersync.verifier.data.app.model;
+
+import lombok.AccessLevel;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.Setter;
+import lombok.experimental.FieldDefaults;
+
+import java.util.Objects;
+
+@Builder
+@Setter
+@Getter
+@FieldDefaults(level = AccessLevel.PRIVATE)
+public class AdaPotsComparisonKey {
+    Long slotNo;
+    Long epochNo;
+
+    @Override
+    public boolean equals(Object o) {
+        if (this == o) return true;
+        if (o == null || getClass() != o.getClass()) return false;
+        AdaPotsComparisonKey that = (AdaPotsComparisonKey) o;
+        return slotNo.equals(that.slotNo) && epochNo.equals(that.epochNo);
+    }
+
+    @Override
+    public int hashCode() {
+        return Objects.hash(slotNo, epochNo);
+    }
+}

verifier-data-app/src/main/java/org/cardanofoundation/ledgersync/verifier/data/app/projection/AdaPotsProjection.java

@@ -0,0 +1,11 @@
+package org.cardanofoundation.ledgersync.verifier.data.app.projection;
+
+import java.math.BigInteger;
+
+public interface AdaPotsProjection {
+    Long getSlotNo();
+    Long getEpochNo();
+    BigInteger getTreasury();
+    BigInteger getReserves();
+    BigInteger getRewards();
+}

verifier-data-app/src/main/java/org/cardanofoundation/ledgersync/verifier/data/app/repository/AdaPotsRepo.java

@@ -0,0 +1,10 @@
+package org.cardanofoundation.ledgersync.verifier.data.app.repository;
+
+import org.cardanofoundation.ledgersync.verifier.data.app.projection.AdaPotsProjection;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+import java.util.Set;
+
+public interface AdaPotsRepo<T> extends JpaRepository<T, Long> {
+    Set<AdaPotsProjection> findByEpochNoIn(Set<Long> epochs);
+}

verifier-data-app/src/main/java/org/cardanofoundation/ledgersync/verifier/data/app/repository/dbsync/AdaPotsRepository.java

@@ -0,0 +1,17 @@
+package org.cardanofoundation.ledgersync.verifier.data.app.repository.dbsync;
+
+import org.cardanofoundation.ledgersync.verifier.data.app.entity.dbsync.AdaPot;
+import org.cardanofoundation.ledgersync.verifier.data.app.projection.AdaPotsProjection;
+import org.cardanofoundation.ledgersync.verifier.data.app.repository.AdaPotsRepo;
+import org.springframework.context.annotation.Primary;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.stereotype.Repository;
+
+import java.util.Set;
+
+@Repository("dbSyncAdaPotsRepository")
+@Primary
+public interface AdaPotsRepository extends AdaPotsRepo<AdaPot> {
+    @Query("select a from AdaPot a where a.epochNo in :epochs")
+    Set<AdaPotsProjection> findByEpochNoIn(Set<Long> epochs);
+}

verifier-data-app/src/main/java/org/cardanofoundation/ledgersync/verifier/data/app/repository/ledgersync/AdaPotsRepository.java

@@ -0,0 +1,15 @@
+package org.cardanofoundation.ledgersync.verifier.data.app.repository.ledgersync;
+
+import org.cardanofoundation.ledgersync.consumercommon.entity.AdaPots;
+import org.cardanofoundation.ledgersync.verifier.data.app.projection.AdaPotsProjection;
+import org.cardanofoundation.ledgersync.verifier.data.app.repository.AdaPotsRepo;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.stereotype.Repository;
+
+import java.util.Set;
+
+@Repository("ledgerSyncAdaPotsRepository")
+public interface AdaPotsRepository extends AdaPotsRepo<AdaPots> {
+    @Query("select a from AdaPots a where a.epochNo in :epochs")
+    Set<AdaPotsProjection> findByEpochNoIn(Set<Long> epochs);
+}