EventStream.hs

-- @generated by keiro-dsl 0.9.0.0 (language keiro-dsl 4) from aggregate Thing; do not edit.
module SkelAggregate.Generated.MyService.Thing.EventStream
  ( thingCategory
  , thingCommandCategory
  , thingEventStream
  , thingEventStreamDef
  , ThingEventStream
  , ThingEventStreamDef
  ) where

import SkelAggregate.Generated.MyService.Thing.Domain
import SkelAggregate.Generated.MyService.Thing.Codec (thingCodec)
import SkelAggregate.Generated.MyService.Thing.Transducer (thingFoldFingerprint, thingTransducer)
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.
thingCategory :: Stream.StreamCategory ThingEventStreamDef
thingCategory = Stream.categoryUnsafe "thing"

-- The same category text, typed for command envelopes such as PMCommand.
thingCommandCategory :: Stream.StreamCategory ThingCommand
thingCommandCategory = Stream.categoryUnsafe "thing"

type ThingEventStreamDef =
  EventStream (HsPred ThingRegs ThingCommand) ThingRegs ThingVertex ThingCommand ThingEvent

type ThingEventStream =
  ValidatedEventStream (HsPred ThingRegs ThingCommand) ThingRegs ThingVertex ThingCommand ThingEvent

thingEventStreamDef :: ThingEventStreamDef
thingEventStreamDef =
  EventStream
    { transducer = thingTransducer,
      initialState = ThingPending,
      initialRegisters = initialThingRegs,
      eventCodec = thingCodec,
      resolveStreamName = Stream.streamName,
      snapshotPolicy = Never,
      stateCodec = Nothing
    }

thingEventStream :: ThingEventStream
thingEventStream =
  mkEventStreamOrThrow "Thing" thingEventStreamDef