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

chore(REST): returning lightpush support and updated filter protocol (#2219)

This commit is contained in:
gabrielmer 2023-11-22 10:56:23 +02:00 committed by GitHub
parent c48accb513
commit 59ee3c69c8
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 19 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
waku/waku_api/rest/admin/handlers.nim
View File

@ -16,6 +16,8 @@ import
../../../waku_core, ../../../waku_core,
../../../waku_store, ../../../waku_store,
../../../waku_filter, ../../../waku_filter,
../../../waku_filter_v2,
../../../waku_lightpush,
../../../waku_relay, ../../../waku_relay,
../../../waku_node, ../../../waku_node,
../../../node/peer_manager, ../../../node/peer_manager,
@ -61,6 +63,14 @@ proc installAdminV1GetPeersHandler(router: var RestRouter, node: WakuNode) =
connected: it.connectedness == Connectedness.Connected)) connected: it.connectedness == Connectedness.Connected))
tuplesToWakuPeers(peers, filterPeers) tuplesToWakuPeers(peers, filterPeers)
if not node.wakuFilter.isNil():
# Map WakuFilter peers to WakuPeers and add to return list
let filterV2Peers = node.peerManager.peerStore.peers(WakuFilterSubscribeCodec)
.mapIt((multiaddr: constructMultiaddrStr(it),
protocol: WakuFilterSubscribeCodec,
connected: it.connectedness == Connectedness.Connected))
tuplesToWakuPeers(peers, filterV2Peers)
if not node.wakuStore.isNil(): if not node.wakuStore.isNil():
# Map WakuStore peers to WakuPeers and add to return list # Map WakuStore peers to WakuPeers and add to return list
let storePeers = node.peerManager.peerStore let storePeers = node.peerManager.peerStore
@ -70,6 +80,15 @@ proc installAdminV1GetPeersHandler(router: var RestRouter, node: WakuNode) =
connected: it.connectedness == Connectedness.Connected)) connected: it.connectedness == Connectedness.Connected))
tuplesToWakuPeers(peers, storePeers) tuplesToWakuPeers(peers, storePeers)
if not node.wakuLightPush.isNil():
# Map WakuStore peers to WakuPeers and add to return list
let lightpushPeers = node.peerManager.peerStore
.peers(WakuLightPushCodec)
.mapIt((multiaddr: constructMultiaddrStr(it),
protocol: WakuLightPushCodec,
connected: it.connectedness == Connectedness.Connected))
tuplesToWakuPeers(peers, lightpushPeers)
let resp = RestApiResponse.jsonResponse(peers, status=Http200) let resp = RestApiResponse.jsonResponse(peers, status=Http200)
if resp.isErr(): if resp.isErr():
error "An error ocurred while building the json respose: ", error=resp.error error "An error ocurred while building the json respose: ", error=resp.error