feat(transport): Add buffer size option to native transport

CHANGELOG.md

@@ -2,6 +2,9 @@
 
 ## Unreleased
 
+### Features
+- Add buffer size option to native transport ([#2578](https://github.com/getsentry/sentry-react-native/pull/2578))
+
 ### Dependencies
 
 - Bump Android SDK from v6.5.0 to v6.6.0 ([#2572](https://github.com/getsentry/sentry-react-native/pull/2572))

android/src/main/java/io/sentry/react/RNSentryModule.java

@@ -130,6 +130,12 @@ public void initNativeSdk(final ReadableMap rnOptions, Promise promise) {
             if (rnOptions.hasKey("sendDefaultPii")) {
                 options.setSendDefaultPii(rnOptions.getBoolean("sendDefaultPii"));
             }
+            if (rnOptions.hasKey("transportOptions")) {
+                final ReadableMap transportOptions = rnOptions.getMap("transportOptions");
+                if (transportOptions.hasKey("bufferSize")) {
+                    options.setMaxQueueSize(rnOptions.getInt("bufferSize"));
+                }
+            }
 
             options.setBeforeSend((event, hint) -> {
                 // React native internally throws a JavascriptException

src/js/client.ts

@@ -19,7 +19,7 @@ import { Alert, LogBox, YellowBox } from 'react-native';
 
 import { defaultSdkInfo } from './integrations/sdkinfo';
 import { ReactNativeClientOptions } from './options';
-import { NativeTransport } from './transports/native';
+import { makeReactNativeTransport } from './transports/native';
 import { createUserFeedbackEnvelope, items } from './utils/envelope';
 import { mergeOutcomes } from './utils/outcome';
 import { NATIVE } from './wrapper';
@@ -44,7 +44,7 @@ export class ReactNativeClient extends BaseClient<ReactNativeClientOptions> {
      if (!options.transport) {
        options.transport = (options: BrowserTransportOptions, nativeFetch?: FetchImpl): Transport => {
          if (NATIVE.isNativeTransportAvailable()) {
-           return new NativeTransport();
+           return makeReactNativeTransport(options);
          }
          return makeFetchTransport(options, nativeFetch);
        };

src/js/sdk.tsx

@@ -22,7 +22,7 @@ import { ReactNativeClientOptions, ReactNativeOptions, ReactNativeWrapperOptions
 import { ReactNativeScope } from './scope';
 import { TouchEventBoundary } from './touchevents';
 import { ReactNativeProfiler, ReactNativeTracing } from './tracing';
-import { makeReactNativeTransport } from './transports/native';
+import { DEFAULT_BUFFER_SIZE, makeReactNativeTransport } from './transports/native';
 import { makeUtf8TextEncoder } from './transports/TextEncoder';
 import { safeFactory, safeTracesSampler } from './utils/safe';
 import { RN_GLOBAL_OBJ } from './utils/worldwide';
@@ -40,6 +40,7 @@ const DEFAULT_OPTIONS: ReactNativeOptions = {
   enableOutOfMemoryTracking: true,
   patchGlobalPromise: true,
   transportOptions: {
+    bufferSize: DEFAULT_BUFFER_SIZE,
     textEncoder: makeUtf8TextEncoder(),
   },
   sendClientReports: true,

src/js/transports/native.ts

@@ -3,12 +3,22 @@ import { makePromiseBuffer, PromiseBuffer } from '@sentry/utils';
 
 import { NATIVE } from '../wrapper';
 
+export const DEFAULT_BUFFER_SIZE = 30;
+
 export type BaseNativeTransport = BaseTransportOptions
 
+export interface BaseNativeTransportOptions {
+  bufferSize?: number;
+}
+
 /** Native Transport class implementation */
 export class NativeTransport implements Transport {
   /** A simple buffer holding all requests. */
-  protected readonly _buffer: PromiseBuffer<void> = makePromiseBuffer(30);
+  protected readonly _buffer: PromiseBuffer<void>;
+
+  public constructor(options: BaseNativeTransportOptions = {}) {
+    this._buffer = makePromiseBuffer(options.bufferSize || DEFAULT_BUFFER_SIZE);
+  }
 
   /**
    * Sends the envelope to the Store endpoint in Sentry.
@@ -35,4 +45,6 @@ export class NativeTransport implements Transport {
 /**
  * Creates a Native Transport.
  */
-export function makeReactNativeTransport(): NativeTransport { return new NativeTransport(); }
+export function makeReactNativeTransport(options: BaseNativeTransportOptions = {}): NativeTransport {
+  return new NativeTransport(options);
+}

test/sdk.test.ts

@@ -62,7 +62,7 @@ jest.spyOn(logger, 'error');
 
 import { initAndBind } from '@sentry/core';
 import { getCurrentHub } from '@sentry/react';
-import { Integration, Scope } from '@sentry/types';
+import { BaseTransportOptions,ClientOptions, Integration, Scope  } from '@sentry/types';
 
 import { ReactNativeClientOptions } from '../src/js/options';
 import { configureScope,flush, init, withScope } from '../src/js/sdk';
@@ -179,6 +179,29 @@ describe('Tests the SDK functionality', () => {
         }
       });
     });
+
+    describe('transport options buffer size', () => {
+      const usedOptions = (): ClientOptions<BaseTransportOptions> | undefined => {
+        return mockedInitAndBind.mock.calls[0]?.[1];
+      }
+
+      it('uses default transport options buffer size', () => {
+        init({
+          tracesSampleRate: 0.5,
+          enableAutoPerformanceTracking: true,
+        });
+        expect(usedOptions()?.transportOptions?.bufferSize).toBe(30);
+      });
+
+      it('uses custom transport options buffer size', () => {
+        init({
+          transportOptions: {
+            bufferSize: 99,
+          },
+        });
+        expect(usedOptions()?.transportOptions?.bufferSize).toBe(99);
+      });
+    });
   });
 
   describe('initIsSafe', () => {