From e2a6003ddd9fd540e4485bbbc5e765050b10d670 Mon Sep 17 00:00:00 2001 From: Dmitriy Ryajov Date: Fri, 27 Aug 2021 11:01:44 -0600 Subject: [PATCH] use PeerInfo in event handlers --- dagger/bitswap.nim | 6 +++++- dagger/bitswap/network.nim | 6 +++++- 2 files changed, 10 insertions(+), 2 deletions(-) diff --git a/dagger/bitswap.nim b/dagger/bitswap.nim index 19766a70..e09529fe 100644 --- a/dagger/bitswap.nim +++ b/dagger/bitswap.nim @@ -133,7 +133,11 @@ proc new*( bool {.gcsafe} = b.taskQueue.pushOrUpdateNoWait(task).isOk() - proc peerEventHandler(peerId: PeerID, event: PeerEvent) {.async.} = + proc peerEventHandler(peerInfo: PeerInfo, event: PeerEvent) {.async.} = + # TODO: temporary until libp2p moves back to PeerID + let + peerId = peerInfo.peerId + if event.kind == PeerEventKind.Joined: b.engine.setupPeer(peerId) else: diff --git a/dagger/bitswap/network.nim b/dagger/bitswap/network.nim index 8774f3ca..4867748e 100644 --- a/dagger/bitswap/network.nim +++ b/dagger/bitswap/network.nim @@ -301,7 +301,11 @@ method init*(b: BitswapNetwork) = ## Perform protocol initialization ## - proc peerEventHandler(peerId: PeerID, event: PeerEvent) {.async.} = + proc peerEventHandler(peerInfo: PeerInfo, event: PeerEvent) {.async.} = + # TODO: temporary until libp2p moves back to PeerID + let + peerId = peerInfo.peerId + if event.kind == PeerEventKind.Joined: b.setupPeer(peerId) else: