Extract execution trace from EVM execution and provide subscription API

.gitignore

@@ -47,3 +47,6 @@ profile.cov
 /dashboard/assets/package-lock.json
 
 **/yarn-error.log
+
+# github
+.github

core/blockchain.go

@@ -1182,17 +1182,18 @@ func (bc *BlockChain) writeKnownBlock(block *types.Block) error {
 }
 
 // WriteBlockWithState writes the block and all associated state to the database.
-func (bc *BlockChain) WriteBlockWithState(block *types.Block, receipts []*types.Receipt, logs []*types.Log, state *state.StateDB, emitHeadEvent bool) (status WriteStatus, err error) {
+func (bc *BlockChain) WriteBlockWithState(block *types.Block, receipts []*types.Receipt, logs []*types.Log, evmTraces []*types.ExecutionResult, state *state.StateDB, emitHeadEvent bool) (status WriteStatus, err error) {
 	if !bc.chainmu.TryLock() {
 		return NonStatTy, errInsertionInterrupted
 	}
 	defer bc.chainmu.Unlock()
-	return bc.writeBlockWithState(block, receipts, logs, state, emitHeadEvent)
+	//rawdb.WriteEvmTraces(bc.db, block.Hash(), evmTraces)
+	return bc.writeBlockWithState(block, receipts, logs, evmTraces, state, emitHeadEvent)
 }
 
 // writeBlockWithState writes the block and all associated state to the database,
 // but is expects the chain mutex to be held.
-func (bc *BlockChain) writeBlockWithState(block *types.Block, receipts []*types.Receipt, logs []*types.Log, state *state.StateDB, emitHeadEvent bool) (status WriteStatus, err error) {
+func (bc *BlockChain) writeBlockWithState(block *types.Block, receipts []*types.Receipt, logs []*types.Log, evmTraces []*types.ExecutionResult, state *state.StateDB, emitHeadEvent bool) (status WriteStatus, err error) {
 	if bc.insertStopped() {
 		return NonStatTy, errInsertionInterrupted
 	}
@@ -1215,6 +1216,7 @@ func (bc *BlockChain) writeBlockWithState(block *types.Block, receipts []*types.
 	rawdb.WriteTd(blockBatch, block.Hash(), block.NumberU64(), externTd)
 	rawdb.WriteBlock(blockBatch, block)
 	rawdb.WriteReceipts(blockBatch, block.Hash(), block.NumberU64(), receipts)
+	rawdb.WriteEvmTraces(blockBatch, block.Hash(), evmTraces)
 	rawdb.WritePreimages(blockBatch, state.Preimages())
 	if err := blockBatch.Write(); err != nil {
 		log.Crit("Failed to write block into disk", "err", err)
@@ -1314,7 +1316,7 @@ func (bc *BlockChain) writeBlockWithState(block *types.Block, receipts []*types.
 	bc.futureBlocks.Remove(block.Hash())
 
 	if status == CanonStatTy {
-		bc.chainFeed.Send(ChainEvent{Block: block, Hash: block.Hash(), Logs: logs})
+		bc.chainFeed.Send(ChainEvent{Block: block, Hash: block.Hash(), Logs: logs, Traces: evmTraces})
 		if len(logs) > 0 {
 			bc.logsFeed.Send(logs)
 		}
@@ -1644,7 +1646,7 @@ func (bc *BlockChain) insertChain(chain types.Blocks, verifySeals bool) (int, er
 
 		// Write the block to the chain and get the status.
 		substart = time.Now()
-		status, err := bc.writeBlockWithState(block, receipts, logs, statedb, false)
+		status, err := bc.writeBlockWithState(block, receipts, logs, nil, statedb, false)
 		atomic.StoreUint32(&followupInterrupt, 1)
 		if err != nil {
 			return it.index, err

core/events.go

@@ -31,9 +31,10 @@ type NewMinedBlockEvent struct{ Block *types.Block }
 type RemovedLogsEvent struct{ Logs []*types.Log }
 
 type ChainEvent struct {
-	Block *types.Block
-	Hash  common.Hash
-	Logs  []*types.Log
+	Block  *types.Block
+	Hash   common.Hash
+	Logs   []*types.Log
+	Traces []*types.ExecutionResult
 }
 
 type ChainSideEvent struct {

core/rawdb/l2trace.go

@@ -0,0 +1,39 @@
+package rawdb
+
+import (
+	"github.com/scroll-tech/go-ethereum/common"
+	"github.com/scroll-tech/go-ethereum/core/types"
+	"github.com/scroll-tech/go-ethereum/ethdb"
+	"github.com/scroll-tech/go-ethereum/log"
+	"github.com/scroll-tech/go-ethereum/rlp"
+)
+
+// ReadEvmTraces retrieves all the evmTraces belonging to a block.
+func ReadEvmTraces(db ethdb.Reader, hash common.Hash) []*types.ExecutionResult {
+	data, _ := db.Get(evmTracesKey(hash))
+	if len(data) == 0 {
+		return nil
+	}
+	var evmTraces []*types.ExecutionResult
+	if err := rlp.DecodeBytes(data, &evmTraces); err != nil {
+		log.Error("Failed to decode evmTraces", "err", err)
+		return nil
+	}
+	return evmTraces
+}
+
+// WriteEvmTraces stores evmTrace list into leveldb.
+func WriteEvmTraces(db ethdb.KeyValueWriter, hash common.Hash, evmTraces []*types.ExecutionResult) {
+	bytes, err := rlp.EncodeToBytes(evmTraces)
+	if err != nil {
+		log.Crit("Failed to RLP encode evmTraces", "err", err)
+	}
+	db.Put(evmTracesKey(hash), bytes)
+}
+
+// DeleteEvmTraces removes all evmTraces with a block hash.
+func DeleteEvmTraces(db ethdb.KeyValueWriter, hash common.Hash) {
+	if err := db.Delete(evmTracesKey(hash)); err != nil {
+		log.Crit("Failed to delete evmTraces", "err", err)
+	}
+}