mirror of
https://github.com/ethereum/go-ethereum.git
synced 2026-07-30 00:23:46 +00:00
Adding erc7562 tracer
This commit is contained in:
parent
9298074633
commit
c94a39c37e
2 changed files with 692 additions and 0 deletions
555
eth/tracers/native/erc7562.go
Normal file
555
eth/tracers/native/erc7562.go
Normal file
|
|
@ -0,0 +1,555 @@
|
|||
// Copyright 2021 The go-ethereum Authors
|
||||
// This file is part of the go-ethereum library.
|
||||
//
|
||||
// The go-ethereum library is free software: you can redistribute it and/or modify
|
||||
// it under the terms of the GNU Lesser General Public License as published by
|
||||
// the Free Software Foundation, either version 3 of the License, or
|
||||
// (at your option) any later version.
|
||||
//
|
||||
// The go-ethereum library is distributed in the hope that it will be useful,
|
||||
// but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||
// GNU Lesser General Public License for more details.
|
||||
//
|
||||
// You should have received a copy of the GNU Lesser General Public License
|
||||
// along with the go-ethereum library. If not, see <http://www.gnu.org/licenses/>.
|
||||
|
||||
package native
|
||||
|
||||
import (
|
||||
"encoding/json"
|
||||
"errors"
|
||||
"github.com/ethereum/go-ethereum/accounts/abi"
|
||||
"github.com/ethereum/go-ethereum/common"
|
||||
"github.com/ethereum/go-ethereum/common/hexutil"
|
||||
"github.com/ethereum/go-ethereum/core/tracing"
|
||||
"github.com/ethereum/go-ethereum/core/types"
|
||||
"github.com/ethereum/go-ethereum/core/vm"
|
||||
"github.com/ethereum/go-ethereum/eth/tracers"
|
||||
"github.com/ethereum/go-ethereum/log"
|
||||
"github.com/ethereum/go-ethereum/params"
|
||||
"github.com/holiman/uint256"
|
||||
"math/big"
|
||||
"runtime"
|
||||
"runtime/debug"
|
||||
"sync/atomic"
|
||||
)
|
||||
|
||||
//go:generate go run github.com/fjl/gencodec -type callFrameWithOpcodes -field-override callFrameWithOpcodesMarshaling -out gen_callframewithopcodes_json.go
|
||||
|
||||
func init() {
|
||||
tracers.DefaultDirectory.Register("erc7562Tracer", newErc7562Tracer, false)
|
||||
}
|
||||
|
||||
type contractSizeWithOpcode struct {
|
||||
ContractSize int `json:"contractSize"`
|
||||
Opcode vm.OpCode `json:"opcode"`
|
||||
}
|
||||
|
||||
type callFrameWithOpcodes struct {
|
||||
Type vm.OpCode `json:"-"`
|
||||
From common.Address `json:"from"`
|
||||
Gas uint64 `json:"gas"`
|
||||
GasUsed uint64 `json:"gasUsed"`
|
||||
To *common.Address `json:"to,omitempty" rlp:"optional"`
|
||||
Input []byte `json:"input" rlp:"optional"`
|
||||
Output []byte `json:"output,omitempty" rlp:"optional"`
|
||||
Error string `json:"error,omitempty" rlp:"optional"`
|
||||
RevertReason string `json:"revertReason,omitempty"`
|
||||
Logs []callLog `json:"logs,omitempty" rlp:"optional"`
|
||||
// Placed at end on purpose. The RLP will be decoded to 0 instead of
|
||||
// nil if there are non-empty elements after in the struct.
|
||||
Value *big.Int `json:"value,omitempty" rlp:"optional"`
|
||||
revertedSnapshot bool
|
||||
|
||||
AccessedSlots accessedSlots `json:"accessedSlots"`
|
||||
ExtCodeAccessInfo []common.Address `json:"extCodeAccessInfo"`
|
||||
UsedOpcodes map[vm.OpCode]uint64 `json:"usedOpcodes"`
|
||||
ContractSize map[common.Address]*contractSizeWithOpcode `json:"contractSize"`
|
||||
OutOfGas bool `json:"outOfGas"`
|
||||
Calls []callFrameWithOpcodes `json:"calls,omitempty" rlp:"optional"`
|
||||
}
|
||||
|
||||
func (f callFrameWithOpcodes) TypeString() string {
|
||||
return f.Type.String()
|
||||
}
|
||||
|
||||
func (f callFrameWithOpcodes) failed() bool {
|
||||
return len(f.Error) > 0 && f.revertedSnapshot
|
||||
}
|
||||
|
||||
func (f *callFrameWithOpcodes) processOutput(output []byte, err error, reverted bool) {
|
||||
output = common.CopyBytes(output)
|
||||
// Clear error if tx wasn't reverted. This happened
|
||||
// for pre-homestead contract storage OOG.
|
||||
if err != nil && !reverted {
|
||||
err = nil
|
||||
}
|
||||
if err == nil {
|
||||
f.Output = output
|
||||
return
|
||||
}
|
||||
f.Error = err.Error()
|
||||
f.revertedSnapshot = reverted
|
||||
if f.Type == vm.CREATE || f.Type == vm.CREATE2 {
|
||||
f.To = nil
|
||||
}
|
||||
if !errors.Is(err, vm.ErrExecutionReverted) || len(output) == 0 {
|
||||
return
|
||||
}
|
||||
f.Output = output
|
||||
if len(output) < 4 {
|
||||
return
|
||||
}
|
||||
if unpacked, err := abi.UnpackRevert(output); err == nil {
|
||||
f.RevertReason = unpacked
|
||||
}
|
||||
}
|
||||
|
||||
type callFrameWithOpcodesMarshaling struct {
|
||||
TypeString string `json:"type"`
|
||||
Gas hexutil.Uint64
|
||||
GasUsed hexutil.Uint64
|
||||
Value *hexutil.Big
|
||||
Input hexutil.Bytes
|
||||
Output hexutil.Bytes
|
||||
}
|
||||
|
||||
type accessedSlots struct {
|
||||
Reads map[string][]string `json:"reads"`
|
||||
Writes map[string]uint64 `json:"writes"`
|
||||
TransientReads map[string]uint64 `json:"transientReads"`
|
||||
TransientWrites map[string]uint64 `json:"transientWrites"`
|
||||
}
|
||||
|
||||
type opcodeWithPartialStack struct {
|
||||
Opcode vm.OpCode
|
||||
StackTopItems []uint256.Int
|
||||
}
|
||||
|
||||
type erc7562Tracer struct {
|
||||
config erc7562TracerConfig
|
||||
gasLimit uint64
|
||||
depth int
|
||||
interrupt atomic.Bool // Atomic flag to signal execution interruption
|
||||
reason error // Textual reason for the interruption
|
||||
env *tracing.VMContext
|
||||
|
||||
ignoredOpcodes map[vm.OpCode]struct{}
|
||||
callstackWithOpcodes []callFrameWithOpcodes
|
||||
lastOpWithStack *opcodeWithPartialStack
|
||||
Keccak map[string]struct{} `json:"keccak"`
|
||||
}
|
||||
|
||||
// catchPanic handles panic recovery and logs the panic and stack trace.
|
||||
func catchPanic() {
|
||||
if r := recover(); r != nil {
|
||||
// Retrieve the function name
|
||||
pc, _, _, _ := runtime.Caller(1)
|
||||
funcName := runtime.FuncForPC(pc).Name()
|
||||
|
||||
// Log the panic and function name
|
||||
log.Error("Panic in", funcName, r)
|
||||
debug.PrintStack()
|
||||
}
|
||||
}
|
||||
|
||||
// newErc7562Tracer returns a native go tracer which tracks
|
||||
// call frames of a tx, and implements vm.EVMLogger.
|
||||
func newErc7562Tracer(ctx *tracers.Context, cfg json.RawMessage, chainConfig *params.ChainConfig) (*tracers.Tracer, error) {
|
||||
t, err := newErc7562TracerObject(ctx, cfg)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return &tracers.Tracer{
|
||||
Hooks: &tracing.Hooks{
|
||||
OnTxStart: t.OnTxStart,
|
||||
OnOpcode: t.OnOpcode,
|
||||
OnTxEnd: t.OnTxEnd,
|
||||
OnEnter: t.OnEnter,
|
||||
OnExit: t.OnExit,
|
||||
OnLog: t.OnLog,
|
||||
},
|
||||
GetResult: t.GetResult,
|
||||
Stop: t.Stop,
|
||||
}, nil
|
||||
}
|
||||
|
||||
type erc7562TracerConfig struct {
|
||||
StackTopItemsSize int `json:"stackTopItemsSize"`
|
||||
IgnoredOpcodes map[vm.OpCode]struct{} `json:"ignoredOpcodes"` // Opcodes to ignore during OnOpcode hook execution
|
||||
WithLog bool `json:"withLog"` // If true, erc7562 tracer will collect event logs
|
||||
}
|
||||
|
||||
// Function to convert byte array to map[vm.OpCode]struct{}
|
||||
func ConvertBytesToOpCodes(byteArray []byte) map[vm.OpCode]struct{} {
|
||||
var opCodes map[vm.OpCode]struct{}
|
||||
for _, b := range byteArray {
|
||||
opCodes[vm.OpCode(b)] = struct{}{}
|
||||
}
|
||||
return opCodes
|
||||
}
|
||||
|
||||
func getFullConfiguration(partial erc7562TracerConfig) erc7562TracerConfig {
|
||||
config := partial
|
||||
|
||||
if config.IgnoredOpcodes == nil {
|
||||
config.IgnoredOpcodes = defaultIgnoredOpcodes()
|
||||
}
|
||||
if config.StackTopItemsSize == 0 {
|
||||
config.StackTopItemsSize = 3
|
||||
}
|
||||
|
||||
return config
|
||||
}
|
||||
|
||||
func newErc7562TracerObject(ctx *tracers.Context, cfg json.RawMessage) (*erc7562Tracer, error) {
|
||||
var config erc7562TracerConfig
|
||||
if cfg != nil {
|
||||
if err := json.Unmarshal(cfg, &config); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
}
|
||||
// First callframe contains tx context info
|
||||
// and is populated on start and end.
|
||||
return &erc7562Tracer{
|
||||
callstackWithOpcodes: make([]callFrameWithOpcodes, 0, 1),
|
||||
Keccak: make(map[string]struct{}),
|
||||
config: getFullConfiguration(config),
|
||||
}, nil
|
||||
}
|
||||
|
||||
func (t *erc7562Tracer) OnTxStart(env *tracing.VMContext, tx *types.Transaction, from common.Address) {
|
||||
defer catchPanic()
|
||||
t.env = env
|
||||
t.gasLimit = tx.Gas()
|
||||
}
|
||||
|
||||
// OnEnter is called when EVM enters a new scope (via call, create or selfdestruct).
|
||||
func (t *erc7562Tracer) OnEnter(depth int, typ byte, from common.Address, to common.Address, input []byte, gas uint64, value *big.Int) {
|
||||
defer catchPanic()
|
||||
t.depth = depth
|
||||
// Skip if tracing was interrupted
|
||||
if t.interrupt.Load() {
|
||||
return
|
||||
}
|
||||
|
||||
toCopy := to
|
||||
call := callFrameWithOpcodes{
|
||||
Type: vm.OpCode(typ),
|
||||
From: from,
|
||||
To: &toCopy,
|
||||
Input: common.CopyBytes(input),
|
||||
Gas: gas,
|
||||
Value: value,
|
||||
AccessedSlots: accessedSlots{
|
||||
Reads: map[string][]string{},
|
||||
Writes: map[string]uint64{},
|
||||
TransientReads: map[string]uint64{},
|
||||
TransientWrites: map[string]uint64{},
|
||||
},
|
||||
UsedOpcodes: map[vm.OpCode]uint64{},
|
||||
ExtCodeAccessInfo: make([]common.Address, 0),
|
||||
ContractSize: map[common.Address]*contractSizeWithOpcode{},
|
||||
}
|
||||
if depth == 0 {
|
||||
call.Gas = t.gasLimit
|
||||
}
|
||||
t.callstackWithOpcodes = append(t.callstackWithOpcodes, call)
|
||||
}
|
||||
|
||||
func (t *erc7562Tracer) captureEnd(output []byte, gasUsed uint64, err error, reverted bool) {
|
||||
if len(t.callstackWithOpcodes) != 1 {
|
||||
return
|
||||
}
|
||||
t.callstackWithOpcodes[0].processOutput(output, err, reverted)
|
||||
}
|
||||
|
||||
// OnExit is called when EVM exits a scope, even if the scope didn't
|
||||
// execute any code.
|
||||
func (t *erc7562Tracer) OnExit(depth int, output []byte, gasUsed uint64, err error, reverted bool) {
|
||||
defer catchPanic()
|
||||
if depth == 0 {
|
||||
t.captureEnd(output, gasUsed, err, reverted)
|
||||
return
|
||||
}
|
||||
|
||||
t.depth = depth - 1
|
||||
|
||||
size := len(t.callstackWithOpcodes)
|
||||
if size <= 1 {
|
||||
return
|
||||
}
|
||||
// Pop call.
|
||||
call := t.callstackWithOpcodes[size-1]
|
||||
t.callstackWithOpcodes = t.callstackWithOpcodes[:size-1]
|
||||
size -= 1
|
||||
|
||||
if errors.Is(err, vm.ErrCodeStoreOutOfGas) || errors.Is(err, vm.ErrOutOfGas) {
|
||||
call.OutOfGas = true
|
||||
}
|
||||
call.GasUsed = gasUsed
|
||||
call.processOutput(output, err, reverted)
|
||||
// Nest call into parent.
|
||||
t.callstackWithOpcodes[size-1].Calls = append(t.callstackWithOpcodes[size-1].Calls, call)
|
||||
}
|
||||
|
||||
func (t *erc7562Tracer) OnTxEnd(receipt *types.Receipt, err error) {
|
||||
defer catchPanic()
|
||||
// Error happened during tx validation.
|
||||
if err != nil {
|
||||
return
|
||||
}
|
||||
t.callstackWithOpcodes[0].GasUsed = receipt.GasUsed
|
||||
if t.config.WithLog {
|
||||
// Logs are not emitted when the call fails
|
||||
t.clearFailedLogs(&t.callstackWithOpcodes[0], false)
|
||||
}
|
||||
}
|
||||
|
||||
func (t *erc7562Tracer) OnLog(log1 *types.Log) {
|
||||
defer catchPanic()
|
||||
// Only logs need to be captured via opcode processing
|
||||
if !t.config.WithLog {
|
||||
return
|
||||
}
|
||||
// Skip if tracing was interrupted
|
||||
if t.interrupt.Load() {
|
||||
return
|
||||
}
|
||||
l := callLog{
|
||||
Address: log1.Address,
|
||||
Topics: log1.Topics,
|
||||
Data: log1.Data,
|
||||
Position: hexutil.Uint(len(t.callstackWithOpcodes[len(t.callstackWithOpcodes)-1].Calls)),
|
||||
}
|
||||
t.callstackWithOpcodes[len(t.callstackWithOpcodes)-1].Logs = append(t.callstackWithOpcodes[len(t.callstackWithOpcodes)-1].Logs, l)
|
||||
}
|
||||
|
||||
// GetResult returns the json-encoded nested list of call traces, and any
|
||||
// error arising from the encoding or forceful termination (via `Stop`).
|
||||
func (t *erc7562Tracer) GetResult() (json.RawMessage, error) {
|
||||
defer catchPanic()
|
||||
if len(t.callstackWithOpcodes) != 1 {
|
||||
return nil, errors.New("incorrect number of top-level calls")
|
||||
}
|
||||
|
||||
callFrameJSON, err := json.Marshal(t.callstackWithOpcodes[0])
|
||||
|
||||
// Unmarshal the generated JSON into a map
|
||||
var resultMap map[string]interface{}
|
||||
if err := json.Unmarshal(callFrameJSON, &resultMap); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
// Converting keccak mapping to array
|
||||
keccakArray := make([]hexutil.Bytes, len(t.Keccak))
|
||||
i := 0
|
||||
for k := range t.Keccak {
|
||||
keccakArray[i] = hexutil.Bytes(k)
|
||||
i++
|
||||
}
|
||||
resultMap["keccak"] = keccakArray
|
||||
|
||||
// Marshal the final map back to JSON
|
||||
finalJSON, err := json.Marshal(resultMap)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return finalJSON, t.reason
|
||||
}
|
||||
|
||||
// Stop terminates execution of the tracer at the first opportune moment.
|
||||
func (t *erc7562Tracer) Stop(err error) {
|
||||
defer catchPanic()
|
||||
t.reason = err
|
||||
t.interrupt.Store(true)
|
||||
}
|
||||
|
||||
// clearFailedLogs clears the logs of a callframe and all its children
|
||||
// in case of execution failure.
|
||||
func (t *erc7562Tracer) clearFailedLogs(cf *callFrameWithOpcodes, parentFailed bool) {
|
||||
failed := cf.failed() || parentFailed
|
||||
// Clear own logs
|
||||
if failed {
|
||||
cf.Logs = nil
|
||||
}
|
||||
for i := range cf.Calls {
|
||||
t.clearFailedLogs(&cf.Calls[i], failed)
|
||||
}
|
||||
}
|
||||
|
||||
func (t *erc7562Tracer) OnOpcode(pc uint64, op byte, gas, cost uint64, scope tracing.OpContext, rData []byte, depth int, err error) {
|
||||
defer catchPanic()
|
||||
opcode := vm.OpCode(op)
|
||||
var opcodeWithStack *opcodeWithPartialStack
|
||||
stackSize := len(scope.StackData())
|
||||
var stackTopItems []uint256.Int
|
||||
for i := 0; i < t.config.StackTopItemsSize && i < stackSize; i++ {
|
||||
stackTopItems = append(stackTopItems, *peepStack(scope.StackData(), i))
|
||||
}
|
||||
opcodeWithStack = &opcodeWithPartialStack{
|
||||
Opcode: opcode,
|
||||
StackTopItems: stackTopItems,
|
||||
}
|
||||
t.handleReturnRevert(opcode)
|
||||
size := len(t.callstackWithOpcodes)
|
||||
currentCallFrame := &t.callstackWithOpcodes[size-1]
|
||||
if t.lastOpWithStack != nil {
|
||||
t.handleExtOpcodes(opcode, currentCallFrame)
|
||||
}
|
||||
t.handleAccessedContractSize(opcode, scope, currentCallFrame)
|
||||
if t.lastOpWithStack != nil {
|
||||
t.handleGasObserved(opcode, currentCallFrame)
|
||||
}
|
||||
t.storeUsedOpcode(opcode, currentCallFrame)
|
||||
t.handleStorageAccess(opcode, scope, currentCallFrame)
|
||||
t.storeKeccak(opcode, scope)
|
||||
t.lastOpWithStack = opcodeWithStack
|
||||
}
|
||||
|
||||
func (t *erc7562Tracer) handleReturnRevert(opcode vm.OpCode) {
|
||||
if opcode == vm.REVERT || opcode == vm.RETURN {
|
||||
t.lastOpWithStack = nil
|
||||
}
|
||||
}
|
||||
|
||||
func (t *erc7562Tracer) handleGasObserved(opcode vm.OpCode, currentCallFrame *callFrameWithOpcodes) {
|
||||
// [OP-012]
|
||||
pendingGasObserved := t.lastOpWithStack.Opcode == vm.GAS && !isCall(opcode)
|
||||
if pendingGasObserved {
|
||||
incrementCount(currentCallFrame.UsedOpcodes, vm.GAS)
|
||||
}
|
||||
}
|
||||
|
||||
func (t *erc7562Tracer) storeUsedOpcode(opcode vm.OpCode, currentCallFrame *callFrameWithOpcodes) {
|
||||
// ignore "unimportant" opcodes
|
||||
if opcode != vm.GAS && !t.isIgnoredOpcode(opcode) {
|
||||
incrementCount(currentCallFrame.UsedOpcodes, opcode)
|
||||
}
|
||||
}
|
||||
|
||||
func (t *erc7562Tracer) handleStorageAccess(opcode vm.OpCode, scope tracing.OpContext, currentCallFrame *callFrameWithOpcodes) {
|
||||
if opcode == vm.SLOAD || opcode == vm.SSTORE || opcode == vm.TLOAD || opcode == vm.TSTORE {
|
||||
slot := common.BytesToHash(peepStack(scope.StackData(), 0).Bytes())
|
||||
slotHex := slot.Hex()
|
||||
addr := scope.Address()
|
||||
|
||||
if opcode == vm.SLOAD {
|
||||
// read slot values before this UserOp was created
|
||||
// (so saving it if it was written before the first read)
|
||||
_, rOk := currentCallFrame.AccessedSlots.Reads[slotHex]
|
||||
_, wOk := currentCallFrame.AccessedSlots.Writes[slotHex]
|
||||
if !rOk && !wOk {
|
||||
currentCallFrame.AccessedSlots.Reads[slotHex] = append(currentCallFrame.AccessedSlots.Reads[slotHex], t.env.StateDB.GetState(addr, slot).Hex())
|
||||
}
|
||||
} else if opcode == vm.SSTORE {
|
||||
incrementCount(currentCallFrame.AccessedSlots.Writes, slotHex)
|
||||
} else if opcode == vm.TLOAD {
|
||||
incrementCount(currentCallFrame.AccessedSlots.TransientReads, slotHex)
|
||||
} else {
|
||||
incrementCount(currentCallFrame.AccessedSlots.TransientWrites, slotHex)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
func (t *erc7562Tracer) storeKeccak(opcode vm.OpCode, scope tracing.OpContext) {
|
||||
if opcode == vm.KECCAK256 {
|
||||
dataOffset := peepStack(scope.StackData(), 0).Uint64()
|
||||
dataLength := peepStack(scope.StackData(), 1).Uint64()
|
||||
memory := scope.MemoryData()
|
||||
keccak := make([]byte, dataLength)
|
||||
copy(keccak, memory[dataOffset:dataOffset+dataLength])
|
||||
t.Keccak[string(keccak)] = struct{}{}
|
||||
}
|
||||
}
|
||||
|
||||
func (t *erc7562Tracer) handleExtOpcodes(opcode vm.OpCode, currentCallFrame *callFrameWithOpcodes) {
|
||||
if isEXT(t.lastOpWithStack.Opcode) {
|
||||
addr := common.HexToAddress(t.lastOpWithStack.StackTopItems[0].Hex())
|
||||
|
||||
// only store the last EXTCODE* opcode per address - could even be a boolean for our current use-case
|
||||
// [OP-051]
|
||||
|
||||
if !(t.lastOpWithStack.Opcode == vm.EXTCODESIZE && opcode == vm.ISZERO) {
|
||||
currentCallFrame.ExtCodeAccessInfo = append(currentCallFrame.ExtCodeAccessInfo, addr)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
func (t *erc7562Tracer) handleAccessedContractSize(opcode vm.OpCode, scope tracing.OpContext, currentCallFrame *callFrameWithOpcodes) {
|
||||
// [OP-041]
|
||||
if isEXTorCALL(opcode) {
|
||||
n := 0
|
||||
if !isEXT(opcode) {
|
||||
n = 1
|
||||
}
|
||||
addr := common.BytesToAddress(peepStack(scope.StackData(), n).Bytes())
|
||||
if _, ok := currentCallFrame.ContractSize[addr]; !ok && !isAllowedPrecompile(addr) {
|
||||
currentCallFrame.ContractSize[addr] = &contractSizeWithOpcode{
|
||||
ContractSize: len(t.env.StateDB.GetCode(addr)),
|
||||
Opcode: opcode,
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
func peepStack(stackData []uint256.Int, n int) *uint256.Int {
|
||||
return &stackData[len(stackData)-n-1]
|
||||
}
|
||||
|
||||
func isEXTorCALL(opcode vm.OpCode) bool {
|
||||
return isEXT(opcode) || isCall(opcode)
|
||||
}
|
||||
|
||||
func isEXT(opcode vm.OpCode) bool {
|
||||
return opcode == vm.EXTCODEHASH ||
|
||||
opcode == vm.EXTCODESIZE ||
|
||||
opcode == vm.EXTCODECOPY
|
||||
}
|
||||
|
||||
func isCall(opcode vm.OpCode) bool {
|
||||
return opcode == vm.CALL ||
|
||||
opcode == vm.CALLCODE ||
|
||||
opcode == vm.DELEGATECALL ||
|
||||
opcode == vm.STATICCALL
|
||||
}
|
||||
|
||||
// Check if this opcode is ignored for the purposes of generating the used opcodes report
|
||||
func (t *erc7562Tracer) isIgnoredOpcode(opcode vm.OpCode) bool {
|
||||
if _, ok := t.ignoredOpcodes[opcode]; ok {
|
||||
return true
|
||||
}
|
||||
return false
|
||||
}
|
||||
|
||||
func defaultIgnoredOpcodes() map[vm.OpCode]struct{} {
|
||||
ignored := make(map[vm.OpCode]struct{})
|
||||
|
||||
// Allow all PUSHx, DUPx and SWAPx opcodes as they have sequential codes
|
||||
for op := vm.PUSH0; op < vm.SWAP16; op++ {
|
||||
ignored[op] = struct{}{}
|
||||
}
|
||||
|
||||
for _, op := range []vm.OpCode{
|
||||
vm.POP, vm.ADD, vm.SUB, vm.MUL,
|
||||
vm.DIV, vm.EQ, vm.LT, vm.GT,
|
||||
vm.SLT, vm.SGT, vm.SHL, vm.SHR,
|
||||
vm.AND, vm.OR, vm.NOT, vm.ISZERO,
|
||||
} {
|
||||
ignored[op] = struct{}{}
|
||||
}
|
||||
|
||||
return ignored
|
||||
}
|
||||
|
||||
// not using 'isPrecompiled' to only allow the ones defined by the ERC-7562 as stateless precompiles
|
||||
// [OP-062]
|
||||
func isAllowedPrecompile(addr common.Address) bool {
|
||||
addrInt := addr.Big()
|
||||
return addrInt.Cmp(big.NewInt(0)) == 1 && addrInt.Cmp(big.NewInt(10)) == -1
|
||||
}
|
||||
|
||||
func incrementCount[K comparable](m map[K]uint64, k K) {
|
||||
m[k] = m[k] + 1
|
||||
}
|
||||
137
eth/tracers/native/gen_callframewithopcodes_json.go
Normal file
137
eth/tracers/native/gen_callframewithopcodes_json.go
Normal file
|
|
@ -0,0 +1,137 @@
|
|||
// Code generated by github.com/fjl/gencodec. DO NOT EDIT.
|
||||
|
||||
package native
|
||||
|
||||
import (
|
||||
"encoding/json"
|
||||
"math/big"
|
||||
|
||||
"github.com/ethereum/go-ethereum/common"
|
||||
"github.com/ethereum/go-ethereum/common/hexutil"
|
||||
"github.com/ethereum/go-ethereum/core/vm"
|
||||
)
|
||||
|
||||
var _ = (*callFrameWithOpcodesMarshaling)(nil)
|
||||
|
||||
// MarshalJSON marshals as JSON.
|
||||
func (c callFrameWithOpcodes) MarshalJSON() ([]byte, error) {
|
||||
type callFrameWithOpcodes0 struct {
|
||||
Type vm.OpCode `json:"-"`
|
||||
From common.Address `json:"from"`
|
||||
Gas hexutil.Uint64 `json:"gas"`
|
||||
GasUsed hexutil.Uint64 `json:"gasUsed"`
|
||||
To *common.Address `json:"to,omitempty" rlp:"optional"`
|
||||
Input hexutil.Bytes `json:"input" rlp:"optional"`
|
||||
Output hexutil.Bytes `json:"output,omitempty" rlp:"optional"`
|
||||
Error string `json:"error,omitempty" rlp:"optional"`
|
||||
RevertReason string `json:"revertReason,omitempty"`
|
||||
Logs []callLog `json:"logs,omitempty" rlp:"optional"`
|
||||
Value *hexutil.Big `json:"value,omitempty" rlp:"optional"`
|
||||
AccessedSlots accessedSlots `json:"accessedSlots"`
|
||||
ExtCodeAccessInfo []common.Address `json:"extCodeAccessInfo"`
|
||||
UsedOpcodes map[vm.OpCode]uint64 `json:"usedOpcodes"`
|
||||
ContractSize map[common.Address]*contractSizeWithOpcode `json:"contractSize"`
|
||||
OutOfGas bool `json:"outOfGas"`
|
||||
Calls []callFrameWithOpcodes `json:"calls,omitempty" rlp:"optional"`
|
||||
TypeString string `json:"type"`
|
||||
}
|
||||
var enc callFrameWithOpcodes0
|
||||
enc.Type = c.Type
|
||||
enc.From = c.From
|
||||
enc.Gas = hexutil.Uint64(c.Gas)
|
||||
enc.GasUsed = hexutil.Uint64(c.GasUsed)
|
||||
enc.To = c.To
|
||||
enc.Input = c.Input
|
||||
enc.Output = c.Output
|
||||
enc.Error = c.Error
|
||||
enc.RevertReason = c.RevertReason
|
||||
enc.Logs = c.Logs
|
||||
enc.Value = (*hexutil.Big)(c.Value)
|
||||
enc.AccessedSlots = c.AccessedSlots
|
||||
enc.ExtCodeAccessInfo = c.ExtCodeAccessInfo
|
||||
enc.UsedOpcodes = c.UsedOpcodes
|
||||
enc.ContractSize = c.ContractSize
|
||||
enc.OutOfGas = c.OutOfGas
|
||||
enc.Calls = c.Calls
|
||||
enc.TypeString = c.TypeString()
|
||||
return json.Marshal(&enc)
|
||||
}
|
||||
|
||||
// UnmarshalJSON unmarshals from JSON.
|
||||
func (c *callFrameWithOpcodes) UnmarshalJSON(input []byte) error {
|
||||
type callFrameWithOpcodes0 struct {
|
||||
Type *vm.OpCode `json:"-"`
|
||||
From *common.Address `json:"from"`
|
||||
Gas *hexutil.Uint64 `json:"gas"`
|
||||
GasUsed *hexutil.Uint64 `json:"gasUsed"`
|
||||
To *common.Address `json:"to,omitempty" rlp:"optional"`
|
||||
Input *hexutil.Bytes `json:"input" rlp:"optional"`
|
||||
Output *hexutil.Bytes `json:"output,omitempty" rlp:"optional"`
|
||||
Error *string `json:"error,omitempty" rlp:"optional"`
|
||||
RevertReason *string `json:"revertReason,omitempty"`
|
||||
Logs []callLog `json:"logs,omitempty" rlp:"optional"`
|
||||
Value *hexutil.Big `json:"value,omitempty" rlp:"optional"`
|
||||
AccessedSlots *accessedSlots `json:"accessedSlots"`
|
||||
ExtCodeAccessInfo []common.Address `json:"extCodeAccessInfo"`
|
||||
UsedOpcodes map[vm.OpCode]uint64 `json:"usedOpcodes"`
|
||||
ContractSize map[common.Address]*contractSizeWithOpcode `json:"contractSize"`
|
||||
OutOfGas *bool `json:"outOfGas"`
|
||||
Calls []callFrameWithOpcodes `json:"calls,omitempty" rlp:"optional"`
|
||||
}
|
||||
var dec callFrameWithOpcodes0
|
||||
if err := json.Unmarshal(input, &dec); err != nil {
|
||||
return err
|
||||
}
|
||||
if dec.Type != nil {
|
||||
c.Type = *dec.Type
|
||||
}
|
||||
if dec.From != nil {
|
||||
c.From = *dec.From
|
||||
}
|
||||
if dec.Gas != nil {
|
||||
c.Gas = uint64(*dec.Gas)
|
||||
}
|
||||
if dec.GasUsed != nil {
|
||||
c.GasUsed = uint64(*dec.GasUsed)
|
||||
}
|
||||
if dec.To != nil {
|
||||
c.To = dec.To
|
||||
}
|
||||
if dec.Input != nil {
|
||||
c.Input = *dec.Input
|
||||
}
|
||||
if dec.Output != nil {
|
||||
c.Output = *dec.Output
|
||||
}
|
||||
if dec.Error != nil {
|
||||
c.Error = *dec.Error
|
||||
}
|
||||
if dec.RevertReason != nil {
|
||||
c.RevertReason = *dec.RevertReason
|
||||
}
|
||||
if dec.Logs != nil {
|
||||
c.Logs = dec.Logs
|
||||
}
|
||||
if dec.Value != nil {
|
||||
c.Value = (*big.Int)(dec.Value)
|
||||
}
|
||||
if dec.AccessedSlots != nil {
|
||||
c.AccessedSlots = *dec.AccessedSlots
|
||||
}
|
||||
if dec.ExtCodeAccessInfo != nil {
|
||||
c.ExtCodeAccessInfo = dec.ExtCodeAccessInfo
|
||||
}
|
||||
if dec.UsedOpcodes != nil {
|
||||
c.UsedOpcodes = dec.UsedOpcodes
|
||||
}
|
||||
if dec.ContractSize != nil {
|
||||
c.ContractSize = dec.ContractSize
|
||||
}
|
||||
if dec.OutOfGas != nil {
|
||||
c.OutOfGas = *dec.OutOfGas
|
||||
}
|
||||
if dec.Calls != nil {
|
||||
c.Calls = dec.Calls
|
||||
}
|
||||
return nil
|
||||
}
|
||||
Loading…
Reference in a new issue