aboutsummaryrefslogtreecommitdiff
path: root/sandbox/testAppNevena/Front/node_modules/promise-retry/index.js
diff options
context:
space:
mode:
authorNevena Bojovic <nenabojov@gmail.com>2022-03-01 20:05:50 +0100
committerNevena Bojovic <nenabojov@gmail.com>2022-03-01 20:05:50 +0100
commit291803c31f829fe0d32bb3207bc11def95a7408c (patch)
treec7d43107d79291b19d8c9eceefbe91c9f9a52acf /sandbox/testAppNevena/Front/node_modules/promise-retry/index.js
parent1fa69862057db4db53cfda5be9c24b4228ef63f7 (diff)
Urađena test aplikacija. Povezan front i back.
Diffstat (limited to 'sandbox/testAppNevena/Front/node_modules/promise-retry/index.js')
-rw-r--r--sandbox/testAppNevena/Front/node_modules/promise-retry/index.js52
1 files changed, 52 insertions, 0 deletions
diff --git a/sandbox/testAppNevena/Front/node_modules/promise-retry/index.js b/sandbox/testAppNevena/Front/node_modules/promise-retry/index.js
new file mode 100644
index 00000000..5df48ae9
--- /dev/null
+++ b/sandbox/testAppNevena/Front/node_modules/promise-retry/index.js
@@ -0,0 +1,52 @@
+'use strict';
+
+var errcode = require('err-code');
+var retry = require('retry');
+
+var hasOwn = Object.prototype.hasOwnProperty;
+
+function isRetryError(err) {
+ return err && err.code === 'EPROMISERETRY' && hasOwn.call(err, 'retried');
+}
+
+function promiseRetry(fn, options) {
+ var temp;
+ var operation;
+
+ if (typeof fn === 'object' && typeof options === 'function') {
+ // Swap options and fn when using alternate signature (options, fn)
+ temp = options;
+ options = fn;
+ fn = temp;
+ }
+
+ operation = retry.operation(options);
+
+ return new Promise(function (resolve, reject) {
+ operation.attempt(function (number) {
+ Promise.resolve()
+ .then(function () {
+ return fn(function (err) {
+ if (isRetryError(err)) {
+ err = err.retried;
+ }
+
+ throw errcode(new Error('Retrying'), 'EPROMISERETRY', { retried: err });
+ }, number);
+ })
+ .then(resolve, function (err) {
+ if (isRetryError(err)) {
+ err = err.retried;
+
+ if (operation.retry(err || new Error())) {
+ return;
+ }
+ }
+
+ reject(err);
+ });
+ });
+ });
+}
+
+module.exports = promiseRetry;