fix: comments addressed

rudderlabs · Dec 16, 2024 · 6e7c01b · 6e7c01b
1 parent 3a3793c
commit 6e7c01b
Show file tree

Hide file tree

Showing 3 changed files with 186 additions and 9 deletions.
diff --git a/src/cdk/v2/destinations/http/procWorkflow.yaml b/src/cdk/v2/destinations/http/procWorkflow.yaml
@@ -36,10 +36,13 @@ steps:
     template: |
       const configAuthHeaders = $.getAuthHeaders(.destination.Config);
       const additionalConfigHeaders = $.getCustomMappings(.message, .destination.Config.headers);   
+      const contentTypeHeader = $.context.format === "FORM-URLENCODED" ? { 'Content-Type': 'application/x-www-form-urlencoded' } : {};
+
       $.context.headers = {
         ...configAuthHeaders,
-        ...additionalConfigHeaders
-      }
+        ...additionalConfigHeaders,
+        ...contentTypeHeader
+      };
 
   - name: prepareParams
     template: |
@@ -55,6 +58,7 @@ steps:
       $.context.payload = $.removeUndefinedAndNullValues($.excludeMappedFields(payload, .destination.Config.propertiesMapping))
       $.context.format === "XML" &&  !$.isEmptyObject($.context.payload) ?  $.context.payload = {payload: $.getXMLPayload($.context.payload)};
       $.context.format === "FORM" &&  !$.isEmptyObject($.context.payload) ?  $.context.payload = {payload: $.getFORMPayload($.context.payload)};
+      $.context.format === "FORM-URLENCODED" &&  !$.isEmptyObject($.context.payload) ?  payload;
 
   - name: buildResponseForProcessTransformation
     template: |

diff --git a/test/integrations/destinations/http/common.ts b/test/integrations/destinations/http/common.ts
@@ -312,17 +312,93 @@ const destinations: Destination[] = [
           from: '$.userId',
           to: '$.userId',
         },
+      ],
+    },
+    DestinationDefinition: {
+      DisplayName: displayName,
+      ID: '123',
+      Name: destTypeInUpperCase,
+      Config: { cdkV2Enabled: true },
+    },
+    Enabled: true,
+    ID: '123',
+    Name: destTypeInUpperCase,
+    Transformations: [],
+    WorkspaceID: 'test-workspace-id',
+  },
+  {
+    Config: {
+      apiUrl: 'http://abc.com/events',
+      auth: 'bearerTokenAuth',
+      bearerToken: 'test-token',
+      method: 'POST',
+      format: 'FORM-URLENCODED',
+      headers: [
         {
-          from: '$.properties.products[*].product_id',
-          to: '$.properties.items[*].item_id',
+          to: '$.h1',
+          from: "'val1'",
         },
         {
-          from: '$.properties.products[*].name',
-          to: '$.properties.items[*].name',
+          to: '$.h2',
+          from: '$.key1',
         },
+      ],
+      propertiesMapping: [
         {
-          from: '$.properties.products[*].price',
-          to: '$.properties.items[*].price',
+          from: '$.event',
+          to: '$.event',
+        },
+        {
+          from: '$.properties.currency',
+          to: '$.currency',
+        },
+        {
+          from: '$.userId',
+          to: '$.userId',
+        },
+      ],
+    },
+    DestinationDefinition: {
+      DisplayName: displayName,
+      ID: '123',
+      Name: destTypeInUpperCase,
+      Config: { cdkV2Enabled: true },
+    },
+    Enabled: true,
+    ID: '123',
+    Name: destTypeInUpperCase,
+    Transformations: [],
+    WorkspaceID: 'test-workspace-id',
+  },
+  {
+    Config: {
+      apiUrl: 'http://abc.com/events',
+      auth: 'bearerTokenAuth',
+      bearerToken: 'test-token',
+      method: 'POST',
+      format: 'FORM-URLENCODED',
+      headers: [
+        {
+          to: '$.h1',
+          from: "'val1'",
+        },
+        {
+          to: '$.h2',
+          from: '$.key1',
+        },
+      ],
+      propertiesMapping: [
+        {
+          from: '$.event',
+          to: '$.event',
+        },
+        {
+          from: '$.properties.currency',
+          to: '$.currency',
+        },
+        {
+          from: '$.userId',
+          to: '$.userId',
         },
       ],
     },

diff --git a/test/integrations/destinations/http/processor/configuration.ts b/test/integrations/destinations/http/processor/configuration.ts
@@ -245,7 +245,7 @@ export const configuration: ProcessorTestData[] = [
                 'content-type': 'application/json',
               },
               FORM: {
-                payload: 'event=Order%20Completed&currency=USD&userId=userId123&properties=',
+                payload: 'event=Order%20Completed&currency=USD&userId=userId123',
               },
             }),
             statusCode: 200,
@@ -255,4 +255,101 @@ export const configuration: ProcessorTestData[] = [
       },
     },
   },
+  {
+    id: 'http-configuration-test-5',
+    name: destType,
+    description: 'Track call with bearer token, form url encoded format',
+    scenario: 'Business',
+    successCriteria:
+      'Response should be in form format with post method, headers and properties mapping',
+    feature: 'processor',
+    module: 'destination',
+    version: 'v0',
+    input: {
+      request: {
+        body: [
+          {
+            destination: destinations[8],
+            message: {
+              type: 'track',
+              userId: 'userId123',
+              event: 'Order Completed',
+              properties,
+            },
+            metadata: generateMetadata(1),
+          },
+        ],
+      },
+    },
+    output: {
+      response: {
+        status: 200,
+        body: [
+          {
+            output: transformResultBuilder({
+              method: 'POST',
+              userId: '',
+              endpoint: destinations[7].Config.apiUrl,
+              headers: {
+                Authorization: 'Bearer test-token',
+                h1: 'val1',
+                'Content-Type': 'application/x-www-form-urlencoded',
+              },
+              FORM: {
+                currency: 'USD',
+                event: 'Order Completed',
+                userId: 'userId123',
+              },
+            }),
+            statusCode: 200,
+            metadata: generateMetadata(1),
+          },
+        ],
+      },
+    },
+  },
+  {
+    id: 'http-configuration-test-6',
+    name: destType,
+    description: 'empty body',
+    scenario: 'Business',
+    successCriteria:
+      'Response should be in form format with post method, headers and properties mapping',
+    feature: 'processor',
+    module: 'destination',
+    version: 'v0',
+    input: {
+      request: {
+        body: [
+          {
+            destination: destinations[9],
+            message: {},
+            metadata: generateMetadata(1),
+          },
+        ],
+      },
+    },
+    output: {
+      response: {
+        status: 200,
+        body: [
+          {
+            output: transformResultBuilder({
+              method: 'POST',
+              userId: '',
+              endpoint: destinations[9].Config.apiUrl,
+              headers: {
+                Authorization: 'Bearer test-token',
+                h1: 'val1',
+                'Content-Type': 'application/x-www-form-urlencoded',
+              },
+              FORM: {},
+            }),
+            statusCode: 200,
+            metadata: generateMetadata(1),
+          },
+        ],
+      },
+    },
+  },
 ];