summaryrefslogtreecommitdiff
path: root/includes/external/matrix/node_modules/p-retry/index.js
diff options
context:
space:
mode:
authorRaindropsSys <raindrops@equestria.dev>2023-11-17 23:25:29 +0100
committerRaindropsSys <raindrops@equestria.dev>2023-11-17 23:25:29 +0100
commit953ddd82e48dd206cef5ac94456549aed13b3ad5 (patch)
tree8f003106ee2e7f422e5a22d2ee04d0db302e66c0 /includes/external/matrix/node_modules/p-retry/index.js
parent62a9199846b0c07c03218703b33e8385764f42d9 (diff)
downloadpluralconnect-953ddd82e48dd206cef5ac94456549aed13b3ad5.tar.gz
pluralconnect-953ddd82e48dd206cef5ac94456549aed13b3ad5.tar.bz2
pluralconnect-953ddd82e48dd206cef5ac94456549aed13b3ad5.zip
Updated 30 files and deleted 2976 files (automated)
Diffstat (limited to 'includes/external/matrix/node_modules/p-retry/index.js')
-rw-r--r--includes/external/matrix/node_modules/p-retry/index.js85
1 files changed, 0 insertions, 85 deletions
diff --git a/includes/external/matrix/node_modules/p-retry/index.js b/includes/external/matrix/node_modules/p-retry/index.js
deleted file mode 100644
index 3679399..0000000
--- a/includes/external/matrix/node_modules/p-retry/index.js
+++ /dev/null
@@ -1,85 +0,0 @@
-'use strict';
-const retry = require('retry');
-
-const networkErrorMsgs = [
- 'Failed to fetch', // Chrome
- 'NetworkError when attempting to fetch resource.', // Firefox
- 'The Internet connection appears to be offline.', // Safari
- 'Network request failed' // `cross-fetch`
-];
-
-class AbortError extends Error {
- constructor(message) {
- super();
-
- if (message instanceof Error) {
- this.originalError = message;
- ({message} = message);
- } else {
- this.originalError = new Error(message);
- this.originalError.stack = this.stack;
- }
-
- this.name = 'AbortError';
- this.message = message;
- }
-}
-
-const decorateErrorWithCounts = (error, attemptNumber, options) => {
- // Minus 1 from attemptNumber because the first attempt does not count as a retry
- const retriesLeft = options.retries - (attemptNumber - 1);
-
- error.attemptNumber = attemptNumber;
- error.retriesLeft = retriesLeft;
- return error;
-};
-
-const isNetworkError = errorMessage => networkErrorMsgs.includes(errorMessage);
-
-const pRetry = (input, options) => new Promise((resolve, reject) => {
- options = {
- onFailedAttempt: () => {},
- retries: 10,
- ...options
- };
-
- const operation = retry.operation(options);
-
- operation.attempt(async attemptNumber => {
- try {
- resolve(await input(attemptNumber));
- } catch (error) {
- if (!(error instanceof Error)) {
- reject(new TypeError(`Non-error was thrown: "${error}". You should only throw errors.`));
- return;
- }
-
- if (error instanceof AbortError) {
- operation.stop();
- reject(error.originalError);
- } else if (error instanceof TypeError && !isNetworkError(error.message)) {
- operation.stop();
- reject(error);
- } else {
- decorateErrorWithCounts(error, attemptNumber, options);
-
- try {
- await options.onFailedAttempt(error);
- } catch (error) {
- reject(error);
- return;
- }
-
- if (!operation.retry(error)) {
- reject(operation.mainError());
- }
- }
- }
- });
-});
-
-module.exports = pRetry;
-// TODO: remove this in the next major version
-module.exports.default = pRetry;
-
-module.exports.AbortError = AbortError;