mirror of
https://github.com/ascribe/onion.git
synced 2024-12-22 17:33:14 +01:00
Only assume TypeError if request's response is null
This commit is contained in:
parent
e24c9c9c74
commit
d9615188b0
@ -10,71 +10,67 @@ import { argsToQueryParams } from '../utils/url_utils';
|
|||||||
|
|
||||||
|
|
||||||
class Requests {
|
class Requests {
|
||||||
unpackResponse(response) {
|
unpackResponse(url) {
|
||||||
if (response.status >= 500) {
|
return (response) => {
|
||||||
let err = new Error(response.status + ' - ' + response.statusText + ' - on URL:' + response.url);
|
if (response == null) {
|
||||||
|
|
||||||
return response
|
|
||||||
.text()
|
|
||||||
.then((resText) => {
|
|
||||||
const resJson = JSON.parse(resText);
|
|
||||||
err = new Error(resJson.errors.pop());
|
|
||||||
|
|
||||||
// ES6 promises don't have a .finally() clause so
|
|
||||||
// we fake that here by forcing the .catch() clause
|
|
||||||
// to run
|
|
||||||
return Promise.reject();
|
|
||||||
})
|
|
||||||
.catch(() => { throw err; });
|
|
||||||
}
|
|
||||||
|
|
||||||
return Q.Promise((resolve, reject) => {
|
|
||||||
response.text()
|
|
||||||
.then((responseText) => {
|
|
||||||
// If the responses' body does not contain any data,
|
|
||||||
// fetch will resolve responseText to the string 'None'.
|
|
||||||
// If this is the case, we can not try to parse it as JSON.
|
|
||||||
if(responseText !== 'None') {
|
|
||||||
let body = JSON.parse(responseText);
|
|
||||||
|
|
||||||
if(body && body.errors) {
|
|
||||||
let error = new Error('Form Error');
|
|
||||||
error.json = body;
|
|
||||||
reject(error);
|
|
||||||
} else if(body && body.detail) {
|
|
||||||
reject(new Error(body.detail));
|
|
||||||
} else if('success' in body && !body.success) {
|
|
||||||
let error = new Error('Client Request Error');
|
|
||||||
error.json = {
|
|
||||||
status: response.status,
|
|
||||||
statusText: response.statusText,
|
|
||||||
type: response.type,
|
|
||||||
url: response.url
|
|
||||||
};
|
|
||||||
reject(error);
|
|
||||||
} else {
|
|
||||||
resolve(body);
|
|
||||||
}
|
|
||||||
|
|
||||||
} else {
|
|
||||||
if(response.status >= 400) {
|
|
||||||
reject(new Error(response.status + ' - ' + response.statusText + ' - on URL:' + response.url));
|
|
||||||
} else {
|
|
||||||
resolve({});
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}).catch(reject);
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
handleError(url) {
|
|
||||||
return (err) => {
|
|
||||||
if (err instanceof TypeError) {
|
|
||||||
throw new Error('For: ' + url + ' - Server did not respond to the request. (Not even displayed a 500)');
|
throw new Error('For: ' + url + ' - Server did not respond to the request. (Not even displayed a 500)');
|
||||||
} else {
|
|
||||||
throw err;
|
|
||||||
}
|
}
|
||||||
};
|
|
||||||
|
if (response.status >= 500) {
|
||||||
|
let err = new Error(response.status + ' - ' + response.statusText + ' - on URL:' + response.url);
|
||||||
|
|
||||||
|
return response
|
||||||
|
.text()
|
||||||
|
.then((resText) => {
|
||||||
|
const resJson = JSON.parse(resText);
|
||||||
|
err = new Error(resJson.errors.pop());
|
||||||
|
|
||||||
|
// ES6 promises don't have a .finally() clause so
|
||||||
|
// we fake that here by forcing the .catch() clause
|
||||||
|
// to run
|
||||||
|
return Promise.reject();
|
||||||
|
})
|
||||||
|
.catch(() => { throw err; });
|
||||||
|
}
|
||||||
|
|
||||||
|
return Q.Promise((resolve, reject) => {
|
||||||
|
response.text()
|
||||||
|
.then((responseText) => {
|
||||||
|
// If the responses' body does not contain any data,
|
||||||
|
// fetch will resolve responseText to the string 'None'.
|
||||||
|
// If this is the case, we can not try to parse it as JSON.
|
||||||
|
if(responseText !== 'None') {
|
||||||
|
let body = JSON.parse(responseText);
|
||||||
|
|
||||||
|
if(body && body.errors) {
|
||||||
|
let error = new Error('Form Error');
|
||||||
|
error.json = body;
|
||||||
|
reject(error);
|
||||||
|
} else if(body && body.detail) {
|
||||||
|
reject(new Error(body.detail));
|
||||||
|
} else if('success' in body && !body.success) {
|
||||||
|
let error = new Error('Client Request Error');
|
||||||
|
error.json = {
|
||||||
|
status: response.status,
|
||||||
|
statusText: response.statusText,
|
||||||
|
type: response.type,
|
||||||
|
url: response.url
|
||||||
|
};
|
||||||
|
reject(error);
|
||||||
|
} else {
|
||||||
|
resolve(body);
|
||||||
|
}
|
||||||
|
|
||||||
|
} else {
|
||||||
|
if(response.status >= 400) {
|
||||||
|
reject(new Error(response.status + ' - ' + response.statusText + ' - on URL:' + response.url));
|
||||||
|
} else {
|
||||||
|
resolve({});
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}).catch(reject);
|
||||||
|
});
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
getUrl(url) {
|
getUrl(url) {
|
||||||
@ -128,8 +124,7 @@ class Requests {
|
|||||||
}
|
}
|
||||||
merged.method = verb;
|
merged.method = verb;
|
||||||
return fetch(url, merged)
|
return fetch(url, merged)
|
||||||
.then(this.unpackResponse)
|
.then(this.unpackResponse(url));
|
||||||
.catch(this.handleError(url));
|
|
||||||
}
|
}
|
||||||
|
|
||||||
get(url, params) {
|
get(url, params) {
|
||||||
|
Loading…
Reference in New Issue
Block a user