EventStream.hs

-- @generated by keiro-dsl 0.9.0.0 (language keiro-dsl 4) from aggregate Page; do not edit.
module Generated.IncidentPaging.Page.EventStream
  ( pageCategory
  , pageCommandCategory
  , pageEventStream
  , pageEventStreamDef
  , PageEventStream
  , PageEventStreamDef
  ) where

import Generated.IncidentPaging.Page.Domain
import Generated.IncidentPaging.Page.Codec (pageCodec)
import Generated.IncidentPaging.Page.Transducer (pageFoldFingerprint, pageTransducer)
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.
pageCategory :: Stream.StreamCategory PageEventStreamDef
pageCategory = Stream.categoryUnsafe "page"

-- The same category text, typed for command envelopes such as PMCommand.
pageCommandCategory :: Stream.StreamCategory PageCommand
pageCommandCategory = Stream.categoryUnsafe "page"

type PageEventStreamDef =
  EventStream (HsPred PageRegs PageCommand) PageRegs PageVertex PageCommand PageEvent

type PageEventStream =
  ValidatedEventStream (HsPred PageRegs PageCommand) PageRegs PageVertex PageCommand PageEvent

pageEventStreamDef :: PageEventStreamDef
pageEventStreamDef =
  EventStream
    { transducer = pageTransducer,
      initialState = PagePending,
      initialRegisters = initialPageRegs,
      eventCodec = pageCodec,
      resolveStreamName = Stream.streamName,
      snapshotPolicy = Never,
      stateCodec = Nothing
    }

pageEventStream :: PageEventStream
pageEventStream =
  mkEventStreamOrThrow "Page" pageEventStreamDef