EventStream.hs

-- @generated by keiro-dsl 0.8.0.0 (language keiro-dsl 4) from aggregate Note; do not edit.
module Generated.ReplayDivergence.Note.EventStream
  ( noteCategory
  , noteCommandCategory
  , noteEventStream
  , noteEventStreamDef
  , NoteEventStream
  , NoteEventStreamDef
  ) where

import Generated.ReplayDivergence.Note.Domain
import Generated.ReplayDivergence.Note.Codec (noteCodec)
import Generated.ReplayDivergence.Note.Transducer (noteFoldFingerprint, noteTransducer)
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.
noteCategory :: Stream.StreamCategory NoteEventStreamDef
noteCategory = Stream.categoryUnsafe "note"

-- The same category text, typed for command envelopes such as PMCommand.
noteCommandCategory :: Stream.StreamCategory NoteCommand
noteCommandCategory = 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