EventStream.hs

-- @generated by keiro-dsl 0.8.0.0 (language keiro-dsl 4) from aggregate Surge; do not edit.
module Generated.HospitalCapacity.Surge.EventStream
  ( surgeCategory
  , surgeCommandCategory
  , surgeEventStream
  , surgeEventStreamDef
  , SurgeEventStream
  , SurgeEventStreamDef
  ) where

import Generated.HospitalCapacity.Surge.Domain
import Generated.HospitalCapacity.Surge.Codec (surgeCodec)
import Generated.HospitalCapacity.Surge.Transducer (surgeFoldFingerprint, surgeTransducer)
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.
surgeCategory :: Stream.StreamCategory SurgeEventStreamDef
surgeCategory = Stream.categoryUnsafe "surge"

-- The same category text, typed for command envelopes such as PMCommand.
surgeCommandCategory :: Stream.StreamCategory SurgeCommand
surgeCommandCategory = Stream.categoryUnsafe "surge"

type SurgeEventStreamDef =
  EventStream (HsPred SurgeRegs SurgeCommand) SurgeRegs SurgeVertex SurgeCommand SurgeEvent

type SurgeEventStream =
  ValidatedEventStream (HsPred SurgeRegs SurgeCommand) SurgeRegs SurgeVertex SurgeCommand SurgeEvent

surgeEventStreamDef :: SurgeEventStreamDef
surgeEventStreamDef =
  EventStream
    { transducer = surgeTransducer,
      initialState = SurgeIdle,
      initialRegisters = initialSurgeRegs,
      eventCodec = surgeCodec,
      resolveStreamName = Stream.streamName,
      snapshotPolicy = Never,
      stateCodec = Nothing
    }

surgeEventStream :: SurgeEventStream
surgeEventStream =
  mkEventStreamOrThrow "Surge" surgeEventStreamDef