feat: ability to inspect drep vote delegation operations

Author: Mateusz Czeladka

api/src/main/java/org/cardanofoundation/rosetta/RosettaApiApplication.java

@@ -12,14 +12,14 @@
 import org.springframework.context.annotation.Profile;
 import org.springframework.core.Ordered;
 import org.springframework.scheduling.annotation.EnableScheduling;
+import org.springframework.transaction.annotation.EnableTransactionManagement;
 import org.springframework.web.client.RestTemplate;
 import org.springframework.web.filter.CommonsRequestLoggingFilter;
 import org.springframework.web.filter.ForwardedHeaderFilter;
 import io.swagger.v3.oas.annotations.OpenAPIDefinition;
 import io.swagger.v3.oas.annotations.info.Info;
 import org.openapitools.jackson.nullable.JsonNullableModule;
 
-
 @SpringBootApplication
 @EntityScan({
     "org.cardanofoundation.rosetta.api.account.model.entity",
@@ -29,6 +29,7 @@
     "org.cardanofoundation.rosetta.api.common.model.entity"})
 @OpenAPIDefinition(info = @Info(title = "APIs", version = "1.0", description = "Rosetta APIs v1.0"))
 @EnableScheduling
+@EnableTransactionManagement
 public class RosettaApiApplication {
 
   public static void main(String[] args) {

api/src/main/java/org/cardanofoundation/rosetta/api/block/mapper/TransactionMapper.java

@@ -35,14 +35,28 @@ public interface TransactionMapper {
 
   PoolRetirement mapEntityToPoolRetirement(PoolRetirementEntity entity);
 
+  @Mapping(source = "txHash", target = "txHash")
+  @Mapping(source = "certIndex", target = "certIndex")
+  @Mapping(source = "address", target = "address")
+  @Mapping(source = "drepHash", target = "drep.drepId") // no this is not a mistake we don't have bech32 representation in rosetta
+  @Mapping(source = "drepType", target = "drep.drepType")
+  DRepDelegation mapEntityToDRepDelegation(DrepDelegationVoteEntity entity);
+
+  @Mapping(source = "txHash", target = "txHash")
+  @Mapping(source = "certIndex", target = "certIndex")
+  @Mapping(source = "address", target = "address")
+  @Mapping(source = "drep.drepId", target = "drepHash")
+  @Mapping(source = "drep.drepType", target = "drepType")
+  DrepDelegationVoteEntity mapDRepDelegationToEntity(DRepDelegation dRepDelegation);
+
   @Mapping(target = "type", constant = Constants.OPERATION_TYPE_POOL_RETIREMENT)
   @Mapping(target = "status", source = "status.status")
   @Mapping(target = "account.address", source = "model.poolId")
   @Mapping(target = "metadata.epoch", source = "model.epoch")
   @Mapping(target = "operationIdentifier", source = "index", qualifiedByName = "OperationIdentifier")
   Operation mapPoolRetirementToOperation(PoolRetirement model, OperationStatus status, int index);
 
-  StakePoolDelegation mapDelegationEntityToDelegation(DelegationEntity entity);
+  StakePoolDelegation mapPoolDelegationEntityToDelegation(PoolDelegationEntity entity);
 
   @Mapping(target = "status", source = "status.status")
   @Mapping(target = "type", constant = Constants.OPERATION_TYPE_STAKE_DELEGATION)

api/src/main/java/org/cardanofoundation/rosetta/api/block/model/domain/DRepDelegation.java

@@ -10,6 +10,7 @@
 @Builder
 @NoArgsConstructor
 @AllArgsConstructor
+@Setter
 public class DRepDelegation {
 
     private String txHash;
@@ -20,10 +21,10 @@ public class DRepDelegation {
     @AllArgsConstructor
     @NoArgsConstructor
     @Getter
+    @Setter
     public static class DRep {
 
         private String drepId;
-
         private DRepType drepType;
 
         public static DRepDelegation.DRep convertDRepToRosetta(DRepParams dRepParams) {

api/src/main/java/org/cardanofoundation/rosetta/api/block/model/entity/DelegationId.java

@@ -9,4 +9,5 @@ public class DelegationId implements Serializable {
 
   private String txHash;
   private long certIndex;
+
 }

api/src/main/java/org/cardanofoundation/rosetta/api/block/model/entity/DelegationVoteId.java

@@ -0,0 +1,17 @@
+package org.cardanofoundation.rosetta.api.block.model.entity;
+
+import java.io.Serializable;
+import jakarta.persistence.Column;
+
+import lombok.EqualsAndHashCode;
+
+@EqualsAndHashCode
+public class DelegationVoteId implements Serializable {
+
+    @Column(name = "tx_hash")
+    private String txHash;
+
+    @Column(name = "cert_index")
+    private long certIndex;
+
+}

api/src/main/java/org/cardanofoundation/rosetta/api/block/model/entity/DrepDelegationVoteEntity.java

@@ -0,0 +1,66 @@
+package org.cardanofoundation.rosetta.api.block.model.entity;
+
+import java.time.LocalDateTime;
+import jakarta.persistence.*;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.Setter;
+
+import com.bloxbean.cardano.client.transaction.spec.cert.StakeCredType;
+import com.bloxbean.cardano.yaci.core.model.governance.DrepType;
+
+@Getter
+@Setter
+@NoArgsConstructor
+@AllArgsConstructor
+@Entity
+@Table(name = "delegation_vote")
+@IdClass(DelegationVoteId.class)
+public class DrepDelegationVoteEntity {
+
+    @jakarta.persistence.Id
+    @Column(name = "tx_hash")
+    private String txHash;
+
+    @jakarta.persistence.Id
+    @Column(name = "cert_index")
+    private long certIndex;
+
+    @Column(name = "slot")
+    private Long slot;
+
+    @Column(name = "block")
+    private Long blockNumber;
+
+    @Column(name = "block_time")
+    private Long blockTime;
+
+    @Column(name = "update_datetime")
+    private LocalDateTime updateDateTime;
+
+    @Column(name = "address")
+    private String address;
+
+    @Column(name = "drep_hash") // actual drep id as hex hash
+    private String drepHash;
+
+    @Column(name = "drep_id") // bech 32
+    private String drepId;
+
+    @Column(name = "drep_type")
+    @Enumerated(EnumType.STRING)
+    private DrepType drepType;
+
+    @Column(name = "credential")
+    private String credential;
+
+    @Column(name = "cred_type")
+    @Enumerated(EnumType.STRING)
+    private StakeCredType credType;
+
+    @Column(name = "epoch")
+    private Integer epoch;
+
+}

api/src/main/java/org/cardanofoundation/rosetta/api/block/model/entity/DelegationEntity.java renamed to api/src/main/java/org/cardanofoundation/rosetta/api/block/model/entity/PoolDelegationEntity.java

@@ -12,7 +12,7 @@
 @Entity
 @Table(name = "delegation")
 @IdClass(DelegationId.class)
-public class DelegationEntity {
+public class PoolDelegationEntity {
 
   @Id
   @Column(name = "tx_hash")

api/src/main/java/org/cardanofoundation/rosetta/api/block/model/entity/PoolRegistrationId.java

@@ -9,4 +9,5 @@ public class PoolRegistrationId implements Serializable {
 
   private String txHash;
   private int certIndex;
+
 }

api/src/main/java/org/cardanofoundation/rosetta/api/block/model/entity/StakeRegistrationId.java

@@ -9,4 +9,5 @@ public class StakeRegistrationId implements Serializable {
 
   private String txHash;
   private long certIndex;
+
 }

api/src/main/java/org/cardanofoundation/rosetta/api/block/model/repository/DRepVoteDelegationRepository.java

@@ -0,0 +1,15 @@
+package org.cardanofoundation.rosetta.api.block.model.repository;
+
+import java.util.List;
+
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.stereotype.Repository;
+
+import org.cardanofoundation.rosetta.api.block.model.entity.DrepDelegationVoteEntity;
+
+@Repository
+public interface DRepVoteDelegationRepository extends JpaRepository<DrepDelegationVoteEntity, DrepDelegationVoteEntity>  {
+
+    List<DrepDelegationVoteEntity> findByTxHashIn(List<String> txHashes);
+
+}