diff options
Diffstat (limited to 'includes/external/matrix/node_modules/matrix-js-sdk/src/http-api/utils.ts')
-rw-r--r-- | includes/external/matrix/node_modules/matrix-js-sdk/src/http-api/utils.ts | 153 |
1 files changed, 0 insertions, 153 deletions
diff --git a/includes/external/matrix/node_modules/matrix-js-sdk/src/http-api/utils.ts b/includes/external/matrix/node_modules/matrix-js-sdk/src/http-api/utils.ts deleted file mode 100644 index c49be74..0000000 --- a/includes/external/matrix/node_modules/matrix-js-sdk/src/http-api/utils.ts +++ /dev/null @@ -1,153 +0,0 @@ -/* -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. -*/ - -import { parse as parseContentType, ParsedMediaType } from "content-type"; - -import { logger } from "../logger"; -import { sleep } from "../utils"; -import { ConnectionError, HTTPError, MatrixError } from "./errors"; - -// Ponyfill for https://developer.mozilla.org/en-US/docs/Web/API/AbortSignal/timeout -export function timeoutSignal(ms: number): AbortSignal { - const controller = new AbortController(); - setTimeout(() => { - controller.abort(); - }, ms); - - return controller.signal; -} - -export function anySignal(signals: AbortSignal[]): { - signal: AbortSignal; - cleanup(): void; -} { - const controller = new AbortController(); - - function cleanup(): void { - for (const signal of signals) { - signal.removeEventListener("abort", onAbort); - } - } - - function onAbort(): void { - 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 - */ -export function parseErrorResponse(response: XMLHttpRequest | Response, body?: string): Error { - let contentType: ParsedMediaType | null; - try { - contentType = getResponseContentType(response); - } catch (e) { - return <Error>e; - } - - if (contentType?.type === "application/json" && body) { - return new MatrixError( - JSON.parse(body), - response.status, - isXhr(response) ? response.responseURL : response.url, - ); - } - if (contentType?.type === "text/plain") { - return new HTTPError(`Server returned ${response.status} error: ${body}`, response.status); - } - return new HTTPError(`Server returned ${response.status} error`, response.status); -} - -function isXhr(response: XMLHttpRequest | Response): response is XMLHttpRequest { - 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: XMLHttpRequest | Response): ParsedMediaType | null { - let contentType: string | null; - if (isXhr(response)) { - contentType = response.getResponseHeader("Content-Type"); - } else { - contentType = response.headers.get("Content-Type"); - } - - if (!contentType) return null; - - try { - return parseContentType(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 - */ -export async function retryNetworkOperation<T>(maxAttempts: number, callback: () => Promise<T>): Promise<T> { - let attempts = 0; - let lastConnectionError: ConnectionError | null = null; - while (attempts < maxAttempts) { - try { - if (attempts > 0) { - const timeout = 1000 * Math.pow(2, attempts); - logger.log(`network operation failed ${attempts} times, retrying in ${timeout}ms...`); - await sleep(timeout); - } - return await callback(); - } catch (err) { - if (err instanceof ConnectionError) { - attempts += 1; - lastConnectionError = err; - } else { - throw err; - } - } - } - throw lastConnectionError; -} |