EventStream.hs

-- @generated by keiro-dsl; do not edit. Regenerated from the .keiro spec.
module SkelRouter.Generated.MyService.Page.EventStream (
    pageCategory,
    pageEventStream,
    pageEventStreamDef,
    PageEventStream,
    PageEventStreamDef,
) where

import Keiki.Core (HsPred)
import Keiro.EventStream (EventStream (..), SnapshotPolicy (..))
import Keiro.EventStream.Validate (ValidatedEventStream, mkEventStreamOrThrow)
import Keiro.Stream qualified as Stream
import SkelRouter.Generated.MyService.Page.Codec (pageCodec)
import SkelRouter.Generated.MyService.Page.Domain
import SkelRouter.MyService.Page.Holes (pageTransducer)

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

type PageEventStreamDef =
    EventStream (HsPred PageRegs PageCommand) PageRegs PageVertex PageCommand PageEvent

type PageEventStream =
    ValidatedEventStream (HsPred PageRegs PageCommand) PageRegs PageVertex PageCommand PageEvent

pageEventStreamDef :: PageEventStreamDef
pageEventStreamDef =
    EventStream
        { transducer = pageTransducer
        , initialState = PagePending
        , initialRegisters = initialPageRegs
        , eventCodec = pageCodec
        , resolveStreamName = Stream.streamName
        , snapshotPolicy = Never
        , stateCodec = Nothing
        }

pageEventStream :: PageEventStream
pageEventStream =
    mkEventStreamOrThrow "Page" pageEventStreamDef