peerEval

Author: Akohjesse

eth/downloader/queue.go

@@ -720,10 +720,6 @@ func (q *queue) DeliverHeaders(id string, headers []*types.Header, hashes []comm
 	q.lock.Lock()
 	defer q.lock.Unlock()
 
-	//begin PluGeth code injection
-	pluginPeerEval(id, headers, hashes)
-	//end PluGeth code injection
-
 	var logger log.Logger
 	if len(id) < 16 {
 		// Tests use short IDs, don't choke on them

eth/fetcher/block_fetcher.go

@@ -515,6 +515,7 @@ func (f *BlockFetcher) loop() {
 							select {
 							case res := <-resCh:
 								res.Done <- nil
+								pluginPeerEval(peer, *res.Res.(*eth.BlockHeadersRequest))
 								f.FilterHeaders(peer, *res.Res.(*eth.BlockHeadersRequest), time.Now(), announcedAt)
 
 							case <-timeout.C:

eth/downloader/xplugeth_hooks.go renamed to eth/fetcher/xplugeth_hooks.go

@@ -1,14 +1,13 @@
-package downloader
+package fetcher
 
 import (
-	"github.com/ethereum/go-ethereum/common"
 	"github.com/ethereum/go-ethereum/core/types"
 	"github.com/openrelayxyz/xplugeth"
 	"github.com/openrelayxyz/xplugeth/hooks/blockchain"
 )
 
-func pluginPeerEval(id string, headers []*types.Header, hashes []common.Hash) {
+func pluginPeerEval(id string, headers []*types.Header) {
 	for _, m := range xplugeth.GetModules[blockchain.PeerEvalPlugin]() {
-		m.PeerEval(id, headers, hashes)
+		m.PeerEval(id, headers)
 	}
 }