Function payloadCodecFor

packages/infra/src/WorkflowEngineSqlite.ts:231–238

(workflow: Workflow.Any)

  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)
    if (!c) {
      c = makePayloadCodec(workflow)
      payloadCodecCache.set(workflow._tag, c)
    }
    return c
  }

  const makeResultCodec = (workflow: Workflow.Any) =>
    S.fromJsonString(S.toCodecJson(Workflow.Result({ success: workflow.successSchema, error: workflow.errorSchema })))