mirror of
https://gitlab.com/pulsechaincom/erigon-pulse.git
synced 2024-12-25 13:07:17 +00:00
170 lines
4.3 KiB
Go
170 lines
4.3 KiB
Go
|
package api
|
||
|
|
||
|
import (
|
||
|
"fmt"
|
||
|
|
||
|
"github.com/ethereum/ethash"
|
||
|
"github.com/ethereum/go-ethereum/core/state"
|
||
|
"github.com/ethereum/go-ethereum/core/vm"
|
||
|
"github.com/ethereum/go-ethereum/eth"
|
||
|
"github.com/ethereum/go-ethereum/rlp"
|
||
|
"github.com/ethereum/go-ethereum/rpc/codec"
|
||
|
"github.com/ethereum/go-ethereum/rpc/shared"
|
||
|
"github.com/ethereum/go-ethereum/xeth"
|
||
|
)
|
||
|
|
||
|
const (
|
||
|
DebugVersion = "1.0.0"
|
||
|
)
|
||
|
|
||
|
var (
|
||
|
// mapping between methods and handlers
|
||
|
DebugMapping = map[string]debughandler{
|
||
|
"debug_dumpBlock": (*DebugApi).DumpBlock,
|
||
|
"debug_getBlockRlp": (*DebugApi).GetBlockRlp,
|
||
|
"debug_printBlock": (*DebugApi).PrintBlock,
|
||
|
"debug_processBlock": (*DebugApi).ProcessBlock,
|
||
|
"debug_seedHash": (*DebugApi).SeedHash,
|
||
|
"debug_setHead": (*DebugApi).SetHead,
|
||
|
}
|
||
|
)
|
||
|
|
||
|
// debug callback handler
|
||
|
type debughandler func(*DebugApi, *shared.Request) (interface{}, error)
|
||
|
|
||
|
// admin api provider
|
||
|
type DebugApi struct {
|
||
|
xeth *xeth.XEth
|
||
|
ethereum *eth.Ethereum
|
||
|
methods map[string]debughandler
|
||
|
codec codec.ApiCoder
|
||
|
}
|
||
|
|
||
|
// create a new debug api instance
|
||
|
func NewDebugApi(xeth *xeth.XEth, ethereum *eth.Ethereum, coder codec.Codec) *DebugApi {
|
||
|
return &DebugApi{
|
||
|
xeth: xeth,
|
||
|
ethereum: ethereum,
|
||
|
methods: DebugMapping,
|
||
|
codec: coder.New(nil),
|
||
|
}
|
||
|
}
|
||
|
|
||
|
// collection with supported methods
|
||
|
func (self *DebugApi) Methods() []string {
|
||
|
methods := make([]string, len(self.methods))
|
||
|
i := 0
|
||
|
for k := range self.methods {
|
||
|
methods[i] = k
|
||
|
i++
|
||
|
}
|
||
|
return methods
|
||
|
}
|
||
|
|
||
|
// Execute given request
|
||
|
func (self *DebugApi) Execute(req *shared.Request) (interface{}, error) {
|
||
|
if callback, ok := self.methods[req.Method]; ok {
|
||
|
return callback(self, req)
|
||
|
}
|
||
|
|
||
|
return nil, &shared.NotImplementedError{req.Method}
|
||
|
}
|
||
|
|
||
|
func (self *DebugApi) Name() string {
|
||
|
return DebugApiName
|
||
|
}
|
||
|
|
||
|
func (self *DebugApi) PrintBlock(req *shared.Request) (interface{}, error) {
|
||
|
args := new(BlockNumArg)
|
||
|
if err := self.codec.Decode(req.Params, &args); err != nil {
|
||
|
return nil, shared.NewDecodeParamError(err.Error())
|
||
|
}
|
||
|
|
||
|
block := self.xeth.EthBlockByNumber(args.BlockNumber)
|
||
|
return fmt.Sprintf("%s", block), nil
|
||
|
}
|
||
|
|
||
|
func (self *DebugApi) DumpBlock(req *shared.Request) (interface{}, error) {
|
||
|
args := new(BlockNumArg)
|
||
|
if err := self.codec.Decode(req.Params, &args); err != nil {
|
||
|
return nil, shared.NewDecodeParamError(err.Error())
|
||
|
}
|
||
|
|
||
|
block := self.xeth.EthBlockByNumber(args.BlockNumber)
|
||
|
if block == nil {
|
||
|
return nil, fmt.Errorf("block #%d not found", args.BlockNumber)
|
||
|
}
|
||
|
|
||
|
stateDb := state.New(block.Root(), self.ethereum.StateDb())
|
||
|
if stateDb == nil {
|
||
|
return nil, nil
|
||
|
}
|
||
|
|
||
|
return stateDb.Dump(), nil
|
||
|
}
|
||
|
|
||
|
func (self *DebugApi) GetBlockRlp(req *shared.Request) (interface{}, error) {
|
||
|
args := new(BlockNumArg)
|
||
|
if err := self.codec.Decode(req.Params, &args); err != nil {
|
||
|
return nil, shared.NewDecodeParamError(err.Error())
|
||
|
}
|
||
|
|
||
|
block := self.xeth.EthBlockByNumber(args.BlockNumber)
|
||
|
if block == nil {
|
||
|
return nil, fmt.Errorf("block #%d not found", args.BlockNumber)
|
||
|
}
|
||
|
encoded, err := rlp.EncodeToBytes(block)
|
||
|
return fmt.Sprintf("%x", encoded), err
|
||
|
}
|
||
|
|
||
|
func (self *DebugApi) SetHead(req *shared.Request) (interface{}, error) {
|
||
|
args := new(BlockNumArg)
|
||
|
if err := self.codec.Decode(req.Params, &args); err != nil {
|
||
|
return nil, shared.NewDecodeParamError(err.Error())
|
||
|
}
|
||
|
|
||
|
block := self.xeth.EthBlockByNumber(args.BlockNumber)
|
||
|
if block == nil {
|
||
|
return nil, fmt.Errorf("block #%d not found", args.BlockNumber)
|
||
|
}
|
||
|
|
||
|
self.ethereum.ChainManager().SetHead(block)
|
||
|
|
||
|
return nil, nil
|
||
|
}
|
||
|
|
||
|
func (self *DebugApi) ProcessBlock(req *shared.Request) (interface{}, error) {
|
||
|
args := new(BlockNumArg)
|
||
|
if err := self.codec.Decode(req.Params, &args); err != nil {
|
||
|
return nil, shared.NewDecodeParamError(err.Error())
|
||
|
}
|
||
|
|
||
|
block := self.xeth.EthBlockByNumber(args.BlockNumber)
|
||
|
if block == nil {
|
||
|
return nil, fmt.Errorf("block #%d not found", args.BlockNumber)
|
||
|
}
|
||
|
|
||
|
old := vm.Debug
|
||
|
defer func() { vm.Debug = old }()
|
||
|
vm.Debug = true
|
||
|
|
||
|
_, err := self.ethereum.BlockProcessor().RetryProcess(block)
|
||
|
if err == nil {
|
||
|
return true, nil
|
||
|
}
|
||
|
return false, err
|
||
|
}
|
||
|
|
||
|
func (self *DebugApi) SeedHash(req *shared.Request) (interface{}, error) {
|
||
|
args := new(BlockNumArg)
|
||
|
if err := self.codec.Decode(req.Params, &args); err != nil {
|
||
|
return nil, shared.NewDecodeParamError(err.Error())
|
||
|
}
|
||
|
|
||
|
if hash, err := ethash.GetSeedHash(uint64(args.BlockNumber)); err == nil {
|
||
|
return fmt.Sprintf("0x%x", hash), nil
|
||
|
} else {
|
||
|
return nil, err
|
||
|
}
|
||
|
}
|