waku-org
/
nwaku
mirror of https://github.com/waku-org/nwaku.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

refactor(libwaku): allow several multiaddresses for a single peer in store queries (#3171) 

* fix: parameter name
* refactor: allow multiple addresses for a peer in a store query
This commit is contained in:
richΛrd 2024-11-08 14:36:16 +07:00 committed by GitHub
parent 8fde70937d
commit 3cb8ebdd8f
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
library/libwaku.nim
View File

@ -710,7 +710,7 @@ proc waku_peer_exchange_request(
proc waku_ping_peer( proc waku_ping_peer(
ctx: ptr WakuContext, ctx: ptr WakuContext,
peerID: cstring, peerAddr: cstring,
timeoutMs: cuint, timeoutMs: cuint,
callback: WakuCallBack, callback: WakuCallBack,
userData: pointer, userData: pointer,
@ -721,7 +721,7 @@ proc waku_ping_peer(
.sendRequestToWakuThread( .sendRequestToWakuThread(
ctx, ctx,
RequestType.PING, RequestType.PING,
PingRequest.createShared(peerID, chronos.milliseconds(timeoutMs)), PingRequest.createShared(peerAddr, chronos.milliseconds(timeoutMs)),
) )
.handleRes(callback, userData) .handleRes(callback, userData)

4
library/waku_thread/inter_thread_communication/requests/protocols/store_request.nim
View File

@ -1,4 +1,4 @@
import std/[json, sugar, options] import std/[json, sugar, strutils, options]
import chronos, chronicles, results import chronos, chronicles, results
import import
../../../../../waku/factory/waku, ../../../../../waku/factory/waku,
@ -125,7 +125,7 @@ proc process(
let storeQueryRequest = JsonStoreQueryRequest.fromJsonNode(jsonContentRes.get()) let storeQueryRequest = JsonStoreQueryRequest.fromJsonNode(jsonContentRes.get())
let peer = peers.parsePeerInfo($self[].peerAddr).valueOr: let peer = peers.parsePeerInfo(($self[].peerAddr).split(",")).valueOr:
return err("JsonStoreQueryRequest failed to parse peer addr: " & $error) return err("JsonStoreQueryRequest failed to parse peer addr: " & $error)
let queryResponse = (await waku.node.wakuStoreClient.query(storeQueryRequest, peer)).valueOr: let queryResponse = (await waku.node.wakuStoreClient.query(storeQueryRequest, peer)).valueOr: