logos-messaging/logos-messaging-nim
1
0
Fork 0
mirror of https://github.com/logos-messaging/logos-messaging-nim.git synced 2026-01-03 22:43:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

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

Browse Source
This commit is contained in:
gabrielmer 2023-11-22 10:56:23 +02:00 committed by GitHub
parent 3236e29e07
commit d07d378bb1
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