{"version":3,"file":"spanstreaming.js","sources":["../../../../../src/integrations/spanstreaming.ts"],"sourcesContent":["import type { IntegrationFn } from '@sentry/core/browser';\nimport {\n  captureSpan,\n  debug,\n  defineIntegration,\n  hasSpanStreamingEnabled,\n  isStreamedBeforeSendSpanCallback,\n  SpanBuffer,\n  spanIsSampled,\n} from '@sentry/core/browser';\nimport { DEBUG_BUILD } from '../debug-build';\n\nexport const spanStreamingIntegration = defineIntegration(() => {\n  return {\n    name: 'SpanStreaming',\n\n    beforeSetup(client) {\n      // If users only set spanStreamingIntegration, without traceLifecycle, we set it to \"stream\" for them.\n      // This avoids the classic double-opt-in problem we'd otherwise have in the browser SDK.\n      const clientOptions = client.getOptions();\n      if (!clientOptions.traceLifecycle) {\n        DEBUG_BUILD && debug.log('[SpanStreaming] setting `traceLifecycle` to \"stream\"');\n        clientOptions.traceLifecycle = 'stream';\n      }\n    },\n\n    setup(client) {\n      const initialMessage = 'SpanStreaming integration requires';\n      const fallbackMsg = 'Falling back to static trace lifecycle.';\n      const clientOptions = client.getOptions();\n\n      if (!hasSpanStreamingEnabled(client)) {\n        clientOptions.traceLifecycle = 'static';\n        DEBUG_BUILD && debug.warn(`${initialMessage} \\`traceLifecycle\\` to be set to \"stream\"! ${fallbackMsg}`);\n        return;\n      }\n\n      const beforeSendSpan = clientOptions.beforeSendSpan;\n      // If users misconfigure their SDK by opting into span streaming but\n      // using an incompatible beforeSendSpan callback, we fall back to the static trace lifecycle.\n      if (beforeSendSpan && !isStreamedBeforeSendSpanCallback(beforeSendSpan)) {\n        clientOptions.traceLifecycle = 'static';\n        DEBUG_BUILD &&\n          debug.warn(`${initialMessage} a beforeSendSpan callback using \\`withStreamedSpan\\`! ${fallbackMsg}`);\n        return;\n      }\n\n      const buffer = new SpanBuffer(client);\n\n      client.on('afterSpanEnd', span => {\n        // Negatively sampled spans must not be captured.\n        // This happens because OTel and we create non-recording spans for negatively sampled spans\n        // that go through the same life cycle as recording spans.\n        if (!spanIsSampled(span)) {\n          return;\n        }\n        buffer.add(captureSpan(span, client));\n      });\n\n      // In addition to capturing the span, we also flush the trace when the segment\n      // span ends to ensure things are sent timely. We never know when the browser\n      // is closed, users navigate away, etc.\n      client.on('afterSegmentSpanEnd', segmentSpan => {\n        const traceId = segmentSpan.spanContext().traceId;\n        setTimeout(() => {\n          buffer.flush(traceId);\n        }, 500);\n      });\n    },\n  };\n}) satisfies IntegrationFn;\n"],"names":["defineIntegration","DEBUG_BUILD","debug","hasSpanStreamingEnabled","isStreamedBeforeSendSpanCallback","SpanBuffer","spanIsSampled","captureSpan"],"mappings":";;;;;AAYO,MAAM,wBAAA,GAA2BA,0BAAkB,MAAM;AAC9D,EAAA,OAAO;AAAA,IACL,IAAA,EAAM,eAAA;AAAA,IAEN,YAAY,MAAA,EAAQ;AAGlB,MAAA,MAAM,aAAA,GAAgB,OAAO,UAAA,EAAW;AACxC,MAAA,IAAI,CAAC,cAAc,cAAA,EAAgB;AACjC,QAAAC,sBAAA,IAAeC,aAAA,CAAM,IAAI,sDAAsD,CAAA;AAC/E,QAAA,aAAA,CAAc,cAAA,GAAiB,QAAA;AAAA,MACjC;AAAA,IACF,CAAA;AAAA,IAEA,MAAM,MAAA,EAAQ;AACZ,MAAA,MAAM,cAAA,GAAiB,oCAAA;AACvB,MAAA,MAAM,WAAA,GAAc,yCAAA;AACpB,MAAA,MAAM,aAAA,GAAgB,OAAO,UAAA,EAAW;AAExC,MAAA,IAAI,CAACC,+BAAA,CAAwB,MAAM,CAAA,EAAG;AACpC,QAAA,aAAA,CAAc,cAAA,GAAiB,QAAA;AAC/B,QAAAF,sBAAA,IAAeC,cAAM,IAAA,CAAK,CAAA,EAAG,cAAc,CAAA,2CAAA,EAA8C,WAAW,CAAA,CAAE,CAAA;AACtG,QAAA;AAAA,MACF;AAEA,MAAA,MAAM,iBAAiB,aAAA,CAAc,cAAA;AAGrC,MAAA,IAAI,cAAA,IAAkB,CAACE,wCAAA,CAAiC,cAAc,CAAA,EAAG;AACvE,QAAA,aAAA,CAAc,cAAA,GAAiB,QAAA;AAC/B,QAAAH,sBAAA,IACEC,cAAM,IAAA,CAAK,CAAA,EAAG,cAAc,CAAA,uDAAA,EAA0D,WAAW,CAAA,CAAE,CAAA;AACrG,QAAA;AAAA,MACF;AAEA,MAAA,MAAM,MAAA,GAAS,IAAIG,kBAAA,CAAW,MAAM,CAAA;AAEpC,MAAA,MAAA,CAAO,EAAA,CAAG,gBAAgB,CAAA,IAAA,KAAQ;AAIhC,QAAA,IAAI,CAACC,qBAAA,CAAc,IAAI,CAAA,EAAG;AACxB,UAAA;AAAA,QACF;AACA,QAAA,MAAA,CAAO,GAAA,CAAIC,mBAAA,CAAY,IAAA,EAAM,MAAM,CAAC,CAAA;AAAA,MACtC,CAAC,CAAA;AAKD,MAAA,MAAA,CAAO,EAAA,CAAG,uBAAuB,CAAA,WAAA,KAAe;AAC9C,QAAA,MAAM,OAAA,GAAU,WAAA,CAAY,WAAA,EAAY,CAAE,OAAA;AAC1C,QAAA,UAAA,CAAW,MAAM;AACf,UAAA,MAAA,CAAO,MAAM,OAAO,CAAA;AAAA,QACtB,GAAG,GAAG,CAAA;AAAA,MACR,CAAC,CAAA;AAAA,IACH;AAAA,GACF;AACF,CAAC;;;;"}