From 2636551a11547a2714067f6ab6d1226bf3e04f80 Mon Sep 17 00:00:00 2001 From: Ivan FB Date: Fri, 26 Jun 2026 15:07:31 +0200 Subject: [PATCH] nph update --- .../api/reliable_channel_manager_api.nim | 15 +++++++-------- logos_delivery/logos_delivery.nim | 3 +-- 2 files changed, 8 insertions(+), 10 deletions(-) diff --git a/logos_delivery/api/reliable_channel_manager_api.nim b/logos_delivery/api/reliable_channel_manager_api.nim index 9c1b19019..8595f2f86 100644 --- a/logos_delivery/api/reliable_channel_manager_api.nim +++ b/logos_delivery/api/reliable_channel_manager_api.nim @@ -14,14 +14,13 @@ import logos_delivery/api/messaging_client_api export event_broker, api_types export channel_types, messaging_client_api -type - SendHandler* = proc(envelope: MessageEnvelope): Future[Result[RequestId, string]] {. - async: (raises: [CatchableError]), gcsafe - .} - ## Egress dispatch boundary. Typically wraps `MessagingClient.send`; - ## tests inject a fake that records calls and returns canned - ## `RequestId`s so the send state machine can be exercised end-to-end - ## without a network. +type SendHandler* = proc(envelope: MessageEnvelope): Future[Result[RequestId, string]] {. + async: (raises: [CatchableError]), gcsafe +.} + ## Egress dispatch boundary. Typically wraps `MessagingClient.send`; + ## tests inject a fake that records calls and returns canned + ## `RequestId`s so the send state machine can be exercised end-to-end + ## without a network. EventBroker: type ChannelMessageReceivedEvent* = object diff --git a/logos_delivery/logos_delivery.nim b/logos_delivery/logos_delivery.nim index d9bc54ea0..03ef5a2d0 100644 --- a/logos_delivery/logos_delivery.nim +++ b/logos_delivery/logos_delivery.nim @@ -72,8 +72,7 @@ type messaging*: MessagingClientConf reliableChannel*: ReliableChannelManagerConf - LogosDelivery* = ref object - ## Entry point. Holds one instance of each API layer. + LogosDelivery* = ref object ## Entry point. Holds one instance of each API layer. waku*: Waku messagingClient*: MessagingClient reliableChannelManager*: ReliableChannelManager