feat: onboard bluecore integration

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

@@ -0,0 +1,52 @@
+const { getMappingConfig } = require('../../../../v0/util');
+
+const BASE_URL = 'https://api.bluecore.com/api/track/mobile/v1';
+
+const CONFIG_CATEGORIES = {
+  IDENTIFY: {
+    name: 'bluecoreIdentifyConfig',
+    type: 'identify',
+  },
+  TRACK: {
+    name: 'bluecoreTrackConfig',
+    type: 'track',
+  },
+};
+
+const EVENT_NAME_MAPPING = [
+  {
+    src: ['product viewed'],
+    dest: 'viewed_product',
+  },
+  {
+    src: ['products searched'],
+    dest: 'search',
+  },
+  {
+    src: ['product added'],
+    dest: 'add_to_cart',
+  },
+  {
+    src: ['product removed'],
+    dest: 'remove_from_cart',
+  },
+  {
+    src: ['product added to wishlist'],
+    dest: 'wishlist',
+  },
+  {
+    src: ['order completed'],
+    dest: 'purchase',
+  },
+];
+
+const BLUECORE_EXCLUSION_FIELDS = ['query','order_id','total']
+
+const MAPPING_CONFIG = getMappingConfig(CONFIG_CATEGORIES, __dirname);
+module.exports = {
+  CONFIG_CATEGORIES,
+  MAPPING_CONFIG,
+  EVENT_NAME_MAPPING,
+  BASE_URL,
+  BLUECORE_EXCLUSION_FIELDS
+};

src/cdk/v2/destinations/bluecore/data/bluecoreIdentifyConfig.json

@@ -0,0 +1,62 @@
+[
+  {
+    "destKey": "properties.distinct_id",
+    "sourceKeys": ["traits.email", "context.traits.email", "userId", "anonymousId"],
+    "required": true
+  },
+  {
+    "destKey": "properties.customer.name",
+    "sourceKeys": "name",
+    "required": false,
+    "sourceFromGenericMap": true
+  },
+  {
+    "destKey": "properties.customer.first_name",
+    "sourceKeys": "firstName",
+    "required": false,
+    "sourceFromGenericMap": true
+  },
+  {
+    "destKey": "properties.customer.last_name",
+    "sourceKeys": "lastName",
+    "required": false,
+    "sourceFromGenericMap": true
+  },
+  {
+    "destKey": "properties.customer.age",
+    "sourceKeys": ["context.traits.age", "traits.age"],
+    "required": false
+  },
+  {
+    "destKey": "event",
+    "sourceKeys": ["traits.action", "context.traits.action"],
+    "required": false
+  },
+  {
+    "destKey": "properties.customer.sex",
+    "sourceKeys": ["traits.gender", "context.traits.gender", "traits.sex", "context.traits.sex"],
+    "required": false
+  },
+  {
+    "destKey": "properties.customer.address",
+    "sourceKeys": "address",
+    "required": false,
+    "sourceFromGenericMap": true
+  },
+  {
+    "destKey": "properties.customer.email",
+    "sourceKeys": "email",
+    "required": false,
+    "sourceFromGenericMap": true
+  },
+  {
+    "destKey": "properties.client",
+    "sourceKeys": "context.app.version",
+    "required": false
+  },
+  {
+    "destKey": "properties.device",
+    "sourceKeys": "context.device.model",
+    "required": false
+  }
+]

src/cdk/v2/destinations/bluecore/data/bluecoreTrackConfig.json

@@ -0,0 +1,77 @@
+[
+  {
+    "destKey": "properties.distinct_id",
+    "sourceKeys": ["userId", "anonymousId", "email"],
+    "required": false
+  },
+  {
+    "destKey": "properties.customer.name",
+    "sourceKeys": "name",
+    "required": false,
+    "sourceFromGenericMap": true
+  },
+  {
+    "destKey": "properties.customer.first_name",
+    "sourceKeys": "firstName",
+    "required": false,
+    "sourceFromGenericMap": true
+  },
+  {
+    "destKey": "properties.customer.last_name",
+    "sourceKeys": "lastName",
+    "required": false,
+    "sourceFromGenericMap": true
+  },
+  {
+    "destKey": "properties.customer.age",
+    "sourceKeys": ["context.traits.age", "traits.age"],
+    "required": false
+  },
+  {
+    "destKey": "properties.customer.sex",
+    "sourceKeys": ["traits.gender", "context.traits.gender", "traits.sex", "context.traits.sex"],
+    "required": false
+  },
+  {
+    "destKey": "properties.customer.address",
+    "sourceKeys": "address",
+    "required": false,
+    "sourceFromGenericMap": true
+  },
+  {
+    "destKey": "properties.customer.email",
+    "sourceKeys": "email",
+    "required": false,
+    "sourceFromGenericMap": true
+  },
+  {
+    "destKey": "properties.search_term",
+    "sourceKeys": "properties.query",
+    "required": false
+  },
+  {
+    "destKey": "properties.order_id",
+    "sourceKeys": "properties.order_id",
+    "required": false
+  },
+  {
+    "destKey": "properties.total",
+    "sourceKeys": "properties.total",
+    "required": false
+  },
+  {
+    "destKey": "properties.client",
+    "sourceKeys": "context.app.version",
+    "required": false
+  },
+  {
+    "destKey": "properties.device",
+    "sourceKeys": "context.device.model",
+    "required": false
+  },
+  {
+    "destKey": "properties.products",
+    "sourceKeys": ["properties.products"],
+    "required": false
+  }
+]

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

@@ -0,0 +1,67 @@
+bindings:
+  - name: EventType
+    path: ../../../../constants
+  - path: ../../bindings/jsontemplate
+  - name: defaultRequestConfig
+    path: ../../../../v0/util
+  - name: removeUndefinedNullValuesAndEmptyObjectArray
+    path: ../../../../v0/util
+  - name: removeUndefinedAndNullValues
+    path: ../../../../v0/util
+  - path: ./utils
+  - path: lodash
+    name: cloneDeep
+
+steps:
+  - name: messageType
+    template: |
+      .message.type.toLowerCase();
+  - name: validateInput
+    template: |
+      let messageType = $.outputs.messageType;
+      $.assert(messageType, "message Type is not present. Aborting");
+      $.assert(messageType in {{$.EventType.([.TRACK, .IDENTIFY])}}, "message type " + messageType + " is not supported");
+      $.assertConfig(.destination.Config.bluecoreNamespace, "[BLUECORE] bluecore account namespace required for Authentication.");
+  - name: prepareIdentifyPayload
+    condition: $.outputs.messageType === {{$.EventType.IDENTIFY}}
+    template: |
+      const payload = $.constructProperties(.message);
+      payload.token = .destination.Config.bluecoreNamespace;
+      $.verifyPayload(payload, .message);
+      payload.event = payload.event ?? 'customer_patch';
+      $.context.payloads = [$.removeUndefinedAndNullValues(payload)];
+  - name: validateInputForTrack
+    description: Additional validation for Track events
+    condition: $.outputs.messageType === {{$.EventType.TRACK}}
+    template: |
+      $.assert(.message.event, "event_name could not be mapped. Aborting.")
+  - name: deduceEventNames
+    condition: $.outputs.messageType === {{$.EventType.TRACK}}
+    template: |
+      $.context.deducedEventNameArray = $.deduceTrackEventName(.message.event,.destination.Config)
+  - name: prepareTrackPayload
+    condition: $.outputs.messageType === {{$.EventType.TRACK}}
+    template: |
+      const payload = $.constructProperties(.message);
+      $.context.payloads = $.context.deducedEventNameArray@eventName.(
+        const newPayload = $.cloneDeep(payload);
+        const temporaryProductArray = newPayload.properties.products ?? $.createProductForStandardEcommEvent(^.message, eventName);
+        newPayload.properties.products = $.addProductArray(temporaryProductArray);
+        newPayload.event = eventName;
+        newPayload.token = ^.destination.Config.bluecoreNamespace;
+        $.verifyPayload(newPayload, ^.message);
+        $.removeUndefinedNullValuesAndEmptyObjectArray(newPayload)
+      )[];
+
+  - name: buildResponse
+    template: |
+      $.context.payloads.(
+        const response = $.defaultRequestConfig();
+        response.body.JSON = .;
+        response.method = "POST";
+        response.endpoint = "https://api.bluecore.com/api/track/mobile/v1";
+        response.headers = {
+          "Content-Type": "application/json"
+        };
+        response
+      )