127 lines
3.8 KiB
JavaScript
Raw Normal View History

import PromiseMiddlewareLayer from './PromiseMiddlewareLayer';
const middlewareLayer = new PromiseMiddlewareLayer();
export default {
2016-07-29 21:15:16 +03:00
/**
* @param {string} url
* @param {object} data
*
* @return {Promise}
*/
post(url, data) {
return doFetch(url, {
method: 'POST',
headers: {
'Content-Type': 'application/x-www-form-urlencoded; charset=UTF-8'
},
body: buildQuery(data)
});
},
2016-07-29 21:15:16 +03:00
/**
* @param {string} url
* @param {object} data
*
* @return {Promise}
*/
get(url, data) {
if (typeof data === 'object') {
const separator = url.indexOf('?') === -1 ? '?' : '&';
url += separator + buildQuery(data);
}
return doFetch(url);
},
2016-07-29 21:15:16 +03:00
/**
* Serializes object into encoded key=value presentation
*
* @param {object} data
*
* @return {string}
*/
buildQuery,
2016-07-29 21:15:16 +03:00
/**
* @param {object} middleware
* @param {function} [middleware.before] - a function({url, options}), that will be called before executing request.
* It will get data object {url, options} as an argument and should return
* Promise, that will resolve into new data object
* @param {function} [middleware.then] - a function(resp), that will be called on successful request result. It will
* get response as an argument and should return a Promise that resolves to
* the new response
* @param {function} [middleware.catch] - a function(resp, restart), that will be called on request fail. It will
* get response and callback to restart request as an arguments and should
* return a Promise that resolves to the new response.
*/
addMiddleware(middleware) {
middlewareLayer.add(middleware);
}
};
2016-02-26 08:25:47 +02:00
2016-03-01 22:36:14 +02:00
const checkStatus = (resp) => Promise[resp.status >= 200 && resp.status < 300 ? 'resolve' : 'reject'](resp);
2016-07-29 22:29:27 +03:00
const toJSON = (resp) => resp.json().then((json) => ({...json, originalResponse: resp}));
2016-03-01 22:36:14 +02:00
const rejectWithJSON = (resp) => toJSON(resp).then((resp) => {throw resp;});
const handleResponseSuccess = (resp) => Promise[resp.success || typeof resp.success === 'undefined' ? 'resolve' : 'reject'](resp);
2016-03-01 22:36:14 +02:00
function doFetch(url, options = {}) {
// NOTE: we are wrapping fetch, because it is returning
// Promise instance that can not be pollyfilled with Promise.prototype.finally
2016-02-26 08:25:47 +02:00
options.headers = options.headers || {};
options.headers.Accept = 'application/json';
2016-02-26 08:25:47 +02:00
return middlewareLayer.run('before', {url, options})
.then(({url, options}) => fetch(url, options))
.then(checkStatus)
.then(toJSON, rejectWithJSON)
.then(handleResponseSuccess)
.then((resp) => middlewareLayer.run('then', resp))
.catch((resp) => middlewareLayer.run('catch', resp, () => doFetch(url, options)))
;
}
2016-07-29 21:15:16 +03:00
/**
* Converts specific js values to query friendly values
*
* @param {any} value
*
* @return {string}
*/
function convertQueryValue(value) {
if (typeof value === 'undefined') {
return '';
}
2016-02-26 08:25:47 +02:00
if (value === true) {
2016-07-29 21:15:16 +03:00
return '1';
}
2016-02-23 07:57:16 +02:00
if (value === false) {
2016-07-29 21:15:16 +03:00
return '0';
}
2016-02-26 08:25:47 +02:00
return value;
}
2016-02-27 12:53:58 +02:00
2016-07-29 21:15:16 +03:00
/**
* Serializes object into encoded key=value presentation
*
* @param {object} data
*
* @return {string}
*/
function buildQuery(data = {}) {
return Object.keys(data)
.map(
(keyName) =>
[keyName, convertQueryValue(data[keyName])]
.map(encodeURIComponent)
.join('=')
)
.join('&')
;
}