Use network.reportPeer

ChainSafe · Feb 20, 2022 · fe7601f · fe7601f
1 parent a222e42
commit fe7601f
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 5 deletions.
diff --git a/packages/lodestar/src/network/gossip/handlers/index.ts b/packages/lodestar/src/network/gossip/handlers/index.ts
@@ -126,7 +126,7 @@ export function getGossipHandlers(modules: ValidatorFnsModules, options: GossipH
               case BlockErrorCode.EXECUTION_ENGINE_ERROR:
                 break;
               default:
-                network.peerRpcScores.applyAction(
+                network.reportPeer(
                   PeerId.createFromB58String(peerIdStr),
                   PeerAction.LowToleranceError,
                   "BadGossipBlock"

diff --git a/packages/lodestar/src/network/interface.ts b/packages/lodestar/src/network/interface.ts
@@ -8,7 +8,7 @@ import PeerId from "peer-id";
 import {INetworkEventBus} from "./events";
 import {Eth2Gossipsub} from "./gossip";
 import {MetadataController} from "./metadata";
-import {IPeerRpcScoreStore, IPeerMetadataStore, PeerAction} from "./peers";
+import {IPeerMetadataStore, PeerAction} from "./peers";
 import {IReqResp} from "./reqresp";
 import {IAttnetsService, ISubnetsService, CommitteeSubscription} from "./subnets";
 
@@ -25,7 +25,6 @@ export interface INetwork {
   gossip: Eth2Gossipsub;
   discv5?: Discv5;
   metadata: MetadataController;
-  peerRpcScores: IPeerRpcScoreStore;
   peerMetadata: IPeerMetadataStore;
   /** Our network identity */
   peerId: PeerId;

diff --git a/packages/lodestar/src/network/network.ts b/packages/lodestar/src/network/network.ts
@@ -46,7 +46,7 @@ export class Network implements INetwork {
   gossip: Eth2Gossipsub;
   metadata: MetadataController;
   peerMetadata: IPeerMetadataStore;
-  peerRpcScores: IPeerRpcScoreStore;
+  private readonly peerRpcScores: IPeerRpcScoreStore;
 
   private readonly peerManager: PeerManager;
   private readonly libp2p: LibP2p;

diff --git a/packages/lodestar/src/sync/unknownBlock.ts b/packages/lodestar/src/sync/unknownBlock.ts
@@ -284,7 +284,7 @@ export class UnknownBlockSync {
       for (const peerIdStr of block.peerIdStrs) {
         // TODO: Refactor peerRpcScores to work with peerIdStr only
         const peer = PeerId.createFromB58String(peerIdStr);
-        this.network.peerRpcScores.applyAction(peer, PeerAction.LowToleranceError, "BadBlockByRoot");
+        this.network.reportPeer(peer, PeerAction.LowToleranceError, "BadBlockByRoot");
       }
     }