feat: disableOnFail

src/dispatch/Dispatch.ts

@@ -235,7 +235,9 @@ export class Dispatch {
         // The handler has run out of retries. We adhere to our convention to
         // fail safe by disabling dispatch. This ensures that we will not
         // continue to attempt requests when the problem is not recoverable.
-        this.disable();
+        if (this.config.disableOnFail) {
+            this.disable();
+        }
         throw e;
     };
 

src/dispatch/__tests__/Dispatch.test.ts

@@ -419,7 +419,7 @@ describe('Dispatch tests', () => {
         );
     });
 
-    test('when a fetch request is rejected then dispatch is disabled', async () => {
+    test('when a fetch request is rejected and disableOnFaile=true then dispatch is disabled', async () => {
         // Init
         const ERROR = 'Something went wrong.';
         const sendFetch = jest.fn(() => Promise.reject(ERROR));
@@ -438,7 +438,11 @@ describe('Dispatch tests', () => {
             eventCache,
             {
                 ...DEFAULT_CONFIG,
-                ...{ dispatchInterval: Utils.AUTO_DISPATCH_OFF, retries: 0 }
+                ...{
+                    dispatchInterval: Utils.AUTO_DISPATCH_OFF,
+                    retries: 0,
+                    disableOnFail: true
+                }
             }
         );
         dispatch.setAwsCredentials(Utils.createAwsCredentials());
@@ -449,6 +453,44 @@ describe('Dispatch tests', () => {
 
         // Assert
         await expect(dispatch.dispatchFetch()).resolves.toEqual(undefined);
+        expect((dispatch as unknown as any).enabled).toBe(false);
+    });
+
+    test('when a fetch request is rejected and disableOnFail=false then dispatch is not disabled', async () => {
+        // Init
+        const ERROR = 'Something went wrong.';
+        const sendFetch = jest.fn(() => Promise.reject(ERROR));
+        (DataPlaneClient as any).mockImplementation(() => {
+            return {
+                sendFetch
+            };
+        });
+
+        const eventCache: EventCache =
+            Utils.createDefaultEventCacheWithEvents();
+
+        const dispatch = new Dispatch(
+            Utils.AWS_RUM_REGION,
+            Utils.AWS_RUM_ENDPOINT,
+            eventCache,
+            {
+                ...DEFAULT_CONFIG,
+                ...{
+                    dispatchInterval: Utils.AUTO_DISPATCH_OFF,
+                    retries: 0,
+                    disableOnFail: false
+                }
+            }
+        );
+        dispatch.setAwsCredentials(Utils.createAwsCredentials());
+
+        // Run
+        await expect(dispatch.dispatchFetch()).rejects.toEqual(ERROR);
+        eventCache.recordEvent('com.amazon.rum.event1', {});
+
+        // Assert
+        await expect(dispatch.dispatchFetch()).rejects.toEqual(ERROR);
+        expect((dispatch as unknown as any).enabled).toBe(true);
     });
 
     test('when signing is disabled then credentials are not needed for dispatch', async () => {

src/orchestration/Orchestration.ts

@@ -72,6 +72,7 @@ export const defaultConfig = (cookieAttributes: CookieAttributes): Config => {
         client: INSTALL_MODULE,
         cookieAttributes,
         disableAutoPageView: false,
+        disableOnFail: true,
         dispatchInterval: 5 * 1000,
         enableRumClient: true,
         enableXRay: false,
@@ -115,6 +116,7 @@ export interface Config {
     cookieAttributes: CookieAttributes;
     sessionAttributes: { [k: string]: string | number | boolean };
     disableAutoPageView: boolean;
+    disableOnFail: boolean;
     dispatchInterval: number;
     enableRumClient: boolean;
     enableXRay: boolean;

src/orchestration/__tests__/Orchestration.test.ts

@@ -175,6 +175,7 @@ describe('Orchestration tests', () => {
             sessionAttributes: {},
             telemetries: [],
             disableAutoPageView: false,
+            disableOnFail: true,
             dispatchInterval: 5000,
             enableXRay: false,
             endpoint: 'https://dataplane.rum.us-west-2.amazonaws.com',