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

Use WakuSubCodec

Browse Source
This commit is contained in:
Oskar Thoren 2020-05-18 13:28:54 +08:00
parent 8bd432ad33
commit 31a6d9a051
No known key found for this signature in database
GPG Key ID: B2ECCFD3BC2EF77E
1 changed files with 4 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
waku/node/v2/wakunode.nim
View File

@ -10,7 +10,8 @@ import
libp2p/crypto/crypto,
libp2p/protocols/protocol,
libp2p/peerinfo,
rpc/wakurpc
rpc/wakurpc,
../../protocol/v2/waku_protocol
# TODO: Use
# protocol/waku_protocol
@ -30,10 +31,6 @@ type WakuProto = ref object of LPProtocol
const clientId = "Nimbus waku node"
# TODO: We want this to be on top of GossipSub, how does that work?
# XXX: waku version not inherited from protocol
const WakuCodec = "/vac/waku/2.0.0-alpha0"
let globalListeningAddr = parseIpAddress("0.0.0.0")
proc setBootNodes(nodes: openArray[string]): seq[ENode] =
@ -59,7 +56,7 @@ proc dialPeer(p: WakuProto, address: string) {.async.} =
let remotePeer = PeerInfo.init(parts[^1], [multiAddr])
info "Dialing peer", multiAddr
p.conn = await p.switch.dial(remotePeer, WakuCodec)
p.conn = await p.switch.dial(remotePeer, WakuSubCodec)
# Isn't there just one p instance? Why connected here?
p.connected = true
@ -117,7 +114,7 @@ proc setupNat(conf: WakuNodeConf): tuple[ip: IpAddress,
(result.tcpPort, result.udpPort) = extPorts.get()
proc newWakuProto(switch: Switch): WakuProto =
var wakuproto = WakuProto(switch: switch, codec: WakuCodec)
var wakuproto = WakuProto(switch: switch, codec: WakuSubCodec)
proc handle(conn: Connection, proto: string) {.async, gcsafe.} =
let msg = cast[string](await conn.readLp())