feat: plugins can now disable integrations by marking them as false in the event.integrations

packages/core/src/__tests__/__helpers__/mockSegmentStore.ts

@@ -1,3 +1,4 @@
+import { SEGMENT_DESTINATION_KEY } from '../../plugins/SegmentDestination';
 import type { DeepLinkData, Storage } from '../../storage';
 import type {
   Context,
@@ -21,7 +22,9 @@ const INITIAL_VALUES: Data = {
   isReady: true,
   events: [],
   context: undefined,
-  settings: {},
+  settings: {
+    [SEGMENT_DESTINATION_KEY]: {},
+  },
   userInfo: {
     anonymousId: 'anonymousId',
     userId: undefined,

packages/core/src/__tests__/internal/fetchSettings.test.ts

@@ -1,10 +1,14 @@
 import { getMockLogger } from '../__helpers__/mockLogger';
 import { SegmentClient } from '../../analytics';
 import { MockSegmentStore } from '../__helpers__/mockSegmentStore';
+import { SEGMENT_DESTINATION_KEY } from '../../plugins/SegmentDestination';
 
 describe('internal #getSettings', () => {
   const defaultIntegrationSettings = {
-    integrations: {},
+    integrations: {
+      // This one is injected by the mock
+      [SEGMENT_DESTINATION_KEY]: {},
+    },
   };
   const store = new MockSegmentStore();
 

packages/core/src/plugin.ts

@@ -100,6 +100,19 @@ export class DestinationPlugin extends EventPlugin {
 
   timeline = new Timeline();
 
+  private hasSettings() {
+    return this.analytics?.settings.get()?.[this.key] !== undefined;
+  }
+
+  private isEnabled(event: SegmentEvent): boolean {
+    let customerDisabled = false;
+    if (event.integrations?.[this.key] === false) {
+      customerDisabled = true;
+    }
+
+    return this.hasSettings() && !customerDisabled;
+  }
+
   /**
      Adds a new plugin to the currently loaded set.
 
@@ -141,6 +154,10 @@ export class DestinationPlugin extends EventPlugin {
   }
 
   execute(event: SegmentEvent): SegmentEvent | undefined {
+    if (!this.isEnabled(event)) {
+      return undefined;
+    }
+
     // Apply before and enrichment plugins
     const beforeResult = this.timeline.applyPlugins({
       type: PluginType.before,

packages/core/src/plugins/__tests__/SegmentDestination.test.ts

@@ -53,6 +53,7 @@ describe('SegmentDestination', () => {
           firebase: {
             someConfig: 'someValue',
           },
+          [SEGMENT_DESTINATION_KEY]: {},
         },
       }),
     });
@@ -140,6 +141,7 @@ describe('SegmentDestination', () => {
           firebase: {
             someConfig: 'someValue',
           },
+          [SEGMENT_DESTINATION_KEY]: {},
         },
       }),
     });
@@ -209,4 +211,33 @@ describe('SegmentDestination', () => {
       })),
     });
   });
+
+  it('lets plugins/events disable destinations individually', () => {
+    const plugin = new SegmentDestination();
+    // @ts-ignore
+    plugin.analytics = new SegmentClient({
+      ...clientArgs,
+      store: new MockSegmentStore({
+        settings: {
+          [SEGMENT_DESTINATION_KEY]: {},
+        },
+      }),
+    });
+
+    const event: TrackEventType = {
+      anonymousId: '3534a492-e975-4efa-a18b-3c70c562fec2',
+      event: 'Awesome event',
+      type: EventType.TrackEvent,
+      properties: {},
+      timestamp: '2000-01-01T00:00:00.000Z',
+      messageId: '1d1744bf-5beb-41ac-ad7a-943eac33babc',
+      context: { app: { name: 'TestApp' } },
+      integrations: {
+        [SEGMENT_DESTINATION_KEY]: false,
+      },
+    };
+
+    const result = plugin.execute(event);
+    expect(result).toEqual(undefined);
+  });
 });