feat(cloudflare): Add option to opt out of capturing errors in wrapRequesHandler

Author: Lms24

packages/cloudflare/src/request.ts

@@ -18,6 +18,12 @@ interface RequestHandlerWrapperOptions {
   options: CloudflareOptions;
   request: Request<unknown, IncomingRequestCfProperties<unknown>>;
   context: ExecutionContext;
+  /**
+   * If true, errors will be captured, rethrown and sent to Sentry.
+   * Otherwise, errors are rethrown but not captured.
+   * @default true
+   */
+  captureErrors?: boolean;
 }
 
 /**
@@ -28,7 +34,7 @@ export function wrapRequestHandler(
   handler: (...args: unknown[]) => Response | Promise<Response>,
 ): Promise<Response> {
   return withIsolationScope(async isolationScope => {
-    const { options, request } = wrapperOptions;
+    const { options, request, captureErrors = true } = wrapperOptions;
 
     // In certain situations, the passed context can become undefined.
     // For example, for Astro while prerendering pages at build time.
@@ -67,7 +73,9 @@ export function wrapRequestHandler(
       try {
         return await handler();
       } catch (e) {
-        captureException(e, { mechanism: { handled: false, type: 'cloudflare' } });
+        if (captureErrors) {
+          captureException(e, { mechanism: { handled: false, type: 'cloudflare' } });
+        }
         throw e;
       } finally {
         waitUntil?.(flush(2000));
@@ -91,7 +99,9 @@ export function wrapRequestHandler(
               setHttpStatus(span, res.status);
               return res;
             } catch (e) {
-              captureException(e, { mechanism: { handled: false, type: 'cloudflare' } });
+              if (captureErrors) {
+                captureException(e, { mechanism: { handled: false, type: 'cloudflare' } });
+              }
               throw e;
             } finally {
               waitUntil?.(flush(2000));

packages/cloudflare/test/request.test.ts

@@ -212,6 +212,33 @@ describe('withSentry', () => {
 
       expect(thrownError).toBe(error);
     });
+
+    test("doesn't capture errors if `captureErrors` is false", async () => {
+      const captureExceptionSpy = vi.spyOn(SentryCore, 'captureException');
+      const error = new Error('test');
+
+      expect(captureExceptionSpy).not.toHaveBeenCalled();
+      let thrownError: Error | undefined;
+
+      try {
+        await wrapRequestHandler(
+          {
+            options: MOCK_OPTIONS,
+            request: new Request('https://example.com'),
+            context: createMockExecutionContext(),
+            captureErrors: false,
+          },
+          () => {
+            throw error;
+          },
+        );
+      } catch (e: any) {
+        thrownError = e;
+      }
+
+      expect(captureExceptionSpy).not.toHaveBeenCalled();
+      expect(thrownError).toBe(error);
+    });
   });
 
   describe('tracing instrumentation', () => {