fix(nestjs): create websocket handler inside isolation scope

Author: faizansaiyed123

packages/nestjs/src/setup.ts

@@ -9,7 +9,7 @@ import type {
 import { Catch, Global, HttpException, Injectable, Logger, Module } from '@nestjs/common';
 import { APP_INTERCEPTOR, BaseExceptionFilter } from '@nestjs/core';
 import { captureException, debug, getDefaultIsolationScope, getIsolationScope, isObjectLike, withIsolationScope } from '@sentry/core';
-import type { Observable } from 'rxjs';
+import { Observable } from 'rxjs';
 import { isExpectedError, isWsOrRpcException } from './helpers';
 
 // Partial extract of FastifyRequest interface
@@ -53,21 +53,18 @@ class SentryTracingInterceptor implements NestInterceptor {
       const client = wsHost.getClient<{ nsp?: { name?: string } }>();
       const pattern = wsHost.getPattern?.();
 
-      const source = next.handle();
-      return source.lift({
-        call(subscriber, source) {
-          return withIsolationScope(isolationScope => {
-            if (pattern) {
-              const namespace = client?.nsp?.name;
-              isolationScope.setTransactionName(
-                namespace ? `WS ${namespace} ${pattern}` : `WS ${pattern}`,
-              );
-            }
-
-            return source.subscribe(subscriber);
-          });
-        },
-      });
+      if (!pattern) {
+        return next.handle();
+      }
+
+      return new Observable(subscriber =>
+        withIsolationScope(isolationScope => {
+          const namespace = client?.nsp?.name;
+          isolationScope.setTransactionName(namespace ? `WS ${namespace} ${pattern}` : `WS ${pattern}`);
+
+          return next.handle().subscribe(subscriber);
+        }),
+      );
     }
 
     if (getIsolationScope() === getDefaultIsolationScope()) {