Archives/ohwgiles_laminar
1
0
Fork 0
mirror of https://github.com/ohwgiles/laminar.git synced 2024-10-27 20:34:20 +00:00
Code Issues Projects Releases Wiki Activity

unify SSE reconnect behaviour

Browse Source 
Chrome auto-reconnects when an EventSource connection is interrupted
but Firefox doesn't. Enforce consistent behaviour by implementing
reconnect logic.
This commit is contained in:
Oliver Giles 2020-06-19 12:01:46 +12:00
parent d5cfa3b94e
commit 1cc6cc6ae9
1 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/resources/js/app.js
View File

@ -23,8 +23,9 @@ const timeScale = function(max){
: { scale:function(v){return v;}, label:'Seconds' }; : { scale:function(v){return v;}, label:'Seconds' };
} }
const ServerEventHandler = function() { const ServerEventHandler = function() {
function setupEventSource(path, query, next) { function setupEventSource(path, query, next, comp) {
const es = new EventSource(document.head.baseURI + path.substr(1) + query); const es = new EventSource(document.head.baseURI + path.substr(1) + query);
es.comp = comp;
es.path = path; // save for later in case we need to add query params es.path = path; // save for later in case we need to add query params
es.onmessage = function(msg) { es.onmessage = function(msg) {
msg = JSON.parse(msg.data); msg = JSON.parse(msg.data);
@ -46,6 +47,7 @@ const ServerEventHandler = function() {
this.comp = comp; this.comp = comp;
// 2. needed to close the ws on navigation away // 2. needed to close the ws on navigation away
comp.es = this; comp.es = this;
comp.esReconnectInterval = 500;
// Update html and nav titles // Update html and nav titles
document.title = comp.$root.title = msg.title; document.title = comp.$root.title = msg.title;
// Calculate clock offset (used by ProgressUpdater) // Calculate clock offset (used by ProgressUpdater)
@ -66,8 +68,14 @@ const ServerEventHandler = function() {
} }
} }
} }
es.onerror = function() { es.onerror = function(e) {
this.comp.$root.connected = false; this.comp.$root.connected = false;
setTimeout(() => {
this.comp.es = setupEventSource(path, query, null, this.comp);
}, this.comp.esReconnectInterval);
if(this.comp.esReconnectInterval < 7500)
this.comp.esReconnectInterval *= 1.5;
this.close();
} }
return es; return es;
} }