feat: onboard tune destination

src/v0/destinations/tune/transform.js

@@ -0,0 +1,71 @@
+const { InstrumentationError } = require('@rudderstack/integrations-lib');
+const { defaultRequestConfig, simpleProcessRouterDest } = require('../../util');
+
+const responseBuilder = (message, { Config }) => {
+  const { tuneEvents } = Config; // Extract tuneEvents from config
+  const { properties, event: messageEvent } = message; // Destructure properties and event from message
+
+  // Find the relevant tune event based on the message's event name
+  const tuneEvent = tuneEvents.find((event) => event.eventName === messageEvent);
+
+  if (tuneEvent) {
+    const params = {};
+
+    // Map the properties to their corresponding destination keys
+    tuneEvent.eventsMapping.forEach((mapping) => {
+      if (properties && properties[mapping.from] !== undefined) {
+        params[mapping.to] = properties[mapping.from]; // Map the property to the destination key
+      }
+    });
+
+    // Prepare the response
+    const response = defaultRequestConfig();
+    response.params = params; // Set only the mapped params
+    response.endpoint = tuneEvent.url; // Use the user-defined URL
+
+    // Add query parameters from the URL to params
+    const urlParams = new URLSearchParams(new URL(tuneEvent.url).search);
+    urlParams.forEach((value, key) => {
+      params[key] = value; // Add each query parameter to params
+    });
+
+    // Include the event name in the response, not in params
+    response.event = tuneEvent.eventName;
+
+    return response;
+  }
+
+  throw new InstrumentationError('No matching tune event found for the provided event.', 400);
+};
+
+const processEvent = (message, destination) => {
+  // Validate message type
+  if (!message.type) {
+    throw new InstrumentationError('Message Type is not present. Aborting message.', 400);
+  }
+  const messageType = message.type.toLowerCase();
+
+  // Initialize response variable
+  let response;
+
+  // Process 'track' messages using the responseBuilder
+  if (messageType === 'track') {
+    response = responseBuilder(message, destination);
+  } else {
+    throw new InstrumentationError('Message type not supported. Only "track" is allowed.', 400);
+  }
+
+  return response;
+};
+
+const process = (event) => processEvent(event.message, event.destination);
+
+const processRouterDest = async (inputs, reqMetadata) => {
+  const respList = await simpleProcessRouterDest(inputs, process, reqMetadata);
+  return respList;
+};
+
+module.exports = {
+  process,
+  processRouterDest,
+};

test/integrations/destinations/tune/router/data.ts

@@ -0,0 +1,181 @@
+export const data = [
+  {
+    name: 'tune',
+    description: 'Track call',
+    feature: 'router',
+    module: 'destination',
+    version: 'v0',
+    input: {
+      request: {
+        body: {
+          input: [
+            {
+              message: {
+                type: 'track',
+                event: 'Product added',
+                context: {
+                  traits: {
+                    customProperty1: 'customValue',
+                    firstName: 'David',
+                    logins: 2,
+                  },
+                },
+                anonymousId: 'david_bowie_anonId',
+                rudderId: '27e0a4fc-db65-47b7-ab3e-692e4e3c6b6b',
+                messageId: '7359e92b-b2d9-4147-9c8c-c0e7f060cbcc',
+              },
+              metadata: { jobId: 1, userId: 'u1' },
+              destination: {
+                secretConfig: {},
+                Config: {
+                  blacklistedEvents: [
+                    {
+                      eventName: '',
+                    },
+                  ],
+                  whitelistedEvents: [
+                    {
+                      eventName: '',
+                    },
+                  ],
+                  eventFilteringOption: 'disable',
+                  connectionMode: {
+                    web: 'cloud',
+                  },
+                  consentManagement: {},
+                  tuneEvents: [
+                    {
+                      url: 'https://demo.go2cloud.org/aff_l?offer_id=45&aff_id=1029',
+                      eventName: 'Product added',
+                      eventsMapping: [
+                        {
+                          to: 'adv_sub',
+                          from: 'advSub',
+                        },
+                        {
+                          to: 'aff_id',
+                          from: 'affId',
+                        },
+                        {
+                          to: 'goal_id',
+                          from: 'goalId',
+                        },
+                        {
+                          to: 'revenue',
+                          from: 'revenue',
+                        },
+                        {
+                          to: 'security_token',
+                          from: 'securityToken',
+                        },
+                        {
+                          to: 'status',
+                          from: 'status',
+                        },
+                        {
+                          to: 'transaction_id',
+                          from: 'transactionId',
+                        },
+                      ],
+                    },
+                  ],
+                },
+              },
+            },
+          ],
+          destType: 'tune',
+        },
+        method: 'POST',
+      },
+    },
+    output: {
+      response: {
+        status: 200,
+        body: {
+          output: [
+            {
+              batchedRequest: {
+                version: '1',
+                type: 'REST',
+                method: 'POST',
+                endpoint: 'https://demo.go2cloud.org/aff_l?offer_id=45&aff_id=1029',
+                event: 'Product added',
+                headers: {},
+                params: {
+                  offer_id: '45',
+                  aff_id: '1029',
+                },
+                body: {
+                  JSON: {},
+                  JSON_ARRAY: {},
+                  XML: {},
+                  FORM: {},
+                },
+                files: {},
+              },
+              metadata: [{ jobId: 1, userId: 'u1' }],
+              batched: false,
+              statusCode: 200,
+              destination: {
+                secretConfig: {},
+                Config: {
+                  blacklistedEvents: [
+                    {
+                      eventName: '',
+                    },
+                  ],
+                  whitelistedEvents: [
+                    {
+                      eventName: '',
+                    },
+                  ],
+                  eventFilteringOption: 'disable',
+                  connectionMode: {
+                    web: 'cloud',
+                  },
+                  consentManagement: {},
+                  tuneEvents: [
+                    {
+                      url: 'https://demo.go2cloud.org/aff_l?offer_id=45&aff_id=1029',
+                      eventName: 'Product added',
+                      eventsMapping: [
+                        {
+                          to: 'adv_sub',
+                          from: 'advSub',
+                        },
+                        {
+                          to: 'aff_id',
+                          from: 'affId',
+                        },
+                        {
+                          to: 'goal_id',
+                          from: 'goalId',
+                        },
+                        {
+                          to: 'revenue',
+                          from: 'revenue',
+                        },
+                        {
+                          to: 'security_token',
+                          from: 'securityToken',
+                        },
+                        {
+                          to: 'status',
+                          from: 'status',
+                        },
+                        {
+                          to: 'transaction_id',
+                          from: 'transactionId',
+                        },
+                      ],
+                    },
+                  ],
+                },
+              },
+            },
+          ],
+        },
+      },
+    },
+  },
+];