Retry functionality update

- Retry Delay with base and conditional backoff added
- Retry on error Condition added

Author: uttamukkoji

lib/contentstack.js

@@ -18,6 +18,10 @@ import httpClient from './core/contentstackHTTPClient.js'
  * @prop {object} params.headers - Optional additional headers
  * @prop {number} params.timeout - Optional number of milliseconds before the request times out. Default is 30000
  * @prop {number} params.retryLimit - Optional number of retries before failure. Default is 5
+ * @prop {number} params.retryDelay - The number of miliseconds to use for operation retries. Default is 300ms
+ * @prop {Function} params.retryCondition - A function to determine if the error can be retried. Default retry is on status 429.
+ * @prop {number} params.retryDelayOptions.base - The base number of milliseconds to use in the exponential backoff for operation retries.
+ * @prop {Function} params.retryDelayOptions.customBackoff - A custom function that accepts a retry count and error and returns the amount of time to delay in milliseconds.
  * @prop {number} params.maxContentLength - Optional maximum content length in bytes (default: 1073741824 i.e. 1GB)
  * @prop {string} params.application - Application name and version e.g myApp/version
  * @prop {string} params.integration - Integration name and version e.g react/version

lib/core/contentstack-retry.js

@@ -1,5 +1,5 @@
 
-export default function contentstckRetry (axios, defaultOptions, retryLimit = 5, retryDelay = 2) {
+export default function contentstckRetry (axios, defaultOptions, retryLimit = 5, retryDelay = 300) {
   var networkError = 0
   axios.interceptors.request.use(function (config) {
     if (config.headers.authorization && config.headers.authorization !== undefined) {
@@ -22,15 +22,22 @@ export default function contentstckRetry (axios, defaultOptions, retryLimit = 5,
       retryErrorType = `Server connection`
       return Promise.reject(error)
     }
-
-    if (response && response.status === 429) {
+    if (defaultOptions.retryCondition && defaultOptions.retryCondition(error)) {
       retryErrorType = 'Rate Limit'
       networkError++
       if (networkError > retryLimit) {
         networkError = 0
         return Promise.reject(error)
       }
-      wait = retryDelay
+      if (defaultOptions.retryDelayOptions) {
+        if (defaultOptions.retryDelayOptions.base) {
+          wait = defaultOptions.retryDelayOptions.base * networkError
+        } else if (defaultOptions.retryDelayOptions.customBackoff) {
+          wait = defaultOptions.retryDelayOptions.customBackoff(networkError, error)
+        }
+      } else {
+        wait = retryDelay
+      }
     } else {
       networkError = 0
     }

lib/core/contentstackHTTPClient.js

@@ -16,6 +16,12 @@ export default function contentstackHttpClient (options) {
       }
       console.log(`[${level}] ${data}`)
     },
+    retryCondition: (error) => {
+      if (error.response && error.response.status === 429) {
+        return true
+      }
+      return false
+    },
     headers: {},
     basePath: '',
     proxy: false,
@@ -71,6 +77,8 @@ export default function contentstackHttpClient (options) {
     responseLogger: config.responseLogger,
     requestLogger: config.requestLogger,
     retryOnError: config.retryOnError,
+    retryDelayOptions: config.retryDelayOptions,
+    retryCondition: config.retryCondition,
     paramsSerializer: function (params) {
       var query = params.query
       delete params.query