diff options
Diffstat (limited to 'includes/external/matrix/node_modules/matrix-js-sdk/lib/http-api/utils.js')
-rw-r--r-- | includes/external/matrix/node_modules/matrix-js-sdk/lib/http-api/utils.js | 145 |
1 files changed, 0 insertions, 145 deletions
diff --git a/includes/external/matrix/node_modules/matrix-js-sdk/lib/http-api/utils.js b/includes/external/matrix/node_modules/matrix-js-sdk/lib/http-api/utils.js deleted file mode 100644 index 9115598..0000000 --- a/includes/external/matrix/node_modules/matrix-js-sdk/lib/http-api/utils.js +++ /dev/null @@ -1,145 +0,0 @@ -"use strict"; - -Object.defineProperty(exports, "__esModule", { - value: true -}); -exports.anySignal = anySignal; -exports.parseErrorResponse = parseErrorResponse; -exports.retryNetworkOperation = retryNetworkOperation; -exports.timeoutSignal = timeoutSignal; -var _contentType3 = require("content-type"); -var _logger = require("../logger"); -var _utils = require("../utils"); -var _errors = require("./errors"); -/* -Copyright 2022 The Matrix.org Foundation C.I.C. - -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ - -// Ponyfill for https://developer.mozilla.org/en-US/docs/Web/API/AbortSignal/timeout -function timeoutSignal(ms) { - const controller = new AbortController(); - setTimeout(() => { - controller.abort(); - }, ms); - return controller.signal; -} -function anySignal(signals) { - const controller = new AbortController(); - function cleanup() { - for (const signal of signals) { - signal.removeEventListener("abort", onAbort); - } - } - function onAbort() { - controller.abort(); - cleanup(); - } - for (const signal of signals) { - if (signal.aborted) { - onAbort(); - break; - } - signal.addEventListener("abort", onAbort); - } - return { - signal: controller.signal, - cleanup - }; -} - -/** - * Attempt to turn an HTTP error response into a Javascript Error. - * - * If it is a JSON response, we will parse it into a MatrixError. Otherwise - * we return a generic Error. - * - * @param response - response object - * @param body - raw body of the response - * @returns - */ -function parseErrorResponse(response, body) { - var _contentType, _contentType2; - let contentType; - try { - contentType = getResponseContentType(response); - } catch (e) { - return e; - } - if (((_contentType = contentType) === null || _contentType === void 0 ? void 0 : _contentType.type) === "application/json" && body) { - return new _errors.MatrixError(JSON.parse(body), response.status, isXhr(response) ? response.responseURL : response.url); - } - if (((_contentType2 = contentType) === null || _contentType2 === void 0 ? void 0 : _contentType2.type) === "text/plain") { - return new _errors.HTTPError(`Server returned ${response.status} error: ${body}`, response.status); - } - return new _errors.HTTPError(`Server returned ${response.status} error`, response.status); -} -function isXhr(response) { - return "getResponseHeader" in response; -} - -/** - * extract the Content-Type header from the response object, and - * parse it to a `{type, parameters}` object. - * - * returns null if no content-type header could be found. - * - * @param response - response object - * @returns parsed content-type header, or null if not found - */ -function getResponseContentType(response) { - let contentType; - if (isXhr(response)) { - contentType = response.getResponseHeader("Content-Type"); - } else { - contentType = response.headers.get("Content-Type"); - } - if (!contentType) return null; - try { - return (0, _contentType3.parse)(contentType); - } catch (e) { - throw new Error(`Error parsing Content-Type '${contentType}': ${e}`); - } -} - -/** - * Retries a network operation run in a callback. - * @param maxAttempts - maximum attempts to try - * @param callback - callback that returns a promise of the network operation. If rejected with ConnectionError, it will be retried by calling the callback again. - * @returns the result of the network operation - * @throws {@link ConnectionError} If after maxAttempts the callback still throws ConnectionError - */ -async function retryNetworkOperation(maxAttempts, callback) { - let attempts = 0; - let lastConnectionError = null; - while (attempts < maxAttempts) { - try { - if (attempts > 0) { - const timeout = 1000 * Math.pow(2, attempts); - _logger.logger.log(`network operation failed ${attempts} times, retrying in ${timeout}ms...`); - await (0, _utils.sleep)(timeout); - } - return await callback(); - } catch (err) { - if (err instanceof _errors.ConnectionError) { - attempts += 1; - lastConnectionError = err; - } else { - throw err; - } - } - } - throw lastConnectionError; -} -//# sourceMappingURL=utils.js.map
\ No newline at end of file |