feat: firehose live tracer

cmd/state/commands/opcode_tracer.go

@@ -398,7 +398,7 @@ func (ot *opcodeTracer) OnBlockStart(b *types.Block, td *big.Int, finalized, saf
 func (ot *opcodeTracer) OnBlockEnd(err error) {
 }
 
-func (ot *opcodeTracer) OnGenesisBlock(b *types.Block, alloc types.GenesisAlloc) {
+func (ot *opcodeTracer) OnGenesisBlock(b *types.Block, alloc types.GenesisAlloc, chainConfig *chain2.Config) {
 }
 
 func (ot *opcodeTracer) OnBeaconBlockRootStart(root libcommon.Hash) {}
@@ -422,6 +422,8 @@ func (ot *opcodeTracer) OnStorageChange(a libcommon.Address, k *libcommon.Hash,
 
 func (ot *opcodeTracer) OnLog(log *types.Log) {}
 
+func (ot *opcodeTracer) OnNewAccount(a libcommon.Address) {}
+
 // GetResult returns an empty json object.
 func (ot *opcodeTracer) GetResult() (json.RawMessage, error) {
 	return json.RawMessage(`{}`), nil

cmd/state/exec3/calltracer_v3.go

@@ -59,7 +59,7 @@ func (ct *CallTracer) OnBlockStart(b *types.Block, td *big.Int, finalized, safe
 func (ct *CallTracer) OnBlockEnd(err error) {
 }
 
-func (ct *CallTracer) OnGenesisBlock(b *types.Block, alloc types.GenesisAlloc) {
+func (ct *CallTracer) OnGenesisBlock(b *types.Block, alloc types.GenesisAlloc, chainConfig *chain.Config) {
 }
 
 func (ct *CallTracer) OnBeaconBlockRootStart(root libcommon.Hash) {}
@@ -83,6 +83,8 @@ func (ct *CallTracer) OnStorageChange(a libcommon.Address, k *libcommon.Hash, pr
 
 func (ct *CallTracer) OnLog(log *types.Log) {}
 
+func (ct *CallTracer) OnNewAccount(a libcommon.Address) {}
+
 // GetResult returns an empty json object.
 func (ct *CallTracer) GetResult() (json.RawMessage, error) {
 	return json.RawMessage(`{}`), nil

core/blockchain.go

@@ -66,7 +66,7 @@ type BlockchainLogger interface {
 	// `td` is the total difficulty prior to `block`.
 	OnBlockStart(block *types.Block, td *big.Int, finalized *types.Header, safe *types.Header, chainConfig *chain.Config)
 	OnBlockEnd(err error)
-	OnGenesisBlock(genesis *types.Block, alloc types.GenesisAlloc)
+	OnGenesisBlock(genesis *types.Block, alloc types.GenesisAlloc, chainConfig *chain.Config)
 }
 
 type RejectedTx struct {

core/genesis_write.go

@@ -288,7 +288,7 @@ func write(tx kv.RwTx, g *types.Genesis, tmpDir string, logger log.Logger, bcLog
 	}
 
 	if bcLogger != nil {
-		bcLogger.OnGenesisBlock(block, g.Alloc)
+		bcLogger.OnGenesisBlock(block, g.Alloc, config)
 	}
 
 	// We support ethash/merge for issuance (for now)

core/state/intra_block_state.go

@@ -50,6 +50,7 @@ type StateLogger interface {
 	OnNonceChange(addr libcommon.Address, prev, new uint64)
 	OnCodeChange(addr libcommon.Address, prevCodeHash libcommon.Hash, prevCode []byte, codeHash libcommon.Hash, code []byte)
 	OnStorageChange(addr libcommon.Address, slot *libcommon.Hash, prev, new uint256.Int)
+	OnNewAccount(addr libcommon.Address)
 	OnLog(log *types.Log)
 }
 
@@ -564,6 +565,10 @@ func (sdb *IntraBlockState) createObject(addr libcommon.Address, previous *state
 		sdb.journal.append(resetObjectChange{account: &addr, prev: previous})
 	}
 
+	if sdb.logger != nil {
+		sdb.logger.OnNewAccount(addr)
+	}
+
 	newobj.newlyCreated = true
 	sdb.setStateObject(addr, newobj)
 	return newobj

eth/calltracer/calltracer.go

@@ -67,7 +67,8 @@ func (ct *CallTracer) OnBlockStart(b *types.Block, td *big.Int, finalized, safe
 
 func (ct *CallTracer) OnBlockEnd(err error) {}
 
-func (ct *CallTracer) OnGenesisBlock(b *types.Block, alloc types.GenesisAlloc) {}
+func (ct *CallTracer) OnGenesisBlock(b *types.Block, alloc types.GenesisAlloc, chainConfig *chain.Config) {
+}
 
 func (ct *CallTracer) OnBeaconBlockRootStart(root libcommon.Hash) {}
 
@@ -90,6 +91,8 @@ func (ct *CallTracer) OnStorageChange(addr libcommon.Address, k *libcommon.Hash,
 
 func (ct *CallTracer) OnLog(log *types.Log) {}
 
+func (ct *CallTracer) OnNewAccount(a libcommon.Address) {}
+
 func (ct *CallTracer) CaptureExit(output []byte, usedGas uint64, err error, reverted bool) {
 }