-
Notifications
You must be signed in to change notification settings - Fork 58
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
fix: make light client examples work with sandbox fleet (#3237)
- Loading branch information
1 parent
d391357
commit 48f04d8
Showing
2 changed files
with
169 additions
and
92 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,57 +1,107 @@ | ||
| ## Example showing how a resource restricted client may | ||
| ## use lightpush to publish messages without relay | ||
| import | ||
| std/[tables, times, sequtils], | ||
| stew/byteutils, | ||
| stew/shims/net, | ||
| chronicles, | ||
| results, | ||
| chronos, | ||
| confutils, | ||
| libp2p/crypto/crypto, | ||
| eth/keys, | ||
| eth/p2p/discoveryv5/enr | ||
|
|
||
| import chronicles, chronos, stew/byteutils, results | ||
| import waku/[common/logging, node/peer_manager, waku_core, waku_lightpush/client] | ||
| import | ||
| waku/[ | ||
| common/logging, | ||
| node/peer_manager, | ||
| waku_core, | ||
| waku_node, | ||
| waku_enr, | ||
| discovery/waku_discv5, | ||
| factory/builder, | ||
| ] | ||
|
|
||
| proc now*(): Timestamp = | ||
| getNanosecondTime(getTime().toUnixFloat()) | ||
|
|
||
| # careful if running pub and sub in the same machine | ||
| const wakuPort = 60000 | ||
|
|
||
| const clusterId = 1 | ||
| const shardId = @[0'u16] | ||
|
|
||
| const | ||
| LightpushPeer = | ||
| "/ip4/178.128.141.171/tcp/30303/p2p/16Uiu2HAkykgaECHswi3YKJ5dMLbq2kPVCo89fcyTd38UcQD6ej5W" | ||
| # node-01.do-ams3.waku.test.status.im on waku.test | ||
| LightpushPubsubTopic = PubsubTopic("/waku/2/rs/0/0") | ||
| "/ip4/64.225.80.192/tcp/30303/p2p/16Uiu2HAmNaeL4p3WEYzC9mgXBmBWSgWjPHRvatZTXnp8Jgv3iKsb" | ||
| LightpushPubsubTopic = PubsubTopic("/waku/2/rs/1/0") | ||
| LightpushContentTopic = ContentTopic("/examples/1/light-pubsub-example/proto") | ||
|
|
||
| proc publishMessages( | ||
| wlc: WakuLightpushClient, | ||
| lightpushPeer: RemotePeerInfo, | ||
| lightpushPubsubTopic: PubsubTopic, | ||
| lightpushContentTopic: ContentTopic, | ||
| ) {.async.} = | ||
| proc setupAndPublish(rng: ref HmacDrbgContext) {.async.} = | ||
| # use notice to filter all waku messaging | ||
| setupLog(logging.LogLevel.NOTICE, logging.LogFormat.TEXT) | ||
|
|
||
| notice "starting publisher", wakuPort = wakuPort | ||
| let | ||
| nodeKey = crypto.PrivateKey.random(Secp256k1, rng[]).get() | ||
| ip = parseIpAddress("0.0.0.0") | ||
| flags = CapabilitiesBitfield.init(relay = true) | ||
|
|
||
| let relayShards = RelayShards.init(clusterId, shardId).valueOr: | ||
| error "Relay shards initialization failed", error = error | ||
| quit(QuitFailure) | ||
|
|
||
| var enrBuilder = EnrBuilder.init(nodeKey) | ||
| enrBuilder.withWakuRelaySharding(relayShards).expect( | ||
| "Building ENR with relay sharding failed" | ||
| ) | ||
|
|
||
| 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() | ||
|
|
||
| node.mountMetadata(clusterId).expect("failed to mount waku metadata protocol") | ||
| node.mountLightPushClient() | ||
|
|
||
| await node.start() | ||
| node.peerManager.start() | ||
|
|
||
| notice "publisher service started" | ||
| while true: | ||
| let text = "hi there i'm a lightpush publisher" | ||
| let text = "hi there i'm a publisher" | ||
| let message = WakuMessage( | ||
| payload: toBytes(text), # content of the message | ||
| contentTopic: lightpushContentTopic, # content topic to publish to | ||
| contentTopic: LightpushContentTopic, # content topic to publish to | ||
| ephemeral: true, # tell store nodes to not store it | ||
| timestamp: getNowInNanosecondTime(), | ||
| timestamp: now(), | ||
| ) # current timestamp | ||
|
|
||
| let wlpRes = await wlc.publish(lightpushPubsubTopic, message, lightpushPeer) | ||
|
|
||
| if wlpRes.isOk(): | ||
| notice "published message using lightpush", message = message | ||
| else: | ||
| notice "failed to publish message using lightpush", err = wlpRes.error() | ||
|
|
||
| await sleepAsync(5000) # Publish every 5 seconds | ||
|
|
||
| proc setupAndPublish(rng: ref HmacDrbgContext) = | ||
| let lightpushPeer = parsePeerInfo(LightpushPeer).get() | ||
| let lightpushPeer = parsePeerInfo(LightpushPeer).get() | ||
|
|
||
| setupLog(logging.LogLevel.NOTICE, logging.LogFormat.TEXT) | ||
| notice "starting lightpush publisher" | ||
| let res = | ||
| await node.lightpushPublish(some(LightpushPubsubTopic), message, lightpushPeer) | ||
|
|
||
| var | ||
| switch = newStandardSwitch() | ||
| pm = PeerManager.new(switch) | ||
| wlc = WakuLightpushClient.new(pm, rng) | ||
| if res.isOk: | ||
| notice "published message", | ||
| text = text, | ||
| timestamp = message.timestamp, | ||
| psTopic = LightpushPubsubTopic, | ||
| contentTopic = LightpushContentTopic | ||
| else: | ||
| error "failed to publish message", error = res.error | ||
|
|
||
| # Start maintaining subscription | ||
| asyncSpawn publishMessages( | ||
| wlc, lightpushPeer, LightpushPubsubTopic, LightpushContentTopic | ||
| ) | ||
| await sleepAsync(5000) | ||
|
|
||
| when isMainModule: | ||
| let rng = newRng() | ||
| setupAndPublish(rng) | ||
| let rng = crypto.newRng() | ||
| asyncSpawn setupAndPublish(rng) | ||
| runForever() |