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,8 @@ 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 'org.springframework.boot:spring-boot-starter-jdbc'
     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/config/JdbcTemplateConfig.java

@@ -0,0 +1,25 @@
+package org.cardanofoundation.ledgersync.verifier.data.app.config;
+
+import javax.sql.DataSource;
+
+import lombok.RequiredArgsConstructor;
+
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.jdbc.core.JdbcTemplate;
+
+@Configuration
+@RequiredArgsConstructor
+public class JdbcTemplateConfig {
+  @Bean(name = "ledgerSyncJdbcTemplate")
+  public JdbcTemplate ledgerSyncJdbcTemplate(
+      @Qualifier("ledgerSyncDataSource") DataSource dataSource) {
+    return new JdbcTemplate(dataSource);
+  }
+
+  @Bean(name = "dbSyncJdbcTemplate")
+  public JdbcTemplate dbSyncJdbcTemplate(@Qualifier("dbSyncDataSource") DataSource dataSource) {
+    return new JdbcTemplate(dataSource);
+  }
+}

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

@@ -0,0 +1,21 @@
+package org.cardanofoundation.ledgersync.verifier.data.app.mapper;
+
+import java.sql.SQLException;
+import java.util.List;
+import java.util.Map;
+
+import org.springframework.stereotype.Component;
+
+import org.cardanofoundation.ledgersync.verifier.data.app.model.AdaPotsComparison;
+import org.cardanofoundation.ledgersync.verifier.data.app.model.AdaPotsComparisonKey;
+
+@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) throws SQLException;
+}

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

@@ -0,0 +1,35 @@
+package org.cardanofoundation.ledgersync.verifier.data.app.mapper.impl;
+
+import java.sql.SQLException;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+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;
+
+public class AdaPotsComparisonMapperImpl implements AdaPotsComparisonMapper<AdaPotsProjection> {
+  @Override
+  public Map<AdaPotsComparisonKey, AdaPotsComparison> buildMap(List<AdaPotsProjection> source)
+      throws SQLException {
+    Map<AdaPotsComparisonKey, AdaPotsComparison> map = new HashMap<>();
+    for (AdaPotsProjection adaPotsProjection : source) {
+      AdaPotsComparisonKey key =
+          AdaPotsComparisonKey.builder()
+              .slotNo(adaPotsProjection.getSlotNo())
+              .epochNo(adaPotsProjection.getEpochNo())
+              .build();
+      AdaPotsComparison value =
+          AdaPotsComparison.builder()
+              .adaPotsComparisonKey(key)
+              .treasury(adaPotsProjection.getTreasury())
+              .reserves(adaPotsProjection.getReserves())
+              .rewards(adaPotsProjection.getRewards())
+              .build();
+      map.put(key, value);
+    }
+    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 java.math.BigInteger;
+
+import lombok.AccessLevel;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.Setter;
+import lombok.experimental.FieldDefaults;
+
+@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 java.util.Objects;
+
+import lombok.AccessLevel;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.Setter;
+import lombok.experimental.FieldDefaults;
+
+@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,16 @@
+package org.cardanofoundation.ledgersync.verifier.data.app.projection;
+
+import java.math.BigInteger;
+import java.sql.SQLException;
+
+public interface AdaPotsProjection {
+  Long getSlotNo() throws SQLException;
+
+  Long getEpochNo() throws SQLException;
+
+  BigInteger getTreasury() throws SQLException;
+
+  BigInteger getReserves() throws SQLException;
+
+  BigInteger getRewards() throws SQLException;
+}

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

@@ -0,0 +1,47 @@
+package org.cardanofoundation.ledgersync.verifier.data.app.projection;
+
+import java.math.BigInteger;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+
+import org.springframework.jdbc.core.RowMapper;
+
+import org.jetbrains.annotations.NotNull;
+
+public class AdaPotsProjectionRowMapper implements RowMapper<AdaPotsProjection> {
+  @Override
+  public AdaPotsProjection mapRow(@NotNull ResultSet rs, int rowNum) throws SQLException {
+    Long slotNo = rs.getLong("slot_no");
+    Long epochNo = rs.getLong("epoch_no");
+    BigInteger treasury = rs.getBigDecimal("treasury").toBigInteger();
+    BigInteger reserves = rs.getBigDecimal("reserves").toBigInteger();
+    BigInteger rewards = rs.getBigDecimal("rewards").toBigInteger();
+
+    return new AdaPotsProjection() {
+      @Override
+      public Long getSlotNo() {
+        return slotNo;
+      }
+
+      @Override
+      public Long getEpochNo() {
+        return epochNo;
+      }
+
+      @Override
+      public BigInteger getTreasury() {
+        return treasury;
+      }
+
+      @Override
+      public BigInteger getReserves() {
+        return reserves;
+      }
+
+      @Override
+      public BigInteger getRewards() {
+        return rewards;
+      }
+    };
+  }
+}

verifier-data-app/src/main/java/org/cardanofoundation/ledgersync/verifier/data/app/service/AdaPotsService.java

@@ -0,0 +1,46 @@
+package org.cardanofoundation.ledgersync.verifier.data.app.service;
+
+import java.sql.SQLException;
+import java.util.*;
+
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate;
+
+import org.cardanofoundation.ledgersync.verifier.data.app.mapper.impl.AdaPotsComparisonMapperImpl;
+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 org.cardanofoundation.ledgersync.verifier.data.app.projection.AdaPotsProjectionRowMapper;
+
+public abstract class AdaPotsService {
+  private final JdbcTemplate jdbcTemplate;
+
+  public AdaPotsService(JdbcTemplate jdbcTemplate) {
+    this.jdbcTemplate = jdbcTemplate;
+  }
+
+  public List<Long> getRandomEpochNos(int maxAdaPots) {
+    List<Long> epochNos =
+        jdbcTemplate.query(
+            "SELECT epoch_no FROM ada_pots ORDER BY RANDOM() LIMIT ?",
+            new Object[] {maxAdaPots},
+            (rs, rowNum) -> rs.getLong("epoch_no"));
+    return epochNos;
+  }
+
+  public List<AdaPotsProjection> getAdaPotsByEpochNos(List<Long> epochNos) {
+    Map<String, Object> params = Collections.singletonMap("epochNos", epochNos);
+    AdaPotsProjectionRowMapper rowMapper = new AdaPotsProjectionRowMapper();
+    return new NamedParameterJdbcTemplate(jdbcTemplate)
+        .query(
+            "SELECT slot_no, epoch_no, treasury, reserves, rewards FROM ada_pots WHERE epoch_no IN (:epochNos)",
+            params,
+            (rs, rowNum) -> rowMapper.mapRow(rs, rowNum));
+  }
+
+  public Map<AdaPotsComparisonKey, AdaPotsComparison> getMapAdaPotsFromEpochNos(List<Long> epochNos)
+      throws SQLException {
+    List<AdaPotsProjection> adaPotsProjections = getAdaPotsByEpochNos(epochNos);
+    return new AdaPotsComparisonMapperImpl().buildMap(adaPotsProjections);
+  }
+}

verifier-data-app/src/main/java/org/cardanofoundation/ledgersync/verifier/data/app/service/impl/AdaPotsDbSyncServiceImpl.java

@@ -0,0 +1,16 @@
+package org.cardanofoundation.ledgersync.verifier.data.app.service.impl;
+
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.stereotype.Service;
+
+import org.cardanofoundation.ledgersync.verifier.data.app.service.AdaPotsService;
+
+@Service
+public class AdaPotsDbSyncServiceImpl extends AdaPotsService {
+
+  public AdaPotsDbSyncServiceImpl(
+      @Qualifier("dbSyncJdbcTemplate") JdbcTemplate dbSyncJdbcTemplate) {
+    super(dbSyncJdbcTemplate);
+  }
+}