support other ibc modules

internal/app/app.go

@@ -35,8 +35,10 @@ import (
 	"github.com/cosmos/cosmos-sdk/x/upgrade"
 	upgradeclient "github.com/cosmos/cosmos-sdk/x/upgrade/client"
 	gaia "github.com/cosmos/gaia/v15/x/metaprotocols"
+	ibcaccounts "github.com/cosmos/ibc-go/v7/modules/apps/27-interchain-accounts"
+	ibcfee "github.com/cosmos/ibc-go/v7/modules/apps/29-fee"
 	ibctransfertypes "github.com/cosmos/ibc-go/v7/modules/apps/transfer/types"
-	ibc "github.com/cosmos/ibc-go/v7/modules/core"
+	ibccore "github.com/cosmos/ibc-go/v7/modules/core"
 	ibclightclient "github.com/cosmos/ibc-go/v7/modules/light-clients/07-tendermint"
 	interchainprovider "github.com/cosmos/interchain-security/v3/x/ccv/provider"
 	"github.com/pkg/errors"
@@ -221,7 +223,9 @@ func MakeEncodingConfig() codec.Codec {
 			vesting.AppModuleBasic{},
 			nftmodule.AppModuleBasic{},
 			consensus.AppModuleBasic{},
-			ibc.AppModuleBasic{},
+			ibccore.AppModuleBasic{},
+			ibcfee.AppModuleBasic{},
+			ibcaccounts.AppModuleBasic{},
 			ibclightclient.AppModuleBasic{},
 			interchainprovider.AppModuleBasic{},
 			gaia.AppModuleBasic{},

pkg/worker/process.go

@@ -117,7 +117,7 @@ func (w *Worker) processHeight(ctx context.Context, workerIndex int, height int6
 
 		_blockDur := time.Now()
 		if block, err = w.grpcClient.Block(ctx2, height); err != nil {
-			return err
+			return fmt.Errorf("failed to get block: %w", err)
 		}
 		w.log.Debug().
 			Int("worker_number", workerIndex).
@@ -131,7 +131,7 @@ func (w *Worker) processHeight(ctx context.Context, workerIndex int, height int6
 		var err error
 		_validatorsDur := time.Now()
 		if vals, err = w.grpcClient.Validators(ctx2, height); err != nil {
-			return err
+			return fmt.Errorf("failed to get validators: %w", err)
 		}
 		w.log.Debug().
 			Int("worker_number", workerIndex).
@@ -147,7 +147,7 @@ func (w *Worker) processHeight(ctx context.Context, workerIndex int, height int6
 		_blockEventsDur := time.Now()
 		beginBlockEvents, endBlockEvents, err = w.rpcClient.GetBlockEvents(ctx2, height)
 		if err != nil {
-			return err
+			return fmt.Errorf("failed to get block events: %w", err)
 		}
 
 		w.log.Debug().
@@ -160,7 +160,7 @@ func (w *Worker) processHeight(ctx context.Context, workerIndex int, height int6
 	})
 
 	if err := g.Wait(); err != nil {
-		w.log.Error().Int64(keyHeight, height).Err(err).Msg("processHeight block got error")
+		w.log.Error().Int64(keyHeight, height).Err(err).Msg("processHeight error")
 		w.setErrorStatusWithLogging(ctx, height, err.Error())
 		return
 	}