Squashed commit of the following:

commit 349c8cb
Author: Nick Aguilar <[email protected]>
Date:   Thu Jul 3 09:26:43 2025 -0700

    Only append tags when isLiquidDirective is true

commit b29a712
Author: Nick Aguilar <[email protected]>
Date:   Thu Jul 3 09:14:02 2025 -0700

    Dry suggestion: uses finally block to call histogram

commit c2d8704
Author: Nick Aguilar <[email protected]>
Date:   Mon Jun 30 16:55:09 2025 -0700

    Reverts packages/browser-destinations/webpack.config.js

commit 1964c15
Author: Nick Aguilar <[email protected]>
Date:   Mon Jun 30 16:45:22 2025 -0700

    Removes perf_hooks usage since it proved to be a never-ending rabbithole of import errors

commit 8850513
Author: Nick Aguilar <[email protected]>
Date:   Mon Jun 30 16:32:42 2025 -0700

    Does not attempt to resolve the perf_hooks package as it's not browser supported

commit 084b860
Author: Nick Aguilar <[email protected]>
Date:   Thu Jun 26 16:44:14 2025 -0700

    Throws error only after logging out metrics

commit 28b117c
Author: Nick Aguilar <[email protected]>
Date:   Thu Jun 26 16:32:56 2025 -0700

    Imports performance

commit 5508da6
Author: Nick Aguilar <[email protected]>
Date:   Thu Jun 26 16:10:24 2025 -0700

    Removes Subscription values which are undefined

commit 856634a
Author: Nick Aguilar <[email protected]>
Date:   Thu Jun 26 09:46:21 2025 -0700

    Adds action and destination metadata values to tags

commit 9ce22c5
Author: Nick Aguilar <[email protected]>
Date:   Thu Jun 26 11:14:39 2025 -0700

    WIP - pipes through statsContext to evaluateLiquid directive function

    Tracks liquid metrics when batching as well

    WIP passes tags hopefully

commit 6e6149c
Author: Nick Aguilar <[email protected]>
Date:   Tue Jun 24 17:21:26 2025 -0700

    WIP - pipes through statsContext to evaluateLiquid directive function

commit b367ebd
Author: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com>
Date:   Tue Aug 12 17:13:24 2025 +0100

    Publish (#3172)

    Co-authored-by: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com>

commit db16abc
Author: Joe Ayoub <[email protected]>
Date:   Tue Aug 12 17:07:03 2025 +0100

    register yonoma (#3170)

commit 8a11fb1
Author: Vanessa Sun <[email protected]>
Date:   Tue Aug 12 23:54:11 2025 +0800

    Stackadapt-Audience: add isPii field to upsertExternalAudienceMapping query (#3095)

    * add isPii field to upsertExternalAudienceMapping query

    * update snapshot for stackadapt-audiences

    * fix query input string format

commit 7a17d8e
Author: Joe Ayoub <[email protected]>
Date:   Tue Aug 12 16:53:39 2025 +0100

    STRATCONN-6040 - [Yonomo] - New Destination (#3140)

    * First Action

    * Actions completed

    * testAuthentication

    * starting on tests

    * saving progress

    * Updated tests

    * all tests done

    * removing unnecesary tests

    * fixing timestamp in snapshots

commit 0e0a155
Author: nk1107 <[email protected]>
Date:   Tue Aug 12 21:07:20 2025 +0530

    Stratconn 6058/batch size (#3106)

    * add enable-batch and batch-size

    * change description

    * update test files

    * Revert "update test files"

    This reverts commit b4a2c43.

    * extract batch properties finally

    * update max limit

    * change label

    * Remove batching configuration fields from payload before sending to Customer.io

    * Remove batching configuration fields from BasePayload type

commit b8d7e8c
Author: Arijit Ray <[email protected]>
Date:   Tue Aug 12 21:06:19 2025 +0530

    Dont throw 404 if profile is not found in intercom Ondelete (#3144)

    * Dont throw 404 if profile is not found in intercom Ondelete

    * fix tests

commit 1924208
Author: Joe Ayoub <[email protected]>
Date:   Tue Aug 12 16:36:06 2025 +0100

    [Attentive] - bugfix (#3151)

    * minor bugfix

    * fixing tests

commit c6ed179
Author: Varadarajan V <[email protected]>
Date:   Tue Aug 12 21:05:48 2025 +0530

    [STRATCONN-6023] - Add feature flag to facilitate GZIP Compression Rollout (#3152)

    * [STRATCONN-6023]- Add feature flag for rolling out compression

    * Revert batch size

    * add gzipcompress flag

    * Add tests

Author: nick-Ag

packages/core/src/destination-kit/action.ts

@@ -318,7 +318,7 @@ export class Action<Settings, Payload extends JSONLikeObject, AudienceSettings =
     const results: Result[] = []
 
     // Resolve/transform the mapping with the input data
-    let payload = transform(bundle.mapping, bundle.data) as Payload
+    let payload = transform(bundle.mapping, bundle.data, bundle.statsContext) as Payload
     results.push({ output: 'Mappings resolved' })
 
     // Remove empty values (`null`, `undefined`, `''`) when not explicitly accepted
@@ -387,7 +387,7 @@ export class Action<Settings, Payload extends JSONLikeObject, AudienceSettings =
 
     const mapping: JSONObject = bundle.mapping
 
-    let payloads = transformBatch(mapping, bundle.data) as Payload[]
+    let payloads = transformBatch(mapping, bundle.data, bundle.statsContext) as Payload[]
     const batchPayloadLength = payloads.length
 
     const multiStatusResponse: ResultMultiStatusNode[] = []

packages/core/src/destination-kit/index.ts

@@ -726,6 +726,10 @@ export class Destination<Settings = JSONObject, AudienceSettings = JSONObject> {
   ): Promise<Result[]> {
     const isBatch = Array.isArray(events)
 
+    if (options?.statsContext?.tags !== undefined) {
+      options.statsContext.tags = [...options.statsContext.tags, `partnerAction:${subscription.partnerAction}`]
+    }
+
     const subscriptionStartedAt = time()
     const actionSlug = subscription.partnerAction
     const input = {

packages/core/src/mapping-kit/index.ts

@@ -8,10 +8,12 @@ import validate from './validate'
 import { arrify } from '../arrify'
 import { flattenObject } from './flatten'
 import { evaluateLiquid } from './liquid-directive'
+import { StatsContext } from '../destination-kit'
+import { isLiquidDirective } from './value-keys'
 
 export type InputData = { [key: string]: unknown }
 export type Features = { [key: string]: boolean }
-type Directive = (options: JSONValue, payload: JSONObject) => JSONLike
+type Directive = (options: JSONValue, payload: JSONObject, statsContext?: StatsContext | undefined) => JSONLike
 type StringDirective = (value: string, payload: JSONObject) => JSONLike
 
 interface Directives {
@@ -42,7 +44,7 @@ function registerStringDirective(name: string, fn: StringDirective): void {
   })
 }
 
-function runDirective(obj: JSONObject, payload: JSONObject): JSONLike {
+function runDirective(obj: JSONObject, payload: JSONObject, statsContext?: StatsContext | undefined): JSONLike {
   const name = Object.keys(obj).find((key) => key.startsWith('@')) as string
   const directiveFn = directives[name]
   const value = obj[name]
@@ -51,6 +53,10 @@ function runDirective(obj: JSONObject, payload: JSONObject): JSONLike {
     throw new Error(`${name} is not a valid directive, got ${realTypeOf(directiveFn)}`)
   }
 
+  if (name === '@liquid') {
+    return directiveFn(value, payload, statsContext)
+  }
+
   return directiveFn(value, payload)
 }
 
@@ -326,8 +332,8 @@ registerDirective('@excludeWhenNull', (value, payload) => {
   return cleanNulls(resolved)
 })
 
-registerDirective('@liquid', (opts, payload) => {
-  return evaluateLiquid(opts, payload)
+registerDirective('@liquid', (opts, payload, statsContext) => {
+  return evaluateLiquid(opts, payload, statsContext)
 })
 
 // Recursively remove all null values from an object
@@ -381,23 +387,40 @@ function getMappingToProcess(mapping: JSONLikeObject): JSONLikeObject {
  * @param payload - the input data to apply to the mapping directives
  * @todo support arrays or array directives?
  */
-function resolve(mapping: JSONLike, payload: JSONObject): JSONLike {
+function resolve(mapping: JSONLike, payload: JSONObject, statsContext?: StatsContext | undefined): JSONLike {
   if (!isObject(mapping) && !isArray(mapping)) {
     return mapping
   }
 
   if (isDirective(mapping)) {
+    if (isLiquidDirective(mapping)) {
+      // Only include stats, and therefore extra fieldKey tags, if the mapping is a liquid directive to save on costs
+      return runDirective(mapping, payload, statsContext)
+    }
+
     return runDirective(mapping, payload)
   }
 
   if (Array.isArray(mapping)) {
-    return mapping.map((value) => resolve(value, payload))
+    return mapping.map((value) => resolve(value, payload, statsContext))
   }
 
   const resolved: JSONLikeObject = {}
 
   for (const key of Object.keys(mapping)) {
-    resolved[key] = resolve(mapping[key], payload)
+    let originalTags: string[] = []
+    const statsTagsExist = statsContext?.tags !== undefined
+
+    if (statsTagsExist) {
+      originalTags = statsContext.tags
+      statsContext.tags = [...statsContext.tags, `fieldKey:${key}`]
+    }
+
+    resolved[key] = resolve(mapping[key], payload, statsContext)
+
+    if (statsTagsExist) {
+      statsContext.tags = originalTags
+    }
   }
 
   return resolved
@@ -409,7 +432,11 @@ function resolve(mapping: JSONLike, payload: JSONObject): JSONLike {
  * @param mapping - the directives and raw values
  * @param data - the input data to apply to directives
  */
-function transform(mapping: JSONLikeObject, data: InputData | undefined = {}): JSONObject {
+function transform(
+  mapping: JSONLikeObject,
+  data: InputData | undefined = {},
+  statsContext?: StatsContext | undefined
+): JSONObject {
   const realType = realTypeOf(data)
   if (realType !== 'object') {
     throw new Error(`data must be an object, got ${realType}`)
@@ -420,7 +447,7 @@ function transform(mapping: JSONLikeObject, data: InputData | undefined = {}): J
   // throws if the mapping config is invalid
   validate(mappingToProcess)
 
-  const resolved = resolve(mappingToProcess, data as JSONObject)
+  const resolved = resolve(mappingToProcess, data as JSONObject, statsContext)
   const cleaned = removeUndefined(resolved)
 
   // Cast because we know there are no `undefined` values anymore
@@ -432,7 +459,11 @@ function transform(mapping: JSONLikeObject, data: InputData | undefined = {}): J
  * @param mapping - the directives and raw values
  * @param data - the array input data to apply to directives
  */
-function transformBatch(mapping: JSONLikeObject, data: Array<InputData> | undefined = []): JSONObject[] {
+function transformBatch(
+  mapping: JSONLikeObject,
+  data: Array<InputData> | undefined = [],
+  statsContext?: StatsContext | undefined
+): JSONObject[] {
   const realType = realTypeOf(data)
   if (!isArray(data)) {
     throw new Error(`data must be an array, got ${realType}`)
@@ -443,7 +474,7 @@ function transformBatch(mapping: JSONLikeObject, data: Array<InputData> | undefi
   // throws if the mapping config is invalid
   validate(mappingToProcess)
 
-  const resolved = data.map((d) => resolve(mappingToProcess, d as JSONObject))
+  const resolved = data.map((d) => resolve(mappingToProcess, d as JSONObject, statsContext))
 
   // Cast because we know there are no `undefined` values after `removeUndefined`
   return removeUndefined(resolved) as JSONObject[]

packages/core/src/mapping-kit/liquid-directive.ts

@@ -1,4 +1,5 @@
 import { Liquid } from 'liquidjs'
+import { StatsContext } from '../destination-kit'
 
 const liquidEngine = new Liquid({
   renderLimit: 500, // 500 ms
@@ -58,7 +59,7 @@ export function getLiquidKeys(liquidValue: string): string[] {
   return liquidEngine.fullVariablesSync(liquidValue)
 }
 
-export function evaluateLiquid(liquidValue: any, event: any): string {
+export function evaluateLiquid(liquidValue: any, event: any, statsContext?: StatsContext | undefined): string {
   if (typeof liquidValue !== 'string') {
     // type checking of @liquid directive is done in validate.ts as well
     throw new Error('liquid template value must be a string')
@@ -72,7 +73,22 @@ export function evaluateLiquid(liquidValue: any, event: any): string {
     throw new Error('liquid template values are limited to 1000 characters')
   }
 
-  const res = liquidEngine.parseAndRenderSync(liquidValue, event)
+  let res: string
+  const start = Date.now()
+  let status: 'success' | 'fail' = 'success'
+
+  try {
+    res = liquidEngine.parseAndRenderSync(liquidValue, event)
+  } catch (e) {
+    status = 'fail'
+    throw e
+  } finally {
+    const duration = Date.now() - start
+    statsContext?.statsClient?.histogram('liquid.template.evaluation_ms', duration, [
+      ...statsContext.tags,
+      `result:${status}`
+    ])
+  }
 
   if (typeof res !== 'string') {
     return 'error'

packages/destination-actions/src/destinations/attentive/functions.ts

@@ -1,13 +1,19 @@
 import { PayloadValidationError } from '@segment/actions-core'
-import { Item, User, EcommEventJSON, CustomEventJSON, UpsertUserAttributesJSON, SubscribeUserJSON, SubscriptionType } from './types'
+import {
+  Item,
+  User,
+  EcommEventJSON,
+  CustomEventJSON,
+  UpsertUserAttributesJSON,
+  SubscribeUserJSON,
+  SubscriptionType
+} from './types'
 import { Payload as CustomEvent } from './customEvents/generated-types'
 import { Payload as EcommEvent } from './ecommEvent/generated-types'
 import { Payload as CustomAttributesEvent } from './upsertUserAttributes/generated-types'
 import { Payload as SubscribeUserEvent } from './subscribeUser/generated-types'
 
-type UserIdentifiers =
-  | CustomEvent['userIdentifiers']
-  | EcommEvent['userIdentifiers']
+type UserIdentifiers = CustomEvent['userIdentifiers'] | EcommEvent['userIdentifiers']
 
 type Items = EcommEvent['items']
 
@@ -19,10 +25,10 @@ export function validate(payload: CustomEvent | EcommEvent | CustomAttributesEve
   if (!email && !phone && !clientUserId && Object.keys(customIdentifiers).length === 0) {
     throw new PayloadValidationError('At least one user identifier is required.')
   }
-} 
+}
 
 export function validateSubscribeUser(payload: SubscribeUserEvent) {
-  const { userIdentifiers, locale } = payload 
+  const { userIdentifiers, locale } = payload
   if (!userIdentifiers && !locale) {
     throw new PayloadValidationError('Either locale or signUpSourceId is required.')
   }
@@ -49,13 +55,13 @@ function formatItems(items: Items): Array<Item> {
     ...rest,
     price: {
       value,
-      currency,
+      currency
     }
   }))
 }
 
-function formatLocale(locale?: string): { language: string, country: string } {
-  if(!locale) {
+function formatLocale(locale?: string): { language: string; country: string } {
+  if (!locale) {
     throw new PayloadValidationError('Locale Signup Source ID is required.')
   }
   const parts = locale.split('-')
@@ -76,15 +82,9 @@ export function formatEcommEventJSON(payload: EcommEvent): EcommEventJSON {
 }
 
 export function formatCustomEventJSON(payload: CustomEvent): CustomEventJSON {
-  const {
-    externalEventId,
-    type, 
-    properties,
-    occurredAt,
-    userIdentifiers
-  } = payload
-  
-  if (Object.values(properties ?? {}).some(value => Array.isArray(value))) {
+  const { externalEventId, type, properties, occurredAt, userIdentifiers } = payload
+
+  if (Object.values(properties ?? {}).some((value) => Array.isArray(value))) {
     throw new PayloadValidationError('Properties cannot contain arrays.')
   }
 
@@ -98,12 +98,9 @@ export function formatCustomEventJSON(payload: CustomEvent): CustomEventJSON {
 }
 
 export function formatUpsertUserAttributesJSON(payload: CustomAttributesEvent): UpsertUserAttributesJSON {
-  const { 
-    properties,  
-    userIdentifiers 
-  } = payload
+  const { properties, userIdentifiers } = payload
 
-  if (Object.values(properties ?? {}).some(value => typeof value === 'object' || Array.isArray(value))) {
+  if (Object.values(properties ?? {}).some((value) => typeof value === 'object' || Array.isArray(value))) {
     throw new PayloadValidationError('Properties cannot contain objects or arrays.')
   }
 
@@ -114,14 +111,15 @@ export function formatUpsertUserAttributesJSON(payload: CustomAttributesEvent):
 }
 
 export function formatSubscribeUserJSON(payload: SubscribeUserEvent): SubscribeUserJSON {
-  const { externalEventId, occurredAt, userIdentifiers, subscriptionType, signUpSourceId, singleOptIn } = payload
+  const { externalEventId, occurredAt, userIdentifiers, subscriptionType, signUpSourceId, singleOptIn, locale } =
+    payload
   return {
     externalEventId,
     occurredAt,
     subscriptionType: subscriptionType as SubscriptionType,
-    locale: formatLocale(payload?.locale),
-    signUpSourceId,
+    ...(locale ? { locale: formatLocale(locale) } : {}),
+    ...(signUpSourceId ? { signUpSourceId } : {}),
     singleOptIn,
     user: formatUser(userIdentifiers)
   }
-}
+}

packages/destination-actions/src/destinations/attentive/subscribeUser/__tests__/__snapshots__/snapshot.test.ts.snap

@@ -3,12 +3,8 @@
 exports[`Testing snapshot for Attentive's subscribeUser destination action: all fields 1`] = `
 Object {
   "externalEventId": "*Cc5M#wXxFe",
-  "locale": Object {
-    "country": "US",
-    "language": "en",
-  },
   "occurredAt": "*Cc5M#wXxFe",
-  "signUpSourceId": "*Cc5M#wXxFe",
+  "signUpSourceId": "test-signup-source-id",
   "singleOptIn": true,
   "subscriptionType": "MARKETING",
   "user": Object {