EventStream.hs

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

import Data.Text (Text)
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.Snapshot.Codec (defaultStateCodec)
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 = Every 100
        , stateCodec = Just (defaultStateCodec 1)
        }

reservationSnapshotFixture :: (Int, Text)
reservationSnapshotFixture = (1, "7eb3a94f62f947231375d44083e2a1c8029d91ffe0329107d55092ed3430efcc")

reservationEventStream :: ReservationEventStream
reservationEventStream =
    mkEventStreamOrThrow "Reservation" reservationEventStreamDef