Popular
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348import { urlJoin } from "./mods/url-join.ts";
import type { Data, IAxiodResponse, IConfig, IRequest } from "./interfaces.ts";import { methods } from "./helpers.ts";
function axiod<T = any>( url: string | IRequest, config?: IRequest): Promise<IAxiodResponse<T>> { if (typeof url === "string") { return axiod.request(Object.assign({}, axiod.defaults, { url }, config)); } return axiod.request(Object.assign({}, axiod.defaults, url));}
axiod.defaults = { url: "/", method: "get", timeout: 0, withCredentials: false, validateStatus: (status: number) => { return status >= 200 && status < 300; },};
axiod.create = (config?: IRequest) => { const instance = Object.assign({}, axiod); instance.defaults = Object.assign({}, axiod.defaults, config);
instance.request = (options: IRequest): Promise<IAxiodResponse> => { return axiod.request(Object.assign({}, instance.defaults, options)); }; instance.get = (url: string, config?: IConfig) => { return instance.request( Object.assign({}, { url }, config, { method: "get" }) ); }; instance.post = (url: string, data?: Data, config?: IConfig) => { return instance.request( Object.assign({}, { url }, config, { method: "post", data }) ); }; instance.put = (url: string, data?: Data, config?: IConfig) => { return instance.request( Object.assign({}, { url }, config, { method: "put", data }) ); }; instance.delete = (url: string, data?: Data, config?: IConfig) => { return instance.request( Object.assign({}, { url }, config, { method: "delete", data }) ); }; instance.options = (url: string, data?: Data, config?: IConfig) => { return instance.request( Object.assign({}, { url }, config, { method: "options", data }) ); }; instance.head = (url: string, data?: Data, config?: IConfig) => { return instance.request( Object.assign({}, { url }, config, { method: "head", data }) ); }; instance.connect = (url: string, data?: Data, config?: IConfig) => { return instance.request( Object.assign({}, { url }, config, { method: "connect", data }) ); }; instance.trace = (url: string, data?: Data, config?: IConfig) => { return instance.request( Object.assign({}, { url }, config, { method: "trace", data }) ); }; instance.patch = (url: string, data?: Data, config?: IConfig) => { return instance.request( Object.assign({}, { url }, config, { method: "patch", data }) ); }; return instance;};
axiod.request = <T = any>({ url = "/", baseURL, method, headers, params, data, timeout, withCredentials, auth, validateStatus, paramsSerializer, transformRequest, transformResponse, redirect,}: IRequest): Promise<IAxiodResponse<T>> => { // Url and Base url if (baseURL) { url = urlJoin(baseURL, url); }
// Method if (method) { if (methods.indexOf(method.toLowerCase().trim()) === -1) { throw new Error(`Method ${method} is not supported`); } else { method = method.toLowerCase().trim(); } } else { method = "get"; }
// Params let _params = ""; if (params) { if (paramsSerializer) { _params = paramsSerializer(params); } else { _params = Object.keys(params) .map((key) => { return ( encodeURIComponent(key) + "=" + encodeURIComponent(params[key]) ); }) .join("&"); } }
// Add credentials to header if (withCredentials) { if (auth?.username && auth?.password) { if (!headers) { headers = {}; }
headers["Authorization"] = "Basic " + btoa(unescape(encodeURIComponent(`${auth.username}:${auth.password}`))); } }
// Create fetch Request Config const fetchRequestObject: RequestInit = {};
// Add method to Request Config if (method !== "get") { fetchRequestObject.method = method.toUpperCase(); }
// Add params to Request Config Url if (_params) { url = urlJoin(url, `?${_params}`); }
// Add body to Request Config if (data && method !== "get") { // transformRequest if ( transformRequest && Array.isArray(transformRequest) && transformRequest.length > 0 ) { for (var i = 0; i < (transformRequest || []).length; i++) { if (transformRequest && transformRequest[i]) { data = transformRequest[i](data, headers); } } }
if ( typeof data === "string" || data instanceof FormData || data instanceof URLSearchParams ) { fetchRequestObject.body = data; } else { try { fetchRequestObject.body = JSON.stringify(data); if (!headers) { headers = {}; }
headers["Accept"] = "application/json"; headers["Content-Type"] = "application/json"; } catch (ex) {} } }
// Add headers to Request Config if (headers) { const _headers: Headers = new Headers(); Object.keys(headers).forEach((header) => { if (headers && headers[header]) { _headers.set(header, headers[header]); } }); fetchRequestObject.headers = _headers; }
// Timeout const controller = new AbortController(); fetchRequestObject.signal = controller.signal;
let timeoutCounter: number = 0;
if ((timeout || 0) > 0) { timeoutCounter = setTimeout(() => { timeoutCounter = 0; controller.abort(); }, timeout); }
if (redirect) { fetchRequestObject.redirect = redirect; }
// Start request return fetch(url, fetchRequestObject).then(async (x) => { // Clear timeout if (timeoutCounter) { clearTimeout(timeoutCounter); }
const _status: number = x.status; const _statusText: string = x.statusText;
// Data let _data: any = null;
// Try to convert to json try { _data = await x.clone().json(); } catch (ex) { _data = await x.clone().text(); }
// transformResponse if (transformResponse) { if ( transformResponse && Array.isArray(transformResponse) && transformResponse.length > 0 ) { for (var i = 0; i < (transformResponse || []).length; i++) { if (transformResponse && transformResponse[i]) { _data = transformResponse[i](_data); } } } }
const _headers: Headers = x.headers; const _config: IRequest = { url, baseURL, method, headers, params, data, timeout, withCredentials, auth, paramsSerializer, redirect, };
// Validate the status code let isValidStatus = true;
if (validateStatus) { isValidStatus = validateStatus(_status); } else { isValidStatus = _status >= 200 && _status <= 303; }
if (isValidStatus) { return Promise.resolve({ status: _status, statusText: _statusText, data: _data, headers: _headers, config: _config, }); } else { const error = { response: { status: _status, statusText: _statusText, data: _data, headers: _headers, }, config: _config, };
return Promise.reject(error); } });};
axiod.get = <T = any>(url: string, config?: IConfig) => { return axiod.request<T>( Object.assign({}, { url }, config, { method: "get" }) );};axiod.post = <T = any>(url: string, data?: Data, config?: IConfig) => { return axiod.request<T>( Object.assign({}, { url }, config, { method: "post", data }) );};axiod.put = <T = any>(url: string, data?: Data, config?: IConfig) => { return axiod.request<T>( Object.assign({}, { url }, config, { method: "put", data }) );};axiod.delete = <T = any>(url: string, data?: Data, config?: IConfig) => { return axiod.request<T>( Object.assign({}, { url }, config, { method: "delete", data }) );};axiod.options = <T = any>(url: string, data?: Data, config?: IConfig) => { return axiod.request<T>( Object.assign({}, { url }, config, { method: "options", data }) );};axiod.head = <T = any>(url: string, data?: Data, config?: IConfig) => { return axiod.request<T>( Object.assign({}, { url }, config, { method: "head", data }) );};axiod.connect = <T = any>(url: string, data?: Data, config?: IConfig) => { return axiod.request<T>( Object.assign({}, { url }, config, { method: "connect", data }) );};axiod.trace = <T = any>(url: string, data?: Data, config?: IConfig) => { return axiod.request<T>( Object.assign({}, { url }, config, { method: "trace", data }) );};axiod.patch = <T = any>(url: string, data?: Data, config?: IConfig) => { return axiod.request<T>( Object.assign({}, { url }, config, { method: "patch", data }) );};
export default axiod;export {axiod};