Merge branch 'multiple_block_tx_fix' into 'main'

Fix indexing Banff proposal blocks

See merge request flarenetwork/network/flare-p-chain-indexer!2

Author: mboben

indexer/pchain/batch_indexer.go

@@ -99,8 +99,12 @@ func (xi *txBatchIndexer) AddContainer(index uint64, container indexer.Container
 		}
 	// Banff blocks were introduced in Avalanche 1.9.0
 	case *block.BanffProposalBlock:
-		tx := innerBlkType.Tx
-		err = xi.addTx(&container, database.PChainProposalBlock, innerBlk.Height(), innerBlkType.Time, tx)
+		for _, tx := range innerBlkType.Txs() {
+			err = xi.addTx(&container, database.PChainProposalBlock, innerBlk.Height(), innerBlkType.Time, tx)
+			if err != nil {
+				break
+			}
+		}
 	case *block.BanffCommitBlock:
 		xi.addEmptyTx(&container, database.PChainCommitBlock, innerBlk.Height(), innerBlkType.Time)
 	case *block.BanffAbortBlock:

indexer/pchain/migrations.go

@@ -11,6 +11,7 @@ import (
 func init() {
 	migrations.Container.Add("2023-02-10-00-00", "Create initial state for P-Chain transactions", createPChainTxState)
 	migrations.Container.Add("2024-11-07-00-00", "Alter type column size in p_chain_txes table", alterPChainTxType)
+	migrations.Container.Add("2025-09-30-00-00", "Delete all P-chain transactions", deleteTransactions)
 }
 
 func createPChainTxState(db *gorm.DB) error {
@@ -25,3 +26,22 @@ func createPChainTxState(db *gorm.DB) error {
 func alterPChainTxType(db *gorm.DB) error {
 	return db.Exec("ALTER TABLE p_chain_txes CHANGE COLUMN type type VARCHAR(40)").Error
 }
+
+// Delete all P-chain transactions and reset the state to start indexing from the beginning
+func deleteTransactions(db *gorm.DB) error {
+	return db.Transaction(func(tx *gorm.DB) error {
+		if err := tx.Exec("DELETE FROM p_chain_tx_inputs").Error; err != nil {
+			return err
+		}
+		if err := tx.Exec("DELETE FROM p_chain_tx_outputs").Error; err != nil {
+			return err
+		}
+		if err := tx.Exec("DELETE FROM p_chain_txes").Error; err != nil {
+			return err
+		}
+		if err := tx.Exec("UPDATE states SET next_db_index = 0, last_chain_index = 0 WHERE name = ?", StateName).Error; err != nil {
+			return err
+		}
+		return nil
+	})
+}

indexer/shared/constants.go

@@ -5,7 +5,7 @@ import (
 )
 
 const (
-	ApplicationVersion = "2.2.1"
+	ApplicationVersion = "2.2.2"
 )
 
 var (