EventStream.hs

-- @generated by keiro-dsl; do not edit. Regenerated from the .keiro spec.
module SkelAggregate.Generated.MyService.Thing.EventStream (
    thingCategory,
    thingEventStream,
    thingEventStreamDef,
    ThingEventStream,
    ThingEventStreamDef,
) where

import Keiki.Core (HsPred)
import Keiro.EventStream (EventStream (..), SnapshotPolicy (..))
import Keiro.EventStream.Validate (ValidatedEventStream, mkEventStreamOrThrow)
import Keiro.Stream qualified as Stream
import SkelAggregate.Generated.MyService.Thing.Codec (thingCodec)
import SkelAggregate.Generated.MyService.Thing.Domain
import SkelAggregate.MyService.Thing.Holes (thingTransducer)

-- 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.
thingCategory :: Stream.StreamCategory a
thingCategory = Stream.categoryUnsafe "thing"

type ThingEventStreamDef =
    EventStream (HsPred ThingRegs ThingCommand) ThingRegs ThingVertex ThingCommand ThingEvent

type ThingEventStream =
    ValidatedEventStream (HsPred ThingRegs ThingCommand) ThingRegs ThingVertex ThingCommand ThingEvent

thingEventStreamDef :: ThingEventStreamDef
thingEventStreamDef =
    EventStream
        { transducer = thingTransducer
        , initialState = ThingPending
        , initialRegisters = initialThingRegs
        , eventCodec = thingCodec
        , resolveStreamName = Stream.streamName
        , snapshotPolicy = Never
        , stateCodec = Nothing
        }

thingEventStream :: ThingEventStream
thingEventStream =
    mkEventStreamOrThrow "Thing" thingEventStreamDef