Merge branch 'refactor.version-workflows' of github.com:rudderlabs/ru…

…dder-transformer into refactor.version-workflows
rudderlabs · Feb 2, 2024 · 7ec5d04 · 7ec5d04
2 parents b897d9d + bd3d192
commit 7ec5d04
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 12 deletions.
diff --git a/src/cdk/v2/destinations/intercom/procWorkflow.yaml b/src/cdk/v2/destinations/intercom/procWorkflow.yaml
@@ -44,7 +44,6 @@ steps:
     template: |
       $.addExternalIdToTraits(.message);
       $.context.payload = $.getFieldValueFromMessage(.message, "traits")
-      
   
   - name: trackWorkflow
     condition: $.outputs.messageType === {{$.EventType.TRACK}}
@@ -65,11 +64,10 @@ steps:
           $.outputs.apiVersion !== "v1" ? payload.created_at = $.toSeconds(timestamp);
           $.outputs.apiVersion === "v1" ? payload.created = $.toSeconds(timestamp);
           !(payload.user_id) && .destination.Config.sendAnonymousId ? payload.user_id = .message.anonymousId;
-          $context.payload = payload;
-
+          $.context.payload = payload;
       - name: finalPayload
         template: |
-          $context.payload = $.addMetadataToPayload($context.payload);
+          $.context.payload = $.addMetadataToPayload($.context.payload);
           $.assert($.context.payload.event_name, "Event name is required for track call");
           $.assert($.context.payload.user_id || $.context.payload.email, "Either email or userId is required for Track call");
           $.context.requestMethod = 'POST';
@@ -112,7 +110,6 @@ steps:
               value: $.outputs.rETLPayload
             - name: groupTransformPayload
               value: $.outputs.rETLPayload || $.outputs.groupTransformPayload
-
       - name: finalPayload
         template: |
           const finalOutput = $.outputs.versionWorkflows.v1 ?? $.outputs.versionWorkflows.v2

diff --git a/src/cdk/v2/destinations/intercom/v1Workflow.yaml b/src/cdk/v2/destinations/intercom/v1Workflow.yaml
@@ -14,12 +14,13 @@ bindings:
 
 steps:
   - name: messageType
-    template: .message.type.toLowerCase()
+    template:  |
+      .message.type.toLowerCase()
 
   - name: searchContact
-      condition: $.outputs.messageType in [{{$.EventType.IDENTIFY}}, {{$.EventType.GROUP}}]
-      template: |
-        await $.searchContact(.message, .destination)
+    condition: $.outputs.messageType in {{$.EventType.([.IDENTIFY, .GROUP])}}
+    template: |
+      await $.searchContact(.message, .destination)
 
   - name: identifyWorkflow
     condition: $.outputs.messageType === {{$.EventType.IDENTIFY}}

diff --git a/src/cdk/v2/destinations/intercom/v2Workflow.yaml b/src/cdk/v2/destinations/intercom/v2Workflow.yaml
@@ -15,9 +15,9 @@ steps:
     template: .message.type.toLowerCase()
 
   - name: searchContact
-      condition: $.outputs.messageType in [{{$.EventType.IDENTIFY}}, {{$.EventType.GROUP}}]
-      template: |
-        await $.searchContact(.message, .destination)
+    condition: $.outputs.messageType in [{{$.EventType.IDENTIFY}}, {{$.EventType.GROUP}}]
+    template: |
+      await $.searchContact(.message, .destination)
 
   - name: identifyWorkflow
     condition: $.outputs.messageType === {{$.EventType.IDENTIFY}}