mirror of
https://github.com/logos-messaging/logos-delivery.git
synced 2026-06-04 05:00:02 +00:00
8b9ed0c804
* Refactor channels to fit layering with explicit mount * Fix channels test to perform the new mount sequence * Add Waku.reliableChannelManager * liblogosdelivery_start_node mounts ReliableChannelManager after MessagingClient * Fix test_wakunode_peer_exchange missing lockNewGlobalBrokerContext * Fix test_protocol missing lockNewGlobalBrokerContext * Harden provider setup vs. misconfiguration (improper shared broker context situations)
24 lines
845 B
Nim
24 lines
845 B
Nim
## Reliable Channel event types emitted to API consumers.
|
|
##
|
|
## Lifecycle events for individual segments (sent / propagated / errored)
|
|
## are the same as the network-level ones the MessagingClient already
|
|
## emits — `requestId` is shared across layers — so we just re-export
|
|
## `waku/events/message_events` and avoid declaring duplicates.
|
|
##
|
|
## Only the channel-level `MessageReceivedEvent` carries data that has
|
|
## no analogue in the lower layer (reassembled application payload,
|
|
## senderId, channelId), so it lives here.
|
|
|
|
import waku/events/message_events as waku_message_events
|
|
import brokers/event_broker
|
|
|
|
import ./types as channel_types
|
|
|
|
export waku_message_events, channel_types, event_broker
|
|
|
|
EventBroker:
|
|
type ChannelMessageReceivedEvent* = object
|
|
channelId*: ChannelId
|
|
senderId*: SdsParticipantID
|
|
payload*: seq[byte]
|