From 76606421a2f4a25af5674a89acbcecea1adbcafb Mon Sep 17 00:00:00 2001 From: gabrielmer <101006718+gabrielmer@users.noreply.github.com> Date: Thu, 24 Oct 2024 10:32:57 +0300 Subject: [PATCH] fix: peer exchange libwaku response handling (#3141) --- .../inter_thread_communication/requests/discovery_request.nim | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/library/waku_thread/inter_thread_communication/requests/discovery_request.nim b/library/waku_thread/inter_thread_communication/requests/discovery_request.nim index 1ccf8ff37..11733fe43 100644 --- a/library/waku_thread/inter_thread_communication/requests/discovery_request.nim +++ b/library/waku_thread/inter_thread_communication/requests/discovery_request.nim @@ -103,8 +103,9 @@ proc updateDiscv5BootstrapNodes(nodes: string, waku: ptr Waku): Result[void, str proc performPeerExchangeRequestTo( numPeers: uint64, waku: ptr Waku ): Future[Result[int, string]] {.async.} = - return (await waku.node.fetchPeerExchangePeers(numPeers)).isOkOr: + let numPeersRecv = (await waku.node.fetchPeerExchangePeers(numPeers)).valueOr: return err($error) + return ok(numPeersRecv) proc process*( self: ptr DiscoveryRequest, waku: ptr Waku