6258ac2a252883396199b71f9cf330f67486db1512fa38a2ab94cd3e277d41615f2500a66cb97bb3101fc5e4f47f3d9be5cf1193fc762e781e88736166b0ff 7.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226
  1. 'use strict';
  2. var utils = require('./../utils');
  3. var settle = require('./../core/settle');
  4. var cookies = require('./../helpers/cookies');
  5. var buildURL = require('./../helpers/buildURL');
  6. var buildFullPath = require('../core/buildFullPath');
  7. var parseHeaders = require('./../helpers/parseHeaders');
  8. var isURLSameOrigin = require('./../helpers/isURLSameOrigin');
  9. var transitionalDefaults = require('../defaults/transitional');
  10. var AxiosError = require('../core/AxiosError');
  11. var CanceledError = require('../cancel/CanceledError');
  12. var parseProtocol = require('../helpers/parseProtocol');
  13. var platform = require('../platform');
  14. module.exports = function xhrAdapter(config) {
  15. return new Promise(function dispatchXhrRequest(resolve, reject) {
  16. var requestData = config.data;
  17. var requestHeaders = config.headers;
  18. var responseType = config.responseType;
  19. var withXSRFToken = config.withXSRFToken;
  20. var onCanceled;
  21. function done() {
  22. if (config.cancelToken) {
  23. config.cancelToken.unsubscribe(onCanceled);
  24. }
  25. if (config.signal) {
  26. config.signal.removeEventListener('abort', onCanceled);
  27. }
  28. }
  29. if (utils.isFormData(requestData) && utils.isStandardBrowserEnv()) {
  30. delete requestHeaders['Content-Type']; // Let the browser set it
  31. }
  32. var request = new XMLHttpRequest();
  33. // HTTP basic authentication
  34. if (config.auth) {
  35. var username = config.auth.username || '';
  36. var password = config.auth.password ? unescape(encodeURIComponent(config.auth.password)) : '';
  37. requestHeaders.Authorization = 'Basic ' + btoa(username + ':' + password);
  38. }
  39. var fullPath = buildFullPath(config.baseURL, config.url);
  40. request.open(config.method.toUpperCase(), buildURL(fullPath, config.params, config.paramsSerializer), true);
  41. // Set the request timeout in MS
  42. request.timeout = config.timeout;
  43. function onloadend() {
  44. if (!request) {
  45. return;
  46. }
  47. // Prepare the response
  48. var responseHeaders = 'getAllResponseHeaders' in request ? parseHeaders(request.getAllResponseHeaders()) : null;
  49. var responseData = !responseType || responseType === 'text' || responseType === 'json' ?
  50. request.responseText : request.response;
  51. var response = {
  52. data: responseData,
  53. status: request.status,
  54. statusText: request.statusText,
  55. headers: responseHeaders,
  56. config: config,
  57. request: request
  58. };
  59. settle(function _resolve(value) {
  60. resolve(value);
  61. done();
  62. }, function _reject(err) {
  63. reject(err);
  64. done();
  65. }, response);
  66. // Clean up request
  67. request = null;
  68. }
  69. if ('onloadend' in request) {
  70. // Use onloadend if available
  71. request.onloadend = onloadend;
  72. } else {
  73. // Listen for ready state to emulate onloadend
  74. request.onreadystatechange = function handleLoad() {
  75. if (!request || request.readyState !== 4) {
  76. return;
  77. }
  78. // The request errored out and we didn't get a response, this will be
  79. // handled by onerror instead
  80. // With one exception: request that using file: protocol, most browsers
  81. // will return status as 0 even though it's a successful request
  82. if (request.status === 0 && !(request.responseURL && request.responseURL.indexOf('file:') === 0)) {
  83. return;
  84. }
  85. // readystate handler is calling before onerror or ontimeout handlers,
  86. // so we should call onloadend on the next 'tick'
  87. setTimeout(onloadend);
  88. };
  89. }
  90. // Handle browser request cancellation (as opposed to a manual cancellation)
  91. request.onabort = function handleAbort() {
  92. if (!request) {
  93. return;
  94. }
  95. reject(new AxiosError('Request aborted', AxiosError.ECONNABORTED, config, request));
  96. // Clean up request
  97. request = null;
  98. };
  99. // Handle low level network errors
  100. request.onerror = function handleError() {
  101. // Real errors are hidden from us by the browser
  102. // onerror should only fire if it's a network error
  103. reject(new AxiosError('Network Error', AxiosError.ERR_NETWORK, config, request));
  104. // Clean up request
  105. request = null;
  106. };
  107. // Handle timeout
  108. request.ontimeout = function handleTimeout() {
  109. var timeoutErrorMessage = config.timeout ? 'timeout of ' + config.timeout + 'ms exceeded' : 'timeout exceeded';
  110. var transitional = config.transitional || transitionalDefaults;
  111. if (config.timeoutErrorMessage) {
  112. timeoutErrorMessage = config.timeoutErrorMessage;
  113. }
  114. reject(new AxiosError(
  115. timeoutErrorMessage,
  116. transitional.clarifyTimeoutError ? AxiosError.ETIMEDOUT : AxiosError.ECONNABORTED,
  117. config,
  118. request));
  119. // Clean up request
  120. request = null;
  121. };
  122. // Add xsrf header
  123. // This is only done if running in a standard browser environment.
  124. // Specifically not if we're in a web worker, or react-native.
  125. if (utils.isStandardBrowserEnv()) {
  126. // Add xsrf header
  127. withXSRFToken && utils.isFunction(withXSRFToken) && (withXSRFToken = withXSRFToken(config));
  128. if (withXSRFToken || (withXSRFToken !== false && isURLSameOrigin(fullPath))) {
  129. // Add xsrf header
  130. var xsrfValue = config.xsrfHeaderName && config.xsrfCookieName && cookies.read(config.xsrfCookieName);
  131. if (xsrfValue) {
  132. requestHeaders[config.xsrfHeaderName] = xsrfValue;
  133. }
  134. }
  135. }
  136. // Add headers to the request
  137. if ('setRequestHeader' in request) {
  138. utils.forEach(requestHeaders, function setRequestHeader(val, key) {
  139. if (typeof requestData === 'undefined' && key.toLowerCase() === 'content-type') {
  140. // Remove Content-Type if data is undefined
  141. delete requestHeaders[key];
  142. } else {
  143. // Otherwise add header to the request
  144. request.setRequestHeader(key, val);
  145. }
  146. });
  147. }
  148. // Add withCredentials to request if needed
  149. if (!utils.isUndefined(config.withCredentials)) {
  150. request.withCredentials = !!config.withCredentials;
  151. }
  152. // Add responseType to request if needed
  153. if (responseType && responseType !== 'json') {
  154. request.responseType = config.responseType;
  155. }
  156. // Handle progress if needed
  157. if (typeof config.onDownloadProgress === 'function') {
  158. request.addEventListener('progress', config.onDownloadProgress);
  159. }
  160. // Not all browsers support upload events
  161. if (typeof config.onUploadProgress === 'function' && request.upload) {
  162. request.upload.addEventListener('progress', config.onUploadProgress);
  163. }
  164. if (config.cancelToken || config.signal) {
  165. // Handle cancellation
  166. // eslint-disable-next-line func-names
  167. onCanceled = function(cancel) {
  168. if (!request) {
  169. return;
  170. }
  171. reject(!cancel || cancel.type ? new CanceledError(null, config, request) : cancel);
  172. request.abort();
  173. request = null;
  174. };
  175. config.cancelToken && config.cancelToken.subscribe(onCanceled);
  176. if (config.signal) {
  177. config.signal.aborted ? onCanceled() : config.signal.addEventListener('abort', onCanceled);
  178. }
  179. }
  180. // false, 0 (zero number), and '' (empty string) are valid JSON values
  181. if (!requestData && requestData !== false && requestData !== 0 && requestData !== '') {
  182. requestData = null;
  183. }
  184. var protocol = parseProtocol(fullPath);
  185. if (protocol && platform.protocols.indexOf(protocol) === -1) {
  186. reject(new AxiosError('Unsupported protocol ' + protocol + ':', AxiosError.ERR_BAD_REQUEST, config));
  187. return;
  188. }
  189. // Send the request
  190. request.send(requestData);
  191. });
  192. };