Improve performance of checker

dipdup-io · Oct 29, 2024 · d94937b · d94937b
1 parent 8339648
commit d94937b
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 69 deletions.
diff --git a/pkg/indexer/state.go b/pkg/indexer/state.go
@@ -4,7 +4,6 @@ import (
 	"sync"
 
 	"github.com/dipdup-io/starknet-indexer/internal/storage"
-	models "github.com/dipdup-io/starknet-indexer/internal/storage"
 )
 
 type state struct {
@@ -15,7 +14,7 @@ type state struct {
 
 func newState(s *storage.State) *state {
 	if s == nil {
-		s = new(models.State)
+		s = new(storage.State)
 	}
 	return &state{
 		state: s,

diff --git a/pkg/indexer/status_checker.go b/pkg/indexer/status_checker.go
@@ -144,76 +144,12 @@ func (checker *statusChecker) init(ctx context.Context) error {
 		end = limit != count
 
 		for i := range blocks {
-			if err := checker.addIndexedBlockToQueue(ctx, blocks[i]); err != nil {
-				return err
-			}
-		}
-	}
-
-	return nil
-}
-
-func (checker *statusChecker) addIndexedBlockToQueue(ctx context.Context, block storage.Block) error {
-	if block.InvokeCount > 0 {
-		hash, err := checker.invoke.HashByHeight(ctx, block.Height)
-		if err != nil {
-			return err
-		}
-		checker.acceptedOnL2.Push(acceptedOnL2{
-			TransactionHash: hash,
-			Height:          block.Height,
-		})
-		return nil
-	}
-	if block.DeployCount > 0 {
-		hash, err := checker.deploys.HashByHeight(ctx, block.Height)
-		if err != nil {
-			return err
-		}
-		checker.acceptedOnL2.Push(acceptedOnL2{
-			TransactionHash: hash,
-			Height:          block.Height,
-		})
-		return nil
-	}
-	if block.DeployAccountCount > 0 {
-		hash, err := checker.deployAccounts.HashByHeight(ctx, block.Height)
-		if err != nil {
-			return err
-		}
-		checker.acceptedOnL2.Push(acceptedOnL2{
-			TransactionHash: hash,
-			Height:          block.Height,
-		})
-		return nil
-	}
-	if block.DeclareCount > 0 {
-		hash, err := checker.declares.HashByHeight(ctx, block.Height)
-		if err != nil {
-			return err
-		}
-		checker.acceptedOnL2.Push(acceptedOnL2{
-			TransactionHash: hash,
-			Height:          block.Height,
-		})
-		return nil
-	}
-	if block.L1HandlerCount > 0 {
-		hash, err := checker.l1Handlers.HashByHeight(ctx, block.Height)
-		if err != nil {
-			return err
+			checker.acceptedOnL2.Push(acceptedOnL2{
+				Height: blocks[i].Height,
+			})
 		}
-		checker.acceptedOnL2.Push(acceptedOnL2{
-			TransactionHash: hash,
-			Height:          block.Height,
-		})
-		return nil
 	}
 
-	checker.acceptedOnL2.Push(acceptedOnL2{
-		Height: block.Height,
-	})
-
 	return nil
 }