EventStream.hs

-- @generated by keiro-dsl 0.18.0.0 (language keiro-dsl 6) from aggregate IdentityLedger; do not edit.
module Generated.IdAdmissionDomains.IdentityLedger.EventStream
  ( identityLedgerCategory
  , identityLedgerCommandCategory
  , identityLedgerEventStream
  , identityLedgerEventStreamDef
  , IdentityLedgerEventStream
  , IdentityLedgerEventStreamDef
  ) where

import Generated.IdAdmissionDomains.IdentityLedger.Domain
import Generated.IdAdmissionDomains.IdentityLedger.Codec (identityLedgerCodec)
import Generated.IdAdmissionDomains.IdentityLedger.Transducer (identityLedgerTransducer)
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.
identityLedgerCategory :: Stream.StreamCategory IdentityLedgerEventStreamDef
identityLedgerCategory = Stream.categoryUnsafe "identityLedger"

-- The same category text, typed for command envelopes such as PMCommand.
identityLedgerCommandCategory :: Stream.StreamCategory IdentityLedgerCommand
identityLedgerCommandCategory = Stream.categoryUnsafe "identityLedger"

type IdentityLedgerEventStreamDef =
  EventStream (HsPred IdentityLedgerRegs IdentityLedgerCommand) IdentityLedgerRegs IdentityLedgerVertex IdentityLedgerCommand IdentityLedgerEvent

type IdentityLedgerEventStream =
  ValidatedEventStream (HsPred IdentityLedgerRegs IdentityLedgerCommand) IdentityLedgerRegs IdentityLedgerVertex IdentityLedgerCommand IdentityLedgerEvent

identityLedgerEventStreamDef :: IdentityLedgerEventStreamDef
identityLedgerEventStreamDef =
  EventStream
    { transducer = identityLedgerTransducer,
      initialState = IdentityLedgerOpen,
      initialRegisters = initialIdentityLedgerRegs,
      eventCodec = identityLedgerCodec,
      resolveStreamName = Stream.streamName,
      snapshotPolicy = Never,
      stateCodec = Nothing
    }

identityLedgerEventStream :: IdentityLedgerEventStream
identityLedgerEventStream =
  mkEventStreamOrThrow "IdentityLedger" identityLedgerEventStreamDef