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

deploy: 544e94fecf24530b6c157c2c542d1338e6cd9199

Browse Source
This commit is contained in:
LNSD 2022-09-01 15:39:11 +00:00
parent 5ea9a83f6d
commit a9ee44c8aa
1 changed files with 13 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
waku/v2/node/wakunode2.nim
View File

@ -590,26 +590,32 @@ proc connectToNode(n: WakuNode, remotePeer: RemotePeerInfo, source = "api") {.as
error "Failed to connect to peer", wireAddr = remotePeer.addrs[0], peerId = remotePeer.peerId
waku_node_errors.inc(labelValues = ["conn_init_failure"])
proc setStorePeer*(n: WakuNode, peer: RemotePeerInfo) =
n.wakuStore.setPeer(peer)
proc setStorePeer*(n: WakuNode, address: string) {.raises: [Defect, ValueError, LPError].} =
info "Set store peer", address = address
let remotePeer = parseRemotePeerInfo(address)
let peer = parseRemotePeerInfo(address)
n.setStorePeer(peer)
n.wakuStore.setPeer(remotePeer)
proc setFilterPeer*(n: WakuNode, peer: RemotePeerInfo) =
n.wakuFilter.setPeer(peer)
proc setFilterPeer*(n: WakuNode, address: string) {.raises: [Defect, ValueError, LPError].} =
info "Set filter peer", address = address
let remotePeer = parseRemotePeerInfo(address)
let peer = parseRemotePeerInfo(address)
n.setFilterPeer(peer)
n.wakuFilter.setPeer(remotePeer)
proc setLightPushPeer*(n: WakuNode, peer: RemotePeerInfo) =
n.wakuLightPush.setPeer(peer)
proc setLightPushPeer*(n: WakuNode, address: string) {.raises: [Defect, ValueError, LPError].} =
info "Set lightpush peer", address = address
let remotePeer = parseRemotePeerInfo(address)
n.wakuLightPush.setPeer(remotePeer)
let peer = parseRemotePeerInfo(address)
n.wakuLightPush.setPeer(peer)
proc connectToNodes*(n: WakuNode, nodes: seq[string], source = "api") {.async.} =
## `source` indicates source of node addrs (static config, api call, discovery, etc)