EventStream.hs

-- @generated by keiro-dsl; do not edit. Regenerated from the .keiro spec.
module Generated.HospitalCapacity.Reservation.EventStream (
    reservationCategory,
    reservationEventStream,
    reservationEventStreamDef,
    ReservationEventStream,
    ReservationEventStreamDef,
) where

import Generated.HospitalCapacity.Reservation.Codec (reservationCodec)
import Generated.HospitalCapacity.Reservation.Domain
import HospitalCapacity.Reservation.Holes (reservationTransducer)
import Keiki.Core (HsPred)
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 a
reservationCategory = 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 = ReservationUnrequested
        , initialRegisters = initialReservationRegs
        , eventCodec = reservationCodec
        , resolveStreamName = Stream.streamName
        , snapshotPolicy = Never
        , stateCodec = Nothing
        }

reservationEventStream :: ReservationEventStream
reservationEventStream =
    mkEventStreamOrThrow "Reservation" reservationEventStreamDef