plugeth/eth/ethconfig/plugin_hooks.go

60 lines
2.2 KiB
Go
Raw Normal View History

2023-03-24 00:03:08 +00:00
package ethconfig
import (
"github.com/ethereum/go-ethereum/log"
// "github.com/ethereum/go-ethereum/node"
"github.com/ethereum/go-ethereum/plugins"
// "github.com/ethereum/go-ethereum/plugins/wrappers"
// "github.com/ethereum/go-ethereum/rpc"
2023-03-24 04:59:14 +00:00
"github.com/openrelayxyz/plugeth-utils/core"
"github.com/openrelayxyz/plugeth-utils/restricted"
2023-03-24 00:03:08 +00:00
// "github.com/ethereum/go-ethereum/common"
"github.com/ethereum/go-ethereum/consensus"
// "github.com/ethereum/go-ethereum/consensus/beacon"
// "github.com/ethereum/go-ethereum/consensus/clique"
// "github.com/ethereum/go-ethereum/consensus/ethash"
// "github.com/ethereum/go-ethereum/core"
// "github.com/ethereum/go-ethereum/core/txpool"
// "github.com/ethereum/go-ethereum/eth/downloader"
// "github.com/ethereum/go-ethereum/eth/gasprice"
"github.com/ethereum/go-ethereum/ethdb"
// "github.com/ethereum/go-ethereum/log"
// "github.com/ethereum/go-ethereum/miner"
"github.com/ethereum/go-ethereum/node"
// "github.com/ethereum/go-ethereum/params"
pconsensus "github.com/openrelayxyz/plugeth-utils/restricted/consensus"
pparams "github.com/openrelayxyz/plugeth-utils/restricted/params"
)
// stack *node.Node, ethashConfig *ethash.Config, cliqueConfig *params.CliqueConfig, notify []string, noverify bool, db ethdb.Database) consensus.Engine
2023-03-24 04:59:14 +00:00
func engineTranslate(engine pconsensus.Engine) consensus.Engine {
result consensus.Engine{
}
return result
}
2023-03-24 00:03:08 +00:00
func PluginGetEngine(pl *plugins.PluginLoader, stack *node.Node, notify []string, noverify bool, db ethdb.Database) consensus.Engine {
2023-03-24 04:59:14 +00:00
fnList := pl.Lookup("CreateEngine", func(item interface{}) bool {
_, ok := item.(func(*core.Node, []string, bool, restricted.Database) pconsensus.Engine)
2023-03-24 00:03:08 +00:00
return ok
})
for _, fni := range fnList {
2023-03-24 04:59:14 +00:00
if fn, ok := fni.(func(*core.Node, []string, bool, restircted.Database)); ok {
engine := fn(wrappers.NewNode(stack), notify, noverify, db) // modify
2023-03-24 00:03:08 +00:00
}
}
2023-03-24 04:59:14 +00:00
return engineTranslate(engine)
2023-03-24 00:03:08 +00:00
}
func pluginGetEngine(stack *node.Node, notify []string, noverify bool, db ethdb.Database) consensus.Engine {
if plugins.DefaultPluginLoader == nil {
log.Warn("Attempting GetEngine, but default PluginLoader has not been initialized")
return nil
}
return PluginGetEngine(plugins.DefaultPluginLoader, stack, notify, noverify, db)
}