fix: adding support for track call

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

@@ -39,19 +39,46 @@ steps:
     description: |
       Builds identify payload.
       ref:
+    condition: $.outputs.messageType === {{$.EventType.IDENTIFY}}
     template: |
       $.context.payload = $.buildIdentifyPayload(.message, .destination.Config,);
   - name: preparePayloadForGroup
     description: |
       Builds group payload.
       ref: https://dev.emarsys.com/docs/core-api-reference/1m0m70hy3tuov-add-contacts-to-a-contact-list
+    condition: $.outputs.messageType === {{$.EventType.GROUP}}
     template: |
       $.context.payload = $.buildGroupPayload(.message, .destination.Config,);
+  - name: preparePayloadForTrack
+    description: |
+      Builds track payload.
+      ref: https://dev.emarsys.com/docs/core-api-reference/fl0xx6rwfbwqb-trigger-an-external-event
+    condition: $.outputs.messageType === {{$.EventType.TRACK}}
+    template: |
+      const integrationObject = $.getIntegrationsObj(message, 'emersys');
+      const emersysIdentifierId = integrationObject?.customIdentifierId || ^.destination.Config.emersysCustomIdentifier || $.EMAIL_FIELD_ID;
+      const payload = {
+          key_id: emersysIdentifierId ,
+          external_id: $.deduceExternalIdValue(.message,emersysIdentifierId,.destination.Config.fieldMapping),
+          trigger_id: integrationObject.trigger_id,
+          data: properties.data,
+          attachment: Array.isArray(properties.attachment)
+          ? properties.attachment
+            : [properties.attachment],
+            event_time: $.getFieldValueFromMessage(message, 'timestamp'),
+          };
+      $.context.payload = {
+          eventType: ^.message.type,
+          destinationPayload: {
+            payload: $.removeUndefinedAndNullValues(payload),
+            eventId: $.deduceEventId(.message,.destination.Config),
+          },
+        };
   - name: buildResponse
     template: |
       const response = $.defaultRequestConfig();
       response.body.JSON = $.context.payload;
-      response.endpoint = $.deduceEndPoint(.message,.destination.Config);
+      response.endpoint = $.deduceEndPoint($.context.payload,.destination.Config);
       response.method = "POST";
       response.headers = $.buildHeader(.destination.Config)
       response

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

@@ -5,13 +5,18 @@ const crypto = require('crypto');
 
 const {
   InstrumentationError,
+  ConfigurationError,
   isDefinedAndNotNullAndNotEmpty,
   removeUndefinedAndNullAndEmptyValues,
   removeUndefinedAndNullValues,
   isDefinedAndNotNull,
+  getHashFromArray,
 } = require('@rudderstack/integrations-lib');
-const { getValueFromMessage } = require('rudder-transformer-cdk/build/utils');
-const { getIntegrationsObj } = require('../../../../v0/util');
+const {
+  getValueFromMessage,
+  getFieldValueFromMessage,
+} = require('rudder-transformer-cdk/build/utils');
+const { getIntegrationsObj, validateEventName } = require('../../../../v0/util');
 const {
   EMAIL_FIELD_ID,
   MAX_BATCH_SIZE,
@@ -104,16 +109,21 @@ const findRudderPropertyByEmersysProperty = (emersysProperty, fieldMapping) => {
   return item ? item.rudderProperty : null;
 };
 
-const buildGroupPayload = (message, destination) => {
-  const { emersysCustomIdentifier, defaultContactList, fieldMapping } = destination.Config;
-  const integrationObject = getIntegrationsObj(message, 'emersys');
-  const emersysIdentifier =
-    integrationObject?.customIdentifierId || emersysCustomIdentifier || EMAIL_FIELD_ID;
+const deduceExternalIdValue = (message, emersysIdentifier, fieldMapping) => {
   const configuredPayloadProperty = findRudderPropertyByEmersysProperty(
     emersysIdentifier,
     fieldMapping,
   );
   const externalIdValue = getValueFromMessage(message.context.traits, configuredPayloadProperty);
+  return externalIdValue;
+};
+
+const buildGroupPayload = (message, destination) => {
+  const { emersysCustomIdentifier, defaultContactList, fieldMapping } = destination.Config;
+  const integrationObject = getIntegrationsObj(message, 'emersys');
+  const emersysIdentifier =
+    integrationObject?.customIdentifierId || emersysCustomIdentifier || EMAIL_FIELD_ID;
+  const externalIdValue = deduceExternalIdValue(message, emersysIdentifier, fieldMapping);
   if (!isDefinedAndNotNull(externalIdValue)) {
     throw new InstrumentationError(
       `No value found in payload for contact custom identifier of id ${emersysIdentifier}`,
@@ -132,18 +142,68 @@ const buildGroupPayload = (message, destination) => {
   };
 };
 
-const deduceEndPoint = (message, destConfig, batchGroupId = undefined) => {
+const deduceEventId = (message, destConfig) => {
+  let eventId;
+  const { eventsMapping } = destConfig;
+  const { event } = message;
+  validateEventName(event);
+  if (eventsMapping.length > 0) {
+    const keyMap = getHashFromArray(eventsMapping, 'from', 'to', false);
+    eventId = keyMap[event];
+  }
+  if (!eventId) {
+    throw new ConfigurationError(`${event} is not mapped to any Emersys external event. Aborting`);
+  }
+};
+
+const buildTrackPayload = (message, destination) => {
+  let eventId;
+  const { emersysCustomIdentifier, eventsMapping } = destination.Config;
+  const { event, properties } = message;
+
+  if (eventsMapping.length > 0) {
+    const keyMap = getHashFromArray(eventsMapping, 'from', 'to', false);
+    eventId = keyMap[event];
+  }
+  const integrationObject = getIntegrationsObj(message, 'emersys');
+  const emersysIdentifier =
+    integrationObject?.customIdentifierId || emersysCustomIdentifier || EMAIL_FIELD_ID;
+  const payload = {
+    key_id: emersysIdentifier,
+    external_id: '[email protected]',
+    trigger_id: integrationObject.trigger_id,
+    data: properties.data,
+    attachment: Array.isArray(properties.attatchment)
+      ? properties.attatchment
+      : [properties.attatchment],
+    event_time: getFieldValueFromMessage(message, 'timestamp'),
+  };
+  return {
+    eventType: message.type,
+    destinationPayload: {
+      payload: removeUndefinedAndNullValues(payload),
+      event: eventId,
+    },
+  };
+};
+
+const deduceEndPoint = (finalPayload) => {
   let endPoint;
+  let eventId;
   let contactListId;
-  const { type, groupId } = message;
-  switch (type) {
+  const { eventType, destinationPayload } = finalPayload;
+  switch (eventType) {
     case EVENT_TYPE.IDENTIFY:
       endPoint = 'https://api.emarsys.net/api/v2/contact/?create_if_not_exists=1';
       break;
     case EVENT_TYPE.GROUP:
-      contactListId = batchGroupId || groupId || destConfig.defaultContactList;
+      contactListId = destinationPayload.contactListId;
       endPoint = `https://api.emarsys.net/api/v2/contactlist/${contactListId}/add`;
       break;
+    case EVENT_TYPE.TRACK:
+      eventId = destinationPayload.eventId;
+      endPoint = `https://api.emarsys.net/api/v2/event/${eventId}/trigger`;
+      break;
     default:
       break;
   }
@@ -347,4 +407,7 @@ module.exports = {
   createIdentifyBatches,
   ensureSizeConstraints,
   createGroupBatches,
+  buildTrackPayload,
+  deduceExternalIdValue,
+  deduceEventId,
 };