Skip to content

Commit

Permalink
Adding request to error objects when it is available
Browse files Browse the repository at this point in the history
  • Loading branch information
rubennorte committed Apr 8, 2017
1 parent e0d59eb commit 22ce6db
Show file tree
Hide file tree
Showing 5 changed files with 16 additions and 10 deletions.
9 changes: 5 additions & 4 deletions lib/adapters/http.js
Expand Up @@ -172,13 +172,14 @@ module.exports = function httpAdapter(config) {

// make sure the content length is not over the maxContentLength if specified
if (config.maxContentLength > -1 && Buffer.concat(responseBuffer).length > config.maxContentLength) {
reject(createError('maxContentLength size of ' + config.maxContentLength + ' exceeded', config));
reject(createError('maxContentLength size of ' + config.maxContentLength + ' exceeded',
config, null, lastRequest));
}
});

stream.on('error', function handleStreamError(err) {
if (aborted) return;
reject(enhanceError(err, config));
reject(enhanceError(err, config, null, lastRequest));
});

stream.on('end', function handleStreamEnd() {
Expand All @@ -196,14 +197,14 @@ module.exports = function httpAdapter(config) {
// Handle errors
req.on('error', function handleRequestError(err) {
if (aborted) return;
reject(enhanceError(err, config));
reject(enhanceError(err, config, null, req));
});

// Handle request timeout
if (config.timeout && !timer) {
timer = setTimeout(function handleRequestTimeout() {
req.abort();
reject(createError('timeout of ' + config.timeout + 'ms exceeded', config, 'ECONNABORTED'));
reject(createError('timeout of ' + config.timeout + 'ms exceeded', config, 'ECONNABORTED', req));
aborted = true;
}, config.timeout);
}
Expand Down
5 changes: 3 additions & 2 deletions lib/adapters/xhr.js
Expand Up @@ -84,15 +84,16 @@ module.exports = function xhrAdapter(config) {
request.onerror = function handleError() {
// Real errors are hidden from us by the browser
// onerror should only fire if it's a network error
reject(createError('Network Error', config));
reject(createError('Network Error', config, null, request));

// Clean up request
request = null;
};

// Handle timeout
request.ontimeout = function handleTimeout() {
reject(createError('timeout of ' + config.timeout + 'ms exceeded', config, 'ECONNABORTED'));
reject(createError('timeout of ' + config.timeout + 'ms exceeded', config, 'ECONNABORTED',
request));

// Clean up request
request = null;
Expand Down
7 changes: 4 additions & 3 deletions lib/core/createError.js
Expand Up @@ -3,15 +3,16 @@
var enhanceError = require('./enhanceError');

/**
* Create an Error with the specified message, config, error code, and response.
* Create an Error with the specified message, config, error code, request and response.
*
* @param {string} message The error message.
* @param {Object} config The config.
* @param {string} [code] The error code (for example, 'ECONNABORTED').
@ @param {Object} [request] The request.
@ @param {Object} [response] The response.
* @returns {Error} The created error.
*/
module.exports = function createError(message, config, code, response) {
module.exports = function createError(message, config, code, request, response) {
var error = new Error(message);
return enhanceError(error, config, code, response);
return enhanceError(error, config, code, request, response);
};
4 changes: 3 additions & 1 deletion lib/core/enhanceError.js
Expand Up @@ -6,14 +6,16 @@
* @param {Error} error The error to update.
* @param {Object} config The config.
* @param {string} [code] The error code (for example, 'ECONNABORTED').
@ @param {Object} [request] The request.
@ @param {Object} [response] The response.
* @returns {Error} The error.
*/
module.exports = function enhanceError(error, config, code, response) {
module.exports = function enhanceError(error, config, code, request, response) {
error.config = config;
if (code) {
error.code = code;
}
error.request = request;
error.response = response;
return error;
};
1 change: 1 addition & 0 deletions lib/core/settle.js
Expand Up @@ -19,6 +19,7 @@ module.exports = function settle(resolve, reject, response) {
'Request failed with status code ' + response.status,
response.config,
null,
response.request,
response
));
}
Expand Down

0 comments on commit 22ce6db

Please sign in to comment.