feat: integrate Impact telemetry with checkout attribution for subscriptions

global.d.ts

@@ -5,6 +5,11 @@ declare const __ALGOLIA_APP_ID__: string
 declare const __ALGOLIA_API_KEY__: string
 declare const __USE_PROD_CONFIG__: boolean
 
+interface ImpactQueueFunction {
+  (...args: unknown[]): void
+  a?: unknown[][]
+}
+
 interface Window {
   __CONFIG__: {
     gtm_container_id?: string
@@ -37,6 +42,8 @@ interface Window {
     session_number?: string
   }
   dataLayer?: Array<Record<string, unknown>>
+  ire_o?: string
+  ire?: ImpactQueueFunction
 }
 
 interface Navigator {

src/platform/cloud/subscription/components/PricingTable.vue

@@ -414,7 +414,7 @@ const handleSubscribe = wrapWithErrorHandlingAsync(
 
     try {
       if (isActiveSubscription.value) {
-        const checkoutAttribution = getCheckoutAttribution()
+        const checkoutAttribution = await getCheckoutAttribution()
         if (userId) {
           telemetry?.trackBeginCheckout({
             user_id: userId,

src/platform/cloud/subscription/composables/useSubscription.test.ts

@@ -9,6 +9,7 @@ const {
   mockAccessBillingPortal,
   mockShowSubscriptionRequiredDialog,
   mockGetAuthHeader,
+  mockGetCheckoutAttribution,
   mockTelemetry,
   mockUserId,
   mockIsCloud
@@ -21,6 +22,11 @@ const {
   mockGetAuthHeader: vi.fn(() =>
     Promise.resolve({ Authorization: 'Bearer test-token' })
   ),
+  mockGetCheckoutAttribution: vi.fn(() => ({
+    im_ref: 'impact-click-001',
+    impact_click_id: 'impact-click-001',
+    utm_source: 'impact'
+  })),
   mockTelemetry: {
     trackSubscription: vi.fn(),
     trackMonthlySubscriptionCancelled: vi.fn()
@@ -84,6 +90,10 @@ vi.mock('@/platform/distribution/types', () => ({
   }
 }))
 
+vi.mock('@/platform/telemetry/utils/checkoutAttribution', () => ({
+  getCheckoutAttribution: mockGetCheckoutAttribution
+}))
+
 vi.mock('@/services/dialogService', () => ({
   useDialogService: vi.fn(() => ({
     showSubscriptionRequiredDialog: mockShowSubscriptionRequiredDialog
@@ -284,6 +294,11 @@ describe('useSubscription', () => {
           headers: expect.objectContaining({
             Authorization: 'Bearer test-token',
             'Content-Type': 'application/json'
+          }),
+          body: JSON.stringify({
+            im_ref: 'impact-click-001',
+            impact_click_id: 'impact-click-001',
+            utm_source: 'impact'
           })
         })
       )

src/platform/cloud/subscription/composables/useSubscription.ts

@@ -8,6 +8,7 @@ import { getComfyApiBaseUrl, getComfyPlatformBaseUrl } from '@/config/comfyApi'
 import { t } from '@/i18n'
 import { isCloud } from '@/platform/distribution/types'
 import { useTelemetry } from '@/platform/telemetry'
+import { getCheckoutAttribution } from '@/platform/telemetry/utils/checkoutAttribution'
 import {
   FirebaseAuthStoreError,
   useFirebaseAuthStore
@@ -231,6 +232,7 @@ function useSubscriptionInternal() {
           t('toastMessages.userNotAuthenticated')
         )
       }
+      const checkoutAttribution = await getCheckoutAttribution()
 
       const response = await fetch(
         buildApiUrl('/customers/cloud-subscription-checkout'),
@@ -239,7 +241,8 @@ function useSubscriptionInternal() {
           headers: {
             ...authHeader,
             'Content-Type': 'application/json'
-          }
+          },
+          body: JSON.stringify(checkoutAttribution)
         }
       )
 

src/platform/cloud/subscription/utils/subscriptionCheckoutUtil.test.ts

@@ -21,6 +21,11 @@ const {
     ga_client_id: 'ga-client-id',
     ga_session_id: 'ga-session-id',
     ga_session_number: 'ga-session-number',
+    im_ref: 'impact-click-123',
+    impact_click_id: 'impact-click-123',
+    utm_source: 'impact',
+    utm_medium: 'affiliate',
+    utm_campaign: 'spring-launch',
     gclid: 'gclid-123',
     gbraid: 'gbraid-456',
     wbraid: 'wbraid-789'
@@ -83,6 +88,11 @@ describe('performSubscriptionCheckout', () => {
       ga_client_id: 'ga-client-id',
       ga_session_id: 'ga-session-id',
       ga_session_number: 'ga-session-number',
+      im_ref: 'impact-click-123',
+      impact_click_id: 'impact-click-123',
+      utm_source: 'impact',
+      utm_medium: 'affiliate',
+      utm_campaign: 'spring-launch',
       gclid: 'gclid-123',
       gbraid: 'gbraid-456',
       wbraid: 'wbraid-789'
@@ -97,6 +107,11 @@ describe('performSubscriptionCheckout', () => {
           ga_client_id: 'ga-client-id',
           ga_session_id: 'ga-session-id',
           ga_session_number: 'ga-session-number',
+          im_ref: 'impact-click-123',
+          impact_click_id: 'impact-click-123',
+          utm_source: 'impact',
+          utm_medium: 'affiliate',
+          utm_campaign: 'spring-launch',
           gclid: 'gclid-123',
           gbraid: 'gbraid-456',
           wbraid: 'wbraid-789'

src/platform/cloud/subscription/utils/subscriptionCheckoutUtil.ts

@@ -46,7 +46,7 @@ export async function performSubscriptionCheckout(
   }
 
   const checkoutTier = getCheckoutTier(tierKey, currentBillingCycle)
-  const checkoutAttribution = getCheckoutAttribution()
+  const checkoutAttribution = await getCheckoutAttribution()
   const checkoutPayload = { ...checkoutAttribution }
 
   const response = await fetch(

src/platform/telemetry/initTelemetry.ts

@@ -23,16 +23,19 @@ export async function initTelemetry(): Promise<void> {
     const [
       { TelemetryRegistry },
       { MixpanelTelemetryProvider },
-      { GtmTelemetryProvider }
+      { GtmTelemetryProvider },
+      { ImpactTelemetryProvider }
     ] = await Promise.all([
       import('./TelemetryRegistry'),
       import('./providers/cloud/MixpanelTelemetryProvider'),
-      import('./providers/cloud/GtmTelemetryProvider')
+      import('./providers/cloud/GtmTelemetryProvider'),
+      import('./providers/cloud/ImpactTelemetryProvider')
     ])
 
     const registry = new TelemetryRegistry()
     registry.registerProvider(new MixpanelTelemetryProvider())
     registry.registerProvider(new GtmTelemetryProvider())
+    registry.registerProvider(new ImpactTelemetryProvider())
 
     setTelemetryRegistry(registry)
   })()

src/platform/telemetry/providers/cloud/ImpactTelemetryProvider.test.ts

@@ -0,0 +1,132 @@
+import { ref } from 'vue'
+import { afterEach, beforeEach, describe, expect, it, vi } from 'vitest'
+
+const { mockCaptureCheckoutAttributionFromSearch, mockUseCurrentUser } =
+  vi.hoisted(() => ({
+    mockCaptureCheckoutAttributionFromSearch: vi.fn(),
+    mockUseCurrentUser: vi.fn()
+  }))
+
+vi.mock('@/platform/telemetry/utils/checkoutAttribution', () => ({
+  captureCheckoutAttributionFromSearch: mockCaptureCheckoutAttributionFromSearch
+}))
+
+vi.mock('@/composables/auth/useCurrentUser', () => ({
+  useCurrentUser: mockUseCurrentUser
+}))
+
+import { ImpactTelemetryProvider } from './ImpactTelemetryProvider'
+
+const IMPACT_SCRIPT_URL =
+  'https://utt.impactcdn.com/A6951770-3747-434a-9ac7-4e582e67d91f1.js'
+
+async function flushAsyncWork() {
+  await Promise.resolve()
+  await Promise.resolve()
+}
+
+describe('ImpactTelemetryProvider', () => {
+  beforeEach(() => {
+    mockCaptureCheckoutAttributionFromSearch.mockReset()
+    mockUseCurrentUser.mockReset()
+    vi.restoreAllMocks()
+    vi.unstubAllGlobals()
+
+    const queueFn: NonNullable<Window['ire']> = (...args: unknown[]) => {
+      ;(queueFn.a ??= []).push(args)
+    }
+    window.ire = queueFn
+    window.ire_o = undefined
+
+    vi.spyOn(document, 'querySelector').mockImplementation((selector) => {
+      if (selector === `script[src="${IMPACT_SCRIPT_URL}"]`) {
+        return document.createElement('script')
+      }
+
+      return null
+    })
+  })
+
+  afterEach(() => {
+    vi.unstubAllGlobals()
+  })
+
+  it('captures attribution and invokes identify with hashed email', async () => {
+    mockUseCurrentUser.mockReturnValue({
+      resolvedUserInfo: ref({ id: 'user-123' }),
+      userEmail: ref('User@Example.com')
+    })
+    vi.stubGlobal('crypto', {
+      subtle: {
+        digest: vi.fn(async () => new Uint8Array([0, 1, 2]).buffer)
+      }
+    })
+    const provider = new ImpactTelemetryProvider()
+    provider.trackPageView('pricing', {
+      path: 'https://cloud.comfy.org/pricing?im_ref=impact-123'
+    })
+
+    await flushAsyncWork()
+
+    expect(window.ire_o).toBe('ire')
+    expect(mockCaptureCheckoutAttributionFromSearch).toHaveBeenCalledWith(
+      '?im_ref=impact-123'
+    )
+    expect(window.ire?.a).toHaveLength(1)
+    expect(window.ire?.a?.[0]?.[0]).toBe('identify')
+    expect(window.ire?.a?.[0]?.[1]).toMatchObject({
+      customerId: 'user-123'
+    })
+  })
+
+  it('falls back to current URL search and empty identify values when user is unresolved', async () => {
+    mockUseCurrentUser.mockImplementation(() => {
+      throw new Error('No active pinia')
+    })
+    window.history.pushState({}, '', '/?im_ref=fallback-123')
+
+    const provider = new ImpactTelemetryProvider()
+    provider.trackPageView('home')
+
+    await flushAsyncWork()
+
+    expect(mockCaptureCheckoutAttributionFromSearch).toHaveBeenCalledWith(
+      '?im_ref=fallback-123'
+    )
+    expect(window.ire?.a).toHaveLength(1)
+    expect(window.ire?.a?.[0]).toEqual([
+      'identify',
+      {
+        customerId: '',
+        customerEmail: ''
+      }
+    ])
+  })
+
+  it('deduplicates repeated identify payloads', async () => {
+    mockUseCurrentUser.mockReturnValue({
+      resolvedUserInfo: ref({ id: 'user-123' }),
+      userEmail: ref('user@example.com')
+    })
+    vi.stubGlobal('crypto', {
+      subtle: {
+        digest: vi.fn(async () => new Uint8Array([16, 32, 48]).buffer)
+      }
+    })
+    const provider = new ImpactTelemetryProvider()
+    provider.trackPageView('home', {
+      path: 'https://cloud.comfy.org/?im_ref=1'
+    })
+    provider.trackPageView('pricing', {
+      path: 'https://cloud.comfy.org/pricing?im_ref=2'
+    })
+
+    await flushAsyncWork()
+
+    expect(window.ire?.a).toHaveLength(1)
+    expect(window.ire?.a?.[0]?.[0]).toBe('identify')
+    expect(window.ire?.a?.[0]?.[1]).toMatchObject({
+      customerId: 'user-123'
+    })
+  })
+})