aggregate-scalars.keiro

language keiro-dsl 4
context aggregate-scalars

aggregate ScalarLedger
  regs
    observedAt Time = "2026-01-02T03:04:05.123456789012Z"
    revision Natural = 0
  states Empty Recorded!

  command Record { observedAt:Time revision:Natural }
  event ScalarsRecorded { observedAt:Time revision:Natural }
  event FieldIdentityObserved {
    as:Text
    family:Text
    mdo:Text
    proc:Text
    qualified:Text
    rec:Text
    safe:Text
    signature:Text
    stock:Text
    unsafe:Text
    via:Text
    type haskell payloadType:Text
    region haskell serviceRegion as "region_code":Text
  }

  Empty -- Record -->
    guard cmd.observedAt >= reg.observedAt && cmd.revision >= reg.revision
    write observedAt := cmd.observedAt
    write revision := cmd.revision
    emit ScalarsRecorded
    goto Recorded

  wire kind=ctorName fields=camelCase schemaVersion=1
  snapshot every 1
    state-codec version=1 shape-hash="aggregate-scalars-v1"