Skip to content

Commit

Permalink
fix: Set record to the Waku Node Builder in the examples as it is r…
Browse files Browse the repository at this point in the history
…equired (#2328)
  • Loading branch information
EmilIvanichkovv authored Jan 5, 2024
1 parent 7b4f4bb commit 42ede93
Show file tree
Hide file tree
Showing 2 changed files with 22 additions and 2 deletions.
12 changes: 11 additions & 1 deletion examples/publisher.nim
Original file line number Diff line number Diff line change
Expand Up @@ -43,8 +43,18 @@ proc setupAndPublish(rng: ref HmacDrbgContext) {.async.} =
ip = parseIpAddress("0.0.0.0")
flags = CapabilitiesBitfield.init(lightpush = false, filter = false, store = false, relay = true)

var enrBuilder = EnrBuilder.init(nodeKey)

let recordRes = enrBuilder.build()
let record =
if recordRes.isErr():
error "failed to create enr record", error=recordRes.error
quit(QuitFailure)
else: recordRes.get()

var builder = WakuNodeBuilder.init()
builder.withNodeKey(nodeKey)
builder.withRecord(record)
builder.withNetworkConfigurationDetails(ip, Port(wakuPort)).tryGet()
let node = builder.build().tryGet()

Expand All @@ -62,7 +72,7 @@ proc setupAndPublish(rng: ref HmacDrbgContext) {.async.} =

# assumes behind a firewall, so not care about being discoverable
let wakuDiscv5 = WakuDiscoveryV5.new(
node.rng,
node.rng,
discv5Conf,
some(node.enr),
some(node.peerManager),
Expand Down
12 changes: 11 additions & 1 deletion examples/subscriber.nim
Original file line number Diff line number Diff line change
Expand Up @@ -38,8 +38,18 @@ proc setupAndSubscribe(rng: ref HmacDrbgContext) {.async.} =
ip = parseIpAddress("0.0.0.0")
flags = CapabilitiesBitfield.init(lightpush = false, filter = false, store = false, relay = true)

var enrBuilder = EnrBuilder.init(nodeKey)

let recordRes = enrBuilder.build()
let record =
if recordRes.isErr():
error "failed to create enr record", error=recordRes.error
quit(QuitFailure)
else: recordRes.get()

var builder = WakuNodeBuilder.init()
builder.withNodeKey(nodeKey)
builder.withRecord(record)
builder.withNetworkConfigurationDetails(ip, Port(wakuPort)).tryGet()
let node = builder.build().tryGet()

Expand All @@ -57,7 +67,7 @@ proc setupAndSubscribe(rng: ref HmacDrbgContext) {.async.} =

# assumes behind a firewall, so not care about being discoverable
let wakuDiscv5 = WakuDiscoveryV5.new(
node.rng,
node.rng,
discv5Conf,
some(node.enr),
some(node.peerManager),
Expand Down

0 comments on commit 42ede93

Please sign in to comment.