fix: 🐛 Formdata retry

Author: uttamukkoji

.talismanrc

@@ -1,11 +1,11 @@
 fileignoreconfig:
 - filename: jsdocs/stack_environment_index.js.html
-  checksum: ef24cd9f2e12802a1abbbc440e22c486863b90823050bf0c7ed17cd95d6d0669
+  checksum: 1093109567f5d30a23900af471422ccbad4c24aac2415d5bdd4f4f1eb95b27b3
 - filename: dist/node/contentstack-management.js
-  checksum: 8313dfeaa7e856ae355b2ef9d9beac095c8b1c7c93aafb9ab73f0d86c23e29ec
+  checksum: 04714b8c8d21f1aec36faed12738dd8d5c16bca6197b57309f87208a15be1c37
 - filename: dist/nativescript/contentstack-management.js
-  checksum: bb55ba77624c3f000c56c9f9730016883be9863973e9177c4e8a3a70fa9796e1
+  checksum: dd7ca11b797a1e00d863a2474433b37c5517d7fe69977dd506680432e7f8c19c
 - filename: dist/react-native/contentstack-management.js
-  checksum: 8edb4ff3adf9f4a4d21047e8aeac28231a3711fae001ef805c8fd093bd211634
+  checksum: 9fdd9277c186a8b670813528c89f8a21484122ca2aca6d4f7b3d501153ed936d
 - filename: dist/web/contentstack-management.js
-  checksum: a04259dd778b2f49aa5652299bdc7828e402de2167f24c33acfa8604ce662c0a
+  checksum: 16fce6e8acfa61a77bb2e900347c17b6bc6f465aeefeac99fb22ec221dffff10

lib/core/concurrency-queue.js

@@ -71,6 +71,11 @@ export function ConcurrencyQueue ({ axios, config }) {
 
   // Request interceptor to queue the request
   const requestHandler = request => {
+    if (typeof request.data === 'function') {
+      request.formdata = request.data
+      request.data = transformFormData(request)
+    }
+    console.log(request.data)
     request.retryCount = request.retryCount || 0
     if (request.headers.authorization && request.headers.authorization !== undefined) {
       delete request.headers.authtoken
@@ -91,6 +96,9 @@ export function ConcurrencyQueue ({ axios, config }) {
     }
 
     return new Promise(resolve => {
+      request.onComplete = () => {
+        this.running.pop({ request, resolve })
+      }
       this.push({ request, resolve })
     })
   }
@@ -117,7 +125,7 @@ export function ConcurrencyQueue ({ axios, config }) {
 
   // Response interceptor used for
   const responseHandler = (response) => {
-    this.running.shift()
+    response.config.onComplete()
     shift()
     return response
   }
@@ -210,12 +218,25 @@ export function ConcurrencyQueue ({ axios, config }) {
       }
     }
 
+    requestConfig.data = transformFormData(requestConfig)
     requestConfig.transformRequest = [function (data) {
       return data
     }]
     return requestConfig
   }
 
+  const transformFormData = (request) => {
+    if (request.formdata) {
+      const formdata = request.formdata()
+      request.headers = {
+        ...request.headers,
+        ...formdata.getHeaders()
+      }
+      return formdata
+    }
+    return request.data
+  }
+
   // Adds interseptors in axios to queue request
   this.interceptors.request = axios.interceptors.request.use(requestHandler)
   this.interceptors.response = axios.interceptors.response.use(responseHandler, responseErrorHandler)

lib/entity.js

@@ -57,7 +57,6 @@ export const upload = async ({ http, urlPath, stackHeaders, formData, params, me
   const headers = {
     headers: {
       ...params,
-      ...formData.getHeaders(),
       ...cloneDeep(stackHeaders)
     }
   } || {}

lib/stack/asset/index.js

@@ -234,27 +234,24 @@ export function AssetCollection (http, data) {
 }
 
 function createFormData (data) {
-  const formData = new FormData()
-  if (typeof data['parent_uid'] === 'string') {
-    formData.append('asset[parent_uid]', data['parent_uid'])
-  }
-
-  if (typeof data.description === 'string') {
-    formData.append('asset[description]', data.description)
-  }
-
-  if (data.tags instanceof Array) {
-    formData.append('asset[tags]', data.tags.join(','))
-  } else if (typeof data.tags === 'string') {
-    formData.append('asset[tags]', data.tags)
-  }
-
-  if (typeof data.title === 'string') {
-    formData.append('asset[title]', data.title)
+  return () => {
+    const formData = new FormData()
+    if (typeof data['parent_uid'] === 'string') {
+      formData.append('asset[parent_uid]', data['parent_uid'])
+    }
+    if (typeof data.description === 'string') {
+      formData.append('asset[description]', data.description)
+    }
+    if (data.tags instanceof Array) {
+      formData.append('asset[tags]', data.tags.join(','))
+    } else if (typeof data.tags === 'string') {
+      formData.append('asset[tags]', data.tags)
+    }
+    if (typeof data.title === 'string') {
+      formData.append('asset[title]', data.title)
+    }
+    const uploadStream = createReadStream(data.upload)
+    formData.append('asset[upload]', uploadStream)
+    return formData
   }
-
-  const uploadStream = createReadStream(data.upload)
-  formData.append('asset[upload]', uploadStream)
-
-  return formData
 }

lib/stack/contentType/index.js

@@ -199,8 +199,10 @@ export function ContentTypeCollection (http, data) {
 }
 
 function createFormData (data) {
-  const formData = new FormData()
-  const uploadStream = createReadStream(data.content_type)
-  formData.append('content_type', uploadStream)
-  return formData
+  return () => {
+    const formData = new FormData()
+    const uploadStream = createReadStream(data.content_type)
+    formData.append('content_type', uploadStream)
+    return formData
+  }
 }

lib/stack/extension/index.js

@@ -156,33 +156,34 @@ export function ExtensionCollection (http, data) {
 }
 
 function createExtensionFormData (data) {
-  const formData = new FormData()
+  return () => {
+    const formData = new FormData()
 
-  if (typeof data.title === 'string') {
-    formData.append('extension[title]', data.title)
-  }
-  if (typeof data.scope === 'object') {
-    formData.append('extension[scope]', `${data.scope}`)
-  }
-  if (typeof data['data_type'] === 'string') {
-    formData.append('extension[data_type]', data['data_type'])
-  }
-  if (typeof data.type === 'string') {
-    formData.append('extension[type]', data.type)
-  }
-  if (data.tags instanceof Array) {
-    formData.append('extension[tags]', data.tags.join(','))
-  } else if (typeof data.tags === 'string') {
-    formData.append('extension[tags]', data.tags)
-  }
-  if (typeof data.multiple === 'boolean') {
-    formData.append('extension[multiple]', `${data.multiple}`)
-  }
-  if (typeof data.enable === 'boolean') {
-    formData.append('extension[enable]', `${data.enable}`)
+    if (typeof data.title === 'string') {
+      formData.append('extension[title]', data.title)
+    }
+    if (typeof data.scope === 'object') {
+      formData.append('extension[scope]', `${data.scope}`)
+    }
+    if (typeof data['data_type'] === 'string') {
+      formData.append('extension[data_type]', data['data_type'])
+    }
+    if (typeof data.type === 'string') {
+      formData.append('extension[type]', data.type)
+    }
+    if (data.tags instanceof Array) {
+      formData.append('extension[tags]', data.tags.join(','))
+    } else if (typeof data.tags === 'string') {
+      formData.append('extension[tags]', data.tags)
+    }
+    if (typeof data.multiple === 'boolean') {
+      formData.append('extension[multiple]', `${data.multiple}`)
+    }
+    if (typeof data.enable === 'boolean') {
+      formData.append('extension[enable]', `${data.enable}`)
+    }
+    const uploadStream = createReadStream(data.upload)
+    formData.append('extension[upload]', uploadStream)
+    return formData
   }
-
-  const uploadStream = createReadStream(data.upload)
-  formData.append('extension[upload]', uploadStream)
-  return formData
 }

lib/stack/globalField/index.js

@@ -149,8 +149,10 @@ export function GlobalFieldCollection (http, data) {
 }
 
 function createFormData (data) {
-  const formData = new FormData()
-  const uploadStream = createReadStream(data.global_field)
-  formData.append('global_field', uploadStream)
-  return formData
+  return () => {
+    const formData = new FormData()
+    const uploadStream = createReadStream(data.global_field)
+    formData.append('global_field', uploadStream)
+    return formData
+  }
 }

lib/stack/webhook/index.js

@@ -232,8 +232,10 @@ export function WebhookCollection (http, data) {
 }
 
 function createFormData (data) {
-  const formData = new FormData()
-  const uploadStream = createReadStream(data.webhook)
-  formData.append('webhook', uploadStream)
-  return formData
+  return () => {
+    const formData = new FormData()
+    const uploadStream = createReadStream(data.webhook)
+    formData.append('webhook', uploadStream)
+    return formData
+  }
 }