Function capture

packages/core/api/src/observability.ts:95–119

(
  eff: Effect.Effect<A, E, R>,
)

 * through unchanged.
 */
export const capture = <A, E, R>(
  eff: Effect.Effect<A, E, R>,
): Effect.Effect<A, Exclude<E, StorageFailure> | InternalError, R> =>
  (eff as Effect.Effect<A, E | StorageFailure, R>).pipe(
    // oxlint-disable-next-line executor/no-effect-escape-hatch -- boundary: unique conflicts that reach the HTTP edge are unexpected defects captured by observabilityMiddleware
    Effect.catchTag("UniqueViolationError", (err) => Effect.die(err)),
    Effect.catchTag("CredentialWriteIncompleteError", (err) =>
      resolveCapture.pipe(
        Effect.flatMap((c) => c.captureException(Cause.fail(err))),
        Effect.flatMap((traceId) => Effect.fail(new InternalError({ traceId, retryable: true }))),
      ),
    ),
    Effect.catchTag("StorageError", (err) =>
      resolveCapture.pipe(
        Effect.flatMap((c) => c.captureException(Cause.fail(err))),
        Effect.flatMap((traceId) => Effect.fail(new InternalError({ traceId }))),
      ),
    ),
    Effect.catchTag("StorageConnectionError", (err) =>
      resolveCapture.pipe(
        Effect.flatMap((c) => c.captureException(Cause.fail(err))),
        Effect.flatMap((traceId) => Effect.fail(new InternalError({ traceId }))),
      ),
    ),
  ) as Effect.Effect<A, Exclude<E, StorageFailure> | InternalError, R>;

/**
 * Translate an engine/runtime-level `YieldableError` (CodeExecutionError,