auto set for http

Author: mydea

packages/node-experimental/src/integrations/http.ts

@@ -4,12 +4,16 @@ import { SpanKind } from '@opentelemetry/api';
 import { registerInstrumentations } from '@opentelemetry/instrumentation';
 import { HttpInstrumentation } from '@opentelemetry/instrumentation-http';
 import { hasTracingEnabled, isSentryRequestUrl } from '@sentry/core';
-import { _INTERNAL, getClient, getCurrentHub, getSpanKind, setSpanMetadata } from '@sentry/opentelemetry';
+import { _INTERNAL, getClient, getCurrentHub, getSpanKind, getSpanScope, setSpanMetadata } from '@sentry/opentelemetry';
 import type { EventProcessor, Hub, Integration } from '@sentry/types';
 import { stringMatchesSomePattern } from '@sentry/utils';
 
+import { getSpanContext } from '@opentelemetry/api/build/src/trace/context-utils';
+import { getIsolationScope, setIsolationScope } from '../sdk/api';
+import { Scope } from '../sdk/scope';
 import type { NodeExperimentalClient } from '../types';
 import { addOriginToSpan } from '../utils/addOriginToSpan';
+import { getScopesFromContext } from '../utils/contextData';
 import { getRequestUrl } from '../utils/getRequestUrl';
 
 interface HttpOptions {
@@ -127,6 +131,11 @@ export class Http implements Integration {
           requireParentforIncomingSpans: false,
           requestHook: (span, req) => {
             this._updateSpan(span, req);
+
+            // Update the isolation scope, isolation this request
+            if (getSpanKind(span) === SpanKind.SERVER) {
+              setIsolationScope(Scope.clone(getIsolationScope()));
+            }
           },
           responseHook: (span, res) => {
             this._addRequestBreadcrumb(span, res);

packages/node-experimental/src/sdk/api.ts

@@ -68,6 +68,14 @@ export function getIsolationScope(): Scope {
   return getScopes().isolationScope;
 }
 
+/**
+ * Set the currently active isolation scope.
+ * Use this with caution! As it updates the isolation scope for the current execution context.
+ */
+export function setIsolationScope(isolationScope: Scope): void {
+  getScopes().isolationScope = isolationScope;
+}
+
 /**
  * Fork a scope from the current scope, and make it the current scope in the given callback
  */