Merge branch 'develop' into salesforcev2-refactor

src/cdk/v2/destinations/bluecore/utils.js

@@ -46,12 +46,12 @@ const verifyPayload = (payload, message) => {
       }
       break;
     case 'purchase':
-      if (!payload?.properties?.order_id) {
+      if (!isDefinedAndNotNull(payload?.properties?.order_id)) {
         throw new InstrumentationError(
           '[Bluecore] property:: order_id is required for purchase event',
         );
       }
-      if (!payload?.properties?.total) {
+      if (!isDefinedAndNotNull(payload?.properties?.total)) {
         throw new InstrumentationError(
           '[Bluecore] property:: total is required for purchase event',
         );

src/cdk/v2/destinations/lytics/config.ts

@@ -0,0 +1,9 @@
+import { getMappingConfig } from '../../../../v0/util';
+
+const CONFIG_CATEGORIES = {
+  CUSTOMER_PROPERTIES_CONFIG: { name: 'LYTICSIdentifyConfig' },
+};
+
+const MAPPING_CONFIG = getMappingConfig(CONFIG_CATEGORIES, __dirname);
+export const CUSTOMER_PROPERTIES_CONFIG =
+  MAPPING_CONFIG[CONFIG_CATEGORIES.CUSTOMER_PROPERTIES_CONFIG.name];

src/cdk/v2/destinations/lytics/data/LYTICSIdentifyConfig.json

@@ -0,0 +1,25 @@
+[
+  {
+    "destKey": "user_id",
+    "sourceKeys": "userIdOnly",
+    "sourceFromGenericMap": true,
+    "required": false
+  },
+  {
+    "destKey": "anonymous_id",
+    "sourceKeys": "anonymousId",
+    "required": false
+  },
+  {
+    "destKey": "first_name",
+    "sourceKeys": "firstName",
+    "sourceFromGenericMap": true,
+    "required": false
+  },
+  {
+    "destKey": "last_name",
+    "sourceKeys": "lastName",
+    "sourceFromGenericMap": true,
+    "required": false
+  }
+]

src/cdk/v2/destinations/lytics/procWorkflow.yaml

@@ -5,9 +5,12 @@ bindings:
     path: ../../../../v0/util
   - name: removeUndefinedAndNullValues
     path: ../../../../v0/util
+  - name: constructPayload
+    path: ../../../../v0/util
   - path: ../../bindings/jsontemplate
   - name: defaultRequestConfig
     path: ../../../../v0/util
+  - path: ./config
 
 steps:
   - name: validateInput
@@ -24,20 +27,19 @@ steps:
     condition: $.context.messageType === {{$.EventType.IDENTIFY}}
     template: |
       const flattenTraits = $.flattenJson(.message.traits ?? .message.context.traits);
-      $.context.payload = .message.({
+      const payload = $.constructPayload(.message, $.CUSTOMER_PROPERTIES_CONFIG);
+      $.context.payload = {
         ...flattenTraits,
-        first_name: {{{{$.getGenericPaths("firstName")}}}},
-        last_name: {{{{$.getGenericPaths("lastName")}}}},
-        user_id: {{{{$.getGenericPaths("userId")}}}}
-      })
+        ...payload,
+      }
     else:
       name: payloadForOthers
       template: |
         const flattenProperties = $.flattenJson(.message.properties);
+        const customerPropertiesInfo = $.constructPayload(.message, $.CUSTOMER_PROPERTIES_CONFIG);
         $.context.payload = .message.({
           ...flattenProperties,
-          first_name: .properties.firstName ?? .properties.firstname,
-          last_name: .properties.lastName ?? .properties.lastname
+          ...customerPropertiesInfo
         })
   - name: trackPayload
     condition: $.context.messageType === {{$.EventType.TRACK}}

src/v0/destinations/braze/braze.util.test.js

@@ -304,6 +304,20 @@ describe('dedup utility tests', () => {
         {
           external_ids: ['user1', 'user2'],
           user_aliases: [{ alias_name: 'user3', alias_label: 'rudder_id' }],
+          fields_to_export: [
+            'created_at',
+            'custom_attributes',
+            'dob',
+            'email',
+            'first_name',
+            'gender',
+            'home_city',
+            'last_name',
+            'phone',
+            'time_zone',
+            'external_id',
+            'user_aliases',
+          ],
         },
         {
           headers: {

src/v0/destinations/braze/util.js

@@ -141,19 +141,36 @@ const BrazeDedupUtility = {
     const identfierChunks = _.chunk(identifiers, 50);
     return identfierChunks;
   },
-
+  getFieldsToExport() {
+    return [
+      'created_at',
+      'custom_attributes',
+      'dob',
+      'email',
+      'first_name',
+      'gender',
+      'home_city',
+      'last_name',
+      'phone',
+      'time_zone',
+      'external_id',
+      'user_aliases',
+      // 'country' and 'language' not needed because it is not billable so we don't use it
+    ];
+  },
   async doApiLookup(identfierChunks, { destination, metadata }) {
     return Promise.all(
       identfierChunks.map(async (ids) => {
         const externalIdentifiers = ids.filter((id) => id.external_id);
         const aliasIdentifiers = ids.filter((id) => id.alias_name !== undefined);
-
+        const fieldsToExport = this.getFieldsToExport();
         const { processedResponse: lookUpResponse } = await handleHttpRequest(
           'post',
           `${getEndpointFromConfig(destination)}/users/export/ids`,
           {
             external_ids: externalIdentifiers.map((extId) => extId.external_id),
             user_aliases: aliasIdentifiers,
+            fields_to_export: fieldsToExport,
           },
           {
             headers: {

src/v0/destinations/posthog/data/PHAliasConfig.json

@@ -1,12 +1,12 @@
 [
   {
-    "destKey": "properties.alias",
+    "destKey": "properties.distinct_id",
     "sourceKeys": "userId",
     "sourceFromGenericMap": true,
     "required": true
   },
   {
-    "destKey": "properties.distinct_id",
+    "destKey": "properties.alias",
     "sourceKeys": "previousId",
     "required": true
   },

src/v0/destinations/singular/config.js

@@ -13,6 +13,10 @@ const CONFIG_CATEGORIES = {
     name: 'SINGULARIosSessionConfig',
     type: 'track',
   },
+  SESSION_UNITY: {
+    name: 'SINGULARUnitySessionConfig',
+    type: 'track',
+  },
   EVENT_ANDROID: {
     name: 'SINGULARAndroidEventConfig',
     type: 'track',
@@ -21,6 +25,10 @@ const CONFIG_CATEGORIES = {
     name: 'SINGULARIosEventConfig',
     type: 'track',
   },
+  EVENT_UNITY: {
+    name: 'SINGULARUnityEventConfig',
+    type: 'track',
+  },
   PRODUCT_PROPERTY: {
     name: 'SINGULAREventProductConfig',
   },
@@ -29,8 +37,15 @@ const CONFIG_CATEGORIES = {
 const SUPPORTED_PLATFORM = {
   android: 'ANDROID',
   ios: 'IOS',
+  pc: 'unity',
+  xbox: 'unity',
+  playstation: 'unity',
+  nintendo: 'unity',
+  metaquest: 'unity',
 };
 
+const SUPPORTED_UNTIY_SUBPLATFORMS = ['pc', 'xbox', 'playstation', 'nintendo', 'metaquest'];
+
 const SINGULAR_SESSION_ANDROID_EXCLUSION = [
   'referring_application',
   'asid',
@@ -93,5 +108,6 @@ module.exports = {
   SINGULAR_EVENT_ANDROID_EXCLUSION,
   SINGULAR_EVENT_IOS_EXCLUSION,
   SUPPORTED_PLATFORM,
+  SUPPORTED_UNTIY_SUBPLATFORMS,
   BASE_URL,
 };