fix: add refetch blocks and transactions fix command

cmd/fix/blocks/blocks.go

@@ -0,0 +1,45 @@
+package blocks
+
+import (
+	"fmt"
+
+	"github.com/forbole/juno/v2/cmd/parse"
+
+	"github.com/forbole/juno/v2/parser"
+	"github.com/forbole/juno/v2/types/config"
+	"github.com/spf13/cobra"
+)
+
+// blocksCmd returns a Cobra command that allows to fix missing blocks in database
+func blocksCmd(parseConfig *parse.Config) *cobra.Command {
+	return &cobra.Command{
+		Use:   "refetch",
+		Short: "Fix missing blocks and transactions in database from the start height",
+		RunE: func(cmd *cobra.Command, args []string) error {
+			parseCtx, err := parse.GetParsingContext(parseConfig)
+			if err != nil {
+				return err
+			}
+
+			workerCtx := parser.NewContext(parseCtx.EncodingConfig.Marshaler, nil, parseCtx.Node, parseCtx.Database, parseCtx.Logger, parseCtx.Modules)
+			worker := parser.NewWorker(0, workerCtx)
+
+			// Get latest height
+			height, err := parseCtx.Node.LatestHeight()
+			if err != nil {
+				return fmt.Errorf("error while getting chain latest block height: %s", err)
+			}
+
+			k := config.Cfg.Parser.StartHeight
+			fmt.Printf("Refetching missing blocks and transactions from height %d ... \n", k)
+			for ; k <= height; k++ {
+				err := worker.Process(k)
+				if err != nil {
+					return fmt.Errorf("error while re-fetching block %d: %s", k, err)
+				}
+			}
+
+			return nil
+		},
+	}
+}

cmd/fix/blocks/cmd.go

@@ -0,0 +1,20 @@
+package blocks
+
+import (
+	"github.com/forbole/juno/v2/cmd/parse"
+	"github.com/spf13/cobra"
+)
+
+// NewBlocksCmd returns the Cobra command that allows to fix all the things related to blocks
+func NewBlocksCmd(parseConfig *parse.Config) *cobra.Command {
+	cmd := &cobra.Command{
+		Use:   "blocks",
+		Short: "Fix things related to blocks and transactions",
+	}
+
+	cmd.AddCommand(
+		blocksCmd(parseConfig),
+	)
+
+	return cmd
+}

cmd/fix/fix.go

@@ -5,6 +5,7 @@ import (
 	"github.com/spf13/cobra"
 
 	fixauth "github.com/forbole/bdjuno/v2/cmd/fix/auth"
+	fixblocks "github.com/forbole/bdjuno/v2/cmd/fix/blocks"
 	fixgov "github.com/forbole/bdjuno/v2/cmd/fix/gov"
 	fixstaking "github.com/forbole/bdjuno/v2/cmd/fix/staking"
 )
@@ -19,6 +20,7 @@ func NewFixCmd(parseCfg *parse.Config) *cobra.Command {
 
 	cmd.AddCommand(
 		fixauth.NewAuthCmd(parseCfg),
+		fixblocks.NewBlocksCmd(parseCfg),
 		fixgov.NewGovCmd(parseCfg),
 		fixstaking.NewStakingCmd(parseCfg),
 	)

go.mod

@@ -4,7 +4,7 @@ go 1.16
 
 require (
 	github.com/cosmos/cosmos-sdk v0.42.9
-	github.com/forbole/juno/v2 v2.0.0-20211206070432-9314a5057955
+	github.com/forbole/juno/v2 v2.0.0-20211213105313-d167239d2dad
 	github.com/go-co-op/gocron v1.11.0
 	github.com/gogo/protobuf v1.3.3
 	github.com/jmoiron/sqlx v1.2.1-0.20200324155115-ee514944af4b

go.sum

@@ -207,8 +207,8 @@ github.com/fatih/color v1.9.0/go.mod h1:eQcE1qtQxscV5RaZvpXrrb8Drkc3/DdQ+uUYCNjL
 github.com/fatih/color v1.13.0/go.mod h1:kLAiJbzzSOZDVNGyDpeOxJ47H46qBXwg5ILebYFFOfk=
 github.com/felixge/httpsnoop v1.0.1 h1:lvB5Jl89CsZtGIWuTcDM1E/vkVs49/Ml7JJe07l8SPQ=
 github.com/felixge/httpsnoop v1.0.1/go.mod h1:m8KPJKqk1gH5J9DgRY2ASl2lWCfGKXixSwevea8zH2U=
-github.com/forbole/juno/v2 v2.0.0-20211206070432-9314a5057955 h1:a8XH7gpsjUgmXjPkeU2C1b3yRppPxc8nVKWqK4vXAGI=
-github.com/forbole/juno/v2 v2.0.0-20211206070432-9314a5057955/go.mod h1:nOZEHr5+sZDXEDpV2E+NHkmH0Zvf4prkt5+UVKwScQ8=
+github.com/forbole/juno/v2 v2.0.0-20211213105313-d167239d2dad h1:0rhtVBf124+gEd7lZtohkR5FshoJgnldaVswpeHftDI=
+github.com/forbole/juno/v2 v2.0.0-20211213105313-d167239d2dad/go.mod h1:nOZEHr5+sZDXEDpV2E+NHkmH0Zvf4prkt5+UVKwScQ8=
 github.com/forbole/tendermint v0.34.13-0.20210820072129-a2a4af55563d h1:pUqGUgTUU24ibHeloQeg1F2pFbgQllddsuZ+x+CcUzw=
 github.com/forbole/tendermint v0.34.13-0.20210820072129-a2a4af55563d/go.mod h1:aeHL7alPh4uTBIJQ8mgFEE8VwJLXI1VD3rVOmH2Mcy0=
 github.com/fortytw2/leaktest v1.3.0 h1:u8491cBMTQ8ft8aeV+adlcytMZylmA5nnwwkRZjI8vw=

modules/registrar.go

@@ -107,11 +107,13 @@ func (r *Registrar) BuildModules(ctx registrar.Context) jmodules.Modules {
 
 	authModule := auth.NewModule(r.parser, cdc, db)
 	bankModule := bank.NewModule(r.parser, sources.BankSource, cdc, db)
+	consensusModule := consensus.NewModule(db)
 	distrModule := distribution.NewModule(ctx.JunoConfig, sources.DistrSource, bankModule, cdc, db)
 	historyModule := history.NewModule(ctx.JunoConfig.Chain, r.parser, cdc, db)
 	mintModule := mint.NewModule(sources.MintSource, cdc, db)
 	slashingModule := slashing.NewModule(sources.SlashingSource, nil, cdc, db)
 	stakingModule := staking.NewModule(sources.StakingSource, bankModule, distrModule, historyModule, slashingModule, cdc, db)
+	govModule := gov.NewModule(sources.GovSource, authModule, bankModule, distrModule, mintModule, slashingModule, stakingModule, cdc, db)
 
 	return []jmodules.Module{
 		messages.NewModule(r.parser, cdc, ctx.Database),
@@ -120,9 +122,9 @@ func (r *Registrar) BuildModules(ctx registrar.Context) jmodules.Modules {
 
 		authModule,
 		bankModule,
-		consensus.NewModule(db),
+		consensusModule,
 		distrModule,
-		gov.NewModule(sources.GovSource, authModule, bankModule, distrModule, mintModule, slashingModule, stakingModule, cdc, db),
+		govModule,
 		historyModule,
 		mint.NewModule(sources.MintSource, cdc, db),
 		modules.NewModule(ctx.JunoConfig.Chain, db),

modules/staking/utils_delegations.go

@@ -3,9 +3,8 @@ package staking
 import (
 	"fmt"
 
-	"google.golang.org/grpc/codes"
-
 	stakingtypes "github.com/cosmos/cosmos-sdk/x/staking/types"
+	"google.golang.org/grpc/codes"
 
 	"github.com/forbole/bdjuno/v2/types"
 )