Use block time for the start time of add validator and add delegator transactions after Durango fork time

Author: mboben

indexer/pchain/batch_indexer.go

@@ -36,6 +36,8 @@ type txBatchIndexer struct {
 	inOutIndexer    *shared.InputOutputIndexer
 	newTxs          []*database.PChainTx
 	dataTransformer *PChainDataTransformer
+
+	durangoTime time.Time
 }
 
 func NewPChainDataTransformer(txTransformer func(tx *database.PChainTx) *database.PChainTx) *PChainDataTransformer {
@@ -50,6 +52,11 @@ func NewPChainBatchIndexer(
 	rpcClient chain.RPCClient,
 	dataTransformer *PChainDataTransformer,
 ) *txBatchIndexer {
+	var durangoTime time.Time
+	if time, ok := shared.DurangoTimes[ctx.Config().Chain.ChainAddressHRP]; ok {
+		durangoTime = time
+	}
+
 	updater := newPChainInputUpdater(ctx, rpcClient)
 	return &txBatchIndexer{
 		db:        ctx.DB(),
@@ -59,6 +66,8 @@ func NewPChainBatchIndexer(
 		inOutIndexer:    shared.NewInputOutputIndexer(updater),
 		newTxs:          make([]*database.PChainTx, 0),
 		dataTransformer: dataTransformer,
+
+		durangoTime: durangoTime,
 	}
 }
 
@@ -296,12 +305,18 @@ func (xi *txBatchIndexer) updateDelegatorTx(
 }
 
 // Common code for Add[Permissionless]DelegatorTx and Add[Permissionless]ValidatorTx
+// We assume that dbTx.blockTime is set to the block time before calling this function
 func (xi *txBatchIndexer) updateAddStakerTx(
 	dbTx *database.PChainTx,
 	tx StakerTx,
 	txIns []*avax.TransferableInput,
 ) error {
-	startTime := tx.StartTime()
+	var startTime time.Time
+	if xi.isDurango(dbTx.BlockTime) {
+		startTime = *dbTx.BlockTime
+	} else {
+		startTime = tx.StartTime()
+	}
 	endTime := tx.EndTime()
 	dbTx.NodeID = tx.NodeID().String()
 	dbTx.StartTime = &startTime
@@ -329,7 +344,11 @@ func (xi *txBatchIndexer) updateAddStakerTx(
 	return nil
 }
 
-func getAddStakerTxOutputs(txID string, tx StakerTx) ([]shared.Output, error) {
+func (xi *txBatchIndexer) isDurango(blockTime *time.Time) bool {
+	return blockTime != nil && !blockTime.Before(xi.durangoTime)
+}
+
+func getAddStakerTxOutputs(txID string, tx PermissionlessStakerTx) ([]shared.Output, error) {
 	outs, err := shared.OutputsFromTxOuts(txID, tx.Outputs(), 0, PChainDefaultInputOutputCreator)
 	if err != nil {
 		return nil, err

indexer/pchain/in_updater.go

@@ -73,8 +73,12 @@ func (iu *pChainInputUpdater) updateFromChain(
 		switch unsignedTx := tx.Unsigned.(type) {
 		case *txs.AddValidatorTx:
 			outs, err = iu.getAddStakerTxAndRewardTxOutputs(txId, unsignedTx)
+		case *txs.AddPermissionlessValidatorTx:
+			outs, err = iu.getAddStakerTxAndRewardTxOutputs(txId, unsignedTx)
 		case *txs.AddDelegatorTx:
 			outs, err = iu.getAddStakerTxAndRewardTxOutputs(txId, unsignedTx)
+		case *txs.AddPermissionlessDelegatorTx:
+			outs, err = iu.getAddStakerTxAndRewardTxOutputs(txId, unsignedTx)
 		default:
 			txOuts := tx.Unsigned.Outputs()
 			outs, err = shared.OutputsFromTxOuts(txId, txOuts, 0, PChainDefaultInputOutputCreator)

indexer/shared/constants.go

@@ -1,5 +1,21 @@
 package shared
 
+import (
+	"time"
+)
+
 const (
 	ApplicationVersion = "2.1.0"
 )
+
+var (
+	// Map from network name (HRP) to Durango fork time
+	DurangoTimes = map[string]time.Time{
+		"flare":      time.Date(10000, time.December, 1, 0, 0, 0, 0, time.UTC),
+		"costwo":     time.Date(10000, time.December, 1, 0, 0, 0, 0, time.UTC),
+		"localflare": time.Date(2025, time.May, 15, 14, 0, 0, 0, time.UTC),
+		"coston":     time.Date(10000, time.December, 1, 0, 0, 0, 0, time.UTC),
+		"songbird":   time.Date(10000, time.December, 1, 0, 0, 0, 0, time.UTC),
+		"local":      time.Date(10000, time.December, 1, 0, 0, 0, 0, time.UTC),
+	}
+)