EventStream.hs

-- @generated by keiro-dsl 0.18.0.0 (language keiro-dsl 6) from aggregate ReplayTarget; do not edit.
module Generated.CheckedMappingReplay.ReplayTarget.EventStream
  ( replayTargetCategory
  , replayTargetCommandCategory
  , replayTargetEventStream
  , replayTargetEventStreamDef
  , ReplayTargetEventStream
  , ReplayTargetEventStreamDef
  ) where

import Generated.CheckedMappingReplay.ReplayTarget.Domain
import Generated.CheckedMappingReplay.ReplayTarget.Codec (replayTargetCodec)
import Generated.CheckedMappingReplay.ReplayTarget.Transducer (replayTargetTransducer)
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.
replayTargetCategory :: Stream.StreamCategory ReplayTargetEventStreamDef
replayTargetCategory = Stream.categoryUnsafe "replayTarget"

-- The same category text, typed for command envelopes such as PMCommand.
replayTargetCommandCategory :: Stream.StreamCategory ReplayTargetCommand
replayTargetCommandCategory = Stream.categoryUnsafe "replayTarget"

type ReplayTargetEventStreamDef =
  EventStream (HsPred ReplayTargetRegs ReplayTargetCommand) ReplayTargetRegs ReplayTargetVertex ReplayTargetCommand ReplayTargetEvent

type ReplayTargetEventStream =
  ValidatedEventStream (HsPred ReplayTargetRegs ReplayTargetCommand) ReplayTargetRegs ReplayTargetVertex ReplayTargetCommand ReplayTargetEvent

replayTargetEventStreamDef :: ReplayTargetEventStreamDef
replayTargetEventStreamDef =
  EventStream
    { transducer = replayTargetTransducer,
      initialState = ReplayTargetReady,
      initialRegisters = initialReplayTargetRegs,
      eventCodec = replayTargetCodec,
      resolveStreamName = Stream.streamName,
      snapshotPolicy = Never,
      stateCodec = Nothing
    }

replayTargetEventStream :: ReplayTargetEventStream
replayTargetEventStream =
  mkEventStreamOrThrow "ReplayTarget" replayTargetEventStreamDef