diff --git a/internal/app/app.go b/internal/app/app.go index bda96a6..9c22cd6 100644 --- a/internal/app/app.go +++ b/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{}, diff --git a/pkg/worker/process.go b/pkg/worker/process.go index cfbadfa..6803b58 100644 --- a/pkg/worker/process.go +++ b/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 }