beremiz: comparison svghmi/svghmi.js

Mercurial Mercurial > beremiz / comparison

summary | shortlog | changelog | graph | tags | bookmarks | branches | files | changeset | file | latest | revisions | annotate | diff | comparison | raw | help

svghmi/svghmi.js

changeset 3648	ff42600fddd7
parent 3645	82882a9f91ce
child 3650	9256c344c2da

equal deleted inserted replaced

-:7c427418396f
+:ff42600fddd7
 });
 };
 // Open WebSocket to relative "/ws" address
 var has_watchdog = window.location.hash == "#watchdog";
-var ws_url =
-window.location.href.replace(/^http(s?:\/\/[^\/]*)\/.*$/, 'ws$1/ws')
-+ '?mode=' + (has_watchdog ? "watchdog" : "multiclient");
-var ws = new WebSocket(ws_url);
-ws.binaryType = 'arraybuffer';
 const dvgetters = {
 INT: (dv,offset) => [dv.getInt16(offset, true), 2],
 BOOL: (dv,offset) => [dv.getInt8(offset, true), 1],
 NODE: (dv,offset) => [dv.getInt8(offset, true), 1],
 }
 // Message reception handler
 // Hash is verified and HMI values updates resulting from binary parsing
 // are stored until browser can compute next frame, DOM is left untouched
-ws.onmessage = function (evt) {
+function ws_onmessage(evt) {
 let data = evt.data;
 let dv = new DataView(data);
 let i = 0;
 try {
 }
 };
 hmi_hash_u8 = new Uint8Array(hmi_hash);
+var ws = null;
 function send_blob(data) {
-if(data.length > 0) {
+if(ws && data.length > 0) {
 ws.send(new Blob([hmi_hash_u8].concat(data)));
 };
 };
 const typedarray_types = {
 } else {
 entry[1] = period;
 }
 }
+function reset_subscription_periods() {
+for(let index in subscriptions)
+subscriptions[index][1] = 0;
+}
 if(has_watchdog){
 // artificially subscribe the watchdog widget to "/heartbeat" hmi variable
 // Since dispatch directly calls change_hmi_value,
 // PLC will periodically send variable at given frequency
 subscribers(heartbeat_index).add({
 setup_lang();
 function update_subscriptions() {
 let delta = [];
+if(!ws)
+// dont' change subscriptions if not connected
+return;
 for(let index in subscriptions){
 let widgets = subscribers(index);
 // periods are in ms
 let previous_period = get_subscription_period(index);
 } else {
 document.exitFullscreen();
 }
 }
-function prepare_svg() {
+// prevents context menu from appearing on right click and long touch
-// prevents context menu from appearing on right click and long touch
+document.body.addEventListener('contextmenu', e => {
-document.body.addEventListener('contextmenu', e => {
+toggleFullscreen();
-toggleFullscreen();
+e.preventDefault();
-e.preventDefault();
+});
-});
+function detach_detachables() {
 for(let eltid in detachable_elements){
 let [element,parent] = detachable_elements[eltid];
 parent.removeChild(element);
 }
 group.transform.baseVal.appendItem(transform);
 ["x", "y"].forEach((axis) => group.removeAttribute("svghmi_"+axis+"_offset"));
 });
 }
+// prepare SVG
+apply_reference_frames();
+init_widgets();
+detach_detachables();
+// show main page
+switch_page(default_page);
+var reconnect_delay = 0;
+// var periodic_reconnect_timer;
 // Once connection established
-ws.onopen = function (evt) {
+function ws_onopen(evt) {
-apply_reference_frames();
+/*
-init_widgets();
+// to force reconnect every hour
+if(periodic_reconnect_timer){
+window.clearTimeout(periodic_reconnect_timer);
+}
+periodic_reconnect_timer = window.setTimeout(() => {
+ws.close();
+periodic_reconnect_timer = null;
+}, 3600*1000);
+*/
+// forget subscriptions remotely
 send_reset();
-// show main page
-prepare_svg();
+// forget earlier subscriptions locally
-switch_page(default_page);
+reset_subscription_periods();
-};
+// update PLC about subscriptions and current page
-ws.onclose = function (evt) {
+switch_page();
+// at first try reconnect immediately
+reconnect_delay = 1;
+};
+function ws_onclose(evt) {
+console.log("Connection closed. code:"+evt.code+" reason:"+evt.reason+" wasClean:"+evt.wasClean+" Reload in "+reconnect_delay+"ms.");
+ws = null;
+// reconect
 // TODO : add visible notification while waiting for reload
-console.log("Connection closed. code:"+evt.code+" reason:"+evt.reason+" wasClean:"+evt.wasClean+" Reload in 10s.");
+window.setTimeout(create_ws, reconnect_delay);
-// TODO : re-enable auto reload when not in debug
+reconnect_delay += 500;
-//window.setTimeout(() => location.reload(true), 10000);
+};
-alert("Connection closed. code:"+evt.code+" reason:"+evt.reason+" wasClean:"+evt.wasClean+".");
+var ws_url =
-};
+window.location.href.replace(/^http(s?:\/\/[^\/]*)\/.*$/, 'ws$1/ws')
++ '?mode=' + (has_watchdog ? "watchdog" : "multiclient");
+function create_ws(){
+ws = new WebSocket(ws_url);
+ws.binaryType = 'arraybuffer';
+ws.onmessage = ws_onmessage;
+ws.onclose = ws_onclose;
+ws.onopen = ws_onopen;
+}
+create_ws()
 const xmlns = "http://www.w3.org/2000/svg";
 var edit_callback;
 const localtypes = {"PAGE_LOCAL":null, "HMI_LOCAL":null}
 function edit_value(path, valuetype, callback, initial) {

beremiz