feat: http form format

package.json

@@ -109,6 +109,7 @@
     "parse-static-imports": "^1.1.0",
     "prom-client": "^14.2.0",
     "qs": "^6.11.1",
+    "querystring": "^0.2.1",
     "rs-jsonpath": "^1.1.2",
     "set-value": "^4.1.0",
     "sha256": "^0.2.0",

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

@@ -54,11 +54,12 @@ steps:
       const payload = $.getCustomMappings(.message, .destination.Config.propertiesMapping);
       $.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)};
 
   - name: buildResponseForProcessTransformation
     template: |
       const response = $.defaultRequestConfig();
-      $.context.format === "JSON" ? response.body.JSON = $.context.payload: response.body.XML = $.context.payload;
+      $.context.format === "JSON" ? response.body.JSON = $.context.payload : $.context.format === "XML" ? response.body.XML = $.context.payload : response.body.FORM = $.context.payload ;
       response.endpoint = $.context.endpoint;
       response.headers = $.context.headers;
       response.method = $.context.method;

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

@@ -1,6 +1,7 @@
 const { toXML } = require('jstoxml');
 const { groupBy } = require('lodash');
 const { createHash } = require('crypto');
+const querystring = require('querystring');
 const { ConfigurationError } = require('@rudderstack/integrations-lib');
 const { BatchUtils } = require('@rudderstack/workflow-engine');
 const {
@@ -146,11 +147,24 @@ const batchSuccessfulEvents = (events, batchSize) => {
   return response;
 };
 
+/**
+ * Converts JSON payload to application/x-www-form-urlencoded format.
+ * @param {Object} payload - The JSON payload to be converted.
+ * @returns {string} - The payload in application/x-www-form-urlencoded format.
+ */
+const getFORMPayload = (payload) => {
+  if (!payload) {
+    throw new ConfigurationError('Invalid payload for FORM format');
+  }
+  return querystring.stringify(payload);
+};
+
 module.exports = {
   getAuthHeaders,
   getCustomMappings,
   addPathParams,
   excludeMappedFields,
   getXMLPayload,
   batchSuccessfulEvents,
+  getFORMPayload,
 };

test/integrations/destinations/http/common.ts

@@ -278,6 +278,66 @@ const destinations: Destination[] = [
     Transformations: [],
     WorkspaceID: 'test-workspace-id',
   },
+  {
+    Config: {
+      apiUrl: 'http://abc.com/events',
+      auth: 'bearerTokenAuth',
+      bearerToken: 'test-token',
+      method: 'POST',
+      format: 'FORM',
+      headers: [
+        {
+          to: '$.h1',
+          from: "'val1'",
+        },
+        {
+          to: '$.h2',
+          from: '$.key1',
+        },
+        {
+          to: "$.'content-type'",
+          from: "'application/json'",
+        },
+      ],
+      propertiesMapping: [
+        {
+          from: '$.event',
+          to: '$.event',
+        },
+        {
+          from: '$.properties.currency',
+          to: '$.currency',
+        },
+        {
+          from: '$.userId',
+          to: '$.userId',
+        },
+        {
+          from: '$.properties.products[*].product_id',
+          to: '$.properties.items[*].item_id',
+        },
+        {
+          from: '$.properties.products[*].name',
+          to: '$.properties.items[*].name',
+        },
+        {
+          from: '$.properties.products[*].price',
+          to: '$.properties.items[*].price',
+        },
+      ],
+    },
+    DestinationDefinition: {
+      DisplayName: displayName,
+      ID: '123',
+      Name: destTypeInUpperCase,
+      Config: { cdkV2Enabled: true },
+    },
+    Enabled: true,
+    ID: '123',
+    Name: destTypeInUpperCase,
+    Transformations: [],
+    WorkspaceID: 'test-workspace-id',
+  },
 ];
 
 const traits = {

test/integrations/destinations/http/processor/configuration.ts

@@ -1,6 +1,6 @@
 import { ProcessorTestData } from '../../../testTypes';
 import { generateMetadata, transformResultBuilder } from '../../../testUtils';
-import { destType, destinations, properties, traits } from '../common';
+import { destinations, destType, properties, traits } from '../common';
 
 export const configuration: ProcessorTestData[] = [
   {
@@ -203,4 +203,56 @@ export const configuration: ProcessorTestData[] = [
       },
     },
   },
+  {
+    id: 'http-configuration-test-4',
+    name: destType,
+    description:
+      'Track call with bearer token, form format, post method, additional headers and properties mapping',
+    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[7],
+            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/json',
+              },
+              FORM: {
+                payload: 'event=Order%20Completed&currency=USD&userId=userId123&properties=',
+              },
+            }),
+            statusCode: 200,
+            metadata: generateMetadata(1),
+          },
+        ],
+      },
+    },
+  },
 ];