Function observabilityMiddleware

packages/core/api/src/observability.ts:150–167

(
  _api: HttpApi.HttpApi<Id, Groups>,
)

) {}

export const observabilityMiddleware = <Id extends string, Groups extends HttpApiGroup.Any>(
  _api: HttpApi.HttpApi<Id, Groups>,
): Layer.Layer<ObservabilityMiddleware> =>
  Layer.succeed(ObservabilityMiddleware, (httpApp) =>
    Effect.catchCause(httpApp, (cause) =>
      Effect.gen(function* () {
        const defect = Cause.findDefect(cause);
        if (Result.isFailure(defect)) {
          return yield* Effect.failCause(cause);
        }
        const c = yield* resolveCapture;
        const traceId = yield* c.captureException(cause);
        return HttpServerResponse.jsonUnsafe(new InternalError({ traceId }), {
          status: 500,
        });
      }),
    ),
  );