EventStream.hs

-- @generated by keiro-dsl 0.21.0.0 (language keiro-dsl 4) from aggregate Assignment; do not edit.
module Proof.WorkspaceProof.Assignment.Generated.EventStream
  ( assignmentCategory
  , assignmentCommandCategory
  , assignmentEventStream
  , assignmentEventStreamDef
  , AssignmentEventStream
  , AssignmentEventStreamDef
  ) where

import Proof.WorkspaceProof.Assignment.Generated.Domain
import Proof.WorkspaceProof.Assignment.Generated.Codec (assignmentCodec)
import Proof.WorkspaceProof.Assignment.Generated.Transducer (assignmentTransducer)
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.
assignmentCategory :: Stream.StreamCategory AssignmentEventStreamDef
assignmentCategory = Stream.categoryUnsafe "assignment"

-- The same category text, typed for command envelopes such as PMCommand.
assignmentCommandCategory :: Stream.StreamCategory AssignmentCommand
assignmentCommandCategory = Stream.categoryUnsafe "assignment"

type AssignmentEventStreamDef =
  EventStream (HsPred AssignmentRegs AssignmentCommand) AssignmentRegs AssignmentVertex AssignmentCommand AssignmentEvent

type AssignmentEventStream =
  ValidatedEventStream (HsPred AssignmentRegs AssignmentCommand) AssignmentRegs AssignmentVertex AssignmentCommand AssignmentEvent

assignmentEventStreamDef :: AssignmentEventStreamDef
assignmentEventStreamDef =
  EventStream
    { transducer = assignmentTransducer,
      initialState = AssignmentActive,
      initialRegisters = initialAssignmentRegs,
      eventCodec = assignmentCodec,
      resolveStreamName = Stream.streamName,
      snapshotPolicy = Never,
      stateCodec = Nothing
    }

assignmentEventStream :: AssignmentEventStream
assignmentEventStream =
  mkEventStreamOrThrow "Assignment" assignmentEventStreamDef