fix: salesforce: handle ECONNABORTED error

src/adapters/utils/networkUtils.js

@@ -71,6 +71,14 @@ const nodeSysErrorToStatus = (code) => {
       status: 500,
       message: '[ETIMEDOUT] :: Operation timed out',
     },
+    EAI_AGAIN: {
+      status: 500,
+      message: '[EAI_AGAIN] :: Temporary failure in name resolution',
+    },
+    ECONNABORTED: {
+      status: 500,
+      message: '[ECONNABORTED] :: Connection aborted',
+    },
   };
   return sysErrorToStatusMap[code] || { status: 400, message: `[${code}]` };
 };

test/__mocks__/data/salesforce/proxy_response.json

@@ -1,4 +1,44 @@
 {
+  "https://rudderstack.my.salesforce.com/services/data/v50.0/sobjects/Lead/101": {
+    "message": "timeout of 1ms exceeded",
+    "name": "Error",
+    "stack": "Error: timeout of 1ms exceeded\n at createError (webpack-internal:///./node_modules/axios/lib/core/createError.js:16:15)\n at XMLHttpRequest.handleTimeout (webpack-internal:///./node_modules/axios/lib/adapters/xhr.js:89:14)",
+    "config": {
+      "url": "redacted",
+      "method": "get",
+      "headers": {
+        "Accept": "application/json, text/plain, */*"
+      },
+      "transformRequest": [
+        null
+      ],
+      "transformResponse": [
+        null
+      ],
+      "timeout": 1
+    },
+    "code": "ECONNABORTED"
+  },
+  "https://rudderstack.my.salesforce.com/services/data/v50.0/sobjects/Lead/102": {
+    "message": "DNS not found",
+    "name": "Error",
+    "stack": "Error: timeout of 1ms exceeded\n at createError (webpack-internal:///./node_modules/axios/lib/core/createError.js:16:15)\n at XMLHttpRequest.handleTimeout (webpack-internal:///./node_modules/axios/lib/adapters/xhr.js:89:14)",
+    "config": {
+      "url": "redacted",
+      "method": "get",
+      "headers": {
+        "Accept": "application/json, text/plain, */*"
+      },
+      "transformRequest": [
+        null
+      ],
+      "transformResponse": [
+        null
+      ],
+      "timeout": 1
+    },
+    "code": "EAI_AGAIN"
+  },
   "https://rudderstack.my.salesforce.com/services/data/v50.0/sobjects/Lead/1": {
     "response": {
       "data": {
@@ -92,4 +132,4 @@
     },
     "status": 200
   }
-}
+}

test/__tests__/data/salesforce_proxy_input.json

@@ -1,4 +1,70 @@
 [
+  {
+    "type": "REST",
+    "files": {},
+    "method": "POST",
+    "userId": "",
+    "headers": {
+      "Content-Type": "application/json",
+      "Authorization": "Bearer token"
+    },
+    "version": "1",
+    "endpoint": "https://rudderstack.my.salesforce.com/services/data/v50.0/sobjects/Lead/101",
+    "body": {
+      "XML": {},
+      "FORM": {},
+      "JSON": {
+        "Email": "[email protected]",
+        "Company": "sbermarket.ru",
+        "LastName": "Корнилов",
+        "FirstName": "Денис",
+        "LeadSource": "App Signup",
+        "account_type__c": "free_trial"
+      },
+      "JSON_ARRAY": {}
+    },
+    "metadata": {
+      "destInfo": {
+        "authKey": "2HezPl1w11opbFSxnLDEgZ7kWTf"
+      }
+    },
+    "params": {
+      "destination": "salesforce"
+    }
+  },
+  {
+    "type": "REST",
+    "files": {},
+    "method": "POST",
+    "userId": "",
+    "headers": {
+      "Content-Type": "application/json",
+      "Authorization": "Bearer token"
+    },
+    "version": "1",
+    "endpoint": "https://rudderstack.my.salesforce.com/services/data/v50.0/sobjects/Lead/102",
+    "body": {
+      "XML": {},
+      "FORM": {},
+      "JSON": {
+        "Email": "[email protected]",
+        "Company": "sbermarket.ru",
+        "LastName": "Корнилов",
+        "FirstName": "Денис",
+        "LeadSource": "App Signup",
+        "account_type__c": "free_trial"
+      },
+      "JSON_ARRAY": {}
+    },
+    "metadata": {
+      "destInfo": {
+        "authKey": "2HezPl1w11opbFSxnLDEgZ7kWTf"
+      }
+    },
+    "params": {
+      "destination": "salesforce"
+    }
+  },
   {
     "type": "REST",
     "files": {},

test/__tests__/data/salesforce_proxy_output.json

@@ -1,4 +1,54 @@
 [
+  {
+    "output": {
+      "status": 500,
+      "message": "Salesforce Request Failed - due to \"\"[ECONNABORTED] :: Connection aborted\"\", (Retryable) during Salesforce Response Handling",
+      "destinationResponse": {
+        "response": "[ECONNABORTED] :: Connection aborted",
+        "status": 500,
+        "rudderJobMetadata": {
+          "destInfo": {
+            "authKey": "2HezPl1w11opbFSxnLDEgZ7kWTf"
+          }
+        }
+      },
+      "statTags": {
+        "destType": "SALESFORCE",
+        "errorCategory": "network",
+        "destinationId": "Non-determininable",
+        "workspaceId": "Non-determininable",
+        "errorType": "retryable",
+        "feature": "dataDelivery",
+        "implementation": "native",
+        "module": "destination"
+      }
+    }
+  },
+  {
+    "output": {
+      "status": 500,
+      "message": "Salesforce Request Failed - due to \"\"[EAI_AGAIN] :: Temporary failure in name resolution\"\", (Retryable) during Salesforce Response Handling",
+      "destinationResponse": {
+        "response": "[EAI_AGAIN] :: Temporary failure in name resolution",
+        "status": 500,
+        "rudderJobMetadata": {
+          "destInfo": {
+            "authKey": "2HezPl1w11opbFSxnLDEgZ7kWTf"
+          }
+        }
+      },
+      "statTags": {
+        "destType": "SALESFORCE",
+        "errorCategory": "network",
+        "destinationId": "Non-determininable",
+        "workspaceId": "Non-determininable",
+        "errorType": "retryable",
+        "feature": "dataDelivery",
+        "implementation": "native",
+        "module": "destination"
+      }
+    }
+  },
   {
     "output": {
       "status": 200,
@@ -207,4 +257,4 @@
       }
     }
   }
-]
+]