feat: use axios-mock-adapter for mocking axios requests

src/adapters/network.js

@@ -86,7 +86,7 @@
   const requestOptions = enhanceRequestOptions(options);
 
   const startTime = new Date();
-  const { url, data, method, ...opts } = requestOptions;
+  const { url, data, method } = requestOptions;
   try {
     const response = await axios(requestOptions);
     clientResponse = { success: true, response };
@@ -96,7 +96,7 @@
     fireHTTPStats(clientResponse, startTime, statTags);
   }
 
-  setResponsesForMockAxiosAdapter({ url, data, method, options: opts }, clientResponse);
+  setResponsesForMockAxiosAdapter({ url, data, method, options }, clientResponse);
   return clientResponse;
 };
 
@@ -122,7 +122,7 @@
   } finally {
     fireHTTPStats(clientResponse, startTime, statTags);
   }
-  setResponsesForMockAxiosAdapter({ url, options: requestOptions, method: 'GET' }, clientResponse);
+  setResponsesForMockAxiosAdapter({ url, options, method: 'GET' }, clientResponse);
   return clientResponse;
 };
 
@@ -148,10 +148,7 @@
   } finally {
     fireHTTPStats(clientResponse, startTime, statTags);
   }
-  setResponsesForMockAxiosAdapter(
-    { url, options: requestOptions, method: 'DELETE' },
-    clientResponse,
-  );
+  setResponsesForMockAxiosAdapter({ url, options, method: 'DELETE' }, clientResponse);
   return clientResponse;
 };
 
@@ -178,10 +175,7 @@
   } finally {
     fireHTTPStats(clientResponse, startTime, statTags);
   }
-  setResponsesForMockAxiosAdapter(
-    { url, data, options: requestOptions, method: 'POST' },
-    clientResponse,
-  );
+  setResponsesForMockAxiosAdapter({ url, data, options, method: 'POST' }, clientResponse);
   return clientResponse;
 };
 
@@ -208,10 +202,7 @@
   } finally {
     fireHTTPStats(clientResponse, startTime, statTags);
   }
-  setResponsesForMockAxiosAdapter(
-    { url, data, options: requestOptions, method: 'PUT' },
-    clientResponse,
-  );
+  setResponsesForMockAxiosAdapter({ url, data, options, method: 'PUT' }, clientResponse);
   return clientResponse;
 };
 
@@ -238,10 +229,7 @@
   } finally {
     fireHTTPStats(clientResponse, startTime, statTags);
   }
-  setResponsesForMockAxiosAdapter(
-    { url, data, options: requestOptions, method: 'PATCH' },
-    clientResponse,
-  );
+  setResponsesForMockAxiosAdapter({ url, data, options, method: 'PATCH' }, clientResponse);
   return clientResponse;
 };
 

src/v0/destinations/canny/util.js

@@ -25,7 +25,7 @@ const retrieveUserId = async (apiKey, message) => {
     message.traits?.email || message.context?.traits?.email || message.properties?.email;
   const { userId } = message;
 
-  const header = {
+  const headers = {
     'Content-Type': 'application/x-www-form-urlencoded',
     Accept: JSON_MIME_TYPE,
   };
@@ -38,10 +38,15 @@ const retrieveUserId = async (apiKey, message) => {
   } else {
     requestBody.userID = `${userId}`;
   }
-  const response = await httpPOST(url, qs.stringify(requestBody), header, {
-    destType: 'canny',
-    feature: 'transformation',
-  });
+  const response = await httpPOST(
+    url,
+    qs.stringify(requestBody),
+    { headers },
+    {
+      destType: 'canny',
+      feature: 'transformation',
+    },
+  );
   logger.debug(response);
   // If the request fails, throwing error.
   if (response.success === false) {

src/v0/destinations/yahoo_dsp/util.js

@@ -1,7 +1,7 @@
 const qs = require('qs');
 const sha256 = require('sha256');
 const { generateJWTToken } = require('../../../util/jwtTokenGenerator');
-const { httpPOST } = require('../../../adapters/network');
+const { httpSend } = require('../../../adapters/network');
 const { isDefinedAndNotNullAndNotEmpty } = require('../../util');
 const { getDynamicErrorType } = require('../../../adapters/utils/networkUtils');
 const { ACCESS_TOKEN_CACHE_TTL, AUDIENCE_ATTRIBUTE, DSP_SUPPORTED_OPERATION } = require('./config');
@@ -119,7 +119,7 @@ const getAccessToken = async (destination) => {
     };
 
     const request = {
-      header: {
+      headers: {
         'Content-Type': 'application/x-www-form-urlencoded',
         Accept: JSON_MIME_TYPE,
       },
@@ -134,7 +134,7 @@ const getAccessToken = async (destination) => {
       }),
       method: 'POST',
     };
-    const dspAuthorisationData = await httpPOST(request.url, request.data, request.header, {
+    const dspAuthorisationData = await httpSend(request, {
       destType: 'yahoo_dsp',
       feature: 'transformation',
     });

test/integrations/component.test.ts

@@ -21,6 +21,7 @@ import { Server } from 'http';
 import { appendFileSync } from 'fs';
 import { responses } from '../testHelper';
 import utils from '../../src/v0/util';
+import isMatch from 'lodash/isMatch';
 
 // To run single destination test cases
 // npm run test:ts -- component  --destination=adobe_analytics
@@ -79,26 +80,32 @@ if (!opts.generate || opts.generate === 'false') {
       const { url, method, data: reqData, ...opts } = axiosMock.httpReq;
       const { data, headers, status } = axiosMock.httpRes;
 
+      const headersAsymMatch = {
+        asymmetricMatch: function (actual) {
+          return isMatch(actual, opts.headers);
+        },
+      };
+
       switch (method.toLowerCase()) {
         case 'get':
           // @ts-ignore
-          mock.onGet(url, reqData, opts.headers).reply(status, data, headers);
+          mock.onGet(url, reqData, headersAsymMatch).reply(status, data, headers);
           break;
         case 'delete':
           // @ts-ignore
-          mock.onDelete(url, reqData, opts.headers).reply(status, data, headers);
+          mock.onDelete(url, reqData, headersAsymMatch).reply(status, data, headers);
           break;
         case 'post':
           // @ts-ignore
-          mock.onPost(url, reqData, opts.headers).reply(status, data, headers);
+          mock.onPost(url, reqData, headersAsymMatch).reply(status, data, headers);
           break;
         case 'patch':
           // @ts-ignore
-          mock.onPatch(url, reqData, opts.headers).reply(status, data, headers);
+          mock.onPatch(url, reqData, headersAsymMatch).reply(status, data, headers);
           break;
         case 'put':
           // @ts-ignore
-          mock.onPut(url, reqData, opts.headers).reply(status, data, headers);
+          mock.onPut(url, reqData, headersAsymMatch).reply(status, data, headers);
           break;
         default:
           break;