Support destination filters for device mode action destinations

.changeset/silver-mugs-provide.md

@@ -0,0 +1,5 @@
+---
+'@segment/analytics-next': minor
+---
+
+Added destination filter support to action destinations

packages/browser/package.json

@@ -43,7 +43,7 @@
   "size-limit": [
     {
       "path": "dist/umd/index.js",
-      "limit": "25.95 KB"
+      "limit": "27 KB"
     }
   ],
   "dependencies": {

packages/browser/src/browser/index.ts

@@ -105,6 +105,13 @@ function hasLegacyDestinations(settings: LegacySettings): boolean {
   )
 }
 
+function hasTsubMiddleware(settings: LegacySettings): boolean {
+  return (
+    getProcessEnv().NODE_ENV !== 'test' &&
+    (settings.middlewareSettings?.routingRules?.length ?? 0) > 0
+  )
+}
+
 /**
  * With AJS classic, we allow users to call setAnonymousId before the library initialization.
  * This is important because some of the destinations will use the anonymousId during the initialization,
@@ -146,11 +153,26 @@ async function registerPlugins(
   options: InitOptions,
   plugins: Plugin[]
 ): Promise<Context> {
+  const tsubMiddleware = hasTsubMiddleware(legacySettings)
+    ? await import(
+        /* webpackChunkName: "tsub-middleware" */ '../plugins/routing-middleware'
+      ).then((mod) => {
+        return mod.tsubMiddleware(
+          legacySettings.middlewareSettings!.routingRules
+        )
+      })
+    : undefined
+
   const legacyDestinations = hasLegacyDestinations(legacySettings)
     ? await import(
         /* webpackChunkName: "ajs-destination" */ '../plugins/ajs-destination'
       ).then((mod) => {
-        return mod.ajsDestinations(legacySettings, analytics.integrations, opts)
+        return mod.ajsDestinations(
+          legacySettings,
+          analytics.integrations,
+          opts,
+          tsubMiddleware
+        )
       })
     : []
 
@@ -175,7 +197,8 @@ async function registerPlugins(
     legacySettings,
     analytics.integrations,
     mergedSettings,
-    options.obfuscate
+    options.obfuscate,
+    tsubMiddleware
   ).catch(() => [])
 
   const toRegister = [

packages/browser/src/core/plugin/index.ts

@@ -15,6 +15,7 @@ export interface Plugin {
   name: string
   version: string
   type: 'before' | 'after' | 'destination' | 'enrichment' | 'utility'
+  alternativeNames?: string[]
 
   isLoaded: () => boolean
   load: (

packages/browser/src/core/queue/delivery.ts

@@ -1,3 +1,4 @@
+import { ActionDestination } from '../../plugins/remote-loader'
 import { Context, ContextCancelation } from '../context'
 import { Plugin } from '../plugin'
 
@@ -13,9 +14,12 @@ async function tryOperation(
 
 export function attempt(
   ctx: Context,
-  plugin: Plugin
+  plugin: Plugin | ActionDestination
 ): Promise<Context | ContextCancelation | Error | undefined> {
-  ctx.log('debug', 'plugin', { plugin: plugin.name })
+  const name = 'action' in plugin ? plugin.action.name : plugin.name
+
+  ctx.log('debug', 'plugin', { plugin: name })
+
   const start = new Date().getTime()
 
   const hook = plugin[ctx.event.type]
@@ -26,7 +30,7 @@ export function attempt(
   const newCtx = tryOperation(() => hook.apply(plugin, [ctx]))
     .then((ctx) => {
       const done = new Date().getTime() - start
-      ctx.stats.gauge('plugin_time', done, [`plugin:${plugin.name}`])
+      ctx.stats.gauge('plugin_time', done, [`plugin:${name}`])
       return ctx
     })
     .catch((err) => {
@@ -39,19 +43,19 @@ export function attempt(
 
       if (err instanceof ContextCancelation) {
         ctx.log('warn', err.type, {
-          plugin: plugin.name,
+          plugin: name,
           error: err,
         })
 
         return err
       }
 
       ctx.log('error', 'plugin Error', {
-        plugin: plugin.name,
+        plugin: name,
         error: err,
       })
 
-      ctx.stats.increment('plugin_error', 1, [`plugin:${plugin.name}`])
+      ctx.stats.increment('plugin_error', 1, [`plugin:${name}`])
       return err as Error
     })
 

packages/browser/src/core/queue/event-queue.ts

@@ -232,9 +232,14 @@ export class EventQueue extends Emitter {
         return true
       }
 
+      const alternativeNameMatch = p.alternativeNames?.filter((name) =>
+        Object.keys(denyList).includes(name)
+      )
+
       // Explicit integration option takes precedence, `All: false` does not apply to Segment.io
       return (
         denyList[p.name] ??
+        alternativeNameMatch ??
         (p.name === 'Segment.io' ? true : denyList.All) !== false
       )
     })

packages/browser/src/lib/klona.ts

@@ -0,0 +1,4 @@
+import { SegmentEvent } from '../core/events'
+
+export const klona = (evt: SegmentEvent): SegmentEvent =>
+  JSON.parse(JSON.stringify(evt))

packages/browser/src/plugins/ajs-destination/__tests__/index.test.ts

@@ -253,7 +253,10 @@ describe('loading ajsDestinations', () => {
   })
 
   it('adds a tsub middleware for matching rules', () => {
-    const destinations = ajsDestinations(cdnResponse)
+    const middleware = tsubMiddleware(
+      cdnResponse.middlewareSettings!.routingRules
+    )
+    const destinations = ajsDestinations(cdnResponse, {}, {}, middleware)
     const amplitude = destinations.find((d) => d.name === 'Amplitude')
     expect(amplitude?.middleware.length).toBe(1)
   })

packages/browser/src/plugins/ajs-destination/index.ts

@@ -1,4 +1,4 @@
-import { Integrations, JSONObject, SegmentEvent } from '@/core/events'
+import { Integrations, JSONObject } from '@/core/events'
 import { Alias, Facade, Group, Identify, Page, Track } from '@segment/facade'
 import { Analytics, InitOptions } from '../../core/analytics'
 import { LegacySettings } from '../../browser'
@@ -17,12 +17,9 @@ import {
   applyDestinationMiddleware,
   DestinationMiddlewareFunction,
 } from '../middleware'
-import { tsubMiddleware } from '../routing-middleware'
 import { loadIntegration, resolveVersion, unloadIntegration } from './loader'
 import { LegacyIntegration } from './types'
-
-const klona = (evt: SegmentEvent): SegmentEvent =>
-  JSON.parse(JSON.stringify(evt))
+import { klona } from '../../lib/klona'
 
 export type ClassType<T> = new (...args: unknown[]) => T
 
@@ -303,7 +300,8 @@ export class LegacyDestination implements Plugin {
 export function ajsDestinations(
   settings: LegacySettings,
   globalIntegrations: Integrations = {},
-  options: InitOptions = {}
+  options: InitOptions = {},
+  routingMiddleware?: DestinationMiddlewareFunction
 ): LegacyDestination[] {
   if (isServer()) {
     return []
@@ -315,7 +313,6 @@ export function ajsDestinations(
   }
 
   const routingRules = settings.middlewareSettings?.routingRules ?? []
-  const routingMiddleware = tsubMiddleware(routingRules)
 
   // merged remote CDN settings with user provided options
   const integrationOptions = mergedOptions(settings, options ?? {}) as Record<
@@ -362,7 +359,7 @@ export function ajsDestinations(
       const routing = routingRules.filter(
         (rule) => rule.destinationName === name
       )
-      if (routing.length > 0) {
+      if (routing.length > 0 && routingMiddleware) {
         destination.addMiddleware(routingMiddleware)
       }