Reconnect web sockets when closed

This commit is contained in:
Frank A. Krueger 2020-03-08 20:03:36 -07:00
parent 04211c0f67
commit edb2296a21
No known key found for this signature in database
GPG Key ID: 0471C67474FFE664
1 changed files with 59 additions and 9 deletions

View File

@ -1,13 +1,15 @@
// Ooui v1.0.0
var debug = true;
var debug = false;
const nodes = {};
const hasText = {};
let nodes = {};
let hasText = {};
let socket = null;
let wasmSession = null;
let lastRootElementPath = "";
function send (json) {
if (debug) console.log ("Send", json);
if (socket != null) {
@ -77,8 +79,47 @@ function initializeNavigation() {
if (debug) console.log("Event", em);
}
let isWindowLoaded = false;
window.addEventListener("load", function () {
connectWebSocket();
isWindowLoaded = true;
});
// Main entrypoint
function ooui (rootElementPath) {
function ooui(rootElementPath) {
lastRootElementPath = rootElementPath;
if (isWindowLoaded) {
connectWebSocket();
}
}
let reloadTryCount = 0;
let reloadRequestTime = 0;
function reloadSocket() {
const now = (new Date()).getTime ();
if (now - reloadRequestTime > 0) {
reloadRequestTime = now + 100;
reloadTryCount++;
window.setTimeout(function () {
connectWebSocket();
}, 10);
}
}
function connectWebSocket() {
rootElementPath = lastRootElementPath;
if (rootElementPath.length === 0)
return;
console.log("Initializing Ooui web socket");
if (reloadTryCount > 0) {
let $body = getBodyNode();
while ($body.firstChild)
$body.removeChild($body.lastChild);
nodes = {};
hasText = {};
}
var initialSize = getSize ();
saveSize (initialSize);
@ -93,8 +134,11 @@ function ooui (rootElementPath) {
socket = new WebSocket (proto + "://" + document.location.host + rootElementPath + wsArgs, "ooui");
let socketOpened = false;
socket.addEventListener ("open", function (event) {
console.log ("Web socket opened");
console.log("Web socket opened");
socketOpened = true;
initializeNavigation();
});
@ -103,7 +147,10 @@ function ooui (rootElementPath) {
});
socket.addEventListener ("close", function (event) {
console.error ("Web socket close", event);
//console.error("Web socket close", event);
if (socketOpened) {
reloadSocket();
}
});
socket.addEventListener("message", function (event) {
@ -177,13 +224,16 @@ function monitorSizeChanges (millis)
window.addEventListener("resize", resizeThrottler, false);
}
function getBodyNode() {
const bodyNode = document.getElementById("ooui-body");
return bodyNode || document.body;
}
function getNode (id) {
switch (id) {
case "window": return window;
case "document": return document;
case "document.body":
const bodyNode = document.getElementById ("ooui-body");
return bodyNode || document.body;
case "document.body": return getBodyNode();
default: return nodes[id];
}
}