EventStream.hs

-- @generated by keiro-dsl 0.9.0.0 (language keiro-dsl 4) from aggregate Project; do not edit.
module Generated.WorkspaceNominalProof.Project.EventStream
  ( projectCategory
  , projectCommandCategory
  , projectEventStream
  , projectEventStreamDef
  , ProjectEventStream
  , ProjectEventStreamDef
  ) where

import Generated.WorkspaceNominalProof.Project.Domain
import Generated.WorkspaceNominalProof.Project.Codec (projectCodec)
import Generated.WorkspaceNominalProof.Project.Transducer (projectFoldFingerprint, projectTransducer)
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.
projectCategory :: Stream.StreamCategory ProjectEventStreamDef
projectCategory = Stream.categoryUnsafe "project"

-- The same category text, typed for command envelopes such as PMCommand.
projectCommandCategory :: Stream.StreamCategory ProjectCommand
projectCommandCategory = Stream.categoryUnsafe "project"

type ProjectEventStreamDef =
  EventStream (HsPred ProjectRegs ProjectCommand) ProjectRegs ProjectVertex ProjectCommand ProjectEvent

type ProjectEventStream =
  ValidatedEventStream (HsPred ProjectRegs ProjectCommand) ProjectRegs ProjectVertex ProjectCommand ProjectEvent

projectEventStreamDef :: ProjectEventStreamDef
projectEventStreamDef =
  EventStream
    { transducer = projectTransducer,
      initialState = ProjectEmpty,
      initialRegisters = initialProjectRegs,
      eventCodec = projectCodec,
      resolveStreamName = Stream.streamName,
      snapshotPolicy = Never,
      stateCodec = Nothing
    }

projectEventStream :: ProjectEventStream
projectEventStream =
  mkEventStreamOrThrow "Project" projectEventStreamDef