itsscb/htmx
1
0
Fork 0
mirror of https://github.com/bigskysoftware/htmx.git synced 2025-10-03 07:45:21 +00:00
Code Issues Packages Projects Releases Wiki Activity

added full-jitter variant of exponential backoff algorithm

Browse Source
This commit is contained in:
Sven R. Kunze 2021-02-27 23:25:10 +01:00
parent 0a321bf65b
commit 29e4d2ada8
1 changed files with 22 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
src/htmx.js
View File

@ -45,7 +45,7 @@ return (function () {
swappingClass:'htmx-swapping', swappingClass:'htmx-swapping',
allowEval:true, allowEval:true,
attributesToSettle:["class", "style", "width", "height"], attributesToSettle:["class", "style", "width", "height"],
wsReconnectInterval: 10000 wsReconnectDelay: 'full-jitter'
}, },
parseInterval:parseInterval, parseInterval:parseInterval,
_:internalEval, _:internalEval,
@ -1044,7 +1044,7 @@ return (function () {
for (var i = 0; i < values.length; i++) { for (var i = 0; i < values.length; i++) {
var value = values[i].split(/:(.+)/); var value = values[i].split(/:(.+)/);
if (value[0] === "connect") { if (value[0] === "connect") {
processWebSocketSource(elt, value[1]); processWebSocketSource(elt, value[1], 0);
} }
if (value[0] === "send") { if (value[0] === "send") {
processWebSocketSend(elt); processWebSocketSend(elt);
@ -1052,7 +1052,7 @@ return (function () {
} }
} }
function processWebSocketSource(elt, wssSource) { function processWebSocketSource(elt, wssSource, retryCount) {
if (wssSource.indexOf("ws:") !== 0 && wssSource.indexOf("wss:") !== 0) { if (wssSource.indexOf("ws:") !== 0 && wssSource.indexOf("wss:") !== 0) {
wssSource = "wss:" + wssSource; wssSource = "wss:" + wssSource;
} }
@ -1064,11 +1064,15 @@ return (function () {
socket.onclose = function (e) { socket.onclose = function (e) {
if ([1006, 1012, 1013].includes(e.code)) { // Abnormal Closure/Service Restart/Try Again Later if ([1006, 1012, 1013].includes(e.code)) { // Abnormal Closure/Service Restart/Try Again Later
var delay = getWebSocketReconnectDelay(retryCount);
setTimeout(function() { setTimeout(function() {
processWebSocketSource(elt, wssSource); // creates a websocket with a new timeout processWebSocketSource(elt, wssSource, retryCount+1); // creates a websocket with a new timeout
}, htmx.config.wsReconnectInterval); }, delay);
} }
}; };
socket.onopen = function (e) {
retryCount = 0;
}
getInternalData(elt).webSocket = socket; getInternalData(elt).webSocket = socket;
socket.addEventListener('message', function (event) { socket.addEventListener('message', function (event) {
@ -1129,6 +1133,19 @@ return (function () {
} }
} }
function getWebSocketReconnectDelay(retryCount) {
var delay = htmx.config.wsReconnectDelay;
if (typeof delay === 'function') {
return delay(retryCount);
}
if (delay === 'full-jitter') {
var exp = Math.min(retryCount, 6);
var maxDelay = 1000 * Math.pow(2, exp);
return maxDelay * Math.random();
}
logError('htmx.config.wsReconnectDelay must either be a function or the string "full-jitter"');
}
//==================================================================== //====================================================================
// Server Sent Events // Server Sent Events
//==================================================================== //====================================================================