EventStream.hs

-- @generated by keiro-dsl; do not edit. Regenerated from the .keiro spec.
module Generated.ReplayDivergence.Note.EventStream (
    noteCategory,
    noteEventStream,
    noteEventStreamDef,
    NoteEventStream,
    NoteEventStreamDef,
) where

import Generated.ReplayDivergence.Note.Codec (noteCodec)
import Generated.ReplayDivergence.Note.Domain
import Keiki.Core (HsPred)
import Keiro.EventStream (EventStream (..), SnapshotPolicy (..))
import Keiro.EventStream.Validate (ValidatedEventStream, mkEventStreamOrThrow)
import Keiro.Stream qualified as Stream
import ReplayDivergence.Note.Holes (noteTransducer)

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

type NoteEventStreamDef =
    EventStream (HsPred NoteRegs NoteCommand) NoteRegs NoteVertex NoteCommand NoteEvent

type NoteEventStream =
    ValidatedEventStream (HsPred NoteRegs NoteCommand) NoteRegs NoteVertex NoteCommand NoteEvent

noteEventStreamDef :: NoteEventStreamDef
noteEventStreamDef =
    EventStream
        { transducer = noteTransducer
        , initialState = NoteEmpty
        , initialRegisters = initialNoteRegs
        , eventCodec = noteCodec
        , resolveStreamName = Stream.streamName
        , snapshotPolicy = Never
        , stateCodec = Nothing
        }

noteEventStream :: NoteEventStream
noteEventStream =
    mkEventStreamOrThrow "Note" noteEventStreamDef