Keine Beschreibung

Fetch.js 5.6KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198
  1. import RNFetchBlob from '../index.js'
  2. import Log from '../utils/log.js'
  3. import fs from '../fs'
  4. import unicode from '../utils/unicode'
  5. import Blob from './Blob'
  6. const log = new Log('FetchPolyfill')
  7. log.disable()
  8. // log.level(3)
  9. export default class Fetch {
  10. constructor(config:RNFetchBlobConfig) {
  11. Object.assign(this, new RNFetchBlobFetchPolyfill(config))
  12. }
  13. }
  14. class RNFetchBlobFetchPolyfill {
  15. constructor(config:RNFetchBlobConfig) {
  16. this.build = () => (url, options = {}) => {
  17. let body = options.body
  18. let promise = Promise.resolve()
  19. let blobCache = null
  20. options.headers = options.headers || {}
  21. let ctype = options['Content-Type'] || options['content-type']
  22. let ctypeH = options.headers['Content-Type'] || options.headers['content-type']
  23. options.headers['Content-Type'] = ctype || ctypeH
  24. options.headers['content-type'] = ctype || ctypeH
  25. options.method = options.method || 'GET'
  26. if(body) {
  27. // When the request body is an instance of FormData, create a Blob cache
  28. // to upload the body.
  29. if(body instanceof FormData) {
  30. log.verbose('convert FormData to blob body')
  31. promise = Blob.build(body).then((b) => {
  32. blobCache = b
  33. options.headers['Content-Type'] = 'multipart/form-data;boundary=' + b.multipartBoundary
  34. return Promise.resolve(RNFetchBlob.wrap(b._ref))
  35. })
  36. }
  37. // When request body is a Blob, use file URI of the Blob as request body.
  38. else if (body.isRNFetchBlobPolyfill)
  39. promise = Promise.resolve(RNFetchBlob.wrap(body.blobPath))
  40. else if (typeof body !== 'object')
  41. promise = Promise.resolve(JSON.stringify(body))
  42. else if (typeof body !== 'string')
  43. promise = Promise.resolve(body.toString())
  44. // send it as-is, leave the native module decide how to send the body.
  45. else
  46. promise = Promise.resolve(body)
  47. }
  48. // task is a progress reportable and cancellable Promise, however,
  49. // task.then is not, so we have to extend task.then with progress and
  50. // cancel function
  51. let task = promise
  52. .then((body) => {
  53. return RNFetchBlob.config(config)
  54. .fetch(options.method, url, options.headers, body)
  55. })
  56. let statefulPromise = task.then((resp) => {
  57. log.verbose('response', resp)
  58. // release blob cache created when sending request
  59. if(blobCache !== null && blobCache instanceof Blob)
  60. blobCache.close()
  61. return Promise.resolve(new RNFetchBlobFetchRepsonse(resp))
  62. })
  63. // extend task.then progress with report and cancelling functions
  64. statefulPromise.cancel = task.cancel
  65. statefulPromise.progress = task.progress
  66. statefulPromise.uploadProgress = task.uploadProgress
  67. return statefulPromise
  68. }
  69. }
  70. }
  71. class RNFetchBlobFetchRepsonse {
  72. constructor(resp:FetchBlobResponse) {
  73. let info = resp.info()
  74. this.headers = info.headers
  75. this.ok = info.status >= 200 && info.status <= 299,
  76. this.status = info.status
  77. this.type = 'basic'
  78. this.bodyUsed = false
  79. this.resp = resp
  80. this.rnfbRespInfo = info
  81. this.rnfbResp = resp
  82. }
  83. arrayBuffer(){
  84. log.verbose('to arrayBuffer', this.rnfbRespInfo)
  85. this.bodyUsed = true
  86. return readArrayBuffer(this.rnfbResp, this.rnfbRespInfo)
  87. }
  88. text() {
  89. log.verbose('to text', this.rnfbResp, this.rnfbRespInfo)
  90. this.bodyUsed = true
  91. return readText(this.rnfbResp, this.rnfbRespInfo)
  92. }
  93. json() {
  94. log.verbose('to json', this.rnfbResp, this.rnfbRespInfo)
  95. this.bodyUsed = true
  96. return readJSON(this.rnfbResp, this.rnfbRespInfo)
  97. }
  98. blob() {
  99. log.verbose('to blob', this.rnfbResp, this.rnfbRespInfo)
  100. this.bodyUsed = true
  101. return readBlob(this.rnfbResp, this.rnfbRespInfo)
  102. }
  103. }
  104. /**
  105. * Get response data as array.
  106. * @param {FetchBlobResponse} resp Response data object from RNFB fetch call.
  107. * @param {RNFetchBlobResponseInfo} info Response informations.
  108. * @return {Promise<Array>}
  109. */
  110. function readArrayBuffer(resp, info):Promise<Array> {
  111. switch (info.rnfbEncode) {
  112. case 'path':
  113. return resp.readFile('ascii')
  114. break
  115. default:
  116. let buffer = []
  117. let str = resp.text()
  118. for (let i in str) {
  119. buffer[i] = str.charCodeAt(i);
  120. }
  121. return Promise.resolve(buffer)
  122. break
  123. }
  124. }
  125. /**
  126. * Get response data as string.
  127. * @param {FetchBlobResponse} resp Response data object from RNFB fetch call.
  128. * @param {RNFetchBlobResponseInfo} info Response informations.
  129. * @return {Promise<string>}
  130. */
  131. function readText(resp, info):Promise<string> {
  132. switch (info.rnfbEncode) {
  133. case 'base64':
  134. return Promise.resolve(resp.text())
  135. break
  136. case 'path':
  137. return resp.text()
  138. break
  139. default:
  140. return Promise.resolve(resp.text())
  141. break
  142. }
  143. }
  144. /**
  145. * Get response data as RNFetchBlob Blob polyfill object.
  146. * @param {FetchBlobResponse} resp Response data object from RNFB fetch call.
  147. * @param {RNFetchBlobResponseInfo} info Response informations.
  148. * @return {Promise<Blob>}
  149. */
  150. function readBlob(resp, info):Promise<Blob> {
  151. log.verbose('readBlob', resp, info)
  152. return resp.blob()
  153. }
  154. /**
  155. * Get response data as JSON object.
  156. * @param {FetchBlobResponse} resp Response data object from RNFB fetch call.
  157. * @param {RNFetchBlobResponseInfo} info Response informations.
  158. * @return {Promise<object>}
  159. */
  160. function readJSON(resp, info):Promise<object> {
  161. log.verbose('readJSON', resp, info)
  162. switch (info.rnfbEncode) {
  163. case 'base64':
  164. return Promise.resolve(resp.json())
  165. case 'path':
  166. return resp.json()
  167. default:
  168. return Promise.resolve(resp.json())
  169. }
  170. }