use PeerInfo in event handlers

This commit is contained in:
Dmitriy Ryajov 2021-08-27 11:01:44 -06:00
parent b049e54d9e
commit e2a6003ddd
No known key found for this signature in database
GPG Key ID: DA8C680CE7C657A4
2 changed files with 10 additions and 2 deletions

View File

@ -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:

View File

@ -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: