logos-messaging/nim-chat-poc
1
0
Fork 0
mirror of https://github.com/logos-messaging/nim-chat-poc.git synced 2026-01-05 23:53:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore: move discovery to ds

Browse Source
This commit is contained in:
kaichaosun 2025-12-03 16:20:10 +08:00
parent cc01e954ef
commit a76af7b2c7
No known key found for this signature in database
GPG Key ID: 223E0F992F4F03BF
2 changed files with 13 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
src/chat/client.nim
View File

@ -15,12 +15,6 @@ import # Foreign
tables, tables,
types types
import
waku/[
waku_node,
discovery/waku_dnsdisc
]
import #local import #local
conversations, conversations,
conversations/convo_impl, conversations/convo_impl,
@ -50,7 +44,7 @@ type
type KeyEntry* = object type KeyEntry* = object
keyType: string keyType: string
privateKey: crypto.PrivateKey privateKey: PrivateKey
timestamp: int64 timestamp: int64
type Client* = ref object type Client* = ref object
@ -293,17 +287,6 @@ proc start*(client: Client) {.async.} =
client.isRunning = true client.isRunning = true
let dnsDiscoveryUrl = "enrtree://AIRVQ5DDA4FFWLRBCHJWUWOO6X6S4ZTZ5B667LQ6AJU6PEYDLRD5O@sandbox.waku.nodes.status.im"
let nameServer = parseIpAddress("1.1.1.1")
let discoveredPeers = await retrieveDynamicBootstrapNodes(dnsDiscoveryUrl, @[nameServer])
if discoveredPeers.isOk:
info "Connecting to discovered peers"
let remotePeers = discoveredPeers.get()
info "Discovered and connecting to peers", peerCount = remotePeers.len
asyncSpawn client.ds.node.connectToNodes(remotePeers)
else:
warn "Failed to find peers via DNS discovery", error = discoveredPeers.error
asyncSpawn client.messageQueueConsumer() asyncSpawn client.messageQueueConsumer()
notice "Client start complete", client = client.getId() notice "Client start complete", client = client.getId()

12
src/chat/delivery/waku_client.nim
View File

@ -15,6 +15,7 @@ import
waku_node, waku_node,
waku_enr, waku_enr,
discovery/waku_discv5, discovery/waku_discv5,
discovery/waku_dnsdisc,
factory/builder, factory/builder,
waku_filter_v2/client, waku_filter_v2/client,
] ]
@ -161,6 +162,17 @@ proc start*(client: WakuClient) {.async.} =
client.node.peerManager.start() client.node.peerManager.start()
let dnsDiscoveryUrl = "enrtree://AIRVQ5DDA4FFWLRBCHJWUWOO6X6S4ZTZ5B667LQ6AJU6PEYDLRD5O@sandbox.waku.nodes.status.im"
let nameServer = parseIpAddress("1.1.1.1")
let discoveredPeers = await retrieveDynamicBootstrapNodes(dnsDiscoveryUrl, @[nameServer])
if discoveredPeers.isOk:
info "Connecting to discovered peers"
let remotePeers = discoveredPeers.get()
info "Discovered and connecting to peers", peerCount = remotePeers.len
asyncSpawn client.node.connectToNodes(remotePeers)
else:
warn "Failed to find peers via DNS discovery", error = discoveredPeers.error
let subscription: SubscriptionEvent = (kind: PubsubSub, topic: let subscription: SubscriptionEvent = (kind: PubsubSub, topic:
client.cfg.pubsubTopic) client.cfg.pubsubTopic)