check if tx index enabled

clientcontroller/babylon.go

@@ -3,6 +3,7 @@ package clientcontroller
 import (
 	"context"
 	"fmt"
+	coretypes "github.com/cometbft/cometbft/rpc/core/types"
 	"strings"
 	"time"
 
@@ -415,6 +416,10 @@ func (bc *BabylonController) QueryBestBlock() (*types.BlockInfo, error) {
 	return blocks[0], nil
 }
 
+func (bc *BabylonController) NodeStatus() (*coretypes.ResultStatus, error) {
+	return bc.bbnClient.GetStatus()
+}
+
 func (bc *BabylonController) queryCometBestBlock() (*types.BlockInfo, error) {
 	ctx, cancel := getContextWithCancel(bc.cfg.Timeout)
 	// this will return 20 items at max in the descending order (highest first)

clientcontroller/interface.go

@@ -2,6 +2,7 @@ package clientcontroller
 
 import (
 	"fmt"
+	coretypes "github.com/cometbft/cometbft/rpc/core/types"
 
 	"cosmossdk.io/math"
 	btcstakingtypes "github.com/babylonlabs-io/babylon/x/btcstaking/types"
@@ -89,6 +90,8 @@ type ClientController interface {
 	// the value zero should be returned.
 	QueryFinalityActivationBlockHeight() (uint64, error)
 
+	NodeStatus() (*coretypes.ResultStatus, error)
+
 	Close() error
 }
 

finality-provider/service/fp_instance.go

@@ -108,6 +108,10 @@ func (fp *FinalityProviderInstance) Start() error {
 		return fmt.Errorf("the finality-provider instance %s is already started", fp.GetBtcPkHex())
 	}
 
+	if err := fp.txIndexEnabled(); err != nil {
+		return err
+	}
+
 	if fp.IsJailed() {
 		fp.logger.Warn("the finality provider is jailed",
 			zap.String("pk", fp.GetBtcPkHex()))
@@ -1035,3 +1039,16 @@ func (fp *FinalityProviderInstance) GetFinalityProviderSlashedOrJailedWithRetry(
 
 	return slashed, jailed, nil
 }
+
+func (fp *FinalityProviderInstance) txIndexEnabled() error {
+	res, err := fp.cc.NodeStatus()
+	if err != nil {
+		return fmt.Errorf("failed to query node status: %w", err)
+	}
+
+	if !res.TxIndexEnabled() {
+		return fmt.Errorf("tx indexing in the babylon node must be enabled")
+	}
+
+	return nil
+}