aboutsummaryrefslogtreecommitdiffstats
path: root/node_modules/rxjs/dist/esm/internal/ajax/ajax.js
diff options
context:
space:
mode:
authorPinapelz <yukais@pinapelz.com>2025-06-29 11:49:28 -0700
committerPinapelz <yukais@pinapelz.com>2025-06-29 11:49:28 -0700
commitd55b767039605256c736166a942a9138e3eacfd7 (patch)
tree947063b634c50d438a794325f13275e134aa5993 /node_modules/rxjs/dist/esm/internal/ajax/ajax.js
parent864ce67d89c77d8ef9c3361f80d619853abcf91c (diff)
remove dev node_modules (oops)
Diffstat (limited to 'node_modules/rxjs/dist/esm/internal/ajax/ajax.js')
-rw-r--r--node_modules/rxjs/dist/esm/internal/ajax/ajax.js236
1 files changed, 0 insertions, 236 deletions
diff --git a/node_modules/rxjs/dist/esm/internal/ajax/ajax.js b/node_modules/rxjs/dist/esm/internal/ajax/ajax.js
deleted file mode 100644
index b5df317..0000000
--- a/node_modules/rxjs/dist/esm/internal/ajax/ajax.js
+++ /dev/null
@@ -1,236 +0,0 @@
-import { map } from '../operators/map';
-import { Observable } from '../Observable';
-import { AjaxResponse } from './AjaxResponse';
-import { AjaxTimeoutError, AjaxError } from './errors';
-function ajaxGet(url, headers) {
- return ajax({ method: 'GET', url, headers });
-}
-function ajaxPost(url, body, headers) {
- return ajax({ method: 'POST', url, body, headers });
-}
-function ajaxDelete(url, headers) {
- return ajax({ method: 'DELETE', url, headers });
-}
-function ajaxPut(url, body, headers) {
- return ajax({ method: 'PUT', url, body, headers });
-}
-function ajaxPatch(url, body, headers) {
- return ajax({ method: 'PATCH', url, body, headers });
-}
-const mapResponse = map((x) => x.response);
-function ajaxGetJSON(url, headers) {
- return mapResponse(ajax({
- method: 'GET',
- url,
- headers,
- }));
-}
-export const ajax = (() => {
- const create = (urlOrConfig) => {
- const config = typeof urlOrConfig === 'string'
- ? {
- url: urlOrConfig,
- }
- : urlOrConfig;
- return fromAjax(config);
- };
- create.get = ajaxGet;
- create.post = ajaxPost;
- create.delete = ajaxDelete;
- create.put = ajaxPut;
- create.patch = ajaxPatch;
- create.getJSON = ajaxGetJSON;
- return create;
-})();
-const UPLOAD = 'upload';
-const DOWNLOAD = 'download';
-const LOADSTART = 'loadstart';
-const PROGRESS = 'progress';
-const LOAD = 'load';
-export function fromAjax(init) {
- return new Observable((destination) => {
- var _a, _b;
- const config = Object.assign({ async: true, crossDomain: false, withCredentials: false, method: 'GET', timeout: 0, responseType: 'json' }, init);
- const { queryParams, body: configuredBody, headers: configuredHeaders } = config;
- let url = config.url;
- if (!url) {
- throw new TypeError('url is required');
- }
- if (queryParams) {
- let searchParams;
- if (url.includes('?')) {
- const parts = url.split('?');
- if (2 < parts.length) {
- throw new TypeError('invalid url');
- }
- searchParams = new URLSearchParams(parts[1]);
- new URLSearchParams(queryParams).forEach((value, key) => searchParams.set(key, value));
- url = parts[0] + '?' + searchParams;
- }
- else {
- searchParams = new URLSearchParams(queryParams);
- url = url + '?' + searchParams;
- }
- }
- const headers = {};
- if (configuredHeaders) {
- for (const key in configuredHeaders) {
- if (configuredHeaders.hasOwnProperty(key)) {
- headers[key.toLowerCase()] = configuredHeaders[key];
- }
- }
- }
- const crossDomain = config.crossDomain;
- if (!crossDomain && !('x-requested-with' in headers)) {
- headers['x-requested-with'] = 'XMLHttpRequest';
- }
- const { withCredentials, xsrfCookieName, xsrfHeaderName } = config;
- if ((withCredentials || !crossDomain) && xsrfCookieName && xsrfHeaderName) {
- const xsrfCookie = (_b = (_a = document === null || document === void 0 ? void 0 : document.cookie.match(new RegExp(`(^|;\\s*)(${xsrfCookieName})=([^;]*)`))) === null || _a === void 0 ? void 0 : _a.pop()) !== null && _b !== void 0 ? _b : '';
- if (xsrfCookie) {
- headers[xsrfHeaderName] = xsrfCookie;
- }
- }
- const body = extractContentTypeAndMaybeSerializeBody(configuredBody, headers);
- const _request = Object.assign(Object.assign({}, config), { url,
- headers,
- body });
- let xhr;
- xhr = init.createXHR ? init.createXHR() : new XMLHttpRequest();
- {
- const { progressSubscriber, includeDownloadProgress = false, includeUploadProgress = false } = init;
- const addErrorEvent = (type, errorFactory) => {
- xhr.addEventListener(type, () => {
- var _a;
- const error = errorFactory();
- (_a = progressSubscriber === null || progressSubscriber === void 0 ? void 0 : progressSubscriber.error) === null || _a === void 0 ? void 0 : _a.call(progressSubscriber, error);
- destination.error(error);
- });
- };
- addErrorEvent('timeout', () => new AjaxTimeoutError(xhr, _request));
- addErrorEvent('abort', () => new AjaxError('aborted', xhr, _request));
- const createResponse = (direction, event) => new AjaxResponse(event, xhr, _request, `${direction}_${event.type}`);
- const addProgressEvent = (target, type, direction) => {
- target.addEventListener(type, (event) => {
- destination.next(createResponse(direction, event));
- });
- };
- if (includeUploadProgress) {
- [LOADSTART, PROGRESS, LOAD].forEach((type) => addProgressEvent(xhr.upload, type, UPLOAD));
- }
- if (progressSubscriber) {
- [LOADSTART, PROGRESS].forEach((type) => xhr.upload.addEventListener(type, (e) => { var _a; return (_a = progressSubscriber === null || progressSubscriber === void 0 ? void 0 : progressSubscriber.next) === null || _a === void 0 ? void 0 : _a.call(progressSubscriber, e); }));
- }
- if (includeDownloadProgress) {
- [LOADSTART, PROGRESS].forEach((type) => addProgressEvent(xhr, type, DOWNLOAD));
- }
- const emitError = (status) => {
- const msg = 'ajax error' + (status ? ' ' + status : '');
- destination.error(new AjaxError(msg, xhr, _request));
- };
- xhr.addEventListener('error', (e) => {
- var _a;
- (_a = progressSubscriber === null || progressSubscriber === void 0 ? void 0 : progressSubscriber.error) === null || _a === void 0 ? void 0 : _a.call(progressSubscriber, e);
- emitError();
- });
- xhr.addEventListener(LOAD, (event) => {
- var _a, _b;
- const { status } = xhr;
- if (status < 400) {
- (_a = progressSubscriber === null || progressSubscriber === void 0 ? void 0 : progressSubscriber.complete) === null || _a === void 0 ? void 0 : _a.call(progressSubscriber);
- let response;
- try {
- response = createResponse(DOWNLOAD, event);
- }
- catch (err) {
- destination.error(err);
- return;
- }
- destination.next(response);
- destination.complete();
- }
- else {
- (_b = progressSubscriber === null || progressSubscriber === void 0 ? void 0 : progressSubscriber.error) === null || _b === void 0 ? void 0 : _b.call(progressSubscriber, event);
- emitError(status);
- }
- });
- }
- const { user, method, async } = _request;
- if (user) {
- xhr.open(method, url, async, user, _request.password);
- }
- else {
- xhr.open(method, url, async);
- }
- if (async) {
- xhr.timeout = _request.timeout;
- xhr.responseType = _request.responseType;
- }
- if ('withCredentials' in xhr) {
- xhr.withCredentials = _request.withCredentials;
- }
- for (const key in headers) {
- if (headers.hasOwnProperty(key)) {
- xhr.setRequestHeader(key, headers[key]);
- }
- }
- if (body) {
- xhr.send(body);
- }
- else {
- xhr.send();
- }
- return () => {
- if (xhr && xhr.readyState !== 4) {
- xhr.abort();
- }
- };
- });
-}
-function extractContentTypeAndMaybeSerializeBody(body, headers) {
- var _a;
- if (!body ||
- typeof body === 'string' ||
- isFormData(body) ||
- isURLSearchParams(body) ||
- isArrayBuffer(body) ||
- isFile(body) ||
- isBlob(body) ||
- isReadableStream(body)) {
- return body;
- }
- if (isArrayBufferView(body)) {
- return body.buffer;
- }
- if (typeof body === 'object') {
- headers['content-type'] = (_a = headers['content-type']) !== null && _a !== void 0 ? _a : 'application/json;charset=utf-8';
- return JSON.stringify(body);
- }
- throw new TypeError('Unknown body type');
-}
-const _toString = Object.prototype.toString;
-function toStringCheck(obj, name) {
- return _toString.call(obj) === `[object ${name}]`;
-}
-function isArrayBuffer(body) {
- return toStringCheck(body, 'ArrayBuffer');
-}
-function isFile(body) {
- return toStringCheck(body, 'File');
-}
-function isBlob(body) {
- return toStringCheck(body, 'Blob');
-}
-function isArrayBufferView(body) {
- return typeof ArrayBuffer !== 'undefined' && ArrayBuffer.isView(body);
-}
-function isFormData(body) {
- return typeof FormData !== 'undefined' && body instanceof FormData;
-}
-function isURLSearchParams(body) {
- return typeof URLSearchParams !== 'undefined' && body instanceof URLSearchParams;
-}
-function isReadableStream(body) {
- return typeof ReadableStream !== 'undefined' && body instanceof ReadableStream;
-}
-//# sourceMappingURL=ajax.js.map \ No newline at end of file
send patches to the email below
yukais@pinapelz.com
include the subject [PATCH repo_name]
pinapelz.com
homepage