/usr/lib/nodejs/fbjs/lib/fetchWithRetries.js is in node-fbjs 0.8.16-1.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 | /**
* Copyright (c) 2013-present, Facebook, Inc.
*
* This source code is licensed under the MIT license found in the
* LICENSE file in the root directory of this source tree.
*
* @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;
|