chore: add requestMethod and module latency labels

src/adapters/network.js

@@ -49,18 +49,24 @@ const fireHTTPStats = (clientResponse, startTime, statTags) => {
   const destType = statTags.destType ? statTags.destType : '';
   const feature = statTags.feature ? statTags.feature : '';
   const endpointPath = statTags.endpointPath ? statTags.endpointPath : '';
+  const requestMethod = statTags.requestMethod ? statTags.requestMethod : '';
+  const module = statTags.module ? statTags.module : '';
   const statusCode = clientResponse.success ? clientResponse.response.status : '';
   stats.timing('outgoing_request_latency', startTime, {
     feature,
     destType,
     endpointPath,
+    requestMethod,
+    module
   });
   stats.counter('outgoing_request_count', 1, {
     feature,
     destType,
     endpointPath,
     success: clientResponse.success,
     statusCode,
+    requestMethod,
+    module
   });
 };
 

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

@@ -246,11 +246,20 @@ const searchContact = async (message, destination) => {
   const headers = getHeaders(destination);
   const baseEndPoint = getBaseEndpoint(destination);
   const endpoint = `${baseEndPoint}/${SEARCH_CONTACT_ENDPOINT}`;
-  const response = await httpPOST(endpoint, data, {
-    headers,
-    destType: 'intercom',
-    feature: 'transformation',
-  });
+  const response = await httpPOST(
+    endpoint,
+    data,
+    {
+      headers,
+    },
+    {
+      destType: 'intercom',
+      feature: 'transformation',
+      endpointPath: '/contacts/search',
+      requestMethod: 'POST',
+      module: 'router',
+    },
+  );
   const processedUserResponse = processAxiosResponse(response);
   if (isHttpStatusSuccess(processedUserResponse.status)) {
     return processedUserResponse.response?.data.length > 0
@@ -280,11 +289,20 @@ const createOrUpdateCompany = async (payload, destination) => {
   const finalPayload = JSON.stringify(removeUndefinedAndNullValues(payload));
   const baseEndPoint = getBaseEndpoint(destination);
   const endpoint = `${baseEndPoint}/${CREATE_OR_UPDATE_COMPANY_ENDPOINT}`;
-  const response = await httpPOST(endpoint, finalPayload, {
-    headers,
-    destType: 'intercom',
-    feature: 'transformation',
-  });
+  const response = await httpPOST(
+    endpoint,
+    finalPayload,
+    {
+      headers,
+    },
+    {
+      destType: 'intercom',
+      feature: 'transformation',
+      endpointPath: '/companies',
+      requestMethod: 'POST',
+      module: 'router',
+    },
+  );
 
   const processedResponse = processAxiosResponse(response);
   if (isHttpStatusSuccess(processedResponse.status)) {

src/util/prometheus.js

@@ -533,7 +533,7 @@ class Prometheus {
         name: 'outgoing_request_count',
         help: 'Outgoing HTTP requests count',
         type: 'counter',
-        labelNames: ['feature', 'destType', 'endpointPath', 'success', 'statusCode'],
+        labelNames: ['feature', 'destType', 'endpointPath', 'success', 'statusCode', 'requestMethod' , 'module'],
       },
 
       // Gauges
@@ -573,7 +573,7 @@ class Prometheus {
         name: 'outgoing_request_latency',
         help: 'Outgoing HTTP requests duration in seconds',
         type: 'histogram',
-        labelNames: ['feature', 'destType', 'endpointPath'],
+        labelNames: ['feature', 'destType', 'endpointPath', 'requestMethod', 'module'],
       },
       {
         name: 'http_request_duration',

src/v0/destinations/active_campaign/transform.js

@@ -62,6 +62,8 @@ const syncContact = async (contactPayload, category, destination) => {
     destType: 'active_campaign',
     feature: 'transformation',
     endpointPath: endPoint,
+    requestMethod: 'POST',
+    module: 'router',
   });
   if (res.success === false) {
     errorHandler(res, 'Failed to create new contact');
@@ -129,6 +131,8 @@ const customTagProcessor = async (message, category, destination, contactId) =>
           destType: 'active_campaign',
           feature: 'transformation',
           endpointPath: `/api/3/tags`,
+          requestMethod: 'GET',
+          module: 'router',
         });
         promises.push(resp);
       }
@@ -253,6 +257,8 @@ const customFieldProcessor = async (message, category, destination) => {
         destType: 'active_campaign',
         feature: 'transformation',
         endpointPath: `/api/3/fields`,
+        requestMethod: 'GET',
+        module: 'router',
       });
       promises.push(resp);
     }
@@ -351,6 +357,8 @@ const customListProcessor = async (message, category, destination, contactId) =>
         destType: 'active_campaign',
         feature: 'transformation',
         endpointPath: mergeListWithContactUrl,
+        requestMethod: 'POST',
+        module: 'router',
       });
       promises.push(res);
     }
@@ -409,6 +417,8 @@ const screenRequestHandler = async (message, category, destination) => {
     destType: 'active_campaign',
     feature: 'transformation',
     endpointPath: `/api/3/eventTrackingEvents`,
+    requestMethod: 'GET',
+    module: 'router',
   });
   if (res.success === false) {
     errorHandler(res, 'Failed to retrieve events');
@@ -473,6 +483,8 @@ const trackRequestHandler = async (message, category, destination) => {
     destType: 'active_campaign',
     feature: 'transformation',
     endpointPath: `/api/3/eventTrackingEvents`,
+    requestMethod: 'GET',
+    module: 'router',
   });
 
   if (res.success === false) {

src/v0/destinations/af/deleteUsers.js

@@ -39,6 +39,8 @@ const deleteUser = async (config, endpoint, body, identityType, identityValue) =
       destType: 'af',
       feature: 'deleteUsers',
       endpointPath: `appsflyer.com/api/gdpr/v1/opendsr_requests`,
+      requestMethod: 'POST',
+      module: 'deletion',
     },
   );
   const handledDelResponse = processAxiosResponse(response);

src/v0/destinations/am/deleteUsers.js

@@ -43,6 +43,8 @@ const userDeletionHandler = async (userAttributes, config) => {
         destType: 'am',
         feature: 'deleteUsers',
         endpointPath,
+        requestMethod: 'POST',
+        module: 'deletion',
       });
       const handledDelResponse = processAxiosResponse(resp);
       if (!isHttpStatusSuccess(handledDelResponse.status)) {

src/v0/destinations/braze/braze.util.test.js

@@ -305,7 +305,14 @@ describe('dedup utility tests', () => {
           },
           timeout: 10000,
         },
-        { destType: 'braze', feature: 'transformation' },
+        {
+          destType: 'braze',
+          feature: 'transformation',
+          endpointPath: '/users/export/ids',
+          feature: 'transformation',
+          module: 'router',
+          requestMethod: 'POST',
+        },
       );
     });
 

src/v0/destinations/braze/deleteUsers.js

@@ -22,7 +22,7 @@ const userDeletionHandler = async (userAttributes, config) => {
   // Endpoints different for different data centers.
   // DOC: https://www.braze.com/docs/user_guide/administrative/access_braze/braze_instances/
   let endPoint;
-  const endpointPath = '/users/delete'; // TODO: to handle for destinations dynamically by extracting from endpoint
+  const endpointPath = '/users/delete';
   const dataCenterArr = dataCenter.trim().split('-');
   if (dataCenterArr[0].toLowerCase() === 'eu') {
     endPoint = 'https://rest.fra-01.braze.eu/users/delete';
@@ -46,6 +46,8 @@ const userDeletionHandler = async (userAttributes, config) => {
         destType: 'braze',
         feature: 'deleteUsers',
         endpointPath,
+        requestMethod: 'POST',
+        module: 'deletion',
       });
       const handledDelResponse = processAxiosResponse(resp);
       if (!isHttpStatusSuccess(handledDelResponse.status) && handledDelResponse.status !== 404) {

src/v0/destinations/braze/transform.js

@@ -223,6 +223,9 @@ async function processIdentify(message, destination) {
     {
       destType: 'braze',
       feature: 'transformation',
+      requestMethod: 'POST',
+      module: 'router',
+      endpointPath: '/users/identify',
     },
   );
   if (!isHttpStatusSuccess(brazeIdentifyResp.status)) {

src/v0/destinations/braze/util.js

@@ -163,6 +163,9 @@ const BrazeDedupUtility = {
           {
             destType: 'braze',
             feature: 'transformation',
+            requestMethod: 'POST',
+            module: 'router',
+            endpointPath: '/users/export/ids',
           },
         );
         stats.counter('braze_lookup_failure_count', 1, {

src/v0/destinations/canny/util.js

@@ -46,6 +46,8 @@ const retrieveUserId = async (apiKey, message) => {
       destType: 'canny',
       feature: 'transformation',
       endpointPath: `/v1/users/retrieve`,
+      requestMethod: 'POST',
+      module: 'processor',
     },
   );
   logger.debug(response);

src/v0/destinations/clevertap/deleteUsers.js

@@ -53,6 +53,8 @@ const userDeletionHandler = async (userAttributes, config) => {
         destType: 'clevertap',
         feature: 'deleteUsers',
         endpointPath,
+        requestMethod: 'POST',
+        module: 'deletion',
       },
     );
     const handledDelResponse = processAxiosResponse(deletionResponse);

src/v0/destinations/clickup/util.js

@@ -217,6 +217,9 @@ const retrieveCustomFields = async (listId, apiToken) => {
   const customFieldsResponse = await httpGET(endpoint, requestOptions, {
     destType: 'clickup',
     feature: 'transformation',
+    endpointPath: '/list/listId/field',
+    requestMethod: 'GET',
+    module: 'router',
   });
   const processedCustomFieldsResponse = processAxiosResponse(customFieldsResponse);
 

src/v0/destinations/custify/deleteUsers.js

@@ -35,6 +35,9 @@ const userDeletionHandler = async (userAttributes, config) => {
   const deletionResponse = await httpDELETE(requestUrl, requestOptions, {
     destType: 'custify',
     feature: 'deleteUsers',
+    requestMethod: 'DELETE',
+    endpointPath: '/people',
+    module: 'deletion',
   });
   const processedDeletionRequest = processAxiosResponse(deletionResponse);
   if (processedDeletionRequest.status !== 200 && processedDeletionRequest.status !== 404) {

src/v0/destinations/custify/util.js

@@ -41,6 +41,8 @@ const createUpdateCompany = async (companyPayload, Config) => {
       destType: 'custify',
       feature: 'transformation',
       endpointPath: `/company`,
+      requestMethod: 'POST',
+      module: 'router',
     },
   );
   const processedCompanyResponse = processAxiosResponse(companyResponse);

src/v0/destinations/delighted/util.js

@@ -61,7 +61,13 @@ const userValidity = async (channel, Config, userId) => {
         },
         params: paramsdata,
       },
-      { destType: 'delighted', feature: 'transformation' },
+      {
+        destType: 'delighted',
+        feature: 'transformation',
+        requestMethod: 'GET',
+        endpointPath: '/people.json',
+        module: 'router',
+      },
     );
     if (response && response.data && response.status === 200 && Array.isArray(response.data)) {
       return response.data.length > 0;

src/v0/destinations/drip/util.js

@@ -31,7 +31,13 @@ const userExists = async (Config, id) => {
           'Content-Type': JSON_MIME_TYPE,
         },
       },
-      { destType: 'drip', feature: 'transformation' },
+      {
+        destType: 'drip',
+        feature: 'transformation',
+        requestMethod: 'GET',
+        endpointPath: '/subscribers/id',
+        module: 'router',
+      },
     );
     if (response && response.status) {
       return response.status === 200;
@@ -70,7 +76,13 @@ const createUpdateUser = async (finalpayload, Config, basicAuth) => {
           'Content-Type': JSON_MIME_TYPE,
         },
       },
-      { destType: 'drip', feature: 'transformation' },
+      {
+        destType: 'drip',
+        feature: 'transformation',
+        requestMethod: 'POST',
+        endpointPath: '/subscribers',
+        module: 'router',
+      },
     );
     if (response) {
       return response.status === 200 || response.status === 201;

src/v0/destinations/engage/deleteUsers.js

@@ -42,6 +42,9 @@ const userDeletionHandler = async (userAttributes, config) => {
           {
             destType: 'engage',
             feature: 'deleteUsers',
+            requestMethod: 'DELETE',
+            endpointPath: '/users/userId',
+            module: 'deletion',
           },
         );
         const handledDelResponse = processAxiosResponse(response);

src/v0/destinations/freshmarketer/utils.js

@@ -50,6 +50,8 @@ const createUpdateAccount = async (payload, Config) => {
     destType: 'freshmarketer',
     feature: 'transformation',
     endpointPath: `/crm/sales/api/sales_accounts/upsert`,
+    requestMethod: 'POST',
+    module: 'router',
   });
   accountResponse = processAxiosResponse(accountResponse);
   if (accountResponse.status !== 200 && accountResponse.status !== 201) {
@@ -95,6 +97,8 @@ const getUserAccountDetails = async (payload, userEmail, Config) => {
     destType: 'freshmarketer',
     feature: 'transformation',
     endpointPath: `crm/sales/api/contacts/upsert?include=sales_accounts`,
+    requestMethod: 'POST',
+    module: 'router',
   });
   userSalesAccountResponse = processAxiosResponse(userSalesAccountResponse);
   if (userSalesAccountResponse.status !== 200 && userSalesAccountResponse.status !== 201) {
@@ -145,6 +149,8 @@ const createOrUpdateListDetails = async (listName, Config) => {
     destType: 'freshmarketer',
     feature: 'transformation',
     endpointPath: `/crm/sales/api/lists`,
+    requestMethod: 'GET',
+    module: 'router',
   });
   listResponse = processAxiosResponse(listResponse);
   if (listResponse.status !== 200) {
@@ -165,6 +171,8 @@ const createOrUpdateListDetails = async (listName, Config) => {
     destType: 'freshmarketer',
     feature: 'transformation',
     endpointPath: `/crm/sales/api/lists`,
+    requestMethod: 'POST',
+    module: 'router',
   });
   listResponse = processAxiosResponse(listResponse);
   if (listResponse.status !== 200) {
@@ -240,6 +248,8 @@ const getContactsDetails = async (userEmail, Config) => {
     destType: 'freshmarketer',
     feature: 'transformation',
     endpointPath: `/crm/sales/api/contacts/upsert`,
+    requestMethod: 'POST',
+    module: 'router',
   });
   userResponse = processAxiosResponse(userResponse);
   if (userResponse.status !== 200 && userResponse.status !== 201) {
@@ -314,6 +324,8 @@ const UpdateContactWithLifeCycleStage = async (message, Config) => {
     destType: 'freshmarketer',
     feature: 'transformation',
     endpointPath: `/crm/sales/api/selector/lifecycle_stages`,
+    requestMethod: 'GET',
+    module: 'router',
   });
   lifeCycleStagesResponse = processAxiosResponse(lifeCycleStagesResponse);
   if (lifeCycleStagesResponse.status !== 200) {
@@ -400,6 +412,8 @@ const UpdateContactWithSalesActivity = async (payload, message, Config) => {
     destType: 'freshmarketer',
     feature: 'transformation',
     endpointPath: `/crm/sales/api/selector/sales_activity_types`,
+    requestMethod: 'GET',
+    module: 'router',
   });
   salesActivityResponse = processAxiosResponse(salesActivityResponse);
   if (salesActivityResponse.status !== 200) {