[STRATCONN-6836] - E2E proof of concept

packages/core/src/e2e-helpers.ts

@@ -0,0 +1,169 @@
+import type { SegmentEvent } from './segment-event'
+import type { JSONValue } from './json-object'
+import type {
+  E2EAudienceEventBase,
+  E2EEngageAudienceEventOptions,
+  E2EEngageAudienceEvent,
+  E2EJourneysV1AudienceEventOptions,
+  E2EJourneysV1AudienceTrackEvent,
+  E2ERetlAudienceEventOptions,
+  E2ERetlAudienceTrackEvent
+} from './e2e-types'
+
+/*
+ * Regular Segment Connections event
+ */
+export function createE2EEvent(
+  type: SegmentEvent['type'],
+  name?: string,
+  overrides?: Partial<Omit<SegmentEvent, 'type' | 'event' | 'name' | 'messageId' | 'timestamp'>>
+): SegmentEvent {
+  if (type === 'track') {
+    return {
+      type,
+      event: name,
+      messageId: '$guid',
+      timestamp: '$now',
+      ...overrides
+    }
+  }
+
+  if (type === 'page' || type === 'screen') {
+    return {
+      type,
+      name,
+      messageId: '$guid',
+      timestamp: '$now',
+      ...overrides
+    }
+  }
+
+  if (name) {
+    throw new Error(
+      `createE2EEvent: "name" is not supported for "${type}" events. Only track, page, and screen accept a name.`
+    )
+  }
+
+  return {
+    type,
+    messageId: '$guid',
+    timestamp: '$now',
+    ...overrides
+  }
+}
+
+function buildAudienceEventBase(options: E2EAudienceEventBase) {
+  const {
+    computationKey,
+    computationId,
+    externalAudienceId,
+    userId,
+    anonymousId,
+    email,
+    audienceFields,
+    includeContextTraits = true
+  } = options
+  return {
+    messageId: '$guid',
+    timestamp: '$now',
+    ...(userId && { userId }),
+    ...(anonymousId && { anonymousId }),
+    context: {
+      personas: {
+        computation_class: 'audience',
+        computation_key: computationKey,
+        computation_id: computationId,
+        ...(externalAudienceId && { external_audience_id: externalAudienceId })
+      },
+      ...(audienceFields && { audienceFields }),
+      ...(includeContextTraits && email && { traits: { email } })
+    }
+  }
+}
+
+/*
+ * Engage Audience event
+ * Supports identify and track events
+ */
+export function createE2EEngageAudienceEvent<ComputationKey extends string>(
+  options: E2EEngageAudienceEventOptions<ComputationKey>
+): E2EEngageAudienceEvent<ComputationKey> {
+  const { type, action, computationKey, eventName, email, enrichedTraits } = options
+
+  if (type === 'identify' && eventName) {
+    throw new Error('createE2EEngageAudienceEvent: "eventName" is not supported for identify events.')
+  }
+
+  const membership = action === 'add'
+  const base = buildAudienceEventBase({ ...options, includeContextTraits: type === 'track' })
+
+  const event = {
+    ...base,
+    ...(type === 'track' && {
+      type: 'track',
+      event: eventName ?? 'Test Engage Audience Membership Event',
+      properties: {
+        [computationKey]: membership,
+        ...(enrichedTraits as { [k: string]: JSONValue })
+      }
+    }),
+    ...(type === 'identify' && {
+      type: 'identify',
+      traits: {
+        [computationKey]: membership,
+        ...(enrichedTraits as { [k: string]: JSONValue }),
+        ...(email && { email })
+      }
+    })
+  }
+
+  return event as E2EEngageAudienceEvent<ComputationKey>
+}
+
+/*
+ * Journeys V1 events (preset journeys_step_entered_track) do not have properties[<computation_key>] value.
+ * All Journeys V1 events enter the user to the audience, never remove them.
+ * Only track events supported
+ */
+export function createE2EJourneysV1AudienceEvent<ComputationKey extends string>(
+  options: E2EJourneysV1AudienceEventOptions<ComputationKey>
+): E2EJourneysV1AudienceTrackEvent<ComputationKey> {
+  const { eventName, enrichedTraits } = options
+  const base = buildAudienceEventBase(options)
+
+  const event = {
+    ...base,
+    type: 'track',
+    event: eventName ?? 'Test Journeys V1 Audience Membership Event',
+    properties: {
+      ...(enrichedTraits as { [k: string]: JSONValue })
+    }
+  }
+
+  return event as E2EJourneysV1AudienceTrackEvent<ComputationKey>
+}
+
+/*
+ * Reverse ETL Audience event
+ * Same payload structure as Engage track events but uses RETL-specific event names: 'new', 'updated', 'deleted'
+ * Only track events supported
+ */
+export function createE2ERetlAudienceEvent<ComputationKey extends string>(
+  options: E2ERetlAudienceEventOptions<ComputationKey>
+): E2ERetlAudienceTrackEvent<ComputationKey> {
+  const { eventName, computationKey, enrichedTraits } = options
+  const membership = eventName !== 'deleted'
+  const base = buildAudienceEventBase(options)
+
+  const event = {
+    ...base,
+    type: 'track',
+    event: eventName,
+    properties: {
+      [computationKey]: membership,
+      ...(enrichedTraits as { [k: string]: JSONValue })
+    }
+  }
+
+  return event as E2ERetlAudienceTrackEvent<ComputationKey>
+}