EventStream.hs

-- @generated by keiro-dsl 0.12.0.0 (language keiro-dsl 5) from aggregate Reservation; do not edit.
module Generated.DomainOutcomes.Reservation.EventStream
  ( reservationCategory
  , reservationCommandCategory
  , reservationEventStream
  , reservationEventStreamDef
  , ReservationEventStream
  , ReservationEventStreamDef
  , reservationDomainCommandHandler
  ) where

import Generated.DomainOutcomes.Reservation.Domain
import Generated.DomainOutcomes.Reservation.Codec (reservationCodec)
import Generated.DomainOutcomes.Reservation.Transducer (reservationTransducer)
import Generated.DomainOutcomes.Nominals (ReservationNoOp (..), ReservationRejection (..))
import Keiki.Core (EdgeRef (..), HsPred)
import Keiki.Core qualified as K
import Keiro.Command (DomainCommandHandler (..), SilentCommandContext (..), SilentDomainDecision (..))
import Keiro.EventStream (EventStream (..), SnapshotPolicy (..))
import Keiro.EventStream.Validate (ValidatedEventStream, mkEventStreamOrThrow)
import Keiro.Stream qualified as Stream

-- The validated aggregate stream category (hole-kind 5: referenced, never retyped).
-- Entity streams are '<category>-<id>' via Keiro.Stream.entityStream.
-- categoryUnsafe is safe here because this generated literal passed the DSL category proof.
reservationCategory :: Stream.StreamCategory ReservationEventStreamDef
reservationCategory = Stream.categoryUnsafe "reservation"

-- The same category text, typed for command envelopes such as PMCommand.
reservationCommandCategory :: Stream.StreamCategory ReservationCommand
reservationCommandCategory = Stream.categoryUnsafe "reservation"

type ReservationEventStreamDef =
  EventStream (HsPred ReservationRegs ReservationCommand) ReservationRegs ReservationVertex ReservationCommand ReservationEvent

type ReservationEventStream =
  ValidatedEventStream (HsPred ReservationRegs ReservationCommand) ReservationRegs ReservationVertex ReservationCommand ReservationEvent

reservationEventStreamDef :: ReservationEventStreamDef
reservationEventStreamDef =
  EventStream
    { transducer = reservationTransducer,
      initialState = ReservationEligible,
      initialRegisters = initialReservationRegs,
      eventCodec = reservationCodec,
      resolveStreamName = Stream.streamName,
      snapshotPolicy = Never,
      stateCodec = Nothing
    }

reservationEventStream :: ReservationEventStream
reservationEventStream =
  mkEventStreamOrThrow "Reservation" reservationEventStreamDef

reservationDomainCommandHandler
  :: DomainCommandHandler
       (HsPred ReservationRegs ReservationCommand)
       ReservationRegs
       ReservationVertex
       ReservationCommand
       ReservationEvent
       ReservationRejection
       ReservationNoOp
reservationDomainCommandHandler =
  DomainCommandHandler reservationEventStream reservationSilentDecision

reservationSilentDecision
  :: SilentCommandContext ReservationRegs ReservationVertex ReservationCommand
  -> SilentDomainDecision
       ReservationRejection
       ReservationNoOp
reservationSilentDecision (SilentCommandContext _ registers command (EdgeRef edgeSource edgeIndex)) =
  case edgeSource of
    ReservationCancelledState ->
      case edgeIndex of
        0 -> SilentRejected (K.evalTerm (K.lit AlreadyCancelled) registers command)
        1 -> SilentNoOp (K.evalTerm (K.lit DuplicateRequest) registers command)
        _ -> outcomeInvariant edgeSource edgeIndex
    _ -> outcomeInvariant edgeSource edgeIndex
 where
  outcomeInvariant source index =
    error ("generated domain outcome invariant failed for aggregate Reservation edge " <> show source <> "#" <> show index)