EventStream.hs

-- @generated by keiro-dsl 0.17.0.0 (language keiro-dsl 6) from aggregate IncidentSaga; do not edit.
module Generated.ProcessReactions.IncidentSaga.EventStream
  ( incidentSagaCategory
  , incidentSagaCommandCategory
  , incidentSagaEventStream
  , incidentSagaEventStreamDef
  , IncidentSagaEventStream
  , IncidentSagaEventStreamDef
  ) where

import Generated.ProcessReactions.IncidentSaga.Domain
import Generated.ProcessReactions.IncidentSaga.Codec (incidentSagaCodec)
import Generated.ProcessReactions.IncidentSaga.Transducer (incidentSagaTransducer)
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.
incidentSagaCategory :: Stream.StreamCategory IncidentSagaEventStreamDef
incidentSagaCategory = Stream.categoryUnsafe "incidentSaga"

-- The same category text, typed for command envelopes such as PMCommand.
incidentSagaCommandCategory :: Stream.StreamCategory IncidentSagaCommand
incidentSagaCommandCategory = Stream.categoryUnsafe "incidentSaga"

type IncidentSagaEventStreamDef =
  EventStream (HsPred IncidentSagaRegs IncidentSagaCommand) IncidentSagaRegs IncidentSagaVertex IncidentSagaCommand IncidentSagaEvent

type IncidentSagaEventStream =
  ValidatedEventStream (HsPred IncidentSagaRegs IncidentSagaCommand) IncidentSagaRegs IncidentSagaVertex IncidentSagaCommand IncidentSagaEvent

incidentSagaEventStreamDef :: IncidentSagaEventStreamDef
incidentSagaEventStreamDef =
  EventStream
    { transducer = incidentSagaTransducer,
      initialState = IncidentSagaOpen,
      initialRegisters = initialIncidentSagaRegs,
      eventCodec = incidentSagaCodec,
      resolveStreamName = Stream.streamName,
      snapshotPolicy = Never,
      stateCodec = Nothing
    }

incidentSagaEventStream :: IncidentSagaEventStream
incidentSagaEventStream =
  mkEventStreamOrThrow "IncidentSaga" incidentSagaEventStreamDef