EventStream.hs

-- @generated by keiro-dsl 0.9.0.0 (language keiro-dsl 4) from aggregate ProjectArtifact; do not edit.
module Generated.WorkspaceNominalProof.ProjectArtifact.EventStream
  ( projectArtifactCategory
  , projectArtifactCommandCategory
  , projectArtifactEventStream
  , projectArtifactEventStreamDef
  , ProjectArtifactEventStream
  , ProjectArtifactEventStreamDef
  ) where

import Generated.WorkspaceNominalProof.ProjectArtifact.Domain
import Generated.WorkspaceNominalProof.ProjectArtifact.Codec (projectArtifactCodec)
import Generated.WorkspaceNominalProof.ProjectArtifact.Transducer (projectArtifactFoldFingerprint, projectArtifactTransducer)
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.
projectArtifactCategory :: Stream.StreamCategory ProjectArtifactEventStreamDef
projectArtifactCategory = Stream.categoryUnsafe "projectArtifact"

-- The same category text, typed for command envelopes such as PMCommand.
projectArtifactCommandCategory :: Stream.StreamCategory ProjectArtifactCommand
projectArtifactCommandCategory = Stream.categoryUnsafe "projectArtifact"

type ProjectArtifactEventStreamDef =
  EventStream (HsPred ProjectArtifactRegs ProjectArtifactCommand) ProjectArtifactRegs ProjectArtifactVertex ProjectArtifactCommand ProjectArtifactEvent

type ProjectArtifactEventStream =
  ValidatedEventStream (HsPred ProjectArtifactRegs ProjectArtifactCommand) ProjectArtifactRegs ProjectArtifactVertex ProjectArtifactCommand ProjectArtifactEvent

projectArtifactEventStreamDef :: ProjectArtifactEventStreamDef
projectArtifactEventStreamDef =
  EventStream
    { transducer = projectArtifactTransducer,
      initialState = ProjectArtifactEmpty,
      initialRegisters = initialProjectArtifactRegs,
      eventCodec = projectArtifactCodec,
      resolveStreamName = Stream.streamName,
      snapshotPolicy = Never,
      stateCodec = Nothing
    }

projectArtifactEventStream :: ProjectArtifactEventStream
projectArtifactEventStream =
  mkEventStreamOrThrow "ProjectArtifact" projectArtifactEventStreamDef