1 files changed, 113 insertions, 0 deletions
diff --git a/node_modules/fbjs/lib/fetchWithRetries.js b/node_modules/fbjs/lib/fetchWithRetries.js
new file mode 100644
index 000000000..47722ea25
--- /dev/null
+++ b/node_modules/fbjs/lib/fetchWithRetries.js
@@ -0,0 +1,113 @@
+/**
+ * Copyright (c) 2013-present, Facebook, Inc.
+ * All rights reserved.
+ *
+ * This source code is licensed under the BSD-style license found in the
+ * LICENSE file in the root directory of this source tree. An additional grant
+ * of patent rights can be found in the PATENTS file in the same directory.
+ *
+ * @typechecks
+ * 
+ */
+
+'use strict';
+
+var Promise = require('./Promise');
+
+function _objectWithoutProperties(obj, keys) { var target = {}; for (var i in obj) { if (keys.indexOf(i) >= 0) continue; if (!Object.prototype.hasOwnProperty.call(obj, i)) continue; target[i] = obj[i]; } return target; }
+
+var ExecutionEnvironment = require('./ExecutionEnvironment');
+
+var sprintf = require('./sprintf');
+var fetch = require('./fetch');
+var warning = require('./warning');
+
+var DEFAULT_TIMEOUT = 15000;
+var DEFAULT_RETRIES = [1000, 3000];
+
+/**
+ * Makes a POST request to the server with the given data as the payload.
+ * Automatic retries are done based on the values in `retryDelays`.
+ */
+function fetchWithRetries(uri, initWithRetries) {
+  var _ref = initWithRetries || {},
+      fetchTimeout = _ref.fetchTimeout,
+      retryDelays = _ref.retryDelays,
+      init = _objectWithoutProperties(_ref, ['fetchTimeout', 'retryDelays']);
+
+  var _fetchTimeout = fetchTimeout != null ? fetchTimeout : DEFAULT_TIMEOUT;
+  var _retryDelays = retryDelays != null ? retryDelays : DEFAULT_RETRIES;
+
+  var requestsAttempted = 0;
+  var requestStartTime = 0;
+  return new Promise(function (resolve, reject) {
+    /**
+     * Sends a request to the server that will timeout after `fetchTimeout`.
+     * If the request fails or times out a new request might be scheduled.
+     */
+    function sendTimedRequest() {
+      requestsAttempted++;
+      requestStartTime = Date.now();
+      var isRequestAlive = true;
+      var request = fetch(uri, init);
+      var requestTimeout = setTimeout(function () {
+        isRequestAlive = false;
+        if (shouldRetry(requestsAttempted)) {
+          process.env.NODE_ENV !== 'production' ? warning(false, 'fetchWithRetries: HTTP timeout, retrying.') : void 0;
+          retryRequest();
+        } else {
+          reject(new Error(sprintf('fetchWithRetries(): Failed to get response from server, ' + 'tried %s times.', requestsAttempted)));
+        }
+      }, _fetchTimeout);
+
+      request.then(function (response) {
+        clearTimeout(requestTimeout);
+        if (isRequestAlive) {
+          // We got a response, we can clear the timeout.
+          if (response.status >= 200 && response.status < 300) {
+            // Got a response code that indicates success, resolve the promise.
+            resolve(response);
+          } else if (shouldRetry(requestsAttempted)) {
+            // Fetch was not successful, retrying.
+            // TODO(#7595849): Only retry on transient HTTP errors.
+            process.env.NODE_ENV !== 'production' ? warning(false, 'fetchWithRetries: HTTP error, retrying.') : void 0, retryRequest();
+          } else {
+            // Request was not successful, giving up.
+            var error = new Error(sprintf('fetchWithRetries(): Still no successful response after ' + '%s retries, giving up.', requestsAttempted));
+            error.response = response;
+            reject(error);
+          }
+        }
+      })['catch'](function (error) {
+        clearTimeout(requestTimeout);
+        if (shouldRetry(requestsAttempted)) {
+          retryRequest();
+        } else {
+          reject(error);
+        }
+      });
+    }
+
+    /**
+     * Schedules another run of sendTimedRequest based on how much time has
+     * passed between the time the last request was sent and now.
+     */
+    function retryRequest() {
+      var retryDelay = _retryDelays[requestsAttempted - 1];
+      var retryStartTime = requestStartTime + retryDelay;
+      // Schedule retry for a configured duration after last request started.
+      setTimeout(sendTimedRequest, retryStartTime - Date.now());
+    }
+
+    /**
+     * Checks if another attempt should be done to send a request to the server.
+     */
+    function shouldRetry(attempt) {
+      return ExecutionEnvironment.canUseDOM && attempt <= _retryDelays.length;
+    }
+
+    sendTimedRequest();
+  });
+}
+
+module.exports = fetchWithRetries;
+\ No newline at end of file