From 63cfd0ef9198450dfb612269d59eb1fe348f2884 Mon Sep 17 00:00:00 2001 From: Roy Crihfield Date: Tue, 23 Apr 2024 18:23:30 +0800 Subject: [PATCH] rm unused - this is in plugeth-statediff now anyway --- pkg/eth/test_helpers/chain_indexer.go | 84 --------------------------- 1 file changed, 84 deletions(-) delete mode 100644 pkg/eth/test_helpers/chain_indexer.go diff --git a/pkg/eth/test_helpers/chain_indexer.go b/pkg/eth/test_helpers/chain_indexer.go deleted file mode 100644 index 986a5c4e..00000000 --- a/pkg/eth/test_helpers/chain_indexer.go +++ /dev/null @@ -1,84 +0,0 @@ -package test_helpers - -import ( - "context" - "math/big" - - "github.com/cerc-io/plugeth-statediff" - "github.com/cerc-io/plugeth-statediff/adapt" - "github.com/ethereum/go-ethereum/common" - "github.com/ethereum/go-ethereum/core/state" - "github.com/ethereum/go-ethereum/core/types" - "github.com/ethereum/go-ethereum/params" - - "github.com/cerc-io/ipld-eth-server/v5/pkg/shared" -) - -type IndexChainParams struct { - Blocks []*types.Block - Receipts []types.Receipts - StateCache state.Database - ChainConfig *params.ChainConfig - - StateDiffParams statediff.Params - TotalDifficulty *big.Int - // Whether to skip indexing state nodes (state_cids, storage_cids) - SkipStateNodes bool - // Whether to skip indexing IPLD blocks - SkipIPLDs bool -} - -func IndexChain(params IndexChainParams) error { - indexer := shared.SetupTestStateDiffIndexer(context.Background(), params.ChainConfig, Genesis.Hash()) - builder := statediff.NewBuilder(adapt.GethStateView(params.StateCache)) - // iterate over the blocks, generating statediff payloads, and transforming the data into Postgres - for i, block := range params.Blocks { - var args statediff.Args - var rcts types.Receipts - if i == 0 { - args = statediff.Args{ - OldStateRoot: common.Hash{}, - NewStateRoot: block.Root(), - BlockNumber: block.Number(), - BlockHash: block.Hash(), - } - } else { - args = statediff.Args{ - OldStateRoot: params.Blocks[i-1].Root(), - NewStateRoot: block.Root(), - BlockNumber: block.Number(), - BlockHash: block.Hash(), - } - rcts = params.Receipts[i-1] - } - - diff, err := builder.BuildStateDiffObject(args, params.StateDiffParams) - if err != nil { - return err - } - tx, err := indexer.PushBlock(block, rcts, params.TotalDifficulty) - if err != nil { - return err - } - defer tx.RollbackOnFailure(err) - - if !params.SkipStateNodes { - for _, node := range diff.Nodes { - if err = indexer.PushStateNode(tx, node, block.Hash().String()); err != nil { - return err - } - } - } - if !params.SkipIPLDs { - for _, ipld := range diff.IPLDs { - if err := indexer.PushIPLD(tx, ipld); err != nil { - return err - } - } - } - if err = tx.Submit(); err != nil { - return err - } - } - return nil -}