mirror of
https://github.com/logos-messaging/logos-messaging-nim.git
synced 2026-07-02 14:29:46 +00:00
ab6dc01a05
9th duplicate EventBroker type: defined in both logos_delivery_api.nim and the decomposed waku/api/events/health_events.nim. The interface file now re-exports it. liblogosdelivery builds clean. Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>
35 lines
1.3 KiB
Nim
35 lines
1.3 KiB
Nim
## `LogosDelivery` is the project entry point. It is a pure concentrator: it
|
|
## owns exactly one instance of each API layer
|
|
##
|
|
## Waku <- MessagingClient <- ReliableChannelManager
|
|
##
|
|
## and chains them together (each layer drives the one below it). Every layer
|
|
## keeps its own, separate public API — `LogosDelivery` only wires them up and
|
|
## drives the shared `new` / `start` / `stop` lifecycle.
|
|
|
|
{.push raises: [].}
|
|
|
|
import results, chronos
|
|
import brokers/event_broker
|
|
import types as api_types
|
|
|
|
# `EventConnectionStatusChange` lives in the decomposed health-events module.
|
|
# Re-export it here so the orchestrator surfaces it without duplicating the type.
|
|
import logos_delivery/waku/api/events/health_events as health_events
|
|
|
|
export api_types, event_broker
|
|
export health_events
|
|
|
|
type
|
|
## Entry point. Holds one instance of each API layer.
|
|
ILogosDelivery* = ref object of RootObj
|
|
|
|
method start*(self: ILogosDelivery): Future[Result[void, string]] {.async, base.} =
|
|
return err("ILogosDelivery.start not implemented")
|
|
|
|
method stop*(self: ILogosDelivery): Future[Result[void, string]] {.async, base.} =
|
|
return err("ILogosDelivery.stop not implemented")
|
|
|
|
method isOnline*(self: ILogosDelivery): Future[Result[bool, string]] {.async, base.} =
|
|
return err("ILogosDelivery.isOnline not implemented")
|