forked from cerc-io/plugeth
99 lines
3.5 KiB
Go
99 lines
3.5 KiB
Go
package core
|
|
|
|
import (
|
|
"github.com/ethereum/go-ethereum/core/types"
|
|
"github.com/ethereum/go-ethereum/plugins"
|
|
"github.com/ethereum/go-ethereum/log"
|
|
)
|
|
|
|
func PluginPreProcessBlock(pl *plugins.PluginLoader, block *types.Block) {
|
|
fnList := pl.Lookup("ProcessBlock", func(item interface{}) bool {
|
|
_, ok := item.(func(*types.Block))
|
|
return ok
|
|
})
|
|
for _, fni := range fnList {
|
|
if fn, ok := fni.(func(*types.Block)); ok {
|
|
fn(block)
|
|
}
|
|
}
|
|
}
|
|
func pluginPreProcessBlock(block *types.Block) {
|
|
if plugins.DefaultPluginLoader == nil {
|
|
log.Warn("Attempting PreProcessBlock, but default PluginLoader has not been initialized")
|
|
return
|
|
}
|
|
PluginPreProcessBlock(plugins.DefaultPluginLoader, block) // TODO
|
|
}
|
|
func PluginPreProcessTransaction(pl *plugins.PluginLoader, tx *types.Transaction, block *types.Block, i int) {
|
|
fnList := pl.Lookup("ProcessTransaction", func(item interface{}) bool {
|
|
_, ok := item.(func(*types.Transaction, *types.Block, int))
|
|
return ok
|
|
})
|
|
for _, fni := range fnList {
|
|
if fn, ok := fni.(func(*types.Transaction, *types.Block, int)); ok {
|
|
fn(tx, block, i)
|
|
}
|
|
}
|
|
}
|
|
func pluginPreProcessTransaction(tx *types.Transaction, block *types.Block, i int) {
|
|
if plugins.DefaultPluginLoader == nil {
|
|
log.Warn("Attempting PreProcessTransaction, but default PluginLoader has not been initialized")
|
|
return
|
|
}
|
|
PluginPreProcessTransaction(plugins.DefaultPluginLoader, tx, block, i)
|
|
}
|
|
func PluginBlockProcessingError(pl *plugins.PluginLoader, tx *types.Transaction, block *types.Block, err error) {
|
|
fnList := pl.Lookup("ProcessingError", func(item interface{}) bool {
|
|
_, ok := item.(func(*types.Transaction, *types.Block, error))
|
|
return ok
|
|
})
|
|
for _, fni := range fnList {
|
|
if fn, ok := fni.(func(*types.Transaction, *types.Block, error)); ok {
|
|
fn(tx, block, err)
|
|
}
|
|
}
|
|
}
|
|
func pluginBlockProcessingError(tx *types.Transaction, block *types.Block, err error) {
|
|
if plugins.DefaultPluginLoader == nil {
|
|
log.Warn("Attempting BlockProcessingError, but default PluginLoader has not been initialized")
|
|
return
|
|
}
|
|
PluginBlockProcessingError(plugins.DefaultPluginLoader, tx, block, err)
|
|
}
|
|
func PluginPostProcessTransaction(pl *plugins.PluginLoader, tx *types.Transaction, block *types.Block, i int, receipt *types.Receipt) {
|
|
fnList := pl.Lookup("ProcessTransaction", func(item interface{}) bool {
|
|
_, ok := item.(func(*types.Transaction, *types.Block, int, *types.Receipt))
|
|
return ok
|
|
})
|
|
for _, fni := range fnList {
|
|
if fn, ok := fni.(func(*types.Transaction, *types.Block, int, *types.Receipt)); ok {
|
|
fn(tx, block, i, receipt)
|
|
}
|
|
}
|
|
}
|
|
func pluginPostProcessTransaction(tx *types.Transaction, block *types.Block, i int, receipt *types.Receipt) {
|
|
if plugins.DefaultPluginLoader == nil {
|
|
log.Warn("Attempting PostProcessTransaction, but default PluginLoader has not been initialized")
|
|
return
|
|
}
|
|
PluginPostProcessTransaction(plugins.DefaultPluginLoader, tx, block, i, receipt)
|
|
}
|
|
func PluginPostProcessBlock(pl *plugins.PluginLoader, block *types.Block) {
|
|
fnList := pl.Lookup("ProcessBlock", func(item interface{}) bool {
|
|
_, ok := item.(func(*types.Block))
|
|
return ok
|
|
})
|
|
for _, fni := range fnList {
|
|
if fn, ok := fni.(func(*types.Block)); ok {
|
|
fn(block)
|
|
}
|
|
}
|
|
}
|
|
func pluginPostProcessBlock(block *types.Block) {
|
|
if plugins.DefaultPluginLoader == nil {
|
|
log.Warn("Attempting PostProcessBlock, but default PluginLoader has not been initialized")
|
|
return
|
|
}
|
|
PluginPostProcessBlock(plugins.DefaultPluginLoader, block)
|
|
}
|