fixes

Author: mydea

packages/cloudflare/src/transport.ts

@@ -1,13 +1,5 @@
-import type {
-  BaseTransportOptions,
-  Transport,
-  TransportMakeRequestResponse,
-  TransportRequest} from '@sentry/core';
-import {
-  SENTRY_BUFFER_FULL_ERROR,
-  createTransport,
-  suppressTracing,
-} from '@sentry/core';
+import type { BaseTransportOptions, Transport, TransportMakeRequestResponse, TransportRequest } from '@sentry/core';
+import { SENTRY_BUFFER_FULL_ERROR, createTransport, suppressTracing } from '@sentry/core';
 
 export interface CloudflareTransportOptions extends BaseTransportOptions {
   /** Fetch API init parameters. */

packages/cloudflare/test/transport.test.ts

@@ -1,4 +1,4 @@
-import { createEnvelope, serializeEnvelope } from '@sentry/core';
+import { SENTRY_BUFFER_FULL_ERROR, createEnvelope, serializeEnvelope } from '@sentry/core';
 import type { EventEnvelope, EventItem } from '@sentry/core';
 import { afterAll, describe, expect, it, vi } from 'vitest';
 
@@ -140,7 +140,12 @@ describe('IsolatedPromiseBuffer', () => {
     await ipb.add(task2);
     await ipb.add(task3);
 
-    await expect(ipb.add(task4)).rejects.toThrowError('Not adding Promise because buffer limit was reached.');
+    try {
+      await ipb.add(task4);
+      throw new Error('Should not be called');
+    } catch (error) {
+      expect(error).toBe(SENTRY_BUFFER_FULL_ERROR);
+    }
   });
 
   it('should not throw when one of the tasks throws when drained', async () => {

packages/core/src/utils-hoist/promisebuffer.ts

@@ -8,7 +8,7 @@ export interface PromiseBuffer<T> {
   drain(timeout?: number): PromiseLike<boolean>;
 }
 
-export const SENTRY_BUFFER_FULL_ERROR = Symbol('SentryBufferFullError');
+export const SENTRY_BUFFER_FULL_ERROR = Symbol.for('SentryBufferFullError');
 
 /**
  * Creates an new PromiseBuffer object with the specified limit

packages/vercel-edge/src/transports/index.ts

@@ -1,13 +1,5 @@
-import type {
-  BaseTransportOptions,
-  Transport,
-  TransportMakeRequestResponse,
-  TransportRequest} from '@sentry/core';
-import {
-  SENTRY_BUFFER_FULL_ERROR,
-  createTransport,
-  suppressTracing,
-} from '@sentry/core';
+import type { BaseTransportOptions, Transport, TransportMakeRequestResponse, TransportRequest } from '@sentry/core';
+import { SENTRY_BUFFER_FULL_ERROR, createTransport, suppressTracing } from '@sentry/core';
 
 export interface VercelEdgeTransportOptions extends BaseTransportOptions {
   /** Fetch API init parameters. */

packages/vercel-edge/test/transports/index.test.ts

@@ -1,6 +1,6 @@
 import { afterAll, describe, expect, it, vi } from 'vitest';
 
-import { createEnvelope, serializeEnvelope } from '@sentry/core';
+import { SENTRY_BUFFER_FULL_ERROR, createEnvelope, serializeEnvelope } from '@sentry/core';
 import type { EventEnvelope, EventItem } from '@sentry/core';
 
 import type { VercelEdgeTransportOptions } from '../../src/transports';
@@ -139,7 +139,12 @@ describe('IsolatedPromiseBuffer', () => {
     await ipb.add(task2);
     await ipb.add(task3);
 
-    await expect(ipb.add(task4)).rejects.toThrowError('Not adding Promise because buffer limit was reached.');
+    try {
+      await ipb.add(task4);
+      throw new Error('Should not be called');
+    } catch (error) {
+      expect(error).toBe(SENTRY_BUFFER_FULL_ERROR);
+    }
   });
 
   it('should not throw when one of the tasks throws when drained', async () => {