mirror of
https://github.com/logos-messaging/logos-messaging-nim.git
synced 2026-01-02 14:03:06 +00:00
4d68e2abd5
* Changes isOk usage into better patterns with e.g. valueOr / isOkOr * Some other refactoring included * This PR partially addresses #1969
112 lines
3.0 KiB
Nim
112 lines
3.0 KiB
Nim
import
|
|
std/[tables, times, sequtils],
|
|
stew/byteutils,
|
|
chronicles,
|
|
results,
|
|
chronos,
|
|
confutils,
|
|
libp2p/crypto/crypto,
|
|
eth/keys,
|
|
eth/p2p/discoveryv5/enr
|
|
|
|
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/64.225.80.192/tcp/30303/p2p/16Uiu2HAmNaeL4p3WEYzC9mgXBmBWSgWjPHRvatZTXnp8Jgv3iKsb"
|
|
LightpushPubsubTopic = PubsubTopic("/waku/2/rs/1/0")
|
|
LightpushContentTopic = ContentTopic("/examples/1/light-pubsub-example/proto")
|
|
|
|
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, shardId).expect(
|
|
"failed to mount waku metadata protocol"
|
|
)
|
|
node.mountLegacyLightPushClient()
|
|
|
|
await node.start()
|
|
node.peerManager.start()
|
|
|
|
notice "publisher service started"
|
|
while true:
|
|
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
|
|
ephemeral: true, # tell store nodes to not store it
|
|
timestamp: now(),
|
|
) # current timestamp
|
|
|
|
let lightpushPeer = parsePeerInfo(LightpushPeer).valueOr:
|
|
error "failed to parse LightpushPeer", error = error
|
|
quit(QuitFailure)
|
|
|
|
let res = await node.legacyLightpushPublish(
|
|
some(LightpushPubsubTopic), message, lightpushPeer
|
|
)
|
|
|
|
if res.isOk:
|
|
notice "published message",
|
|
text = text,
|
|
timestamp = message.timestamp,
|
|
psTopic = LightpushPubsubTopic,
|
|
contentTopic = LightpushContentTopic
|
|
else:
|
|
error "failed to publish message", error = res.error
|
|
|
|
await sleepAsync(5000)
|
|
|
|
when isMainModule:
|
|
let rng = crypto.newRng()
|
|
asyncSpawn setupAndPublish(rng)
|
|
runForever()
|