134 lines
3.1 KiB
JavaScript
134 lines
3.1 KiB
JavaScript
|
|
const debug = false;
|
|
|
|
// Create WebSocket connection.
|
|
const socket = new WebSocket ("ws://" + document.location.host + rootElementPath, "ooui");
|
|
|
|
console.log("Web socket created");
|
|
|
|
const nodes = {};
|
|
|
|
function getNode (id) {
|
|
switch (id) {
|
|
case "window": return window;
|
|
case "document": return document;
|
|
case "document.body": return document.body;
|
|
default: return nodes[id];
|
|
}
|
|
}
|
|
|
|
function msgCreate (m) {
|
|
const id = m.id;
|
|
const tagName = m.k;
|
|
const node = tagName === "#text" ?
|
|
document.createTextNode ("") :
|
|
document.createElement (tagName);
|
|
if (tagName !== "#text")
|
|
node.id = id;
|
|
nodes[id] = node;
|
|
if (debug) console.log ("Created node", node);
|
|
}
|
|
|
|
function msgSet (m) {
|
|
const id = m.id;
|
|
const node = getNode (id);
|
|
if (!node) {
|
|
console.error ("Unknown node id", m);
|
|
return;
|
|
}
|
|
const parts = m.k.split(".");
|
|
let o = node;
|
|
for (let i = 0; i < parts.length - 1; i++) {
|
|
o = o[parts[i]];
|
|
}
|
|
o[parts[parts.length - 1]] = m.v;
|
|
if (debug) console.log ("Set", node, parts, m.v);
|
|
}
|
|
|
|
function msgCall (m) {
|
|
const id = m.id;
|
|
const node = getNode (id);
|
|
if (!node) {
|
|
console.error ("Unknown node id", m);
|
|
return;
|
|
}
|
|
const f = node[m.k];
|
|
if (debug) console.log ("Call", node, f, m.v);
|
|
f.apply (node, m.v);
|
|
}
|
|
|
|
function msgListen (m) {
|
|
const node = getNode (m.id);
|
|
if (!node) {
|
|
console.error ("Unknown node id", m);
|
|
return;
|
|
}
|
|
if (debug) console.log ("Listen", node, m.k);
|
|
node.addEventListener(m.k, function () {
|
|
const em = {
|
|
m: "event",
|
|
id: m.id,
|
|
k: m.k,
|
|
};
|
|
if (m.k === "change") {
|
|
em.v = node.value;
|
|
}
|
|
const ems = JSON.stringify (em);
|
|
socket.send (ems);
|
|
if (debug) console.log ("Event", em);
|
|
});
|
|
}
|
|
|
|
function processMessage (m) {
|
|
switch (m.m) {
|
|
case "nop":
|
|
break;
|
|
case "create":
|
|
msgCreate (m);
|
|
break;
|
|
case "set":
|
|
msgSet (m);
|
|
break;
|
|
case "call":
|
|
msgCall (m);
|
|
break;
|
|
case "listen":
|
|
msgListen (m);
|
|
break;
|
|
default:
|
|
console.error ("Unknown message type", m.m, m);
|
|
}
|
|
}
|
|
|
|
function fixupValue (v) {
|
|
if (Array.isArray (v)) {
|
|
for (x in v) {
|
|
v[x] = fixupValue (v[x]);
|
|
}
|
|
return v;
|
|
}
|
|
else if (typeof v === 'string' || v instanceof String) {
|
|
if ((v.length > 1) && (v[0] === "\u2999")) {
|
|
// console.log("V", v);
|
|
return getNode (v);
|
|
}
|
|
}
|
|
return v;
|
|
}
|
|
|
|
socket.addEventListener('open', function (event) {
|
|
console.log("Web socket opened");
|
|
});
|
|
|
|
socket.addEventListener('message', function (event) {
|
|
const messages = JSON.parse (event.data);
|
|
if (debug) console.log("Messages", messages);
|
|
if (Array.isArray (messages)) {
|
|
messages.forEach (function (m) {
|
|
// console.log('Raw value from server', m.v);
|
|
m.v = fixupValue (m.v);
|
|
processMessage (m);
|
|
});
|
|
}
|
|
});
|