diff --git a/logos_delivery/channels/reliable_channel_manager.nim b/logos_delivery/channels/reliable_channel_manager.nim index 3b2d1c6a1..2dbe924de 100644 --- a/logos_delivery/channels/reliable_channel_manager.nim +++ b/logos_delivery/channels/reliable_channel_manager.nim @@ -36,28 +36,14 @@ type ReliableChannelManager* = ref object of IReliableChannelManager channels: Table[ChannelId, ReliableChannel] - messagingClient: MessagingClient ## The channel layer chains onto messaging. brokerCtx: BrokerContext proc new*( T: type ReliableChannelManager, conf: ReliableChannelManagerConf, - messagingClient: MessagingClient, brokerCtx: BrokerContext = globalBrokerContext(), ): Result[T, string] = - ## The reliable channel layer chains onto the messaging layer: its default - ## egress is `MessagingClient.send`, wrapped here so callers never wire the - ## handler themselves. - if messagingClient.isNil(): - return err("messaging client is required") - - return ok( - T( - channels: initTable[ChannelId, ReliableChannel](), - messagingClient: messagingClient, - brokerCtx: brokerCtx, - ) - ) + return ok(T(channels: initTable[ChannelId, ReliableChannel](), brokerCtx: brokerCtx)) proc start*(self: ReliableChannelManager): Result[void, string] = ## Placeholder: per-channel listeners are installed in `ReliableChannel.new`, diff --git a/logos_delivery/logos_delivery.nim b/logos_delivery/logos_delivery.nim index f739851e7..6bee5c87f 100644 --- a/logos_delivery/logos_delivery.nim +++ b/logos_delivery/logos_delivery.nim @@ -70,7 +70,7 @@ proc new*( return err("failed to create MessagingClient: " & error) let reliableChannelManager = ReliableChannelManager.new( - layerConf.reliableChannel, messagingClient, waku.brokerCtx + layerConf.reliableChannel, waku.brokerCtx ).valueOr: return err("failed to create ReliableChannelManager: " & error)