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

adjust nph

Browse Source
This commit is contained in:
Ivan FB 2026-06-26 12:43:31 +02:00
parent 00322ca0b8
commit 0a9adbd274
No known key found for this signature in database
GPG Key ID: DF0C67A04C543270
1 changed files with 4 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
logos_delivery/messaging/api/send.nim
View File

@ -17,9 +17,9 @@ proc send*(
## id the caller can correlate with `MessageSentEvent` / `MessageErrorEvent`.
?self.checkApiAvailability()
let isSubbed = self.waku.node.subscriptionManager.isSubscribed(
envelope.contentTopic
).valueOr(false)
let isSubbed = self.waku.node.subscriptionManager
.isSubscribed(envelope.contentTopic)
.valueOr(false)
if not isSubbed:
info "Auto-subscribing to topic on send", contentTopic = envelope.contentTopic
self.waku.node.subscriptionManager.subscribe(envelope.contentTopic).isOkOr:
@ -28,9 +28,7 @@ proc send*(
let requestId = RequestId.new(self.waku.node.rng)
let deliveryTask = DeliveryTask.new(
requestId, envelope, self.waku.node.brokerCtx
).valueOr:
let deliveryTask = DeliveryTask.new(requestId, envelope, self.waku.node.brokerCtx).valueOr:
return err("MessagingClient.send: Failed to create delivery task: " & error)
asyncSpawn self.sendService.send(deliveryTask)