feat: added multiplexing for zapUrls

.eslintignore

@@ -1,4 +1,4 @@
 node_modules/
 .husky/
 reports/
 test/
@@ -10,6 +10,8 @@
 *.md
 *.test.js
 *.test.ts
+*.yaml
+*.yml
 src/util/lodash-es-core.js
 **/ivm*.js
 **/custom*.js

.prettierrc

@@ -1,7 +1,8 @@
 {
   "trailingComma": "all",
   "tabWidth": 2,
   "semi": true,
   "singleQuote": true,
-  "printWidth": 100
+  "printWidth": 100,
+  "overrides": [{ "files": "*eslintignore", "options": { "parser": "yaml" } }]
 }

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

@@ -1,10 +1,9 @@
 bindings:
   - name: EventType
     path: ../../../../constants
-  - name: getHashFromArray
+  - name: getHashFromArrayWithDuplicate
     path: ../../../../v0/util/index
-  - name: defaultRequestConfig
-    path: ../../../../v0/util
+  - path: ./utils
 
 steps:
   - name: validateInput
@@ -15,18 +14,18 @@ steps:
   - name: prepareContext
     template: |
       $.context.messageType = .message.type.toLowerCase();
-      $.context.endpoint = .destination.Config.zapUrl;
+      $.context.endpoint = [.destination.Config.zapUrl];
   - name: trackEndpoint
     condition: $.context.messageType === {{$.EventType.TRACK}}
     template: |
-      const trackEventsMap = $.getHashFromArray(.destination.Config.trackEventsToZap);
+      const trackEventsMap = $.getHashFromArrayWithDuplicate(.destination.Config.trackEventsToZap);
       const eventName = .message.event.toLowerCase();
       (eventName && trackEventsMap[eventName]) ? 
         ($.context.endpoint = trackEventsMap[eventName])
     else:
       name: endpointForOthers
       template: |
-        const pageScreenEventsMap = $.getHashFromArray(.destination.Config.pageScreenEventsToZap);
+        const pageScreenEventsMap = $.getHashFromArrayWithDuplicate(.destination.Config.pageScreenEventsToZap);
         const pageName = .message.name.toLowerCase();
         (pageName && pageScreenEventsMap[pageName]) ? 
           ($.context.endpoint = pageScreenEventsMap[pageName])
@@ -37,10 +36,5 @@ steps:
     else:
       name: buildResponseForProcessTransformation
       template: |
-        const response = $.defaultRequestConfig();
-        response.body.JSON = .message;
-        response.endpoint = $.context.endpoint;
-        response.headers = {
-          "content-type": "application/json"
-        };
-        response
+        const responseList = $.buildResponseList(.message, $.context.endpoint)
+        responseList

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

@@ -0,0 +1,15 @@
+const { defaultRequestConfig } = require('../../../../v0/util');
+
+const buildResponseList = (payload, endpointList) => {
+  const responseList = [];
+  endpointList.forEach((endpoint) => {
+    const response = defaultRequestConfig();
+    response.body.JSON = payload;
+    response.endpoint = endpoint;
+    response.headers = { 'content-type': 'application/json' };
+    responseList.push(response);
+  });
+  return responseList;
+};
+
+module.exports = { buildResponseList };

test/integrations/destinations/zapier/processor/data.ts

@@ -643,6 +643,62 @@ export const data = [
       response: {
         status: 200,
         body: [
+          {
+            output: {
+              version: '1',
+              type: 'REST',
+              method: 'POST',
+              endpoint: 'def.zap-hook',
+              headers: {
+                'content-type': 'application/json',
+              },
+              params: {},
+              body: {
+                JSON: {
+                  event: 'def',
+                  userId: 'identified user id',
+                  type: 'track',
+                  anonymousId: 'anon-id-new',
+                  context: {
+                    traits: {
+                      trait1: 'new-val',
+                    },
+                    ip: '14.5.67.21',
+                    library: {
+                      name: 'http',
+                    },
+                  },
+                  properties: {
+                    abc: '123',
+                    key: {
+                      abc: 123,
+                    },
+                    array: [
+                      {
+                        abc: 123,
+                      },
+                      {
+                        def: 123,
+                      },
+                    ],
+                  },
+                  timestamp: '2020-02-02T00:23:09.544Z',
+                  originalTimestamp: '2020-04-17T14:42:44.724Z',
+                  sentAt: '2020-04-17T14:42:44.724Z',
+                },
+                JSON_ARRAY: {},
+                XML: {},
+                FORM: {},
+              },
+              files: {},
+              userId: '',
+            },
+            statusCode: 200,
+            metadata: {
+              destinationId: 'destId',
+              workspaceId: 'wspId',
+            },
+          },
           {
             output: {
               version: '1',
@@ -703,4 +759,214 @@ export const data = [
       },
     },
   },
+  {
+    id: 'Test 5',
+    name: 'zapier',
+    description: 'Track call with Multiplexing',
+    scenario: 'Framework+Business',
+    feature: 'processor',
+    module: 'destination',
+    version: 'v0',
+    input: {
+      request: {
+        body: [
+          {
+            message: {
+              event: 'def',
+              userId: 'identified user id',
+              type: 'track',
+              anonymousId: 'anon-id-new',
+              timestamp: '2020-02-02T00:23:09.544Z',
+              originalTimestamp: '2020-04-17T14:42:44.724Z',
+              sentAt: '2020-04-17T14:42:44.724Z',
+            },
+            metadata: {
+              destinationId: 'destId',
+              workspaceId: 'wspId',
+            },
+            destination: {
+              DestinationDefinition: {
+                Config: {
+                  cdkV2Enabled: true,
+                },
+              },
+              Config: {
+                zapUrl: 'abcd.zap-hook',
+                trackEventsToZap: [
+                  {
+                    from: 'def',
+                    to: ['def.zap-hook', 'ghi.zap-hook'],
+                  },
+                ],
+                pageScreenEventsToZap: [{}],
+              },
+              Enabled: true,
+              Transformations: [],
+              IsProcessorEnabled: true,
+            },
+          },
+        ],
+        method: 'POST',
+      },
+    },
+    output: {
+      response: {
+        status: 200,
+        body: [
+          {
+            output: {
+              version: '1',
+              type: 'REST',
+              method: 'POST',
+              endpoint: ['def.zap-hook', 'ghi.zap-hook'],
+              headers: {
+                'content-type': 'application/json',
+              },
+              params: {},
+              body: {
+                JSON: {
+                  event: 'def',
+                  userId: 'identified user id',
+                  type: 'track',
+                  anonymousId: 'anon-id-new',
+                  timestamp: '2020-02-02T00:23:09.544Z',
+                  originalTimestamp: '2020-04-17T14:42:44.724Z',
+                  sentAt: '2020-04-17T14:42:44.724Z',
+                },
+                JSON_ARRAY: {},
+                XML: {},
+                FORM: {},
+              },
+              files: {},
+              userId: '',
+            },
+            statusCode: 200,
+            metadata: {
+              destinationId: 'destId',
+              workspaceId: 'wspId',
+            },
+          },
+        ],
+      },
+    },
+  },
+  {
+    id: 'Test 6',
+    name: 'zapier',
+    description: 'Page call with Multiplexing',
+    scenario: 'Framework+Business',
+    feature: 'processor',
+    module: 'destination',
+    version: 'v0',
+    input: {
+      request: {
+        body: [
+          {
+            message: {
+              name: 'abc_page_test',
+              userId: 'identified user id',
+              type: 'page',
+              anonymousId: 'anon-id-new',
+              properties: {
+                abc: '123',
+                key: {
+                  abc: 123,
+                },
+                array: [
+                  {
+                    abc: 123,
+                  },
+                  {
+                    def: 123,
+                  },
+                ],
+              },
+              timestamp: '2020-02-02T00:23:09.544Z',
+              originalTimestamp: '2020-04-17T14:42:44.724Z',
+              sentAt: '2020-04-17T14:42:44.724Z',
+            },
+            metadata: {
+              destinationId: 'destId',
+              workspaceId: 'wspId',
+            },
+            destination: {
+              DestinationDefinition: {
+                Config: {
+                  cdkV2Enabled: true,
+                },
+              },
+              Config: {
+                zapUrl: 'abcd.zap-hook',
+                trackEventsToZap: [{}],
+                pageScreenEventsToZap: [
+                  {
+                    from: 'abc_page_test',
+                    to: ['page.zap-hook', 'ghi.zap-hook'],
+                  },
+                ],
+              },
+              Enabled: true,
+              Transformations: [],
+              IsProcessorEnabled: true,
+            },
+          },
+        ],
+        method: 'POST',
+      },
+    },
+    output: {
+      response: {
+        status: 200,
+        body: [
+          {
+            output: {
+              version: '1',
+              type: 'REST',
+              method: 'POST',
+              endpoint: ['page.zap-hook', 'ghi.zap-hook'],
+              headers: {
+                'content-type': 'application/json',
+              },
+              params: {},
+              body: {
+                JSON: {
+                  name: 'abc_page_test',
+                  userId: 'identified user id',
+                  type: 'page',
+                  anonymousId: 'anon-id-new',
+                  properties: {
+                    abc: '123',
+                    key: {
+                      abc: 123,
+                    },
+                    array: [
+                      {
+                        abc: 123,
+                      },
+                      {
+                        def: 123,
+                      },
+                    ],
+                  },
+                  timestamp: '2020-02-02T00:23:09.544Z',
+                  originalTimestamp: '2020-04-17T14:42:44.724Z',
+                  sentAt: '2020-04-17T14:42:44.724Z',
+                },
+                JSON_ARRAY: {},
+                XML: {},
+                FORM: {},
+              },
+              files: {},
+              userId: '',
+            },
+            statusCode: 200,
+            metadata: {
+              destinationId: 'destId',
+              workspaceId: 'wspId',
+            },
+          },
+        ],
+      },
+    },
+  },
 ];