Function resultCodecFor

packages/infra/src/WorkflowEngineCosmos.ts:210–217

(workflow: Workflow.Any)

    S.fromJsonString(S.toCodecJson(Workflow.Result({ success: workflow.successSchema, error: workflow.errorSchema })))
  const resultCodecCache = new Map<string, ReturnType<typeof makeResultCodec>>()
  const resultCodecFor = (workflow: Workflow.Any) => {
    let c = resultCodecCache.get(workflow._tag)
    if (!c) {
      c = makeResultCodec(workflow)
      resultCodecCache.set(workflow._tag, c)
    }
    return c
  }

  const encodePayload = (workflow: Workflow.Any, payload: object) =>
    Effect.orDie(S.encodeEffect(payloadCodecFor(workflow))(payload)) as Effect.Effect<string>