From 0a9adbd27435885380a2f978a0e69fa00ac4c247 Mon Sep 17 00:00:00 2001 From: Ivan FB Date: Fri, 26 Jun 2026 12:43:31 +0200 Subject: [PATCH] adjust nph --- logos_delivery/messaging/api/send.nim | 10 ++++------ 1 file changed, 4 insertions(+), 6 deletions(-) diff --git a/logos_delivery/messaging/api/send.nim b/logos_delivery/messaging/api/send.nim index ed909b6d0..ca7256b3e 100644 --- a/logos_delivery/messaging/api/send.nim +++ b/logos_delivery/messaging/api/send.nim @@ -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)