add configurable timeout and retry delay for requests

Author: harshithad0703

src/api.ts

@@ -13,12 +13,14 @@ import { readFileSync } from './util/fs'
 
 const debug = Debug('api')
 let MAX_RETRY_LIMIT
+let RETRY_DELAY_BASE = 200 // Default base delay in milliseconds
+let TIMEOUT = 30000 // Default timeout in milliseconds
 let Contentstack
 
 /**
  * @description Initialize sync utilities API requests
  * @param {Object} contentstack - Contentstack configuration details
- */
+*/
 export const init = (contentstack) => {
   const packageInfo: any = JSON.parse(readFileSync(join(__dirname, '..', 'package.json')))
   Contentstack = contentstack
@@ -35,6 +37,14 @@ export const init = (contentstack) => {
   if (Contentstack.MAX_RETRY_LIMIT) {
     MAX_RETRY_LIMIT = Contentstack.MAX_RETRY_LIMIT
   }
+
+  if (Contentstack.RETRY_DELAY_BASE) {
+    RETRY_DELAY_BASE = Contentstack.RETRY_DELAY_BASE
+  }
+
+  if (Contentstack.TIMEOUT) {
+    TIMEOUT = Contentstack.TIMEOUT
+  }
 }
 
 /**
@@ -60,7 +70,7 @@ export const get = (req, RETRY = 1) => {
       path: sanitizeUrl(encodeURI(req.path)),
       port: Contentstack.port,
       protocol: Contentstack.protocol,
-      timeout: 30000, // 30 second timeout to prevent socket hang ups
+      timeout: TIMEOUT, // Configurable timeout to prevent socket hang ups
     }
 
     try {
@@ -77,8 +87,8 @@ export const get = (req, RETRY = 1) => {
               if (response.statusCode >= 200 && response.statusCode <= 399) {
                 return resolve(JSON.parse(body))
               } else if (response.statusCode === 429) {
-                timeDelay = Math.pow(Math.SQRT2, RETRY) * 200
-                debug(`API rate limit exceeded. Retrying ${options.path} with ${timeDelay} sec delay`)
+                timeDelay = Math.pow(Math.SQRT2, RETRY) * RETRY_DELAY_BASE
+                debug(`API rate limit exceeded. Retrying ${options.path} with ${timeDelay} ms delay`)
 
                 return setTimeout(() => {
                   return get(req, RETRY)
@@ -87,8 +97,8 @@ export const get = (req, RETRY = 1) => {
                 }, timeDelay)
               } else if (response.statusCode >= 500) {
                 // retry, with delay
-                timeDelay = Math.pow(Math.SQRT2, RETRY) * 200
-                debug(`Retrying ${options.path} with ${timeDelay} sec delay`)
+                timeDelay = Math.pow(Math.SQRT2, RETRY) * RETRY_DELAY_BASE
+                debug(`Retrying ${options.path} with ${timeDelay} ms delay`)
                 RETRY++
 
                 return setTimeout(() => {
@@ -105,20 +115,20 @@ export const get = (req, RETRY = 1) => {
         })
 
       // Set socket timeout to handle socket hang ups
-      httpRequest.setTimeout(30000, () => {
-        debug(`Request timeout for ${options.path}`)
+      httpRequest.setTimeout(options.timeout, () => {
+        debug(`Request timeout for ${options.path || 'unknown'}`)
         httpRequest.destroy()
         reject(new Error('Request timeout'))
       })
 
       // Enhanced error handling for socket hang ups and connection resets
       httpRequest.on('error', (error: any) => {
-        debug(`Request error for ${options.path}: ${error.message} (${error.code || 'NO_CODE'})`)
+        debug(`Request error for ${options.path || 'unknown'}: ${error?.message || 'Unknown error'} (${error?.code || 'NO_CODE'})`)
 
         // Handle socket hang up and connection reset errors with retry
-        if ((error.code === 'ECONNRESET' || error.message?.includes('socket hang up')) && RETRY <= MAX_RETRY_LIMIT) {
-          timeDelay = Math.pow(Math.SQRT2, RETRY) * 200
-          debug(`Socket hang up detected. Retrying ${options.path} with ${timeDelay} ms delay (attempt ${RETRY}/${MAX_RETRY_LIMIT})`)
+        if ((error?.code === 'ECONNRESET' || error?.message?.includes('socket hang up')) && RETRY <= MAX_RETRY_LIMIT) {
+          timeDelay = Math.pow(Math.SQRT2, RETRY) * RETRY_DELAY_BASE
+          debug(`Socket hang up detected. Retrying ${options.path || 'unknown'} with ${timeDelay} ms delay (attempt ${RETRY}/${MAX_RETRY_LIMIT})`)
           RETRY++
 
           return setTimeout(() => {

src/config.ts

@@ -33,6 +33,8 @@ export const config = {
   },
   contentstack: {
     MAX_RETRY_LIMIT: 6,
+    TIMEOUT: 30000,  // 30 seconds - can be overridden by user config
+    RETRY_DELAY_BASE: 200,  // Base delay for retry logic - can be overridden by user config
     actions: {
       delete: 'delete',
       publish: 'publish',