fix: retryNetworkError method to update the running queue using shifts

Author: nadeem-cs

lib/core/concurrency-queue.js

@@ -130,24 +130,42 @@ export function ConcurrencyQueue ({ axios, config }) {
 
     return new Promise((resolve, reject) => {
       setTimeout(() => {
-        // Remove the failed request from running queue
-        const runningIndex = this.running.findIndex(item => item.request === error.config)
-        if (runningIndex !== -1) {
-          this.running.splice(runningIndex, 1)
-        }
-
-        // Retry the request
+        // Keep the request in running queue to maintain maxRequests constraint
+        // Set retry flags to ensure proper queue handling
         const sanitizedConfig = validateAndSanitizeConfig(updateRequestConfig(error, `Network retry ${attempt}`, delay))
+        sanitizedConfig.retryCount = sanitizedConfig.retryCount || 0
+
+        // Use axios directly but ensure the running queue is properly managed
+        // The request interceptor will handle this retry appropriately
         axios(sanitizedConfig)
-          .then(resolve)
+          .then((response) => {
+            // On successful retry, call the original onComplete to properly clean up
+            if (error.config.onComplete) {
+              error.config.onComplete()
+            }
+            shift() // Process next queued request
+            resolve(response)
+          })
           .catch((retryError) => {
             // Check if this is still a transient error and we can retry again
             const retryErrorInfo = isTransientNetworkError(retryError)
             if (retryErrorInfo) {
               retryNetworkError(retryError, retryErrorInfo, attempt + 1)
                 .then(resolve)
-                .catch(reject)
+                .catch((finalError) => {
+                  // On final failure, clean up the running queue
+                  if (error.config.onComplete) {
+                    error.config.onComplete()
+                  }
+                  shift() // Process next queued request
+                  reject(finalError)
+                })
             } else {
+              // On non-retryable error, clean up the running queue
+              if (error.config.onComplete) {
+                error.config.onComplete()
+              }
+              shift() // Process next queued request
               reject(retryError)
             }
           })