feat: tx index sorting (#642)

Author: matiwinnetou

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

@@ -2,6 +2,7 @@
 
 import java.math.BigInteger;
 import java.util.List;
+import jakarta.annotation.Nullable;
 import jakarta.persistence.Column;
 import jakarta.persistence.ConstraintMode;
 import jakarta.persistence.Entity;
@@ -50,6 +51,10 @@ public class TxnEntity {
   @Column(name = "fee")
   private BigInteger fee;
 
+  @Column(name = "tx_index")
+  @Nullable
+  private Integer txIndex;
+
   @OneToMany(mappedBy = "txHash")
   private List<TxScriptEntity> script;
 

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

@@ -123,6 +123,7 @@ public List<TxnEntity> findTransactionsByBlockHash(String blockHash) {
                         TRANSACTION.OUTPUTS,
                         TRANSACTION.FEE,
                         TRANSACTION.SLOT,
+                        TRANSACTION.TX_INDEX,
                         BLOCK.HASH.as("joined_block_hash"),
                         BLOCK.NUMBER.as("joined_block_number"),
                         BLOCK.SLOT.as("joined_block_slot"),
@@ -133,6 +134,7 @@ public List<TxnEntity> findTransactionsByBlockHash(String blockHash) {
                 .leftJoin(BLOCK).on(TRANSACTION.BLOCK_HASH.eq(BLOCK.HASH))
                 .leftJoin(TRANSACTION_SIZE).on(TRANSACTION.TX_HASH.eq(TRANSACTION_SIZE.TX_HASH))
                 .where(TRANSACTION.BLOCK_HASH.eq(blockHash))
+                .orderBy(TRANSACTION.TX_INDEX.asc())
                 .fetch(queryBuilder::mapRecordToTxnEntity);
     }
 
@@ -182,12 +184,12 @@ protected int executeCountQuery(Condition conditions, @Nullable Boolean isSucces
      * Ensures count and results queries use identical conditions and JOINs.
      * Currency conditions use EXISTS subqueries - no JOIN needed.
      */
-    protected List<? extends org.jooq.Record> executeResultsQuery(Condition conditions, 
-                                                                  @Nullable Boolean isSuccess, 
+    protected List<? extends org.jooq.Record> executeResultsQuery(Condition conditions,
+                                                                  @Nullable Boolean isSuccess,
                                                                   OffsetBasedPageRequest offsetBasedPageRequest) {
         return buildBaseResultsQuery(isSuccess)
                 .where(conditions)
-                .orderBy(TRANSACTION.SLOT.desc())
+                .orderBy(TRANSACTION.SLOT.desc(), TRANSACTION.TX_INDEX.desc())
                 .limit(offsetBasedPageRequest.getLimit())
                 .offset(offsetBasedPageRequest.getOffset())
                 .fetch();

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

@@ -36,14 +36,15 @@ public interface CurrencyConditionBuilder {
         Condition buildCurrencyCondition(Currency currency);
     }
 
-    public SelectJoinStep<Record11<String, String, JSONB, JSONB, Long, Long, String, Long, Long, Integer, Integer>> buildTransactionSelectQuery(DSLContext dsl) {
+    public SelectJoinStep<Record12<String, String, JSONB, JSONB, Long, Long, Integer, String, Long, Long, Integer, Integer>> buildTransactionSelectQuery(DSLContext dsl) {
         return dsl.select(
                 TRANSACTION.TX_HASH,
                 TRANSACTION.BLOCK_HASH,
                 TRANSACTION.INPUTS,
                 TRANSACTION.OUTPUTS,
                 TRANSACTION.FEE,
                 TRANSACTION.SLOT,
+                TRANSACTION.TX_INDEX,
                 BLOCK.HASH.as("joined_block_hash"),
                 BLOCK.NUMBER.as("joined_block_number"),
                 BLOCK.SLOT.as("joined_block_slot"),
@@ -161,6 +162,8 @@ public TxnEntity mapRecordToTxnEntity(org.jooq.Record record) {
         @Nullable BigInteger fee = Optional.ofNullable(record.get(TRANSACTION.FEE))
                 .map(BigInteger::valueOf).orElse(null);
 
+        @Nullable Integer txIndex = record.get(TRANSACTION.TX_INDEX);
+
         @Nullable BlockEntity blockEntity = null;
         String blockHashFromRecord = record.get("joined_block_hash", String.class);
         if (blockHashFromRecord != null) {
@@ -178,6 +181,7 @@ public TxnEntity mapRecordToTxnEntity(org.jooq.Record record) {
                 .inputKeys(readUtxoKeys(inputs, txHash))
                 .outputKeys(readUtxoKeys(outputs, txHash))
                 .fee(fee)
+                .txIndex(txIndex)
                 .build();
     }