chore: propagate metadata to api call fn in intercom dest

rudderlabs · Jun 18, 2024 · 9a39d67 · 9a39d67
1 parent 6ce30f0
commit 9a39d67
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 4 deletions.
diff --git a/src/cdk/v2/destinations/intercom/procWorkflow.yaml b/src/cdk/v2/destinations/intercom/procWorkflow.yaml
@@ -50,7 +50,7 @@ steps:
   - name: searchContact
     condition: ($.outputs.messageType === {{$.EventType.IDENTIFY}} || $.outputs.messageType === {{$.EventType.GROUP}}) && $.outputs.apiVersion !== "v1"
     template: |
-      const contactId = await $.searchContact(.message, .destination);
+      const contactId = await $.searchContact(.message, .destination, .metadata);
       contactId;
 
   - name: identifyTransformationForLatestVersion
@@ -176,7 +176,7 @@ steps:
         condition: $.isDefinedAndNotNull($.outputs.searchContact)
         template: |
           const contactId = $.outputs.searchContact;
-          const companyId = await $.createOrUpdateCompany($.context.payload, .destination);
+          const companyId = await $.createOrUpdateCompany($.context.payload, .destination, .metadata);
           $.assert(companyId, "Unable to create or update company");
           $.context.payload = {
             id: companyId,

diff --git a/src/cdk/v2/destinations/intercom/utils.js b/src/cdk/v2/destinations/intercom/utils.js
@@ -227,7 +227,7 @@ const filterCustomAttributes = (payload, type, destination) => {
  * @param {*} destination
  * @returns
  */
-const searchContact = async (message, destination) => {
+const searchContact = async (message, destination, metadata) => {
   const lookupField = getLookUpField(message);
   const lookupFieldValue = getFieldValueFromMessage(message, lookupField);
   const data = JSON.stringify({
@@ -258,6 +258,7 @@ const searchContact = async (message, destination) => {
       endpointPath: '/contacts/search',
       requestMethod: 'POST',
       module: 'router',
+      metadata,
     },
   );
   const processedUserResponse = processAxiosResponse(response);
@@ -284,7 +285,7 @@ const searchContact = async (message, destination) => {
  * @param {*} destination
  * @returns
  */
-const createOrUpdateCompany = async (payload, destination) => {
+const createOrUpdateCompany = async (payload, destination, metadata) => {
   const headers = getHeaders(destination);
   const finalPayload = JSON.stringify(removeUndefinedAndNullValues(payload));
   const baseEndPoint = getBaseEndpoint(destination);
@@ -296,6 +297,7 @@ const createOrUpdateCompany = async (payload, destination) => {
       headers,
     },
     {
+      metadata,
       destType: 'intercom',
       feature: 'transformation',
       endpointPath: '/companies',