import chronos, results

import brokers/event_broker

import logos_delivery/api/types as api_types

export event_broker, api_types

type
  IReliableChannelManager* = ref object of RootObj

  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
    channelId*: ChannelId
    senderId*: SdsParticipantID
    payload*: seq[byte]

EventBroker:
  ## Emitted when every segment of a channel-level `send()` reached
  ## `Confirmed`. Channel-level analogue of `MessageSentEvent`; the
  ## `requestId` is the channel-layer parent returned by `send()`.
  type ChannelMessageSentEvent* = object
    channelId*: ChannelId
    requestId*: RequestId

EventBroker:
  ## Emitted when a channel-level `send()` finalises with at least one
  ## segment in `Failed`. Channel-level analogue of `MessageErrorEvent`.
  type ChannelMessageErrorEvent* = object
    channelId*: ChannelId
    requestId*: RequestId
    error*: string

method createReliableChannel*(
    self: IReliableChannelManager,
    channelId: ChannelId,
    contentTopic: ContentTopic,
    senderId: SdsParticipantID,
): Result[ChannelId, string] {.base.} =
  return err("Interface IReliableChannelManager.createReliableChannel not implemented")

method closeChannel*(
    self: IReliableChannelManager, channelId: ChannelId
): Future[Result[void, string]] {.async: (raises: []), base.} =
  return err("Interface IReliableChannelManager.closeChannel not implemented")

method send*(
    self: IReliableChannelManager,
    channelId: ChannelId,
    appPayload: seq[byte],
    ephemeral: bool = false,
): Future[Result[RequestId, string]] {.async: (raises: []), base.} =
  return err("Interface IReliableChannelManager.send not implemented")