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: