EventStream.hs

-- @generated by keiro-dsl 0.9.0.0 (language keiro-dsl 4) from aggregate CollisionLedger; do not edit.
module Generated.ImportPlanningCollisions.CollisionLedger.EventStream
  ( collisionLedgerCategory
  , collisionLedgerCommandCategory
  , collisionLedgerEventStream
  , collisionLedgerEventStreamDef
  , CollisionLedgerEventStream
  , CollisionLedgerEventStreamDef
  ) where

import Generated.ImportPlanningCollisions.CollisionLedger.Domain
import Generated.ImportPlanningCollisions.CollisionLedger.Codec (collisionLedgerCodec)
import Generated.ImportPlanningCollisions.CollisionLedger.Transducer (collisionLedgerFoldFingerprint, collisionLedgerTransducer)
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.
collisionLedgerCategory :: Stream.StreamCategory CollisionLedgerEventStreamDef
collisionLedgerCategory = Stream.categoryUnsafe "collisionLedger"

-- The same category text, typed for command envelopes such as PMCommand.
collisionLedgerCommandCategory :: Stream.StreamCategory CollisionLedgerCommand
collisionLedgerCommandCategory = Stream.categoryUnsafe "collisionLedger"

type CollisionLedgerEventStreamDef =
  EventStream (HsPred CollisionLedgerRegs CollisionLedgerCommand) CollisionLedgerRegs CollisionLedgerVertex CollisionLedgerCommand CollisionLedgerEvent

type CollisionLedgerEventStream =
  ValidatedEventStream (HsPred CollisionLedgerRegs CollisionLedgerCommand) CollisionLedgerRegs CollisionLedgerVertex CollisionLedgerCommand CollisionLedgerEvent

collisionLedgerEventStreamDef :: CollisionLedgerEventStreamDef
collisionLedgerEventStreamDef =
  EventStream
    { transducer = collisionLedgerTransducer,
      initialState = CollisionLedgerEmpty,
      initialRegisters = initialCollisionLedgerRegs,
      eventCodec = collisionLedgerCodec,
      resolveStreamName = Stream.streamName,
      snapshotPolicy = Never,
      stateCodec = Nothing
    }

collisionLedgerEventStream :: CollisionLedgerEventStream
collisionLedgerEventStream =
  mkEventStreamOrThrow "CollisionLedger" collisionLedgerEventStreamDef