logos-messaging/logos-messaging-nim
1
0
Fork 0
mirror of https://github.com/logos-messaging/logos-messaging-nim.git synced 2026-06-28 04:19:29 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'chore/separate-rln-from-relay-phase1' into chore/separate-rln-from-relay-phase2

Browse Source
This commit is contained in:
stubbsta 2026-06-24 10:47:18 +02:00
commit cc4dfd6b30
No known key found for this signature in database
1 changed files with 13 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
tests/api/test_api_send.nim
View File

@ -355,22 +355,20 @@ suite "Waku API - Send":
asyncTest "Edge sender delivers via lightpush (no relay)":
## Reproduces issue #3847: an Edge node (no relay mounted) that is only
## connected to a lightpush-capable peer must deliver through lightpush.
var node: Waku
var node: LogosDelivery
lockNewGlobalBrokerContext:
node = (await createNode(createApiNodeConf(cli_args.WakuMode.Edge))).valueOr:
node = (await LogosDelivery.new(createApiNodeConf(cli_args.WakuMode.Edge))).valueOr:
raiseAssert error
node.mountMessagingClient().isOkOr:
raiseAssert "Failed to mount messaging: " & error
(await node.start()).isOkOr:
raiseAssert "Failed to start Waku node: " & error
# Edge node has no relay; its only path to the network is the
# lightpush peer it is connected to.
await node.node.connectToNodes(@[lightpushNodePeerInfo])
await node.waku.node.connectToNodes(@[lightpushNodePeerInfo])
check node.node.wakuRelay.isNil()
check node.waku.node.wakuRelay.isNil()
let eventManager = newSendEventListenerManager(node.brokerCtx)
let eventManager = newSendEventListenerManager(node.waku.brokerCtx)
defer:
await eventManager.teardown()
@ -378,7 +376,7 @@ suite "Waku API - Send":
ContentTopic("/waku/2/default-content/proto"), "test payload"
)
let requestId = (await node.send(envelope)).valueOr:
let requestId = (await node.messagingClient.send(envelope)).valueOr:
raiseAssert error
const eventTimeout = 10.seconds
@ -497,19 +495,19 @@ suite "Waku API - Send":
# it can answer store queries but never holds the published message.
let isolatedStoreNodePeerInfo = isolatedStoreNode.peerInfo.toRemotePeerInfo()
var node: Waku
var node: LogosDelivery
lockNewGlobalBrokerContext:
node = (await createNode(createApiNodeConf())).valueOr:
node = (await LogosDelivery.new(createApiNodeConf())).valueOr:
raiseAssert error
node.mountMessagingClient().isOkOr:
raiseAssert "Failed to mount messaging: " & error
(await node.start()).isOkOr:
raiseAssert "Failed to start Waku node: " & error
# Propagate via relayNode1; store queries can only reach the isolated store node.
await node.node.connectToNodes(@[relayNode1PeerInfo, isolatedStoreNodePeerInfo])
await node.waku.node.connectToNodes(
@[relayNode1PeerInfo, isolatedStoreNodePeerInfo]
)
let eventManager = newSendEventListenerManager(node.brokerCtx)
let eventManager = newSendEventListenerManager(node.waku.brokerCtx)
defer:
await eventManager.teardown()
@ -517,7 +515,7 @@ suite "Waku API - Send":
ContentTopic("/waku/2/default-content/proto"), "test payload"
)
let requestId = (await node.send(envelope)).valueOr:
let requestId = (await node.messagingClient.send(envelope)).valueOr:
raiseAssert error
# Must outlive MaxTimeInCache (1 min) so the store-validation timeout drop fires.