fix bug in retry while error handling

src/internal/request.ts

@@ -65,24 +65,34 @@ export async function requestWithRetry(
   maxRetries: number = MAX_RETRIES,
 ): Promise<http.IncomingMessage> {
   let attempt = 0
+  let isRetryable = false
   while (attempt <= maxRetries) {
     try {
       const response = await request(transport, opt, body)
       // Check if the HTTP status code is retryable
       if (isHttpRetryable(response.statusCode as number)) {
+        isRetryable = true
         throw new Error(`Retryable HTTP status: ${response.statusCode}`) // trigger retry attempt with calculated delay
       }
+
       return response // Success, return the raw response
     } catch (err) {
-      attempt++
+      if (isRetryable) {
+        attempt++
+        isRetryable = false
 
-      if (attempt > maxRetries) {
-        throw new Error(`Request failed after ${maxRetries} retries: ${err}`)
+        if (attempt > maxRetries) {
+          throw new Error(`Request failed after ${maxRetries} retries: ${err}`)
+        }
+        const delay = getExpBackOffDelay(attempt)
+        // eslint-disable-next-line no-console
+        console.warn(
+          `${new Date().toLocaleString()} Retrying request (attempt ${attempt}/${maxRetries}) after ${delay}ms due to: ${err}`,
+        )
+        await sleep(delay)
+      } else {
+        throw err // re-throw if any request, syntax errors
       }
-      const delay = getExpBackOffDelay(attempt)
-      // eslint-disable-next-line no-console
-      // console.warn( `${new Date().toLocaleString()} Retrying request (attempt ${attempt}/${maxRetries}) after ${delay}ms due to: ${err}`,)
-      await sleep(delay)
     }
   }
 

tests/functional/functional-tests.js

@@ -40,7 +40,7 @@
 const isWindowsPlatform = process.platform === 'win32'
 
 describe('functional tests', function () {
-  this.timeout(300000) // 5 minutes
+  this.timeout(30 * 60 * 1000)
   var clientConfigParams = {}
   var region_conf_env = process.env['MINIO_REGION']
 
@@ -3629,13 +3629,13 @@
     const metadata = { 'X-Amz-Meta-Test': 'test-value' }
 
     before(() => {
       return client.makeBucket(bucketName, '').then((res) => {
         return client.putObject(bucketName, objectName, fdObject, fdObject.length, metadata).then((res) => {
           return client.setObjectTagging(bucketName, objectName, tags)
         })
       })
     })
     after(() => client.removeObject(bucketName, objectName).then((_) => client.removeBucket(bucketName)))
 
     step(
       `extensions.listObjectsV2WithMetadata(bucketName, prefix, recursive)_bucketName:${bucketName}, prefix:"", recursive:true`,

tests/unit/test.js

@@ -253,7 +253,7 @@ describe('CopyConditions', () => {
 
 describe('Client', function () {
   var nockRequests = []
-  this.timeout(300000) // 5 minutes
+  this.timeout(5000) // 5 minutes
   beforeEach(() => {
     Nock.cleanAll()
     nockRequests = []