Function makePayloadCodec

packages/infra/src/WorkflowEngineSqlite.ts:229–229

(workflow: Workflow.Any)

  // workflow name; derived from the workflow's own schemas so typed values
  // (dates, branded ids, schema classes) survive the storage round-trip.
  const makePayloadCodec = (workflow: Workflow.Any) => S.fromJsonString(S.toCodecJson(workflow.payloadSchema))
  const payloadCodecCache = new Map<string, ReturnType<typeof makePayloadCodec>>()
  const payloadCodecFor = (workflow: Workflow.Any) => {
    let c = payloadCodecCache.get(workflow._tag)