[iip-15] sgd indexer to ignore block less than start height (#3873)

iotexproject · May 30, 2023 · e0b129f · CoderZhi · May 30, 2023 · e0b129f
1 parent 23645ff
commit e0b129f
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 2 deletions.
diff --git a/blockindex/contractstaking/dummy_indexer.go b/blockindex/contractstaking/dummy_indexer.go
@@ -35,6 +35,11 @@ func (d *dummyContractStakingIndexer) Stop(ctx context.Context) error {
 	return nil
 }
 
+// StartHeight returns the start height of the indexer
+func (d *dummyContractStakingIndexer) StartHeight() uint64 {
+	return 0
+}
+
 // Height returns the height of the indexer
 func (d *dummyContractStakingIndexer) Height() (uint64, error) {
 	return 0, nil

diff --git a/blockindex/contractstaking/indexer.go b/blockindex/contractstaking/indexer.go
@@ -26,7 +26,7 @@ const (
 type (
 	// ContractIndexer defines the interface of contract staking reader
 	ContractIndexer interface {
-		blockdao.BlockIndexer
+		blockdao.BlockIndexerWithStart
 
 		// CandidateVotes returns the total staked votes of a candidate
 		// candidate identified by owner address

diff --git a/blockindex/sgd_indexer.go b/blockindex/sgd_indexer.go
@@ -285,11 +285,14 @@ func (sgd *sgdRegistry) StartHeight() uint64 {
 
 // PutBlock puts a block into SGDIndexer
 func (sgd *sgdRegistry) PutBlock(ctx context.Context, blk *block.Block) error {
+	if blk.Height() < sgd.startHeight {
+		return nil
+	}
 	var (
 		r  *action.Receipt
 		ok bool
+		b  = batch.NewBatch()
 	)
-	b := batch.NewBatch()
 	receipts := getReceiptsFromBlock(blk)
 	for _, selp := range blk.Actions {
 		actHash, err := selp.Hash()