retry seinding request in case request failed due to network connection

Author: brootle

QencodeApiClient.js

@@ -1,20 +1,11 @@
 const axios = require('axios');
 const querystring = require('querystring');
-const axiosRetry = require('axios-retry');
 
 const TranscodingTask = require('./Classes/TranscodingTask');
 
-// Set the retry logic
-axiosRetry(axios, {
-    retries: 20, 
-    retryDelay: (retryCount) => {
-      return 3000; // time interval between retries
-    },
-    // retry on Network Error and 5xx responses
-    retryCondition: (error) => {
-      return axiosRetry.isNetworkOrIdempotentRequestError(error) || error.code === 'ECONNABORTED';
-    },
-  });
+function delay(time) {
+    return new Promise(resolve => setTimeout(resolve, time));
+} 
 
 class QencodeApiClient {
     constructor(options) {
@@ -93,9 +84,10 @@ class QencodeApiClient {
         }
         return new TranscodingTask(this, response.task_token, response.upload_url);
     }    
-
-    async Request(path, parameters, statusUrl){
-
+    
+    
+    async Request(path, parameters, statusUrl){    
+   
         this.lastResponseRaw = null;
         this.lastResponse = null;
 
@@ -117,22 +109,31 @@ class QencodeApiClient {
             parameters = querystring.stringify(parameters);        
         }  
 
-        try {
-            this.lastResponseRaw = await axios.post(
-                requestUrl,
-                parameters,
-                {
-                    headers: {
-                        'Content-Type': 'application/x-www-form-urlencoded'
-                    },                    
-                    timeout: this.ConnectTimeout * 1000 
-                }
+        let retry = 20;
+        const retryDelay = 3000;
 
-            );
-        } catch (err) {
-            throw new Error("Error executing request to url: " + requestUrl, err);
+        for (let i = 0; i < retry; i++) {
+            try {
+                this.lastResponseRaw = await axios.post(
+                    requestUrl,
+                    parameters,
+                    {
+                        headers: {
+                            'Content-Type': 'application/x-www-form-urlencoded'
+                        },
+                        timeout: this.ConnectTimeout * 1000
+                    }
+                );
+                break;
+            } catch (err) {
+                if(i === retry - 1) {
+                    throw new Error("All attempts to execute request failed.");
+                }
+                console.error(`Error executing request to url: ${requestUrl} on attempt ${i + 1}. Retrying in ${retryDelay / 1000} seconds...`);
+                await delay(retryDelay);
+            }
         }
-
+        
         let response = this.lastResponseRaw.data;
 
         if (response == null || response.error == null){

package-lock.json

@@ -26,7 +26,7 @@
   "bundleDependencies": [],
   "dependencies": {
     "axios": "^1.2.1",
-    "axios-retry": "^3.5.1",
+    "qencode-api": "^3.0.0",
     "querystring": "^0.2.1"
   },
   "deprecated": false,