diff --git a/data-src/index.js b/data-src/index.js
index 444b929..7bbb3c4 100644
--- a/data-src/index.js
+++ b/data-src/index.js
@@ -245,7 +245,7 @@ var httpStatusText = {
'504': 'Gateway Timeout',
'505': 'HTTP Version Not Supported'
};
-function getJSON(url, cb, attempt) {
+function getJSON(url, cb) {
let xhr = new XMLHttpRequest();
console.log({ get: url });
xhr.open('GET', baseUrl.length > 0 ? `${baseUrl}${url}` : url, true);
@@ -253,10 +253,6 @@ function getJSON(url, cb, attempt) {
xhr.responseType = 'json';
xhr.onload = () => {
let status = xhr.status;
- if (isBusy(status, xhr.response) && (attempt || 0) < 10) {
- setTimeout(() => getJSON(url, cb, (attempt || 0) + 1), 250);
- return;
- }
if (status !== 200) {
let err = xhr.response || {};
err.htmlError = status;
@@ -278,17 +274,12 @@ function getJSON(url, cb, attempt) {
};
xhr.send();
}
-function getJSONSync(url, cb, attempt) {
+function getJSONSync(url, cb) {
let overlay = ui.waitMessage(document.getElementById('divContainer'));
let xhr = new XMLHttpRequest();
xhr.responseType = 'json';
xhr.onload = () => {
let status = xhr.status;
- if (isBusy(status, xhr.response) && (attempt || 0) < 10) {
- if (typeof overlay !== 'undefined') overlay.remove();
- setTimeout(() => getJSONSync(url, cb, (attempt || 0) + 1), 250);
- return;
- }
if (status !== 200) {
let err = xhr.response || {};
err.htmlError = status;
@@ -320,109 +311,6 @@ function getJSONSync(url, cb, attempt) {
xhr.setRequestHeader('apikey', security.apiKey);
xhr.send();
}
-function getText(url, cb) {
- let xhr = new XMLHttpRequest();
- console.log({ get: url });
- xhr.open('GET', baseUrl.length > 0 ? `${baseUrl}${url}` : url, true);
- xhr.setRequestHeader('apikey', security.apiKey);
- xhr.responseType = 'text';
- xhr.onload = () => {
- let status = xhr.status;
- if (status !== 200) {
- let err = xhr.response || {};
- err.htmlError = status;
- err.service = `GET ${url}`;
- if (typeof err.desc === 'undefined') err.desc = xhr.statusText || httpStatusText[xhr.status || 500];
- cb(err, null);
- }
- else
- cb(null, xhr.response);
- };
- xhr.onerror = (evt) => {
- let err = {
- htmlError: xhr.status || 500,
- service: `GET ${url}`
- };
- if (typeof err.desc === 'undefined') err.desc = xhr.statusText || httpStatusText[xhr.status || 500];
- cb(err, null);
- };
- xhr.send();
-}
-function postJSONSync(url, data, cb) {
- let overlay = ui.waitMessage(document.getElementById('divContainer'));
- try {
- let xhr = new XMLHttpRequest();
- console.log({ post: url, data: data });
- let fd = new FormData();
- for (let name in data) {
- fd.append(name, data[name]);
- }
- xhr.open('POST', baseUrl.length > 0 ? `${baseUrl}${url}` : url, true);
- xhr.responseType = 'json';
- xhr.setRequestHeader('Accept', 'application/json');
- xhr.setRequestHeader('apikey', security.apiKey);
- xhr.onload = () => {
- let status = xhr.status;
- console.log(xhr);
- if (status !== 200) {
- let err = xhr.response || {};
- err.htmlError = status;
- err.service = `POST ${url}`;
- err.data = data;
- if (typeof err.desc === 'undefined') err.desc = xhr.statusText || httpStatusText[xhr.status || 500];
- cb(err, null);
- }
- else {
- cb(null, xhr.response);
- }
- overlay.remove();
- };
- xhr.onerror = (evt) => {
- console.log(xhr);
- let err = {
- htmlError: xhr.status || 500,
- service: `POST ${url}`
- };
- if (typeof err.desc === 'undefined') err.desc = xhr.statusText || httpStatusText[xhr.status || 500];
- cb(err, null);
- overlay.remove();
- };
- xhr.send(fd);
- } catch (err) { ui.serviceError(document.getElementById('divContainer'), err); }
-}
-function putJSON(url, data, cb) {
- let xhr = new XMLHttpRequest();
- console.log({ put: url, data: data });
- xhr.open('PUT', baseUrl.length > 0 ? `${baseUrl}${url}` : url, true);
- xhr.responseType = 'json';
- xhr.setRequestHeader('Content-Type', 'application/json; charset=utf-8');
- xhr.setRequestHeader('Accept', 'application/json');
- xhr.setRequestHeader('apikey', security.apiKey);
- xhr.onload = () => {
- let status = xhr.status;
- if (status !== 200) {
- let err = xhr.response || {};
- err.htmlError = status;
- err.service = `PUT ${url}`;
- err.data = data;
- if (typeof err.desc === 'undefined') err.desc = xhr.statusText || httpStatusText[xhr.status || 500];
- cb(err, null);
- }
- else {
- cb(null, xhr.response);
- }
- };
- xhr.onerror = (evt) => {
- console.log(xhr);
- let err = {
- htmlError: xhr.status || 500,
- service: `PUT ${url}`
- };
- if (typeof err.desc === 'undefined') err.desc = xhr.statusText || httpStatusText[xhr.status || 500];
- cb(err, null);
- };
- xhr.send(JSON.stringify(data));
-}
function putJSONSync(url, data, cb) {
let overlay = ui.waitMessage(document.getElementById('divContainer'));
try {
@@ -462,264 +350,195 @@ function putJSONSync(url, data, cb) {
xhr.send(JSON.stringify(data));
} catch (err) { ui.serviceError(document.getElementById('divContainer'), err); }
}
-// Edits of rooms, shades, groups and repeaters run on the device's main loop
-// after the reply, so the reply only says the edit was accepted. How it went
-// comes over the socket as requestResult with the same requestId. On success
-// readUrl(id) is read back, so cb gets what the edit route itself used to
-// return; without readUrl cb gets the result.
-var pendingEdits = {};
-var earlyResults = {};
-function editJSON(url, data, readUrl, cb) {
- let overlay = ui.waitMessage(document.getElementById('divContainer'));
- let attempts = 0;
- let finish = (result) => {
- overlay.remove();
- if (!result.ok) {
- let err = { htmlError: 500, service: `PUT ${url}`, desc: result.desc, data: data };
- if (result.code) err.code = result.code;
- cb(err, null);
- }
- else if (typeof readUrl === 'function') getJSONSync(readUrl(result.id), cb);
- else cb(null, result);
- };
- let send = () => {
- putJSON(url, data, (err, reply) => {
- // Another edit is still being applied.
- if (err && err.htmlError === 503 && typeof err.desc === 'string' && err.desc.startsWith('Busy') && ++attempts < 10) {
- setTimeout(send, 300);
- return;
- }
- if (err) {
- overlay.remove();
- cb(err, null);
- return;
- }
- let id = reply.requestId;
- if (typeof earlyResults[id] !== 'undefined') {
- let result = earlyResults[id];
- delete earlyResults[id];
- finish(result);
- return;
- }
- let timer = setTimeout(() => {
- delete pendingEdits[id];
- overlay.remove();
- let prompt = ui.promptMessage('The device did not confirm the change.', () => { location.reload(); });
- prompt.querySelector('.sub-message').innerHTML = '';
document.getElementById('btnScanAPs').classList.add('disabled');
- //document.getElementById('btnConnectWiFi').classList.add('disabled');
- getJSON('/scanaps', (err, aps) => {
+ let done = (networks) => {
document.getElementById('btnScanAPs').classList.remove('disabled');
- //document.getElementById('btnConnectWiFi').classList.remove('disabled');
- console.log(aps);
- if (err) {
- this.displayAPs({ connected: { name: '' }, accessPoints: [] });
- }
- else {
- this.displayAPs(aps);
- }
+ this.displayAPs({ accessPoints: networks.map((n) => ({ name: n.ssid, channel: n.channel || 0, strength: n.strength || 0, macAddress: n.macAddress || '' })) });
+ };
+ // The scan takes a few seconds; its networks come as an event.
+ sendOp('scanWifi', {}, (err) => {
+ if (err) done([]);
+ else proto.waitFor('wifiNetworks', null, 20000).then((d) => done(d && d.networks ? d.networks : []));
});
}
displayAPs(aps) {
@@ -1962,12 +1799,9 @@ class Wifi {
return;
}
}
- putJSONSync('/setIP', obj, (err, response) => {
- if (err) {
- ui.serviceError(err);
- }
- console.log(response);
- });
+ // With DHCP the static address stays as it was.
+ if (obj.dhcp) this.saveNetworkSection({ dhcp: true });
+ else this.saveNetworkSection({ dhcp: false, ip: obj.ip, subnet: obj.subnet, gateway: obj.gateway, dns1: obj.dns1, dns2: obj.dns2 });
}
saveNetwork() {
let pnl = document.getElementById('divNetAdapter');
@@ -2012,12 +1846,10 @@ class Wifi {
// A blank passphrase for the saved SSID keeps the stored one; for a new SSID it means an open network.
keepSavedPassphrase(ssid, passphrase) { return passphrase === '' && ssid === this.savedSsid; }
sendNetworkSettings(obj) {
- putJSONSync('/setNetwork', obj, (err, response) => {
- if (err) {
- ui.serviceError(err);
- }
- console.log(response);
- });
+ let fields = { connMode: obj.connType, ssid: obj.wifi.ssid, passphrase: obj.wifi.passphrase, roaming: obj.wifi.roaming, hidden: obj.wifi.hidden };
+ // A device without Ethernet refuses its settings.
+ if (this.hasEthernet) for (let name of ProtoViews.ETHERNET) fields[name] = obj.ethernet[name];
+ this.saveNetworkSection(fields);
}
connectWiFi() {
if (document.getElementById('btnConnectWiFi').classList.contains('disabled')) return;
@@ -2035,14 +1867,8 @@ class Wifi {
return;
}
if (this.keepSavedPassphrase(obj.ssid, obj.passphrase)) delete obj.passphrase;
-
-
- let overlay = ui.waitMessage(document.getElementById('divNetAdapter'));
- putJSON('/connectwifi', obj, (err, response) => {
- overlay.remove();
+ this.saveNetworkSection({ ssid: obj.ssid, passphrase: obj.passphrase }, () => {
document.getElementById('btnConnectWiFi').classList.remove('disabled');
- console.log(response);
-
});
}
procWifiStrength(strength) {
@@ -2108,31 +1934,25 @@ class Somfy {
this.loadPins('out', document.getElementById('selShadeGPIODown'));
this.loadPins('out', document.getElementById('selShadeGPIOMy'));
}
- async loadSomfy() {
- getJSONSync('/controller', (err, somfy) => {
+ // The shade model from the sync, and the radio's settings.
+ loadSomfy() {
+ let header = proto.model.header;
+ document.getElementById('spanMaxRooms').innerText = header.maxRooms;
+ document.getElementById('spanMaxShades').innerText = header.maxShades;
+ document.getElementById('spanMaxGroups').innerText = header.maxGroups;
+ renderAll();
+ firmware.procFwStatus({ fwVersion: { name: header.fw } });
+ this.loadRadio();
+ }
+ loadRadio() {
+ sendOp('getSettings', { section: 'radio' }, (err, radio) => {
if (err) {
- console.log(err);
ui.serviceError(err);
+ return;
}
- else {
- console.log(somfy);
- document.getElementById('spanMaxRooms').innerText = somfy.maxRooms || 0;
- document.getElementById('spanMaxShades').innerText = somfy.maxShades;
- document.getElementById('spanMaxGroups').innerText = somfy.maxGroups;
- ui.toElement(document.getElementById('divTransceiverSettings'), somfy);
- if (somfy.transceiver.config.radioInit) {
- document.getElementById('divRadioError').style.display = 'none';
- }
- else {
- document.getElementById('divRadioError').style.display = '';
- }
- // Create the shades list.
- this.setRoomsList(somfy.rooms);
- this.setShadesList(somfy.shades);
- this.setGroupsList(somfy.groups);
- this.setRepeaterList(somfy.repeaters);
- if (typeof somfy.version !== 'undefined') firmware.procFwStatus(somfy.version);
- }
+ let config = ProtoViews.radio(proto.schema, radio);
+ ui.toElement(document.getElementById('divTransceiverSettings'), { transceiver: { config: config } });
+ document.getElementById('divRadioError').style.display = config.radioInit ? 'none' : '';
});
}
saveRadio() {
@@ -2180,20 +2000,14 @@ class Somfy {
if (valid) valid = fnValDup(trans.config, 'TXPin');
if (valid) valid = fnValDup(trans.config, 'RXPin');
if (valid) {
- putJSONSync('/saveRadio', trans, (err, trans) => {
- if (err)
- ui.serviceError(err);
+ sendOp('saveSettings', ProtoViews.radioSave(trans.config), (err) => {
+ if (err) ui.serviceError(err);
else {
document.getElementById('btnSaveRadio').classList.remove('disabled');
- if (trans.config.radioInit) {
- document.getElementById('divRadioError').style.display = 'none';
- }
- else {
- document.getElementById('divRadioError').style.display = '';
- }
+ // Whether the radio came up with them.
+ this.loadRadio();
}
- console.log(trans);
- });
+ }, true);
}
}
}
@@ -2242,8 +2056,9 @@ class Somfy {
}
if (initScan) {
div.setAttribute('data-initscan', true);
- putJSONSync('/beginFrequencyScan', {}, (err, trans) => {
- if (!err) {
+ sendOp('beginFrequencyScan', {}, (err) => {
+ if (err) ui.serviceError(err);
+ else {
document.getElementById('btnStopScanning').style.display = '';
document.getElementById('btnRestartScanning').style.display = 'none';
document.getElementById('btnCopyFrequency').style.display = 'none';
@@ -2267,7 +2082,7 @@ class Somfy {
div.remove();
}
else {
- putJSONSync('/endFrequencyScan', {}, (err, trans) => {
+ sendOp('endFrequencyScan', {}, (err) => {
if (err) ui.serviceError(err);
else {
let freq = parseFloat(div.getAttribute('data-frequency'));
@@ -2281,39 +2096,6 @@ class Somfy {
}
btnDown = null;
btnTimer = null;
- procRoomAdded(room) {
- let r = _rooms.find(x => x.roomId === room.roomId);
- if (typeof r === 'undefined' || !r) {
- _rooms.push(room);
- _rooms.sort((a, b) => { return a.sortOrder - b.sortOrder });
- this.setRoomsList(_rooms);
- }
- }
- procRoomRemoved(room) {
- if (room.roomId === 0) return;
- let r = _rooms.find(x => x.roomId === room.roomId);
- if (typeof r !== 'undefined' && r.roomId === room.roomId) {
- _rooms = _rooms.filter(x => x.roomId !== room.roomId);
- _rooms.sort((a, b) => { return a.sortOrder - b.sortOrder });
- this.setRoomsList(_rooms);
- let rs = document.getElementById('divRoomSelector');
- let ss = document.getElementById('divShadeControls');
- let gs = document.getElementById('divGroupControls');
- let ctls = ss.querySelectorAll('.somfyShadeCtl');
- for (let i = 0; i < ctls.length; i++) {
- let x = ctls[i];
- if (parseInt(x.getAttribute('data-roomid'), 10) === room.roomId)
- x.setAttribute('data-roomid', '0');
- }
- ctls = gs.querySelectorAll('.somfyGroupCtl');
- for (let i = 0; i < ctls.length; i++) {
- let x = ctls[i];
- if (parseInt(x.getAttribute('data-roomid'), 10) === room.roomId)
- x.setAttribute('data-roomid', '0');
- }
- if (parseInt(rs.getAttribute('data-roomid'), 10) === room.roomId) this.selectRoom(0);
- }
- }
selectRoom(roomId) {
let room = _rooms.find(x => x.roomId === roomId) || { roomId: 0, name: '' };
let rs = document.getElementById('divRoomSelector');
@@ -2371,9 +2153,8 @@ class Somfy {
order.push(parseInt(items[i].getAttribute('data-roomid'), 10));
// Reorder the shades on the main page.
}
- editJSON('/roomSortOrder', order, null, (err) => {
+ sendEdit('roomSortOrder', { ids: order }, null, (err) => {
if (err) ui.serviceError(err);
- else this.updateRoomsList();
});
});
}
@@ -2567,13 +2348,8 @@ class Somfy {
order.push(parseInt(items[i].getAttribute('data-shadeid'), 10));
// Reorder the shades on the main page.
}
- editJSON('/shadeSortOrder', order, null, (err) => {
- for (let i = order.length - 1; i >= 0; i--) {
- let el = shadeControls.querySelector(`.somfyShadeCtl[data-shadeid="${order[i]}"`);
- if (el) {
- shadeControls.prepend(el);
- }
- }
+ sendEdit('shadeSortOrder', { ids: order }, null, (err) => {
+ if (err) ui.serviceError(err);
});
});
}
@@ -2812,13 +2588,8 @@ class Somfy {
order.push(parseInt(items[i].getAttribute('data-groupid'), 10));
// Reorder the shades on the main page.
}
- editJSON('/groupSortOrder', order, null, (err) => {
- for (let i = order.length - 1; i >= 0; i--) {
- let el = groupControls.querySelector(`.somfyGroupCtl[data-groupid="${order[i]}"`);
- if (el) {
- groupControls.prepend(el);
- }
- }
+ sendEdit('groupSortOrder', { ids: order }, null, (err) => {
+ if (err) ui.serviceError(err);
});
});
@@ -2911,12 +2682,10 @@ class Somfy {
}
sendShadeMyPosition(shadeId, pos, tilt) {
console.log(`Sending My Position for shade id ${shadeId} to ${pos} and ${tilt}`);
- let overlay = ui.waitMessage(document.getElementById('divContainer'));
- putJSON('/setMyPosition', { shadeId: shadeId, pos: pos, tilt: tilt }, (err, response) => {
+ sendOp('setMyPosition', { shadeId: shadeId, myPos: pos, myTiltPos: tilt }, (err) => {
this.closeShadePositioners();
- overlay.remove();
- console.log(response);
- });
+ if (err) ui.serviceError(err);
+ }, true);
}
setLinkedRemotesList(shade) {
let divCfg = '';
@@ -3019,22 +2788,21 @@ class Somfy {
let obj = {
shadeId: parseInt(lnk.dataset.shadeid, 10),
remoteAddress: frame.address,
- rollingCode: frame.rcode
+ lastRollingCode: frame.rcode
};
- editJSON('/linkRemote', obj, (id) => `/shade?shadeId=${id}`, (err, shade) => {
- console.log(shade);
- lnk.remove();
+ // The frames keep coming while the edit runs: link it once.
+ lnk.remove();
+ sendEdit('linkRemote', obj, editTarget('shade', () => obj.shadeId), (err, shade) => {
if (err) ui.serviceError(err);
- else this.setLinkedRemotesList(shade);
+ else if (shade) this.setLinkedRemotesList(shade);
});
}
else {
lnk = document.getElementById('divLinkRepeater');
if (lnk) {
- editJSON(`/linkRepeater`, {address:frame.address}, () => '/repeaters', (err, repeaters) => {
- lnk.remove();
+ lnk.remove();
+ sendEdit('linkRepeater', { remoteAddress: frame.address }, null, (err) => {
if (err) ui.serviceError(err);
- else this.setRepeaterList(repeaters);
});
}
}
@@ -3151,11 +2919,12 @@ class Somfy {
if (typeof roomId === 'undefined') {
document.getElementById('btnSaveRoom').innerText = 'Add Room';
- getJSONSync('/getNextRoom', (err, room) => {
+ sendOp('getNextRoom', {}, (err, room) => {
document.getElementById('spanRoomId').innerText = '*';
if (err) ui.serviceError(err);
else {
- console.log(room);
+ // What the reply leaves out is a new room's default.
+ room = proto.schema.fill(room, ProtoModel.FIELDS.room);
let elRoom = document.getElementById('somfyRoom');
room.name = '';
ui.toElement(elRoom, room);
@@ -3165,22 +2934,20 @@ class Somfy {
}
else {
document.getElementById('btnSaveRoom').innerText = 'Save Room';
- getJSONSync(`/room?roomId=${roomId}`, (err, room) => {
- if (err) ui.serviceError(err);
- else {
- console.log(room);
- document.getElementById('spanRoomId').innerText = roomId;
- ui.toElement(document.getElementById('somfyRoom'), room);
- this.showEditRoom(true);
- document.getElementById('btnSaveRoom').style.display = 'inline-block';
- }
- });
+ let room = proto.model.rooms.get(roomId);
+ if (!room) gone('room');
+ else {
+ document.getElementById('spanRoomId').innerText = roomId;
+ ui.toElement(document.getElementById('somfyRoom'), room);
+ this.showEditRoom(true);
+ document.getElementById('btnSaveRoom').style.display = 'inline-block';
+ }
}
}
openEditShade(shadeId) {
if (typeof shadeId === 'undefined') {
- getJSONSync('/getNextShade', (err, shade) => {
+ sendOp('getNextShade', {}, (err, shade) => {
document.getElementById('btnPairShade').style.display = 'none';
document.getElementById('btnUnpairShade').style.display = 'none';
document.getElementById('btnLinkRemote').style.display = 'none';
@@ -3195,7 +2962,8 @@ class Somfy {
ui.serviceError(err);
}
else {
- console.log(shade);
+ // What the reply leaves out is a new shade's default.
+ shade = proto.schema.fill(shade, ProtoModel.FIELDS.shade);
let elShade = document.getElementById('somfyShade');
shade.name = '';
shade.downTime = shade.upTime = 10000;
@@ -3217,7 +2985,7 @@ class Somfy {
document.getElementById('btnSaveShade').innerText = 'Save Shade';
document.getElementById('spanShadeId').innerText = shadeId;
- getJSONSync(`/shade?shadeId=${shadeId}`, (err, shade) => {
+ let fnShow = (err, shade) => {
if (err) {
ui.serviceError(err);
}
@@ -3252,13 +3020,16 @@ class Somfy {
}
this.setLinkedRemotesList(shade);
}
- });
+ };
+ let shade = proto.model.shades.get(shadeId);
+ if (shade) fnShow(null, shade);
+ else gone('shade');
}
}
openEditGroup(groupId) {
document.getElementById('btnLinkShade').style.display = 'none';
if (typeof groupId === 'undefined') {
- getJSONSync('/getNextGroup', (err, group) => {
+ sendOp('getNextGroup', {}, (err, group) => {
document.getElementById('btnSaveGroup').innerText = 'Add Group';
document.getElementById('spanGroupId').innerText = '*';
document.getElementById('divLinkedShadeList').innerHTML = '';
@@ -3267,7 +3038,7 @@ class Somfy {
ui.serviceError(err);
}
else {
- console.log(group);
+ group = proto.schema.fill(group, ProtoModel.FIELDS.group);
group.name = '';
group.flipCommands = false;
ui.toElement(document.getElementById('somfyGroup'), group);
@@ -3280,20 +3051,16 @@ class Somfy {
document.getElementById('btnSaveGroup').style.display = 'none';
document.getElementById('btnSaveGroup').innerText = 'Save Group';
document.getElementById('spanGroupId').innerText = groupId;
- getJSONSync(`/group?groupId=${groupId}`, (err, group) => {
- if (err) {
- ui.serviceError(err);
- }
- else {
- console.log(group);
- ui.toElement(document.getElementById('somfyGroup'), group);
- this.showEditGroup(true);
- document.getElementById('btnSaveGroup').style.display = 'inline-block';
- document.getElementById('btnLinkShade').style.display = '';
- document.getElementById('btnSetRollingCode').style.display = 'inline-block';
- this.setLinkedShadesList(group);
- }
- });
+ let group = ProtoViews.group(proto.model, proto.model.groups.get(groupId));
+ if (!group) gone('group');
+ else {
+ ui.toElement(document.getElementById('somfyGroup'), group);
+ this.showEditGroup(true);
+ document.getElementById('btnSaveGroup').style.display = 'inline-block';
+ document.getElementById('btnLinkShade').style.display = '';
+ document.getElementById('btnSetRollingCode').style.display = 'inline-block';
+ this.setLinkedShadesList(group);
+ }
}
}
showEditRoom(bShow) {
@@ -3362,7 +3129,7 @@ class Somfy {
if (valid) {
if (isNaN(roomId) || roomId === 0) {
// We are adding.
- editJSON('/addRoom', obj, (id) => `/room?roomId=${id}`, (err, room) => {
+ sendEdit('addRoom', obj, editTarget('room', (r) => r.roomId), (err, room) => {
if (err) {
ui.serviceError(err);
console.log(err);
@@ -3372,16 +3139,13 @@ class Somfy {
document.getElementById('spanRoomId').innerText = room.roomId;
document.getElementById('btnSaveRoom').innerText = 'Save Room';
document.getElementById('btnSaveRoom').style.display = 'inline-block';
- this.updateRoomsList();
}
});
}
else {
obj.roomId = roomId;
- editJSON('/saveRoom', obj, (id) => `/room?roomId=${id}`, (err, room) => {
+ sendEdit('saveRoom', obj, null, (err) => {
if (err) ui.serviceError(err);
- else this.updateRoomsList();
- console.log(room);
});
}
}
@@ -3435,7 +3199,7 @@ class Somfy {
if (valid) {
if (isNaN(shadeId) || shadeId >= 255) {
// We are adding.
- editJSON('/addShade', obj, (id) => `/shade?shadeId=${id}`, (err, shade) => {
+ sendEdit('addShade', obj, editTarget('shade', (r) => r.shadeId), (err, shade) => {
if (err) {
ui.serviceError(err);
console.log(err);
@@ -3448,19 +3212,17 @@ class Somfy {
document.getElementById('btnLinkRemote').style.display = '';
document.getElementById(shade.paired ? 'btnUnpairShade' : 'btnPairShade').style.display = 'inline-block';
document.getElementById('btnSetRollingCode').style.display = 'inline-block';
- this.updateShadeList();
}
});
}
else {
obj.shadeId = shadeId;
- editJSON('/saveShade', obj, (id) => `/shade?shadeId=${id}`, (err, shade) => {
+ sendEdit('saveShade', obj, editTarget('shade', () => shadeId), (err, shade) => {
if (err) {
ui.serviceError(err);
return;
}
- this.updateShadeList();
- console.log(shade);
+ if (!shade) return;
let ico = document.getElementById('icoShade');
let tilt = ico.parentElement.querySelector('i.icss-window-tilt');
tilt.style.display = shade.tiltType !== 0 ? '' : 'none';
@@ -3490,7 +3252,7 @@ class Somfy {
if (valid) {
if (isNaN(groupId) || groupId >= 255) {
// We are adding.
- editJSON('/addGroup', obj, (id) => `/group?groupId=${id}`, (err, group) => {
+ sendEdit('addGroup', obj, editTarget('group', (r) => r.groupId), (err, group) => {
if (err) ui.serviceError(err);
else {
console.log(group);
@@ -3498,68 +3260,17 @@ class Somfy {
document.getElementById('btnSaveGroup').innerText = 'Save Group';
document.getElementById('btnSaveGroup').style.display = 'inline-block';
document.getElementById('btnLinkShade').style.display = '';
- //document.getElementById('btnSetRollingCode').style.display = 'inline-block';
- this.updateGroupList();
}
});
}
else {
obj.groupId = groupId;
- editJSON('/saveGroup', obj, (id) => `/group?groupId=${id}`, (err, shade) => {
+ sendEdit('saveGroup', obj, null, (err) => {
if (err) ui.serviceError(err);
- else this.updateGroupList();
- console.log(shade);
});
}
}
}
- updateRoomsList() {
- getJSONSync('/rooms', (err, shades) => {
- if (err) {
- console.log(err);
- ui.serviceError(err);
- }
- else {
- this.setRoomsList(shades);
-
- }
- });
- }
- updateShadeList() {
- getJSONSync('/shades', (err, shades) => {
- if (err) {
- console.log(err);
- ui.serviceError(err);
- }
- else {
- //console.log(shades);
- // Create the shades list.
- this.setShadesList(shades);
- }
- });
- }
- updateGroupList() {
- getJSONSync('/groups', (err, groups) => {
- if (err) {
- console.log(err);
- ui.serviceError(err);
- }
- else {
- console.log(groups);
- // Create the groups list.
- this.setGroupsList(groups);
- }
- });
- }
- updateRepeatList() {
- getJSONSync('/repeaters', (err, repeaters) => {
- if (err) {
- console.log(err);
- ui.serviceError(err);
- }
- else this.setRepeaterList(repeaters);
- });
- }
deleteRoom(roomId) {
let valid = true;
if (isNaN(roomId) || roomId >= 255 || roomId <= 0) {
@@ -3567,21 +3278,18 @@ class Somfy {
valid = false;
}
if (valid) {
- getJSONSync(`/room?roomId=${roomId}`, (err, room) => {
- if (err) ui.serviceError(err);
- else {
- let prompt = ui.promptMessage(`Are you sure you want to delete this room?`, () => {
- ui.clearErrors();
- editJSON('/deleteRoom', { roomId: roomId }, null, (err, room) => {
- prompt.remove();
- if (err) ui.serviceError(err);
- else
- this.updateRoomsList();
- });
+ let room = proto.model.rooms.get(roomId);
+ if (!room) gone('room');
+ else {
+ let prompt = ui.promptMessage(`Are you sure you want to delete this room?`, () => {
+ ui.clearErrors();
+ sendEdit('deleteRoom', { roomId: roomId }, null, (err) => {
+ prompt.remove();
+ if (err) ui.serviceError(err);
});
- prompt.querySelector('.sub-message').innerHTML = `
It may or may not have been made. Press YES to reload the page and see.
'; - }, 5000); - pendingEdits[id] = (result) => { - clearTimeout(timer); - finish(result); - }; - }); - }; - send(); -} -function procRequestResult(result) { - let fn = pendingEdits[result.requestId]; - if (typeof fn === 'function') { - delete pendingEdits[result.requestId]; - fn(result); - } - // The socket can beat the reply that carries the id. Results of other - // clients' edits land here too, so only the latest few are kept. - else { - earlyResults[result.requestId] = result; - let ids = Object.keys(earlyResults); - if (ids.length > 10) delete earlyResults[ids[0]]; - } -} -function editsPending() { return Object.keys(pendingEdits).length > 0; } -// Reads are served from a copy of the shade model the device takes for each, -// and it takes at most two at once: a third is told to try again. -function isBusy(status, response) { - return status === 503 && response && typeof response.desc === 'string' && response.desc.startsWith('Busy'); -} -var socket; -var tConnect = null; -var sockIsOpen = false; -var connecting = false; -var connects = 0; +// The device over socket protocol 2 (docs/PROTOCOL.md; the client is in +// data-src/js). Everything but the login and the file transfers goes over the +// one socket: a page load opens no other connection, which the device's heap +// can't spare (docs/adr/0005-one-websocket-protocol.md). +var proto = null; +var protoSynced = false; +var everSynced = false; var connectFailed = 0; -async function initSockets() { - if (connecting) return; - console.log('Connecting to socket...'); - connecting = true; - if (tConnect) clearTimeout(tConnect); - tConnect = null; - let wms = document.getElementsByClassName('socket-wait'); - for (let i = 0; i < wms.length; i++) { - wms[i].remove(); - } - ui.waitMessage(document.getElementById('divContainer')).classList.add('socket-wait'); - let host = window.location.protocol === 'file:' ? hst : window.location.hostname; - try { - socket = new WebSocket(`ws://${host}:8080/`); - socket.onmessage = (evt) => { - if (evt.data.startsWith('42')) { - let ndx = evt.data.indexOf(','); - let eventName = evt.data.substring(3, ndx); - let data = evt.data.substring(ndx + 1, evt.data.length - 1); - try { - var reISO = /^(\d{4}|\+010000)-(\d{2})-(\d{2})T(\d{2}):(\d{2}):(\d{2}(?:\.\d*))(?:Z|(\+|-)([\d|:]*))?$/; - var reMsAjax = /^\/Date\((d|-|.*)\)[\/|\\]$/; - var msg = JSON.parse(data, (key, value) => { - if (typeof value === 'string') { - var a = reISO.exec(value); - if (a) return new Date(value); - a = reMsAjax.exec(value); - if (a) { - var b = a[1].split(/[-+,.]/); - return new Date(b[0] ? +b[0] : 0 - +b[1]); - } - } - return value; - }); - switch (eventName) { - case 'memStatus': - firmware.procMemoryStatus(msg); - break; - case 'fwStatus': - firmware.procFwStatus(msg); - break; - case 'remoteFrame': - somfy.procRemoteFrame(msg); - break; - case 'groupState': - somfy.procGroupState(msg); - break; - case 'shadeState': - somfy.procShadeState(msg); - break; - case 'shadeCommand': - console.log(msg); - break; - case 'requestResult': - procRequestResult(msg); - break; - case 'roomRemoved': - somfy.procRoomRemoved(msg); - break; - case 'roomAdded': - somfy.procRoomAdded(msg); - break; - // Another client changed the lists. This one's own edits - // refresh them when their result comes in. - case 'shadeRemoved': - case 'shadeAdded': - if (!editsPending()) somfy.updateShadeList(); - break; - case 'groupRemoved': - case 'groupAdded': - if (!editsPending()) somfy.updateGroupList(); - break; - case 'ethernet': - wifi.procEthernet(msg); - break; - case 'wifiStrength': - wifi.procWifiStrength(msg); - break; - case 'packetPulses': - console.log(msg); - break; - case 'frequencyScan': - somfy.procFrequencyScan(msg); - break; - - } - } catch (err) { - console.log({ eventName: eventName, data: data, err: err }); - } - } - }; - socket.onopen = (evt) => { - if (tConnect) clearTimeout(tConnect); - tConnect = null; - console.log({ msg: 'open', evt: evt }); - sockIsOpen = true; - connecting = false; - connects++; - connectFailed = 0; - let wms = document.getElementsByClassName('socket-wait'); - for (let i = 0; i < wms.length; i++) { - wms[i].remove(); - } - let errs = document.getElementsByClassName('socket-error'); - for (let i = 0; i < errs.length; i++) - errs[i].remove(); - if (general.reloadApp) { - general.reload(); - } - else { - (async () => { - ui.clearErrors(); - await general.loadGeneral(); - await wifi.loadNetwork(); - await somfy.loadSomfy(); - await mqtt.loadMQTT(); - if (ui.isConfigOpen()) socket.send('join:0'); - - //await general.init(); - //await somfy.init(); - //await mqtt.init(); - //await wifi.init(); - })(); - } - }; - socket.onclose = (evt) => { - wifi.procWifiStrength({ ssid: '', channel: -1, strength: -100 }); - wifi.procEthernet({ connected: false, speed: 0, fullduplex: false }); - if (document.getElementsByClassName('socket-wait').length === 0) - ui.waitMessage(document.getElementById('divContainer')).classList.add('socket-wait'); - if (evt.wasClean) { - console.log({ msg: 'close-clean', evt: evt }); - connectFailed = 0; - tConnect = setTimeout(async () => { await reopenSocket(); }, 7000); - console.log('Reconnecting socket in 7 seconds'); - } - else { - console.log({ msg: 'close-died', reason: evt.reason, evt: evt, sock: socket }); - if (connects > 0) { - console.log('Reconnecting socket in 3 seconds'); - tConnect = setTimeout(async () => { await reopenSocket(); }, 3000); - } - else { - if (connecting) { - connectFailed++; - let timeout = Math.min(connectFailed * 500, 10000); - console.log(`Initial socket did not connect try again (server was busy and timed out ${connectFailed} times)`); - tConnect = setTimeout(async () => { await reopenSocket(); }, timeout); - if (connectFailed === 5) { - ui.socketError('Too many clients connected. A maximum of 5 clients may be connected at any one time. Close some connections to the ESP Somfy RTS device to proceed.'); - } - let spanAttempts = document.getElementById('spanSocketAttempts'); - if (spanAttempts) spanAttempts.innerHTML = connectFailed.fmt("#,##0"); - - } - else { - console.log('Connecting socket in .5 seconds'); - tConnect = setTimeout(async () => { await reopenSocket(); }, 500); - } - - } - - } - connecting = false; - }; - socket.onerror = (evt) => { - console.log({ msg: 'socket error', evt: evt, sock: socket }); - }; - } catch (err) { - console.log({ - msg: 'Websocket connection error', err: err +// An op as a promise of its reply, refused with what ui.serviceError shows. +// retryBusy sends it again while the device says busy: it saves settings and +// applies edits one at a time, whoever sent them. A busy command is the +// radio's queue or a moving shade, which the user decides about. +function runOp(name, fields, retryBusy) { + return new Promise((resolve, reject) => { + if (!proto) { + reject(ProtoViews.opError(name, { code: 'notConnected', desc: 'Not connected to the device' })); + return; + } + let attempts = 0; + let send = () => proto.op(name, fields).then(resolve, (err) => { + if (retryBusy && err.code === 'busy' && ++attempts < 10) setTimeout(send, 300); + else reject(ProtoViews.opError(name, err)); }); - tConnect = setTimeout(async () => { await reopenSocket(); }, 5000); - } + send(); + }); } -async function reopenSocket() { - if (tConnect) clearTimeout(tConnect); - tConnect = null; - await initSockets(); +// cb(err, reply) as the HTTP helpers did. With wait the spinner shows until +// the reply. +function sendOp(name, fields, cb, wait) { + let overlay = wait ? ui.waitMessage(document.getElementById('divContainer')) : null; + let done = (err, d) => { + if (overlay) overlay.remove(); + if (typeof cb === 'function') cb(err, d); + }; + runOp(name, fields, name === 'saveSettings').then((d) => done(null, d), (err) => done(err, null)); +} +// Where an edit's room, shade or group is once its event is in: the event to +// wait for, and the item's id from the reply (an add's new id) or the fields. +function editTarget(kind, idOf) { + let key = `${kind}Id`; + let map = { room: 'rooms', shade: 'shades', group: 'groups' }[kind]; + return { + event: kind, idOf: idOf, match: (d, id) => d[key] === id, + read: (id) => kind === 'group' ? ProtoViews.group(proto.model, proto.model.groups.get(id)) : proto.model[map].get(id) + }; +} +// An edit, with the spinner up until it is done. Its events follow the +// reply: with a target, cb gets the item once its event is in; without, the +// lists redraw from the events anyway. +function sendEdit(name, fields, target, cb) { + let overlay = ui.waitMessage(document.getElementById('divContainer')); + let finish = (err, item) => { + overlay.remove(); + if (typeof cb === 'function') cb(err, item); + }; + runOp(name, fields, true).then((reply) => { + if (!target) { + finish(null, reply); + return; + } + let id = target.idOf(reply); + // Without the event the reply is all there is, an add's new id in it. + proto.waitFor(target.event, (d) => target.match(d, id), 3000).then(() => finish(null, target.read(id) || reply)); + }, (err) => finish(err, null)); +} +// A command's repeat count, when the caller gave one. +function repeatOf(repeat) { return typeof repeat === 'number' ? repeat : undefined; } +function gone(what) { ui.errorMessage(`The ${what} is no longer there.`); } +// The lists redraw from the model after events, a burst of them at once. +// While the socket is down they wait for the next sync. +var renderPending = {}; +var renderTimer = null; +function render(part) { + renderPending[part] = true; + if (!protoSynced || renderTimer) return; + renderTimer = setTimeout(() => { + renderTimer = null; + let p = renderPending; + renderPending = {}; + // Shades and groups show their room's name. + if (p.rooms) somfy.setRoomsList(proto.model.roomList()); + if (p.rooms || p.shades) somfy.setShadesList(proto.model.shadeList()); + if (p.rooms || p.groups) somfy.setGroupsList(proto.model.groupList().map((g) => ProtoViews.group(proto.model, g))); + if (p.repeaters) somfy.setRepeaterList(proto.model.repeaters); + }, 20); +} +function renderAll() { + renderPending = { rooms: true, shades: true, groups: true, repeaters: true }; + render('rooms'); +} +function showSocketWait() { + if (document.getElementsByClassName('socket-wait').length === 0) + ui.waitMessage(document.getElementById('divContainer')).classList.add('socket-wait'); +} +function clearSocketWait() { + for (let el of [...document.getElementsByClassName('socket-wait')]) el.remove(); + for (let el of [...document.getElementsByClassName('socket-error')]) el.remove(); +} +function showStatus(status) { + firmware.procMemoryStatus({ free: status.freeHeap, max: status.maxHeap, min: status.minHeap, uptime: status.uptime }); + if (proto.model.header.connType === 'Ethernet') wifi.procEthernet({ connected: status.connected, speed: status.speed, fullduplex: status.fullDuplex }); + else wifi.procWifiStrength({ ssid: status.ssid, channel: status.channel, strength: status.strength }); +} +// The feeds the config panel shows: received frames and the frequency scan. +// The client keeps them across reconnects, so they are set even while the +// socket is down. +function subscribeConfigFeeds(on) { + if (!proto) return; + for (let feed of ['frames', 'frequencyScan']) (on ? proto.subscribe(feed) : proto.unsubscribe(feed)).catch(() => {}); +} +function showVersionMismatch(v) { + if (document.getElementById('divVersionMismatch')) return; + let div = document.createElement('div'); + div.id = 'divVersionMismatch'; + div.className = 'version-banner'; + div.innerHTML = `This page speaks protocol ${v.client} but the device speaks ${v.device}. Update the application files, or reload the page.`; + document.body.prepend(div); +} +// Opens the socket, or opens it again with the token a login gave. +function startSocket() { + if (proto) { + proto.setToken(security.apiKey); + return; + } + let host = window.location.protocol === 'file:' ? hst : window.location.host; + proto = new ProtoClient({ host: host, token: security.apiKey }); + // Each sync, the first and after a reconnect: what changed meanwhile shows. + proto.on('synced', () => { + let first = !everSynced; + everSynced = true; + protoSynced = true; + connectFailed = 0; + clearSocketWait(); + if (general.reloadApp) { + general.reload(); + return; + } + if (first) ui.clearErrors(); + general.loadGeneral(); + wifi.loadNetwork(); + somfy.loadSomfy(); + mqtt.loadMQTT(); + showStatus(proto.model.status); + if (first && ui.isConfigOpen()) subscribeConfigFeeds(true); + }); + let lost = (refused) => { + protoSynced = false; + wifi.procWifiStrength({ ssid: '', channel: -1, strength: -100 }); + wifi.procEthernet({ connected: false, speed: 0, fullduplex: false }); + showSocketWait(); + if (++connectFailed === 5) + ui.socketError('The device does not answer, or 5 clients are connected to it already. Close some connections to the ESP Somfy RTS device to proceed.'); + let spanAttempts = document.getElementById('spanSocketAttempts'); + if (spanAttempts) spanAttempts.innerHTML = connectFailed.fmt('#,##0'); + if (refused) security.socketRefused(); + }; + proto.on('closed', () => lost(false)); + proto.on('refused', () => lost(true)); + proto.on('versionMismatch', showVersionMismatch); + proto.on('shadeState', (d) => { + let shade = proto.model.shades.get(d.shadeId); + if (shade) somfy.procShadeState(shade); + }); + proto.on('groupState', (d) => { + let group = proto.model.groups.get(d.groupId); + if (group) somfy.procGroupState(group); + }); + for (let e of ['room', 'roomRemoved', 'roomOrder']) proto.on(e, () => render('rooms')); + for (let e of ['shade', 'shadeRemoved', 'shadeOrder']) proto.on(e, () => render('shades')); + for (let e of ['group', 'groupRemoved', 'groupOrder']) proto.on(e, () => render('groups')); + proto.on('repeaters', () => render('repeaters')); + proto.on('memory', () => showStatus(proto.model.status)); + proto.on('wifi', () => showStatus(proto.model.status)); + proto.on('ethernet', () => showStatus(proto.model.status)); + proto.on('frame', (d) => somfy.procRemoteFrame(ProtoViews.frame(proto.schema, d))); + proto.on('frequencyScan', (d) => somfy.procFrequencyScan(ProtoViews.scan(proto.schema, d))); + proto.on('shadeCommanded', (d) => console.log(d)); + // Another client saved settings: show them as they are now. + proto.on('settingsChanged', (d) => { + switch (d.section) { + case 'general': general.loadGeneral(); break; + case 'network': wifi.loadNetwork(); break; + case 'mqtt': mqtt.loadMQTT(); break; + case 'radio': somfy.loadRadio(); break; + } + }); + proto.on('error', (err) => console.log(err)); + showSocketWait(); + proto.connect(); } async function init() { await security.init(); @@ -1213,17 +1032,8 @@ class UIBinder { divHome.style.display = 'none'; divCfg.style.display = ''; document.getElementById('icoConfig').className = 'icss-home'; - if (sockIsOpen) socket.send('join:0'); - let overlay = ui.waitMessage(document.getElementById('divSecurityOptions')); - overlay.style.borderRadius = '5px'; - getJSON('/getSecurity', (err, security) => { - overlay.remove(); - if (err) ui.serviceError(err); - else { - console.log(security); - general.setSecurityConfig(security); - } - }); + subscribeConfigFeeds(true); + general.loadSecurity(); } setHomePanel() { if (!this.isConfigOpen()) return; @@ -1232,8 +1042,8 @@ class UIBinder { divHome.style.display = ''; divCfg.style.display = 'none'; document.getElementById('icoConfig').className = 'icss-gear'; - if (sockIsOpen) socket.send('leave:0'); - general.setSecurityConfig({ type: 0, username: '', permissions: 0 }); + subscribeConfigFeeds(false); + general.setSecurityConfig({ securityType: 0, username: '' }); } toggleConfig() { if (this.isConfigOpen()) @@ -1257,21 +1067,62 @@ class Security { type = 0; authenticated = false; apiKey = ''; - permissions = 0; + checkingRefusal = false; + // The token lives as long as the tab: a reload keeps it, closing the tab + // drops it (docs/SECURITY_PLAN.md). + static TOKEN_KEY = 'espsomfyToken'; + loadToken() { + try { return sessionStorage.getItem(Security.TOKEN_KEY) || ''; } catch (e) { return ''; } + } + setToken(token) { + this.apiKey = token || ''; + try { + if (this.apiKey) sessionStorage.setItem(Security.TOKEN_KEY, this.apiKey); + else sessionStorage.removeItem(Security.TOKEN_KEY); + } catch (e) { /* No storage: a reload asks for the login again. */ } + } + showApp() { + document.getElementById('divUnauthenticated').style.display = 'none'; + document.getElementById('divAuthenticated').style.display = ''; + document.getElementById('divContainer').setAttribute('data-auth', true); + } async init() { - let fld = document.getElementById('divUnauthenticated').querySelector('.pin-digit[data-bind="security.pin.d0"]'); document.getElementById('divUnauthenticated').querySelector('.pin-digit[data-bind="login.pin.d3"]').addEventListener('digitentered', (evt) => { security.login(); }); await this.loadContext(); - if (this.type === 0 || (this.permissions & 0x01) === 0x01) { // No login required or only the config is protected. - if (typeof socket === 'undefined' || !socket) (async () => { await initSockets(); })(); - //ui.setMode(mode); - document.getElementById('divUnauthenticated').style.display = 'none'; - document.getElementById('divAuthenticated').style.display = ''; - document.getElementById('divContainer').setAttribute('data-auth', true); + this.apiKey = this.loadToken(); + // Under Secured the socket needs a token; one kept from earlier in this + // tab is tried, and a refusal brings the login back. + if (this.type === 0 || this.apiKey) { + this.authenticated = this.type !== 0; + this.showApp(); + startSocket(); } } + // The socket closed before it opened. A browser can't tell a refused + // token from a device that is down, so ask the device: if it answers and + // wants a login, stop retrying and show the login. + socketRefused() { + if (this.checkingRefusal) return; + this.checkingRefusal = true; + getJSON('/loginContext', (err, ctx) => { + this.checkingRefusal = false; + if (err || ctx.type === 0) return; + this.type = ctx.type; + this.tokenRefused(); + }); + } + // The device refused the token: open the login, with no retry. Logging + // in connects the socket again with the new one. + tokenRefused() { + if (proto) proto.close(); + clearSocketWait(); + this.setToken(''); + this.authenticated = false; + this.authUser(); + document.getElementById('btnCancelLogin').style.display = 'none'; + } async loadContext() { let pnl = document.getElementById('divUnauthenticated'); pnl.querySelector('#loginButtons').style.display = 'none'; @@ -1286,7 +1137,6 @@ class Security { console.log(ctx); document.getElementById('divContainer').setAttribute('data-securitytype', ctx.type); this.type = ctx.type; - this.permissions = ctx.permissions; switch (ctx.type) { case 1: pnl.querySelector('#divLoginPin').style.display = ''; @@ -1351,14 +1201,10 @@ class Security { navigator.credentials.store(cred); } catch (e) { /* ignore; browsers without support fall back to the form-submit heuristic */ } } - if (typeof socket === 'undefined' || !socket) (async () => { await initSockets(); })(); - //ui.setMode(mode); - - document.getElementById('divUnauthenticated').style.display = 'none'; - document.getElementById('divAuthenticated').style.display = ''; - document.getElementById('divContainer').setAttribute('data-auth', true); - this.apiKey = log.apiKey; + this.setToken(log.apiKey); this.authenticated = true; + this.showApp(); + startSocket(); let evt2 = new CustomEvent('afterlogin', { detail: { authenticated: true } }); document.getElementById('divContainer').dispatchEvent(evt2); } @@ -1397,7 +1243,6 @@ class General { if (this.initialized) return; this.setAppVersion(); this.setTimeZones(); - if (sockIsOpen && ui.isConfigOpen()) socket.send('join:0'); ui.toElement(document.getElementById('divSystemSettings'), { general: { hostname: 'ESPSomfyRTS', username: '', password: '', posixZone: 'UTC0', ntpServer: 'pool.ntp.org' } }); this.initialized = true; } @@ -1528,44 +1373,25 @@ class General { ]; loadGeneral() { let pnl = document.getElementById('divSystemOptions'); - getJSONSync('/modulesettings', (err, settings) => { - if (err) { - console.log(err); - } - else { - console.log(settings); - document.getElementById('spanFwVersion').innerText = settings.fwVersion; - document.getElementById('spanHwVersion').innerText = settings.chipModel.length > 0 ? '-' + settings.chipModel : ''; - document.getElementById('divContainer').setAttribute('data-chipmodel', settings.chipModel); - somfy.initPins(); - general.setAppVersion(); - ui.toElement(pnl, { general: settings }); - } + // The firmware and the chip come with the sync. + let header = proto.model.header; + document.getElementById('spanFwVersion').innerText = header.fw; + document.getElementById('spanHwVersion').innerText = header.chipModel.length > 0 ? '-' + header.chipModel : ''; + document.getElementById('divContainer').setAttribute('data-chipmodel', header.chipModel); + somfy.initPins(); + general.setAppVersion(); + sendOp('getSettings', { section: 'general' }, (err, settings) => { + if (err) console.log(err); + else ui.toElement(pnl, { general: ProtoViews.settings(proto.schema, 'general', settings) }); }); } - loadLogin() { - getJSONSync('/loginContext', (err, ctx) => { + loadSecurity() { + let overlay = ui.waitMessage(document.getElementById('divSecurityOptions')); + overlay.style.borderRadius = '5px'; + sendOp('getSettings', { section: 'security' }, (err, security) => { + overlay.remove(); if (err) ui.serviceError(err); - else { - console.log(ctx); - let pnl = document.getElementById('divContainer'); - pnl.setAttribute('data-securitytype', ctx.type); - let fld; - switch (ctx.type) { - case 1: - document.getElementById('divPinSecurity').style.display = ''; - fld = document.getElementById('divPinSecurity').querySelector('.pin-digit[data-bind="security.pin.d0"]'); - document.getElementById('divPinSecurity').querySelector('.pin-digit[data-bind="security.pin.d3"]').addEventListener('digitentered', (evt) => { - general.login(); - }); - break; - case 2: - document.getElementById('divPasswordSecurity').style.display = ''; - fld = document.getElementById('fldUsername'); - break; - } - if (fld) fld.focus(); - } + else general.setSecurityConfig(ProtoViews.settings(proto.schema, 'security', security)); }); } async setAppVersion() { @@ -1598,8 +1424,8 @@ class General { ui.errorMessage('Invalid Host Name').querySelector('.sub-message').innerHTML = 'The host name must only include numbers, letters, or dash.'; valid = false; } - if (valid && obj.hostname.length > 32) { - ui.errorMessage('Invalid Host Name').querySelector('.sub-message').innerHTML = 'The maximum Host Name length is 32 characters.'; + if (valid && obj.hostname.length > 31) { + ui.errorMessage('Invalid Host Name').querySelector('.sub-message').innerHTML = 'The maximum Host Name length is 31 characters.'; valid = false; } if (valid && typeof obj.ntpServer === 'string' && obj.ntpServer.length > 64) { @@ -1607,20 +1433,21 @@ class General { valid = false; } if (valid) { - putJSONSync('/setgeneral', obj, (err, response) => { + sendOp('saveSettings', { section: 'general', hostname: obj.hostname, ssdpBroadcast: obj.ssdpBroadcast, ntpServer: obj.ntpServer, + posixZone: obj.posixZone }, (err, response) => { if (err) ui.serviceError(err); console.log(response); - }); + }, true); } } + // security: the security section's settings. setSecurityConfig(security) { // The device never returns the stored password or PIN, only whether one is set. - this.savedSecurity = { type: security.type, username: security.username, hasPassword: makeBool(security.hasPassword), hasPin: makeBool(security.hasPin) }; + this.savedSecurity = { type: security.securityType, username: security.username, hasPassword: makeBool(security.hasPassword), hasPin: makeBool(security.hasPin) }; // We need to transform the security object so that it can be set to the configuration. let obj = { security: { - type: security.type, username: security.username, password: '', repeatpassword: '', - permissions: { configOnly: makeBool(security.permissions & 0x01) }, + type: security.securityType, username: security.username, password: '', repeatpassword: '', pin: { d0: '', d1: '', d2: '', d3: '' } } }; @@ -1634,10 +1461,9 @@ class General { } rebootDevice() { ui.promptMessage(document.getElementById('divContainer'), 'Are you sure you want to reboot the device?', () => { - if(typeof socket !== 'undefined') socket.close(3000, 'reboot'); - putJSONSync('/reboot', {}, (err, response) => { + sendOp('reboot', {}, (err, response) => { document.getElementById('btnSaveGeneral').classList.remove('disabled'); - console.log(response); + if (err) ui.serviceError(err); }); ui.clearErrors(); }); @@ -1647,17 +1473,14 @@ class General { let sec = ui.fromElement(pnl).security; switch (sec.type) { case 0: - pnl.querySelector('#divPermissions').style.display = 'none'; pnl.querySelector('#divPinSecurity').style.display = 'none'; pnl.querySelector('#divPasswordSecurity').style.display = 'none'; break; case 1: - pnl.querySelector('#divPermissions').style.display = ''; pnl.querySelector('#divPinSecurity').style.display = ''; pnl.querySelector('#divPasswordSecurity').style.display = 'none'; break; case 2: - pnl.querySelector('#divPermissions').style.display = ''; pnl.querySelector('#divPinSecurity').style.display = 'none'; pnl.querySelector('#divPasswordSecurity').style.display = ''; break; @@ -1665,25 +1488,24 @@ class General { } } saveSecurity() { - let security = ui.fromElement(document.getElementById('divSecurityOptions')).security; - console.log(security); - let sec = { type: security.type, username: security.username, password: security.password, pin: '', perm: 0 }; + let form = ui.fromElement(document.getElementById('divSecurityOptions')).security; + console.log(form); + let sec = { type: form.type, username: form.username, password: form.password, pin: '' }; // Pin entry. for (let i = 0; i < 4; i++) { - sec.pin += security.pin[`d${i}`]; + sec.pin += form.pin[`d${i}`]; } - sec.permissions |= security.permissions.configOnly ? 0x01 : 0x00; // Blank secret fields keep the stored value while the type (and username) stay the same. let saved = this.savedSecurity || {}; - let keepPin = security.type === 1 && sec.pin === '' && saved.hasPin && saved.type === 1; - let keepPassword = security.type === 2 && sec.password === '' && security.repeatpassword === '' && + let keepPin = form.type === 1 && sec.pin === '' && saved.hasPin && saved.type === 1; + let keepPassword = form.type === 2 && sec.password === '' && form.repeatpassword === '' && saved.hasPassword && saved.type === 2 && sec.username === saved.username; // Only send the secret for the selected type so the other one stays stored. - if (security.type !== 1 || keepPin) delete sec.pin; - if (security.type !== 2 || keepPassword) delete sec.password; + if (form.type !== 1 || keepPin) delete sec.pin; + if (form.type !== 2 || keepPassword) delete sec.password; let confirm = ''; console.log(sec); - if (security.type === 1 && !keepPin) { // Pin Entry + if (form.type === 1 && !keepPin) { // Pin Entry // Make sure our pin is 4 digits. if (sec.pin.length !== 4) { ui.errorMessage('Invalid Pin').querySelector('.sub-message').innerHTML = 'Pins must be exactly 4 alpha-numeric values in length. Please enter a complete pin.'; @@ -1691,7 +1513,7 @@ class General { } confirm = 'Please keep your PIN safe and above all remember it. The only way to recover a lost PIN is to completely reload the onboarding firmware which will wipe out your configuration.
Have you stored your PIN in a safe place?
'; } - else if (security.type === 2) { // Password + else if (form.type === 2) { // Password if (sec.username.length === 0) { ui.errorMessage('No Username Provided').querySelector('.sub-message').innerHTML = 'You must provide a username for password security.'; return; @@ -1701,7 +1523,7 @@ class General { return; } } - if (security.type === 2 && !keepPassword) { // Password + if (form.type === 2 && !keepPassword) { // Password if (sec.password.length === 0) { ui.errorMessage('No Password Provided').querySelector('.sub-message').innerHTML = 'You must provide a password for password security.'; return; @@ -1711,24 +1533,33 @@ class General { return; } - if (security.repeatpassword.length === 0) { + if (form.repeatpassword.length === 0) { ui.errorMessage('Re-enter Password').querySelector('.sub-message').innerHTML = 'You must re-enter the password in the Re-enter Password field.'; return; } - if (sec.password !== security.repeatpassword) { + if (sec.password !== form.repeatpassword) { ui.errorMessage('Passwords do not Match').querySelector('.sub-message').innerHTML = 'Please re-enter the password exactly as you typed it in the Re-enter Password field.'; return; } confirm = 'Please keep your password safe and above all remember it. The only way to recover a password is to completely reload the onboarding firmware which will wipe out your configuration.
Have you stored your username and password in a safe place?
'; } let prompt = ui.promptMessage('Confirm Security', () => { - putJSONSync('/saveSecurity', sec, (err, objApiKey) => { + let fields = { section: 'security', securityType: sec.type, username: sec.username, password: sec.password, pin: sec.pin }; + sendOp('saveSettings', fields, (err, reply) => { prompt.remove(); - if (err) ui.serviceError(err); - else { - console.log(objApiKey); + if (err) { + ui.serviceError(err); + return; } - }); + // The device closes every socket when a save leaves it Secured or + // changes its mode; this one comes back with the token in the + // reply. None to None closes nothing. + let closed = sec.type !== 0 || security.type !== 0; + security.type = sec.type; + security.authenticated = sec.type !== 0; + security.setToken(reply.apiKey); + if (closed) startSocket(); + }, true); }); prompt.querySelector('.sub-message').innerHTML = confirm; @@ -1801,16 +1632,25 @@ class Wifi { } } onDHCPClicked(cb) { document.getElementById('divStaticIP').style.display = cb.checked ? 'none' : ''; } + // Saves part of the network section; the device may restart for it. + saveNetworkSection(fields, done) { + sendOp('saveSettings', Object.assign({ section: 'network' }, fields), (err, reply) => { + if (err) ui.serviceError(err); + else if (reply.rebooting) ui.infoMessage('The device is restarting with the new network settings.'); + if (typeof done === 'function') done(err, reply); + }, true); + } loadNetwork() { let pnl = document.getElementById('divNetAdapter'); - getJSONSync('/networksettings', (err, settings) => { - console.log(settings); + sendOp('getSettings', { section: 'network' }, (err, reply) => { if (err) { ui.serviceError(err); } else { - // Firmware older than hasEthernet always built Ethernet in. - let hasEthernet = settings.hasEthernet !== false; + let settings = ProtoViews.network(proto.schema, reply); + console.log(settings); + let hasEthernet = settings.hasEthernet; + this.hasEthernet = hasEthernet; document.getElementById('divHardwired').style.display = hasEthernet ? '' : 'none'; document.getElementById('cbHardwired').checked = hasEthernet && settings.connType >= 2; document.getElementById('cbFallbackWireless').checked = hasEthernet && settings.connType === 3; @@ -1861,17 +1701,14 @@ class Wifi { if (document.getElementById('btnScanAPs').classList.contains('disabled')) return; document.getElementById('divAps').innerHTML = 'If this room was previously selected for motors or groups, they will be automatically assigned to the Home room.
`; - } - }); + }); + prompt.querySelector('.sub-message').innerHTML = `If this room was previously selected for motors or groups, they will be automatically assigned to the Home room.
`; + } } } deleteShade(shadeId) { @@ -3591,21 +3299,19 @@ class Somfy { valid = false; } if (valid) { - getJSONSync(`/shade?shadeId=${shadeId}`, (err, shade) => { - if (err) ui.serviceError(err); - else if (shade.inGroup) ui.errorMessage(`You may not delete this shade because it is a member of a group.`); - else { - let prompt = ui.promptMessage(`Are you sure you want to delete this shade?`, () => { - ui.clearErrors(); - editJSON('/deleteShade', { shadeId: shadeId }, null, (err, shade) => { - prompt.remove(); - if (err) ui.serviceError(err); - this.updateShadeList(); - }); + let shade = proto.model.shades.get(shadeId); + if (!shade) gone('shade'); + else if (shade.inGroup) ui.errorMessage(`You may not delete this shade because it is a member of a group.`); + else { + let prompt = ui.promptMessage(`Are you sure you want to delete this shade?`, () => { + ui.clearErrors(); + sendEdit('deleteShade', { shadeId: shadeId }, null, (err) => { + prompt.remove(); + if (err) ui.serviceError(err); }); - prompt.querySelector('.sub-message').innerHTML = `If this shade was previously paired with a motor, you should first unpair it from the motor and remove it from any groups. Otherwise its address will remain in the motor memory.
Press YES to delete ${shade.name} or NO to cancel this operation.
`; - } - }); + }); + prompt.querySelector('.sub-message').innerHTML = `If this shade was previously paired with a motor, you should first unpair it from the motor and remove it from any groups. Otherwise its address will remain in the motor memory.
Press YES to delete ${shade.name} or NO to cancel this operation.
`; + } } } deleteGroup(groupId) { @@ -3615,144 +3321,65 @@ class Somfy { valid = false; } if (valid) { - getJSONSync(`/group?groupId=${groupId}`, (err, group) => { - if (err) ui.serviceError(err); - else { - if (group.linkedShades.length > 0) { - ui.errorMessage('You may not delete this group until all shades have been removed from it.'); - } - else { - let prompt = ui.promptMessage(`Are you sure you want to delete this group?`, () => { - editJSON('/deleteGroup', { groupId: groupId }, null, (err, g) => { - if (err) ui.serviceError(err); - this.updateGroupList(); - prompt.remove(); - }); - - }); - prompt.querySelector('.sub-message').innerHTML = `Press YES to delete the ${group.name} group or NO to cancel this operation.
`; - - } - } - }); + let group = proto.model.groups.get(groupId); + if (!group) gone('group'); + else if (group.linkedShades.length > 0) { + ui.errorMessage('You may not delete this group until all shades have been removed from it.'); + } + else { + let prompt = ui.promptMessage(`Are you sure you want to delete this group?`, () => { + sendEdit('deleteGroup', { groupId: groupId }, null, (err) => { + if (err) ui.serviceError(err); + prompt.remove(); + }); + }); + prompt.querySelector('.sub-message').innerHTML = `Press YES to delete the ${group.name} group or NO to cancel this operation.
`; + } } } - sendPairCommand(shadeId) { - putJSON('/pairShade', { shadeId: shadeId }, (err, shade) => { - if (err) { - console.log(err); - } - else { - console.log(shade); - document.getElementById('somfyMain').style.display = 'none'; - document.getElementById('somfyShade').style.display = ''; - document.getElementById('btnSaveShade').style.display = 'inline-block'; - document.getElementById('btnLinkRemote').style.display = ''; - document.getElementsByName('shadeAddress')[0].value = shade.remoteAddress; - document.getElementsByName('shadeName')[0].value = shade.name; - document.getElementsByName('shadeUpTime')[0].value = shade.upTime; - document.getElementsByName('shadeDownTime')[0].value = shade.downTime; - let ico = document.getElementById('icoShade'); - ico.style.setProperty('--shade-position', `${shade.flipPosition ? 100 - shade.position : shade.position}%`); - ico.style.setProperty('--fpos', `${shade.position}%`); - //ico.style.setProperty('--shade-position', `${shade.position}%`); - ico.setAttribute('data-shadeid', shade.shadeId); - if (shade.paired) { - document.getElementById('btnUnpairShade').style.display = 'inline-block'; - document.getElementById('btnPairShade').style.display = 'none'; - } - else { - document.getElementById('btnPairShade').style.display = 'inline-block'; - document.getElementById('btnUnpairShade').style.display = 'none'; - } - this.setLinkedRemotesList(shade); - document.getElementById('divPairing').remove(); - } - - }); - } - sendUnpairCommand(shadeId) { - putJSON('/unpairShade', { shadeId: shadeId }, (err, shade) => { - if (err) { - console.log(err); - } - else { - console.log(shade); - document.getElementById('somfyMain').style.display = 'none'; - document.getElementById('somfyShade').style.display = ''; - document.getElementById('btnSaveShade').style.display = 'inline-block'; - document.getElementById('btnLinkRemote').style.display = ''; - document.getElementsByName('shadeAddress')[0].value = shade.remoteAddress; - document.getElementsByName('shadeName')[0].value = shade.name; - document.getElementsByName('shadeUpTime')[0].value = shade.upTime; - document.getElementsByName('shadeDownTime')[0].value = shade.downTime; - let ico = document.getElementById('icoShade'); - ico.style.setProperty('--shade-position', `${shade.flipPosition ? 100 - shade.position : shade.position}%`); - ico.style.setProperty('--fpos', `${shade.position}%`); - //ico.style.setProperty('--shade-position', `${shade.position}%`); - ico.setAttribute('data-shadeid', shade.shadeId); - if (shade.paired) { - document.getElementById('btnUnpairShade').style.display = 'inline-block'; - document.getElementById('btnPairShade').style.display = 'none'; - } - else { - document.getElementById('btnPairShade').style.display = 'inline-block'; - document.getElementById('btnUnpairShade').style.display = 'none'; - } - this.setLinkedRemotesList(shade); - document.getElementById('divPairing').remove(); - } - }); - } setRollingCode(shadeId, rollingCode) { - putJSONSync('/setRollingCode', { shadeId: shadeId, rollingCode: rollingCode }, (err, shade) => { + sendOp('setRollingCode', { shadeId: shadeId, lastRollingCode: rollingCode }, (err) => { if (err) ui.serviceError(document.getElementById('divSomfySettings'), err); else { let dlg = document.getElementById('divRollingCode'); if (dlg) dlg.remove(); } - }); + }, true); } openSetRollingCode(shadeId) { - let overlay = ui.waitMessage(document.getElementById('divContainer')); - getJSON(`/shade?shadeId=${shadeId}`, (err, shade) => { - overlay.remove(); - if (err) { - ui.serviceError(err); - } - else { - console.log(shade); - let div = document.createElement('div'); - div.setAttribute('id', 'divRollingCode'); - let html = ``;
- html += '
'; - html += '
BEWARE ... WARNING ... DANGER
';
- html += ''; - html += '
If this shade is already paired with a motor then changing the rolling code WILL cause it to stop working. Rolling codes are tied to the remote address and the Somfy motor expects these to be sequential.
'; - html += 'If you hesitated just a little bit do not press the red button. Green represents safety so press it, wipe the sweat from your brow, and go through the normal pairing process.'; - html += '
';
- html += ``;
- html += '';
- html += '
';
- html += ``;
- div.innerHTML = html;
- document.getElementById('somfyShade').appendChild(div);
- }
- });
+ let shade = proto.model.shades.get(shadeId);
+ if (!shade) {
+ gone('shade');
+ return;
+ }
+ console.log(shade);
+ let div = document.createElement('div');
+ div.setAttribute('id', 'divRollingCode');
+ let html = ``;
+ html += '
'; + html += '
,"id":,"d":{...}}`, with `id` only on ops and replies. Message types and error codes are numbers that fit one byte and are never reused. A later binary encoding would put the same four fields in a fixed header, be asked for at the upgrade, and use binary websocket frames. The `42[...]` socket.io framing goes.
- **Short keys, described by a schema the device sends.** Payload keys are one or two characters from one global dictionary. Booleans are 1/0, and fields at their default are left out. The schema lists every type, field (name, kind, default) and error code. The firmware's table is the only copy, and its writers can only emit declared fields. `hello` carries the schema's hash, and a client that has it cached reconnects with `?schema=` to skip it. Clients expand frames to full names, so client code stays readable.
+- **The web UI loads two files of its own: `index.js` and `app.css`.** Each file a page load fetches costs the device an open response, so the minify step joins the CSS files into `app.css`, and the protocol 2 client (`data-src/js/`) into `index.js`. Each client module ends with a `module.exports` footer, so Node can load it for the tests, and in the browser it adds nothing global but its classes.
- **Feeds.** High-rate events (received frames, frequency scan) go only to clients that subscribed to that feed.
- **A clean break, released as 4.0.0.** The firmware speaks only protocol 2. The new HA integration falls back to the old HTTP API and events when a device doesn't send `hello`; old integrations stop working against 4.0.0. The web UI checks `v` and shows a banner when the firmware and the web application don't match.
- **Tests.** Native tests cover parsing, the op table, permissions, the sync stream and the largest item fitting in 4 KB. A Python e2e suite, run by hand against a device, checks the protocol and survival under a reconnect storm and a page-load replay, and records fixtures. The web UI's client layer is tested with `node --test`. The HA integration tests its protocol module with plain pytest and the integration with pytest-homeassistant-custom-component, against a fake device that replays the fixtures.
diff --git a/minify.py b/minify.py
index a5c581c..fe47611 100644
--- a/minify.py
+++ b/minify.py
@@ -52,6 +52,16 @@ MINIFY_AND_GZIP = {".html", ".htm", ".css", ".js", ".json", ".svg", ".xml"}
# Extensions that optipng can optimise
PNG_EXTENSIONS = {".png"}
+# Files joined into one, in this order, before they are minified: a page load
+# then opens fewer connections, each of which costs the device heap
+# (docs/adr/0005-one-websocket-protocol.md). The protocol 2 client in js/
+# comes before index.js, which uses it. A source listed here isn't copied on
+# its own.
+BUNDLES = {
+ "index.js": ["js/schema.js", "js/model.js", "js/client.js", "js/views.js", "index.js"],
+ "app.css": ["main.css", "widgets.css", "icons.css"],
+}
+
# Everything else is copied verbatim
# ──────────────────────────────────────────────
@@ -252,6 +262,39 @@ def minify_all():
total_final = 0
file_count = 0
+ def report(rel_path, stats):
+ nonlocal total_original, total_final, file_count
+ pct = (1 - stats["final"] / stats["original"]) * 100 if stats["original"] > 0 else 0
+ print(
+ f" {rel_path:<40s} "
+ f"{stats['original']:>8,d} → {stats['final']:>8,d} B "
+ f"({pct:+.0f}%) [{stats['action']}]"
+ )
+ total_original += stats["original"]
+ total_final += stats["final"]
+ file_count += 1
+
+ bundled = set()
+ # Inside data/, so it goes even when a bundle fails: left there, it would
+ # end up in the LittleFS image.
+ work_dir = os.path.join(dst_dir, ".bundles")
+ os.makedirs(work_dir, exist_ok=True)
+ try:
+ for name, parts in BUNDLES.items():
+ joined = os.path.join(work_dir, name)
+ with open(joined, "w", encoding="utf-8") as out:
+ for part in parts:
+ # utf-8-sig drops a byte order mark: mid-file it would be
+ # read as part of the next selector, and that rule lost.
+ with open(os.path.join(src_dir, part), "r", encoding="utf-8-sig") as f:
+ out.write(f.read())
+ # A file without a final newline would run into the next.
+ out.write("\n")
+ bundled.add(os.path.normpath(part))
+ report(f"{name} ({len(parts)} files)", process_file(joined, os.path.join(dst_dir, name)))
+ finally:
+ shutil.rmtree(work_dir, ignore_errors=True)
+
for root, dirs, files in os.walk(src_dir):
for fname in sorted(files):
# Skip hidden files and editor temp files
@@ -260,20 +303,11 @@ def minify_all():
src_path = os.path.join(root, fname)
rel_path = os.path.relpath(src_path, src_dir)
+ if os.path.normpath(rel_path) in bundled:
+ continue
dst_path = os.path.join(dst_dir, rel_path)
- stats = process_file(src_path, dst_path)
-
- pct = (1 - stats["final"] / stats["original"]) * 100 if stats["original"] > 0 else 0
- print(
- f" {rel_path:<40s} "
- f"{stats['original']:>8,d} → {stats['final']:>8,d} B "
- f"({pct:+.0f}%) [{stats['action']}]"
- )
-
- total_original += stats["original"]
- total_final += stats["final"]
- file_count += 1
+ report(rel_path, process_file(src_path, dst_path))
print(f"[minify] {file_count} files processed")
print(
diff --git a/test/e2e/README.md b/test/e2e/README.md
index e18355f..a42e530 100644
--- a/test/e2e/README.md
+++ b/test/e2e/README.md
@@ -17,4 +17,6 @@ Runs against a real device on your network, by hand, never in CI. It checks sock
A plain run sends nothing on air, changes no setting (it saves only values the device already has) and doesn't reboot the device. The command tests send ops that are refused before they reach the radio, and one `setPositions` that sets a shade to the position the sync gave: that drops the fraction of a percent the shade's believed position may have had. The edit tests send edits that are refused, and one shade sort order set to the order it has, which saves the shades again unchanged. The settings tests send saves that are refused, and one that saves the NTP server and time zone the device already has. The frequency scan test pauses the radio's sending for a second or two, as a scan does. It does fill every socket slot for a few seconds, and replays a page load.
+The web UI holds one of the device's 5 socket slots for each open tab. The tests that fill every slot skip while one is taken, so close the UI's tabs before a run.
+
The tests run in whatever security mode the device is in; the suite never changes it. To test both modes, run the suite once in each.
diff --git a/test/e2e/test_survival.py b/test/e2e/test_survival.py
index 457e40e..8c56d29 100644
--- a/test/e2e/test_survival.py
+++ b/test/e2e/test_survival.py
@@ -2,6 +2,7 @@
(docs/adr/0005-one-websocket-protocol.md): every client reconnecting at once,
and a browser loading the page."""
import threading
+import time
import urllib.request
import pytest
@@ -29,7 +30,24 @@ def watch_heap(host):
assert after["min"] >= HEAP_FLOOR, "the heap fell to %u bytes (floor %u)" % (after["min"], HEAP_FLOOR)
-def test_every_client_reconnecting_at_once(connect, schema, watch_heap):
+@pytest.fixture
+def all_slots_free(host, token):
+ """Skips unless every socket slot is free. The web UI holds one per open
+ tab, which would leave these tests a client short."""
+ clients = [ProtoClient(host, params={"apikey": token} if token else None) for _ in range(MAX_CLIENTS)]
+ try:
+ time.sleep(1)
+ taken = sum(1 for c in clients if c.closed.is_set())
+ finally:
+ for c in clients:
+ c.close()
+ # The device frees a slot when it sees the disconnect.
+ time.sleep(0.5)
+ if taken:
+ pytest.skip("%u socket slot(s) in use, likely by the web UI: close its tabs" % taken)
+
+
+def test_every_client_reconnecting_at_once(connect, schema, watch_heap, all_slots_free):
clients = [connect() for _ in range(MAX_CLIENTS)]
errors = []
@@ -44,7 +62,7 @@ def test_every_client_reconnecting_at_once(connect, schema, watch_heap):
assert not errors, errors
-def test_one_client_too_many_is_closed(connect, schema):
+def test_one_client_too_many_is_closed(connect, schema, all_slots_free):
clients = [connect(schema=schema.hash) for _ in range(MAX_CLIENTS)]
for c in clients:
run_sync(c)
@@ -54,7 +72,7 @@ def test_one_client_too_many_is_closed(connect, schema):
def test_page_load(host, token, connect, watch_heap):
"""The static files in parallel, as a browser fetches them, then the socket."""
- files = ["/", "/main.css", "/widgets.css", "/icons.css", "/index.js", "/icon.png"]
+ files = ["/", "/app.css", "/index.js", "/icon.png"]
errors = []
def get(path):
diff --git a/test/js/client.test.js b/test/js/client.test.js
new file mode 100644
index 0000000..571ec5e
--- /dev/null
+++ b/test/js/client.test.js
@@ -0,0 +1,339 @@
+// The web UI's ProtoClient (data-src/js/client.js): the recorded hello and
+// sync replayed through a stand-in socket.
+const test = require('node:test');
+const assert = require('node:assert/strict');
+const { ProtoClient, ProtoError } = require('../../data-src/js/client.js');
+const { hello, sync, syncWithoutSchema, recordedItems, recordedSchema, FakeSocket, FakeTimers, FakeStorage } = require('./helpers.js');
+
+function client(opts) {
+ FakeSocket.reset();
+ const timers = new FakeTimers();
+ const c = new ProtoClient(Object.assign({ host: 'device', WebSocket: FakeSocket, setTimeout: timers.setTimeout,
+ clearTimeout: timers.clearTimeout, storage: null }, opts || {}));
+ c.timers = timers;
+ return c;
+}
+// Connects and plays the recorded hello and sync.
+function connected(opts) {
+ const c = client(opts);
+ c.connect();
+ const ws = FakeSocket.last;
+ ws.open();
+ ws.deliver(hello);
+ for (const f of sync) ws.deliver(f);
+ return { c, ws };
+}
+const schema = recordedSchema();
+const T = schema.typeNumbers;
+function reply(id, d) { return { v: 2, t: T.reply, id: id, d: d }; }
+
+test('the client connects with its token and syncs, sending next after each sync frame', () => {
+ const c = client({ token: 'abc 123' });
+ c.connect();
+ const ws = FakeSocket.last;
+ assert.equal(ws.url, 'ws://device/ws?apikey=abc%20123');
+ ws.open();
+ ws.deliver(hello);
+ for (const f of sync) ws.deliver(f);
+ const syncFrames = sync.filter((f) => f.t === T.sync).length;
+ assert.equal(ws.sent.filter((f) => f.t === T.next).length, syncFrames);
+ assert.ok(c.ready);
+ assert.equal(c.fw, hello.d.fw);
+ assert.equal(c.model.shades.size, recordedItems('S').length);
+});
+
+test('synced comes once the sync has ended', () => {
+ const c = client();
+ let synced = 0;
+ c.on('synced', () => synced++);
+ c.connect();
+ const ws = FakeSocket.last;
+ ws.open();
+ ws.deliver(hello);
+ for (const f of sync.filter((f) => f.t === T.sync)) ws.deliver(f);
+ assert.equal(synced, 0);
+ ws.deliver(sync.find((f) => f.t === T.syncEnd));
+ assert.equal(synced, 1);
+});
+
+test('an op resolves with its reply', async () => {
+ const { c, ws } = connected();
+ const p = c.op('getSettings', { section: 'radio' });
+ const sent = ws.sent[ws.sent.length - 1];
+ assert.deepEqual(sent, { v: 2, t: T.getSettings, id: sent.id, d: { se: 'radio' } });
+ ws.deliver(reply(sent.id, { k: 1, bl: 80, en: 1 }));
+ assert.deepEqual(await p, { ok: true, bitLength: 80, enabled: true });
+});
+
+test('a refused op rejects with the error by its name', async () => {
+ const { c, ws } = connected();
+ const p = c.op('saveSettings', { section: 'mqtt' });
+ const id = ws.sent[ws.sent.length - 1].id;
+ ws.deliver(reply(id, { e: schema.errorNumbers.badRequest, x: 'Nothing to save' }));
+ await assert.rejects(p, (err) => err instanceof ProtoError && err.code === 'badRequest' && err.desc === 'Nothing to save');
+});
+
+test('an op is refused before the sync, and when its reply never comes', async () => {
+ const c = client();
+ await assert.rejects(c.op('reboot'), (err) => err.code === 'notConnected');
+ const { c: c2 } = connected();
+ const p = c2.op('reboot');
+ c2.timers.runAll();
+ await assert.rejects(p, (err) => err.code === 'timeout');
+});
+
+test('an op of a name or field the device lacks is refused here', async () => {
+ const { c } = connected();
+ await assert.rejects(c.op('noSuchOp'), (err) => err.code === 'unknownOp');
+ await assert.rejects(c.op('reboot', { noSuchField: 1 }), (err) => err.code === 'badRequest');
+});
+
+test('ops waiting when the socket closes are refused, and the client connects again', async () => {
+ const { c, ws } = connected();
+ const p = c.op('scanWifi');
+ let closed = 0;
+ c.on('closed', () => closed++);
+ ws.drop();
+ await assert.rejects(p, (err) => err.code === 'closed');
+ assert.equal(closed, 1);
+ assert.equal(c.ready, false);
+ assert.deepEqual(c.timers.runAll(), [500]);
+ assert.notEqual(FakeSocket.last, ws);
+});
+
+test('a socket refused before it opened says so, and the retries slow down', () => {
+ const c = client();
+ let refused = 0;
+ c.on('refused', () => refused++);
+ c.connect();
+ const delays = [];
+ for (let i = 0; i < 6; i++) {
+ FakeSocket.last.drop();
+ delays.push(...c.timers.runAll());
+ }
+ assert.equal(refused, 6);
+ assert.deepEqual(delays, [500, 1000, 2000, 4000, 8000, 10000]);
+});
+
+test('close stops the reconnecting', () => {
+ const { c } = connected();
+ c.close();
+ assert.deepEqual(c.timers.runAll(), []);
+});
+
+test('events update the model, and are told by name', () => {
+ const { c, ws } = connected();
+ const shade = c.model.shadeList()[0];
+ const seen = [];
+ c.on('shadeState', (d) => seen.push(d));
+ ws.deliver({ v: 2, t: T.shadeState, d: { s: shade.shadeId, t: 30, d: 1 } });
+ assert.equal(c.model.shades.get(shade.shadeId).target, 30);
+ assert.deepEqual(seen, [{ shadeId: shade.shadeId, target: 30, direction: 1 }]);
+});
+
+test('an event before the schema waits for it, and goes before the sync frames formatted after it', () => {
+ const c = client();
+ const states = [];
+ c.on('shadeState', (d) => states.push(d));
+ c.connect();
+ const ws = FakeSocket.last;
+ ws.open();
+ ws.deliver(hello);
+ // Before the schema: the client can't read it yet.
+ const recorded = recordedItems('S')[0];
+ ws.deliver({ v: 2, t: T.shadeState, d: { s: recorded.s, t: 55 } });
+ assert.deepEqual(states, []);
+ for (const f of sync) ws.deliver(f);
+ assert.deepEqual(states, [{ shadeId: recorded.s, target: 55 }]);
+ // The shade's sync frame was formatted after the event, so it wins.
+ assert.equal(c.model.shades.get(recorded.s).target, recorded.t || 0);
+});
+
+test('an event after the schema goes at once, during the sync', () => {
+ const c = client();
+ c.connect();
+ const ws = FakeSocket.last;
+ ws.open();
+ ws.deliver(hello);
+ const syncFrames = sync.filter((f) => f.t === T.sync);
+ for (const f of syncFrames) ws.deliver(f);
+ const shadeId = recordedItems('S')[0].s;
+ ws.deliver({ v: 2, t: T.shadeState, d: { s: shadeId, t: 66 } });
+ assert.equal(c.ready, false);
+ assert.equal(c.model.shades.get(shadeId).target, 66);
+});
+
+test('the schema is kept, and the device is told it has it', () => {
+ const storage = new FakeStorage();
+ connected({ storage: storage });
+ const c = client({ storage: storage });
+ c.connect();
+ const ws = FakeSocket.last;
+ assert.equal(ws.url, `ws://device/ws?schema=${hello.d.sh}`);
+ ws.open();
+ ws.deliver(hello);
+ for (const f of syncWithoutSchema()) ws.deliver(f);
+ assert.ok(c.ready);
+ assert.equal(c.model.shades.size, recordedItems('S').length);
+});
+
+test('a schema cut off by a lost socket is not kept, so it comes whole again', () => {
+ const c = client();
+ c.connect();
+ const ws = FakeSocket.last;
+ ws.open();
+ ws.deliver(hello);
+ ws.deliver(sync[0]);
+ ws.drop();
+ c.timers.runAll();
+ assert.equal(FakeSocket.last.url, 'ws://device/ws');
+ FakeSocket.last.open();
+ FakeSocket.last.deliver(hello);
+ for (const f of sync) FakeSocket.last.deliver(f);
+ assert.equal(Object.keys(c.schema.fields).length, Object.keys(schema.fields).length);
+ assert.equal(c.schema.hash, hello.d.sh);
+});
+
+test('a socket is replaced, never doubled', () => {
+ const { c, ws } = connected();
+ c.connect();
+ assert.equal(FakeSocket.count, 1);
+ // A new token while a reconnect is waiting: one socket, and no timer left.
+ ws.drop();
+ c.setToken('new');
+ assert.equal(FakeSocket.count, 2);
+ assert.deepEqual(c.timers.runAll(), []);
+ // While it connects: the old one goes without a refused.
+ let refused = 0;
+ c.on('refused', () => refused++);
+ c.setToken('newer');
+ assert.equal(refused, 0);
+ assert.equal(FakeSocket.count, 3);
+ assert.match(FakeSocket.last.url, /apikey=newer/);
+});
+
+test('a listener can stop the retries after a refusal', () => {
+ const c = client();
+ c.on('refused', () => c.close());
+ c.connect();
+ FakeSocket.last.drop();
+ assert.deepEqual(c.timers.runAll(), []);
+ assert.equal(FakeSocket.count, 1);
+});
+
+test('feeds are subscribed again after a reconnect', () => {
+ const { c, ws } = connected();
+ // Its reply never comes: the socket closes first.
+ c.subscribe('frames').catch(() => {});
+ ws.drop();
+ c.timers.runAll();
+ const again = FakeSocket.last;
+ again.open();
+ again.deliver(hello);
+ for (const f of sync) again.deliver(f);
+ const sent = again.sent.filter((f) => f.t === T.subscribe);
+ assert.deepEqual(sent.map((f) => f.d), [{ fe: schema.feedNumbers.frames }]);
+});
+
+test('a feed the device lacks is refused here', async () => {
+ const { c } = connected();
+ await assert.rejects(c.subscribe('nope'), (err) => err.code === 'badRequest');
+});
+
+test('a long op refused as busy without its id goes again', () => {
+ const { c, ws } = connected();
+ c.op('saveRoom', { roomId: 1, name: 'x'.repeat(1500) }).catch(() => {});
+ const sent = ws.sent.length;
+ ws.deliver(reply(undefined, { e: schema.errorNumbers.busy, x: 'Another long message is on its way' }));
+ c.timers.runAll();
+ assert.equal(ws.sent.length, sent + 1);
+ assert.equal(ws.sent[ws.sent.length - 1].d.n.length, 1500);
+});
+
+test('a refusal without an id for nothing long is reported', () => {
+ const { c, ws } = connected();
+ let error = null;
+ c.on('error', (err) => { error = err; });
+ ws.deliver(reply(undefined, { e: schema.errorNumbers.badRequest, x: 'Malformed message' }));
+ assert.equal(error.code, 'badRequest');
+});
+
+test('a sync asked for and refused is called off', async () => {
+ const { c, ws } = connected();
+ const p = c.resync();
+ const id = ws.sent[ws.sent.length - 1].id;
+ ws.deliver(reply(id, { e: schema.errorNumbers.busy, x: 'busy' }));
+ await assert.rejects(p);
+ assert.equal(c.model.seen, null);
+});
+
+test('a kept schema of another firmware is dropped', () => {
+ const storage = new FakeStorage();
+ connected({ storage: storage });
+ const c = client({ storage: storage });
+ c.connect();
+ const ws = FakeSocket.last;
+ ws.open();
+ ws.deliver({ v: 2, t: 1, d: { fw: 'v4.0.0', sh: 'ffffffff' } });
+ // Its hash only counts once the new one has come whole.
+ assert.equal(c.schema.hash, null);
+ assert.ok(c.schema.empty);
+});
+
+test('a frame of another protocol version is reported', () => {
+ const { c, ws } = connected();
+ let mismatch = null;
+ c.on('versionMismatch', (d) => { mismatch = d; });
+ ws.deliver({ v: 3, t: 1, d: {} });
+ assert.deepEqual(mismatch, { device: 3, client: 2 });
+});
+
+test('a new token connects again with it', () => {
+ const { c, ws } = connected();
+ c.setToken('new');
+ assert.ok(ws.closed);
+ c.timers.runAll();
+ assert.match(FakeSocket.last.url, /apikey=new/);
+});
+
+test('waitFor resolves with the first event that matches, after the model has it', async () => {
+ const { c, ws } = connected();
+ const shadeId = recordedItems('S')[0].s;
+ const p = c.waitFor('shade', (d) => d.shadeId === shadeId, 3000);
+ ws.deliver({ v: 2, t: T.shade, d: { s: 250, n: 'Other' } });
+ ws.deliver({ v: 2, t: T.shade, d: { s: shadeId, n: 'Renamed' } });
+ const d = await p;
+ assert.equal(d.name, 'Renamed');
+ assert.equal(c.model.shades.get(shadeId).name, 'Renamed');
+});
+
+test('waitFor gives null when no event comes, and stops listening', async () => {
+ const { c } = connected();
+ const p = c.waitFor('room', null, 3000);
+ c.timers.runAll();
+ assert.equal(await p, null);
+ assert.equal((c.listeners.room || []).length, 0);
+});
+
+test('off stops a listener, and one that removes itself mid-event leaves the others called', () => {
+ const { c, ws } = connected();
+ const seen = [];
+ const once = (d) => { seen.push('once'); c.off('memory', once); };
+ const always = () => seen.push('always');
+ const dropped = () => seen.push('dropped');
+ c.on('memory', once);
+ c.on('memory', always);
+ c.on('memory', dropped);
+ c.off('memory', dropped);
+ ws.deliver({ v: 2, t: T.memory, d: { fr: 1 } });
+ ws.deliver({ v: 2, t: T.memory, d: { fr: 2 } });
+ assert.deepEqual(seen, ['once', 'always', 'always']);
+});
+
+test('subscribe sends the feed number', () => {
+ const { c, ws } = connected();
+ c.subscribe('frames');
+ const sent = ws.sent[ws.sent.length - 1];
+ assert.equal(sent.t, T.subscribe);
+ assert.deepEqual(sent.d, { fe: schema.feedNumbers.frames });
+});
diff --git a/test/js/helpers.js b/test/js/helpers.js
new file mode 100644
index 0000000..e452575
--- /dev/null
+++ b/test/js/helpers.js
@@ -0,0 +1,84 @@
+// What the web UI client tests share: the frames the e2e suite recorded from a
+// device (test/fixtures/proto2), and stand-ins for the socket and the timers.
+const path = require('node:path');
+
+const FIXTURES = path.join(__dirname, '..', 'fixtures', 'proto2');
+const hello = require(path.join(FIXTURES, 'hello.json'));
+const sync = require(path.join(FIXTURES, 'sync.json'));
+const schemaJson = require(path.join(FIXTURES, 'schema.json'));
+const { ProtoSchema } = require('../../data-src/js/schema.js');
+
+// A schema filled from the recorded sync, as a client builds it.
+function recordedSchema() {
+ const s = new ProtoSchema();
+ for (const f of sync) if (f.t === 4) s.add(f.d);
+ s.hash = hello.d.sh;
+ return s;
+}
+// The recorded sync's device sections, expanded, frame by frame.
+function deviceSections(schema) {
+ return sync.filter((f) => f.t === 4).map((f) => schema.expand(ProtoSchema.withoutRows(f.d)));
+}
+// The recorded sync as the device sends it to a client that has the schema.
+function syncWithoutSchema() {
+ return sync.map((f) => Object.assign({}, f, { d: ProtoSchema.withoutRows(f.d || {}) }));
+}
+// The recorded sync's items under their short keys.
+function recordedItems(key) {
+ return sync.filter((f) => f.t === 4 && f.d[key]).flatMap((f) => f.d[key]);
+}
+
+// A WebSocket the test drives: it records what the client sends, and the test
+// opens, delivers and closes.
+class FakeSocket {
+ constructor(url) {
+ this.url = url;
+ this.sent = [];
+ this.closed = false;
+ FakeSocket.last = this;
+ FakeSocket.count++;
+ }
+ send(text) { this.sent.push(JSON.parse(text)); }
+ close() {
+ if (this.closed) return;
+ this.closed = true;
+ if (this.onclose) this.onclose({});
+ }
+ open() { if (this.onopen) this.onopen({}); }
+ deliver(frame) { this.onmessage({ data: typeof frame === 'string' ? frame : JSON.stringify(frame) }); }
+ // The device closing it, or refusing it before it opened.
+ drop() { this.close(); }
+}
+// How many the client has opened.
+FakeSocket.count = 0;
+FakeSocket.reset = () => { FakeSocket.count = 0; FakeSocket.last = null; };
+
+// Timers the test runs by hand.
+class FakeTimers {
+ constructor() {
+ this.timers = new Map();
+ this.next = 1;
+ this.setTimeout = (fn, ms) => {
+ const id = this.next++;
+ this.timers.set(id, { fn: fn, ms: ms });
+ return id;
+ };
+ this.clearTimeout = (id) => { this.timers.delete(id); };
+ }
+ // Runs every timer waiting, the shortest first, and returns their delays.
+ runAll() {
+ const due = [...this.timers.entries()].sort((a, b) => a[1].ms - b[1].ms);
+ this.timers.clear();
+ for (const [, t] of due) t.fn();
+ return due.map(([, t]) => t.ms);
+ }
+}
+// localStorage as far as the client uses it.
+class FakeStorage {
+ constructor() { this.items = {}; }
+ getItem(key) { return Object.prototype.hasOwnProperty.call(this.items, key) ? this.items[key] : null; }
+ setItem(key, value) { this.items[key] = String(value); }
+}
+
+module.exports = { hello, sync, schemaJson, recordedSchema, deviceSections, syncWithoutSchema, recordedItems, FakeSocket,
+ FakeTimers, FakeStorage };
diff --git a/test/js/model.test.js b/test/js/model.test.js
new file mode 100644
index 0000000..3d8cd4e
--- /dev/null
+++ b/test/js/model.test.js
@@ -0,0 +1,125 @@
+// The web UI's ProtoModel (data-src/js/model.js): the recorded sync, then
+// events.
+const test = require('node:test');
+const assert = require('node:assert/strict');
+const { ProtoModel } = require('../../data-src/js/model.js');
+const { recordedSchema, deviceSections, recordedItems } = require('./helpers.js');
+
+function synced() {
+ const schema = recordedSchema();
+ const model = new ProtoModel(schema);
+ model.beginSync();
+ for (const d of deviceSections(schema)) model.applySync(d);
+ model.endSync();
+ return model;
+}
+
+test('the sync fills every room, shade and group', () => {
+ const m = synced();
+ assert.equal(m.rooms.size, recordedItems('R').length);
+ assert.equal(m.shades.size, recordedItems('S').length);
+ assert.equal(m.groups.size, recordedItems('G').length);
+ assert.equal(m.header.model, 'ESPSomfyRTS');
+ assert.equal(m.header.maxShades, 32);
+ assert.ok(m.status.freeHeap > 0);
+});
+
+test('a field the sync left out is its default', () => {
+ const m = synced();
+ const raw = recordedItems('S').find((s) => typeof s.m === 'undefined');
+ const shade = m.shades.get(raw.s);
+ // Left out because they were at their default.
+ assert.equal(shade.myPos, -1);
+ assert.equal(shade.stepSize, raw.z === undefined ? 100 : raw.z);
+ assert.equal(typeof shade.paired, 'boolean');
+ assert.ok(Array.isArray(shade.linkedRemotes));
+ for (const r of shade.linkedRemotes) assert.equal(typeof r.lastRollingCode, 'number');
+ for (const g of m.groupList()) assert.ok(Array.isArray(g.linkedShades));
+});
+
+test('the lists come in their sort order', () => {
+ const m = synced();
+ const orders = m.shadeList().map((s) => s.sortOrder);
+ assert.deepEqual(orders, [...orders].sort((a, b) => a - b));
+});
+
+test('a state event changes only the state, and a left-out field is its default', () => {
+ const m = synced();
+ const shade = m.shadeList()[0];
+ const name = shade.name;
+ // A shade at rest at the top: position 0 is left out.
+ assert.ok(m.applyEvent('shadeState', { shadeId: shade.shadeId, target: 40, direction: 1 }));
+ assert.equal(m.shades.get(shade.shadeId).position, 0);
+ assert.equal(m.shades.get(shade.shadeId).target, 40);
+ assert.equal(m.shades.get(shade.shadeId).name, name);
+ // Of a shade the client doesn't have yet: nothing to change.
+ assert.equal(m.applyEvent('shadeState', { shadeId: 250, position: 5 }), false);
+});
+
+test('a whole item replaces what was there', () => {
+ const m = synced();
+ const shade = m.shadeList()[0];
+ m.applyEvent('shade', { shadeId: shade.shadeId, name: 'Renamed' });
+ assert.equal(m.shades.get(shade.shadeId).name, 'Renamed');
+ assert.equal(m.shades.get(shade.shadeId).upTime, 0);
+ m.applyEvent('room', { roomId: 9, name: 'New' });
+ assert.equal(m.rooms.get(9).sortOrder, 0);
+});
+
+test('removals, orders and repeaters', () => {
+ const m = synced();
+ const changes = [];
+ m.onChange((kind, id) => changes.push([kind, id]));
+ const [first, second] = m.shadeList();
+ assert.ok(m.applyEvent('shadeRemoved', { shadeId: first.shadeId }));
+ assert.equal(m.shades.has(first.shadeId), false);
+ // An id it doesn't have is ignored.
+ assert.equal(m.applyEvent('roomRemoved', { roomId: 250 }), false);
+ m.applyEvent('shadeOrder', { ids: [second.shadeId] });
+ assert.equal(m.shades.get(second.shadeId).sortOrder, 0);
+ m.applyEvent('repeaters', { repeaters: [7, 8] });
+ assert.deepEqual(m.repeaters, [7, 8]);
+ // An order says which list it is.
+ assert.deepEqual(changes.map((c) => c[0]), ['shadeRemoved', 'shadeOrder', 'repeaters']);
+});
+
+test('a sync without repeaters clears them, as the device leaves the list out when it has none', () => {
+ const m = synced();
+ m.applyEvent('repeaters', { repeaters: [7] });
+ m.beginSync();
+ for (const d of deviceSections(m.schema)) m.applySync(Object.assign({}, d, { repeaters: undefined }));
+ m.endSync();
+ assert.deepEqual(m.repeaters, []);
+});
+
+test('a sync that is called off removes nothing', () => {
+ const m = synced();
+ const shades = m.shades.size;
+ m.beginSync();
+ m.cancelSync();
+ m.endSync();
+ assert.equal(m.shades.size, shades);
+});
+
+test('a sync drops what it no longer lists, and keeps what an event added during it', () => {
+ const m = synced();
+ const schema = m.schema;
+ m.applyEvent('room', { roomId: 99, name: 'Gone' });
+ m.beginSync();
+ m.applyEvent('room', { roomId: 98, name: 'Added during the sync' });
+ for (const d of deviceSections(schema)) m.applySync(d);
+ m.endSync();
+ assert.equal(m.rooms.has(99), false);
+ assert.equal(m.rooms.has(98), true);
+});
+
+test('status events', () => {
+ const m = synced();
+ m.applyEvent('memory', { freeHeap: 1000, uptime: 5 });
+ assert.equal(m.status.freeHeap, 1000);
+ assert.equal(m.status.loopRate, 0);
+ m.applyEvent('wifi', { strength: -60, channel: 6 });
+ assert.equal(m.status.ssid, '');
+ assert.equal(m.status.strength, -60);
+ assert.equal(m.applyEvent('frame', { remoteAddress: 1 }), false);
+});
diff --git a/test/js/schema.test.js b/test/js/schema.test.js
new file mode 100644
index 0000000..0ec1136
--- /dev/null
+++ b/test/js/schema.test.js
@@ -0,0 +1,56 @@
+// The web UI's ProtoSchema (data-src/js/schema.js) against the schema a
+// device sent (test/fixtures/proto2).
+const test = require('node:test');
+const assert = require('node:assert/strict');
+const { ProtoSchema } = require('../../data-src/js/schema.js');
+const { recordedSchema, schemaJson } = require('./helpers.js');
+
+test('the schema is collected from every sync frame it spans', () => {
+ const s = recordedSchema();
+ assert.equal(Object.keys(s.types).length, Object.keys(schemaJson.types).length);
+ assert.equal(Object.keys(s.fields).length, Object.keys(schemaJson.fields).length);
+ assert.equal(s.typeNumbers.shadeCommand, 16);
+ assert.equal(s.typeNumbers.saveSettings, 50);
+ assert.equal(s.keys.shadeId, 's');
+ assert.equal(s.errorNumbers.busy, 5);
+ assert.equal(s.feedNumbers.frequencyScan, 2);
+});
+
+test('short keys become names, and 1/0 booleans, all the way down', () => {
+ const s = recordedSchema();
+ const shade = s.expand({ s: 3, n: 'Office', i: 1, fp: 0, lk: [{ a: 5, c: 9 }] });
+ assert.deepEqual(shade, { shadeId: 3, name: 'Office', paired: true, flipPosition: false,
+ linkedRemotes: [{ remoteAddress: 5, lastRollingCode: 9 }] });
+ // A whole number that happens to be 1 stays a number.
+ assert.deepEqual(s.expand({ p: 1 }), { position: 1 });
+});
+
+test('names become short keys for an op', () => {
+ const s = recordedSchema();
+ assert.deepEqual(s.pack({ shadeId: 3, command: 'Up', paired: true, sunny: false }), { s: 3, cm: 'Up', i: 1, sn: 0 });
+ assert.deepEqual(s.pack({ ids: [3, 1, 2] }), { is: [3, 1, 2] });
+ // Left out, not sent as undefined.
+ assert.deepEqual(s.pack({ shadeId: 3, target: undefined }), { s: 3 });
+ assert.throws(() => s.pack({ nonsense: 1 }), /no field nonsense/);
+});
+
+test('a field left out is its default', () => {
+ const s = recordedSchema();
+ assert.equal(s.defaultOf('myPos'), -1);
+ assert.equal(s.defaultOf('stepSize'), 100);
+ assert.equal(s.defaultOf('bitLength'), 56);
+ assert.equal(s.defaultOf('paired'), false);
+ assert.equal(s.defaultOf('name'), '');
+ assert.deepEqual(s.defaultOf('linkedShades'), []);
+ assert.deepEqual(s.fill({ shadeId: 2 }, ['shadeId', 'position', 'myPos']), { shadeId: 2, position: 0, myPos: -1 });
+});
+
+test('a cached schema comes back whole, with its hash', () => {
+ const s = recordedSchema();
+ const back = ProtoSchema.load(JSON.parse(JSON.stringify(s.save())));
+ assert.equal(back.hash, s.hash);
+ assert.deepEqual(back.fields, s.fields);
+ assert.deepEqual(back.types, s.types);
+ assert.equal(ProtoSchema.load(null), null);
+ assert.equal(ProtoSchema.load({ hash: 'x', rows: {} }), null);
+});
diff --git a/test/js/views.test.js b/test/js/views.test.js
new file mode 100644
index 0000000..30e1775
--- /dev/null
+++ b/test/js/views.test.js
@@ -0,0 +1,82 @@
+// What the web UI's panels bind (data-src/js/views.js), from protocol 2's
+// shapes.
+const test = require('node:test');
+const assert = require('node:assert/strict');
+const { ProtoViews } = require('../../data-src/js/views.js');
+const { ProtoModel } = require('../../data-src/js/model.js');
+const { recordedSchema, deviceSections } = require('./helpers.js');
+
+const schema = recordedSchema();
+function synced() {
+ const model = new ProtoModel(schema);
+ model.beginSync();
+ for (const d of deviceSections(schema)) model.applySync(d);
+ model.endSync();
+ return model;
+}
+
+test('a settings section has every field, defaults where the device left them out', () => {
+ // ssdpBroadcast off and no NTP server are at their defaults, so not sent.
+ assert.deepEqual(ProtoViews.settings(schema, 'general', { hostname: 'Somfy' }),
+ { hostname: 'Somfy', ssdpBroadcast: false, ntpServer: '', posixZone: '' });
+ assert.deepEqual(ProtoViews.settings(schema, 'security', {}), { securityType: 0, username: '', hasPassword: false, hasPin: false });
+});
+
+test('the settings sections are what the device sends', () => {
+ for (const section of Object.keys(ProtoViews.SETTINGS))
+ for (const name of ProtoViews.SETTINGS[section]) assert.ok(schema.keys[name], `${section}.${name}`);
+});
+
+test('a group shows its shades whole', () => {
+ const m = synced();
+ const group = m.groupList()[0];
+ const view = ProtoViews.group(m, group);
+ assert.equal(view.linkedShades.length, group.linkedShades.length);
+ assert.equal(view.linkedShades[0].name, m.shades.get(group.linkedShades[0]).name);
+ // The model's item is left as it is.
+ assert.equal(typeof group.linkedShades[0], 'number');
+ // A shade the model hasn't got yet still shows.
+ assert.equal(ProtoViews.group(m, Object.assign({}, group, { linkedShades: [250] })).linkedShades[0].shadeId, 250);
+ assert.equal(ProtoViews.group(m, undefined), undefined);
+});
+
+test('a frame and a scan under the names the UI reads', () => {
+ const f = ProtoViews.frame(schema, { remoteAddress: 5, lastRollingCode: 9, command: 'Up', rssi: -60, valid: true, pulses: [1, 2] });
+ assert.equal(f.address, 5);
+ assert.equal(f.rcode, 9);
+ assert.equal(f.encKey, 0);
+ assert.deepEqual(f.pulses, [1, 2]);
+ assert.equal(f.stepSize, undefined);
+ const s = ProtoViews.scan(schema, { scanning: true, testFreq: 433.1, testRssi: -80 });
+ assert.deepEqual(s, { scanning: true, testFreq: 433.1, testRSSI: -80, frequency: 0, RSSI: 0 });
+});
+
+test('the network section as the panel binds it', () => {
+ const v = ProtoViews.network(schema, { connMode: 1, ssid: 'home', hasPassphrase: true, dhcp: true, PWRPin: -1 });
+ assert.equal(v.connType, 1);
+ assert.equal(v.hasEthernet, false);
+ assert.deepEqual(v.wifi, { ssid: 'home', hasPassphrase: true, roaming: false, hidden: false });
+ assert.equal(v.ethernet.PWRPin, -1);
+ assert.deepEqual(v.ip, { dhcp: true, ip: '', gateway: '', subnet: '', dns1: '', dns2: '' });
+});
+
+test('the radio section as the panel binds it, and back', () => {
+ const config = ProtoViews.radio(schema, { bitLength: 80, frequency: 433.42, enabled: true, radioInit: true });
+ assert.equal(config.type, 80);
+ assert.equal(config.bitLength, undefined);
+ assert.equal(config.TXPin, 0);
+ const save = ProtoViews.radioSave(config);
+ assert.equal(save.section, 'radio');
+ assert.equal(save.bitLength, 80);
+ assert.equal(save.frequency, 433.42);
+ // Only shown, never saved.
+ assert.equal('radioInit' in save, false);
+ assert.equal('type' in save, false);
+});
+
+test('an op refusal for the error box, with a shade validation code', () => {
+ assert.deepEqual(ProtoViews.opError('saveShade', { code: 'badRequest', desc: 'Pin in use', data: { validation: -10 } }),
+ { htmlError: 'badRequest', service: 'saveShade', desc: 'Pin in use', code: -10 });
+ assert.deepEqual(ProtoViews.opError('reboot', { code: 'closed', desc: 'The connection closed' }),
+ { htmlError: 'closed', service: 'reboot', desc: 'The connection closed' });
+});
BEWARE ... WARNING ... DANGER
';
+ html += ''; + html += '
If this shade is already paired with a motor then changing the rolling code WILL cause it to stop working. Rolling codes are tied to the remote address and the Somfy motor expects these to be sequential.
'; + html += 'If you hesitated just a little bit do not press the red button. Green represents safety so press it, wipe the sweat from your brow, and go through the normal pairing process.'; + html += '
';
+ html += ``;
+ html += '';
+ html += '
';
+ html += ``;
+ div.innerHTML = html;
+ document.getElementById('somfyShade').appendChild(div);
}
setPaired(shadeId, paired) {
let obj = { shadeId: shadeId, paired: paired || false };
let div = document.getElementById('divPairing');
- let overlay = typeof div === 'undefined' ? undefined : ui.waitMessage(div);
- editJSON('/setPaired', obj, (id) => `/shade?shadeId=${id}`, (err, shade) => {
- if (overlay) overlay.remove();
+ sendEdit('setPaired', obj, editTarget('shade', () => shadeId), (err, shade) => {
if (err) {
console.log(err);
- ui.errorMessage(err.message);
+ ui.errorMessage(err.desc);
}
- else if (div) {
+ else if (div && shade) {
console.log(shade);
this.showEditShade(true);
document.getElementById('btnSaveShade').style.display = 'inline-block';
@@ -3887,55 +3514,30 @@ class Somfy {
return div;
}
+ // A command, or a position to move to. shadeId may instead be an object
+ // with shadeId, command, repeat and stepSize, as the virtual remote sends.
+ // cb(err, reply): the reply carries no state; the shade's state events
+ // follow as it moves.
sendCommand(shadeId, command, repeat, cb) {
- let obj = {};
- if (typeof shadeId.shadeId !== 'undefined') {
- obj = shadeId;
- cb = command;
- shadeId = obj.shadeId;
- repeat = obj.repeat;
- command = obj.command;
- }
- else {
- obj = { shadeId: shadeId };
- if (isNaN(parseInt(command, 10))) obj.command = command;
- else obj.target = parseInt(command, 10);
- if (typeof repeat === 'number') obj.repeat = parseInt(repeat);
- }
- putJSON('/shadeCommand', obj, (err, shade) => {
- if (typeof cb === 'function') cb(err, shade);
- });
+ let [cmd, done] = this.commandArgs(shadeId, command, repeat, cb);
+ let fields = { shadeId: cmd.shadeId, repeat: repeatOf(cmd.repeat), stepSize: cmd.stepSize };
+ if (isNaN(parseInt(cmd.command, 10))) fields.command = cmd.command;
+ else fields.target = parseInt(cmd.command, 10);
+ sendOp('shadeCommand', fields, done);
}
+ // The last frame again when it was this command, otherwise the command.
sendCommandRepeat(shadeId, command, repeat, cb) {
- //console.log(`Sending Shade command ${shadeId}-${command}`);
- let obj = {};
- if (typeof shadeId.shadeId !== 'undefined') {
- obj = shadeId;
- cb = command;
- shadeId = obj.shadeId;
- repeat = obj.repeat;
- command = obj.command;
- }
- else {
- obj = { shadeId: shadeId, command: command };
- if (typeof repeat === 'number') obj.repeat = parseInt(repeat);
- }
- putJSON('/repeatCommand', obj, (err, shade) => {
- if (typeof cb === 'function') cb(err, shade);
- });
-
- /*
- putJSON(`/repeatCommand?shadeId=${shadeId}&command=${command}`, null, (err, shade) => {
- if(typeof cb === 'function') cb(err, shade);
- });
- */
+ let [cmd, done] = this.commandArgs(shadeId, command, repeat, cb);
+ sendOp('repeatCommand', { shadeId: cmd.shadeId, command: cmd.command, repeat: repeatOf(cmd.repeat), stepSize: cmd.stepSize }, done);
+ }
+ // (shadeId, command, repeat, cb), or (object, cb) as the virtual remote
+ // calls it: the command and the callback.
+ commandArgs(shadeId, command, repeat, cb) {
+ if (typeof shadeId === 'object') return [shadeId, command];
+ return [{ shadeId: shadeId, command: command, repeat: repeat }, cb];
}
sendGroupRepeat(groupId, command, repeat, cb) {
- let obj = { groupId: groupId, command: command };
- if (typeof repeat === 'number') obj.repeat = parseInt(repeat);
- putJSON(`/repeatCommand?groupId=${groupId}&command=${command}`, null, (err, group) => {
- if (typeof cb === 'function') cb(err, group);
- });
+ sendOp('repeatCommand', { groupId: groupId, command: command, repeat: repeatOf(repeat) }, cb);
}
sendVRCommand(el) {
let pnl = document.getElementById('divVirtualRemote');
@@ -3981,30 +3583,21 @@ class Somfy {
else
somfy.sendCommand(o, (err, shade) => { fnRepeatCommand(err, shade); });
}
+ // obj: a shade's or a group's id, and sunny, windy or both.
sendSetSensor(obj, cb) {
- putJSON('/setSensor', obj, (err, device) => {
- if (typeof cb === 'function') cb(err, device);
- });
+ let fields = { sunny: obj.sunny, windy: obj.windy, repeat: repeatOf(obj.repeat) };
+ if (typeof obj.groupId === 'number' && !isNaN(obj.groupId)) fields.groupId = obj.groupId;
+ else fields.shadeId = obj.shadeId;
+ sendOp('setSensor', fields, cb);
}
sendGroupCommand(groupId, command, repeat, cb) {
console.log(`Sending Group command ${groupId}-${command}`);
- let obj = { groupId: groupId };
- if (isNaN(parseInt(command, 10))) obj.command = command;
- if (typeof repeat === 'number') obj.repeat = parseInt(repeat);
- putJSON('/groupCommand', obj, (err, group) => {
- if (typeof cb === 'function') cb(err, group);
- });
+ sendOp('groupCommand', { groupId: groupId, command: command, repeat: repeatOf(repeat) }, cb);
}
sendTiltCommand(shadeId, command, cb) {
console.log(`Sending Tilt command ${shadeId}-${command}`);
- if (isNaN(parseInt(command, 10)))
- putJSON('/tiltCommand', { shadeId: shadeId, command: command }, (err, shade) => {
- if (typeof cb === 'function') cb(err, shade);
- });
- else
- putJSON('/tiltCommand', { shadeId: shadeId, target: parseInt(command, 10) }, (err, shade) => {
- if (typeof cb === 'function') cb(err, shade);
- });
+ if (isNaN(parseInt(command, 10))) sendOp('tiltCommand', { shadeId: shadeId, command: command }, cb);
+ else sendOp('tiltCommand', { shadeId: shadeId, target: parseInt(command, 10) }, cb);
}
linkRemote(shadeId) {
let div = document.createElement('div');
@@ -4083,7 +3676,7 @@ class Somfy {
btnOpenMemory.addEventListener('click', (evt) => {
let obj = ui.fromElement(div);
console.log(obj);
- putJSONSync('/shadeCommand', { shadeId: obj.shadeId, command: 'prog', repeat: 40 }, (err, shade) => {
+ sendOp('shadeCommand', { shadeId: obj.shadeId, command: 'prog', repeat: 40 }, (err) => {
if (err) ui.serviceError(err);
else {
let prompt = ui.promptMessage('Confirm Motor Response', () => {
@@ -4119,11 +3712,9 @@ class Somfy {
mouseDown = false;
let obj = ui.fromElement(div);
let prompt = ui.promptMessage('Confirm Motor Response', () => {
- editJSON('/linkToGroup', { groupId: groupId, shadeId: obj.shadeId }, (id) => `/group?groupId=${id}`, (err, group) => {
- console.log(group);
+ sendEdit('linkToGroup', { groupId: groupId, shadeId: obj.shadeId }, editTarget('group', () => groupId), (err, group) => {
if (err) ui.serviceError(err);
- else somfy.setLinkedShadesList(group);
- this.updateGroupList();
+ else if (group) somfy.setLinkedShadesList(group);
});
prompt.remove();
div.remove();
@@ -4131,13 +3722,15 @@ class Somfy {
prompt.querySelector('.sub-message').innerHTML = `Did the shade jog? If the shade jogged press the YES button and your shade will be linked to the group. If it did not press the NO button and try again.
Once the shade has jogged the shade will be added to the group and this process will be finished.
`; }); - getJSONSync(`/groupOptions?groupId=${groupId}`, (err, options) => { + sendOp('groupOptions', { groupId: groupId }, (err, reply) => { if (err) { div.remove(); ui.serviceError(err); } else { - console.log(options); + // The shades the group doesn't have yet, by name from the model. + let group = proto.model.groups.get(groupId) || { name: '' }; + let options = { name: group.name, availShades: (reply.ids || []).map((id) => proto.model.shades.get(id)).filter((x) => x) }; if (options.availShades.length > 0) { // Add in all the available shades. let selAvail = div.querySelector('#selAvailShades'); @@ -4196,7 +3789,7 @@ class Somfy { btnOpenMemory.addEventListener('click', (evt) => { let obj = ui.fromElement(div); console.log(obj); - putJSONSync('/shadeCommand', { shadeId: shadeId, command: 'prog', repeat: 40 }, (err, shade) => { + sendOp('shadeCommand', { shadeId: shadeId, command: 'prog', repeat: 40 }, (err) => { if (err) ui.serviceError(err); else { let prompt = ui.promptMessage('Confirm Motor Response', () => { @@ -4210,15 +3803,13 @@ class Somfy { let btnUnpairFromGroup = div.querySelector('#btnUnpairFromGroup'); btnUnpairFromGroup.addEventListener('click', (evt) => { let obj = ui.fromElement(div); - putJSONSync('/groupCommand', { groupId: groupId, command: 'prog', repeat: 1 }, (err, shade) => { + sendOp('groupCommand', { groupId: groupId, command: 'prog', repeat: 1 }, (err) => { if (err) ui.serviceError(err); else { let prompt = ui.promptMessage('Confirm Motor Response', () => { - editJSON('/unlinkFromGroup', { groupId: groupId, shadeId: shadeId }, (id) => `/group?groupId=${id}`, (err, group) => { - console.log(group); + sendEdit('unlinkFromGroup', { groupId: groupId, shadeId: shadeId }, editTarget('group', () => groupId), (err, group) => { if (err) ui.serviceError(err); - else somfy.setLinkedShadesList(group); - this.updateGroupList(); + else if (group) somfy.setLinkedShadesList(group); }); prompt.remove(); div.remove(); @@ -4227,35 +3818,31 @@ class Somfy { } }); }); - getJSONSync(`/group?groupId=${groupId}`, (err, group) => { - if (err) { - div.remove(); - ui.serviceError(err); + let group = ProtoViews.group(proto.model, proto.model.groups.get(groupId)); + if (!group) { + div.remove(); + gone('group'); + } + else { + let shade = group.linkedShades.find((x) => { return shadeId === x.shadeId; }); + if (typeof shade !== 'undefined') { + // Add in all the available shades. + let grpName = div.querySelector('#divGroupName'); + if (grpName) grpName.innerHTML = group.name; + let divWizShadeName = div.querySelector('#divWizShadeName'); + if (divWizShadeName) divWizShadeName.innerHTML = shade.name; } else { - console.log(group); - console.log(shadeId); - let shade = group.linkedShades.find((x) => { return shadeId === x.shadeId; }); - if (typeof shade !== 'undefined') { - // Add in all the available shades. - let grpName = div.querySelector('#divGroupName'); - if (grpName) grpName.innerHTML = group.name; - let divWizShadeName = div.querySelector('#divWizShadeName'); - if (divWizShadeName) divWizShadeName.innerHTML = shade.name; - } - else { - div.remove(); - ui.errorMessage('The specified shade could not be found in this group.'); - } + div.remove(); + ui.errorMessage('The specified shade could not be found in this group.'); } - }); + } return div; } unlinkRepeater(address) { let prompt = ui.promptMessage('Are you sure you want to stop repeating frames from this address?', () => { - editJSON('/unlinkRepeater', { address: address }, () => '/repeaters', (err, repeaters) => { + sendEdit('unlinkRepeater', { remoteAddress: address }, null, (err) => { if (err) ui.serviceError(err); - else this.setRepeaterList(repeaters); prompt.remove(); }); @@ -4268,11 +3855,10 @@ class Somfy { shadeId: shadeId, remoteAddress: remoteAddress }; - editJSON('/unlinkRemote', obj, (id) => `/shade?shadeId=${id}`, (err, shade) => { - console.log(shade); + sendEdit('unlinkRemote', obj, editTarget('shade', () => shadeId), (err, shade) => { prompt.remove(); if (err) ui.serviceError(err); - else this.setLinkedRemotesList(shade); + else if (shade) this.setLinkedRemotesList(shade); }); }); @@ -4378,12 +3964,12 @@ var somfy = new Somfy(); class MQTT { initialized = false; init() { this.initialized = true; } - async loadMQTT() { - getJSONSync('/mqttsettings', (err, settings) => { - if (err) + loadMQTT() { + sendOp('getSettings', { section: 'mqtt' }, (err, reply) => { + if (err) console.log(err); else { - console.log(settings); + let settings = ProtoViews.settings(proto.schema, 'mqtt', reply); ui.toElement(document.getElementById('divMQTT'), { mqtt: settings }); // The device never returns the stored password; leave the field blank to keep it. this.savedUsername = settings.username; @@ -4425,10 +4011,12 @@ class MQTT { return; } } - putJSONSync('/connectmqtt', obj.mqtt, (err, response) => { + let fields = { section: 'mqtt' }; + for (let name of ProtoViews.SETTINGS.mqtt) if (name !== 'hasPassword') fields[name] = obj.mqtt[name]; + fields.password = obj.mqtt.password; + sendOp('saveSettings', fields, (err) => { if (err) ui.serviceError(err); - console.log(response); - }); + }, true); } } var mqtt = new MQTT(); @@ -4469,7 +4057,11 @@ class Firmware { xhr.onload = (evt) => { if (typeof overlay !== 'undefined') overlay.remove(); let status = xhr.status; - if (status !== 200) { + if (status === 401) { + security.tokenRefused(); + reject({ htmlError: status, service: 'GET /backup', desc: 'Log in again, then back up' }); + } + else if (status !== 200) { let err = xhr.response || {}; err.htmlError = status; err.service = `GET /backup`; @@ -4498,6 +4090,8 @@ class Firmware { reject({ htmlError: status, service: 'GET /backup' }); }; xhr.open('GET', baseUrl.length > 0 ? `${baseUrl}/backup?attach=true` : '/backup?attach=true', true); + // Under Secured the file transfers need the token too. + xhr.setRequestHeader('apikey', security.apiKey); xhr.send(); }); } @@ -4684,8 +4278,8 @@ class Firmware { prog.style.display = ''; btnSelectFile.style.visibility = 'hidden'; let xhr = new XMLHttpRequest(); - //xhr.open('POST', service, true); xhr.open('POST', baseUrl.length > 0 ? `${baseUrl}${service}` : service, true); + xhr.setRequestHeader('apikey', security.apiKey); xhr.upload.onprogress = function (evt) { let pct = evt.total ? Math.round((evt.loaded / evt.total) * 100) : 0; prog.style.setProperty('--progress', `${pct}%`); @@ -4700,6 +4294,15 @@ class Firmware { xhr.onload = function () { console.log('File upload load called'); btnCancel.innerText = 'Close'; + if (xhr.status === 401) { + el.remove(); + security.tokenRefused(); + return; + } + if (service !== '/restore' && (xhr.status < 200 || xhr.status >= 300)) { + ui.errorMessage(el, `The upload failed (${xhr.status}).`); + return; + } switch (service) { case '/restore': if (xhr.status < 200 || xhr.status >= 300) { diff --git a/data-src/js/client.js b/data-src/js/client.js new file mode 100644 index 0000000..533e1ae --- /dev/null +++ b/data-src/js/client.js @@ -0,0 +1,352 @@ +// A socket protocol 2 client (docs/PROTOCOL.md): ws://host/ws, hello, the sync +// with next after each frame, ops answered by their reply, events and feeds. +// It keeps the shade model (ProtoModel) up to date and connects again when the +// socket closes. The WebSocket, the timers and the schema's storage can be +// handed in, so the tests (test/js) run it without a device. The minify step +// joins this file into index.js after schema.js and model.js. +class ProtoError extends Error { + // code is an error name from the schema (badRequest, busy ...), or + // notConnected, closed or timeout from the client itself. + constructor(code, desc, data) { + super(desc || code); + this.code = code; + this.desc = desc || code; + this.data = data || {}; + } +} +class ProtoClient { + // opts: host, token, WebSocket, storage (getItem/setItem for the schema; + // localStorage when there is one), setTimeout/clearTimeout, opTimeoutMs. + constructor(opts) { + const deps = ProtoClient.deps(); + this.Schema = deps.ProtoSchema; + this.host = opts.host; + this.token = opts.token || ''; + this.WebSocket = opts.WebSocket || (typeof WebSocket !== 'undefined' ? WebSocket : null); + this.storage = typeof opts.storage !== 'undefined' ? opts.storage : ProtoClient.browserStorage(); + this.setTimeout = opts.setTimeout || ((fn, ms) => setTimeout(fn, ms)); + this.clearTimeout = opts.clearTimeout || ((t) => clearTimeout(t)); + this.opTimeoutMs = opts.opTimeoutMs || 10000; + this.schema = this.loadSchema() || new this.Schema(); + this.model = new deps.ProtoModel(this.schema); + this.model.onChange((kind, id, item) => this.emit('change', { kind: kind, id: id, item: item })); + this.listeners = {}; + this.pending = new Map(); + this.feeds = new Set(); + this.nextId = 1; + this.ws = null; + this.ready = false; // synced: ops may go + this.schemaReady = false; // frames can be read + this.helloHash = null; + this.opened = false; + this.stopped = true; + this.retries = 0; + this.reconnectTimer = null; + this.held = []; + this.fw = null; + } + // In the browser the classes are the ones index.js was joined with; in + // Node they are loaded. + static deps() { + if (typeof require === 'function' && typeof module !== 'undefined' && module.exports) + return { ProtoSchema: require('./schema.js').ProtoSchema, ProtoModel: require('./model.js').ProtoModel }; + return { ProtoSchema: ProtoSchema, ProtoModel: ProtoModel }; + } + static browserStorage() { + try { + return typeof localStorage !== 'undefined' ? localStorage : null; + } catch (err) { + return null; + } + } + + // cb(d) for a device event by its name (shadeState, frame ...), and for + // the client's own: open, hello, synced, change, closed, versionMismatch, + // error (a refusal the device couldn't tie to an op) and refused. + // refused: the socket closed before it opened. A browser can't tell a + // refused token from a device that is down, so the client tries again + // unless a listener calls close(), as the UI does once /loginContext says + // a login is needed (docs/SECURITY_PLAN.md). + on(name, cb) { (this.listeners[name] = this.listeners[name] || []).push(cb); } + off(name, cb) { this.listeners[name] = (this.listeners[name] || []).filter((x) => x !== cb); } + emit(name, d) { for (const cb of (this.listeners[name] || []).slice()) cb(d); } + // The next event of that name that match(d) accepts, or null after ms. + // An edit's events follow its reply, so this is how a caller gets the + // item the edit left: the model has it by then. + waitFor(name, match, ms) { + return new Promise((resolve) => { + let timer = null; + const cb = (d) => { + if (match && !match(d)) return; + this.off(name, cb); + this.clearTimeout(timer); + resolve(d); + }; + this.on(name, cb); + timer = this.setTimeout(() => { + this.off(name, cb); + resolve(null); + }, ms); + }); + } + + connect() { + if (!this.stopped && (this.ws || this.reconnectTimer)) return; + this.stopped = false; + this.open(); + } + close() { + this.stopped = true; + this.cancelReconnect(); + if (this.ws) this.ws.close(); + } + // A new token, from a login: the device checks it as the socket opens, so + // the client connects again with it at once. + setToken(token) { + this.token = token || ''; + this.stopped = false; + this.retries = 0; + this.open(); + } + url() { + const params = []; + if (this.token) params.push(`apikey=${encodeURIComponent(this.token)}`); + if (this.schema.hash) params.push(`schema=${encodeURIComponent(this.schema.hash)}`); + return `ws://${this.host}/ws${params.length ? '?' + params.join('&') : ''}`; + } + cancelReconnect() { + if (this.reconnectTimer) this.clearTimeout(this.reconnectTimer); + this.reconnectTimer = null; + } + // One socket at a time: one being replaced is let go without a word. + open() { + this.cancelReconnect(); + if (this.ws) { + const old = this.ws; + this.ws = null; + this.lost(); + old.close(); + } + this.ready = false; + this.schemaReady = false; + this.opened = false; + this.held = []; + const ws = new this.WebSocket(this.url()); + this.ws = ws; + ws.onopen = () => { + if (this.ws !== ws) return; + this.opened = true; + this.retries = 0; + this.emit('open'); + }; + ws.onmessage = (evt) => { + if (this.ws === ws) this.receive(evt.data); + }; + ws.onclose = () => { + if (this.ws !== ws) return; + this.ws = null; + this.lost(); + this.emit(this.opened ? 'closed' : 'refused'); + if (this.stopped) return; + // Soon after a close, slower after each failure, at most 10 s. + const ms = Math.min(500 * Math.pow(2, this.retries++), 10000); + this.reconnectTimer = this.setTimeout(() => this.open(), ms); + }; + } + // The socket has gone: nothing waiting gets its reply. + lost() { + this.ready = false; + for (const [, p] of this.pending) { + this.clearTimeout(p.timer); + p.reject(new ProtoError('closed', 'The connection closed')); + } + this.pending.clear(); + } + frame(type, d, id) { + const frame = { v: ProtoClient.VERSION, t: this.schema.typeNumbers[type] }; + if (typeof frame.t === 'undefined') throw new ProtoError('unknownOp', `The device has no message ${type}`); + if (id) frame.id = id; + if (d) frame.d = d; + return JSON.stringify(frame); + } + + // Sends an op, or a control message that wants a reply, by its name with + // its fields by name. Resolves with the reply's fields, rejects with a + // ProtoError. + op(name, fields) { + return new Promise((resolve, reject) => { + if (!this.ready || !this.ws) { + reject(new ProtoError('notConnected', 'Not connected to the device')); + return; + } + const id = this.nextId++; + let text; + try { + text = this.frame(name, this.schema.pack(fields || {}), id); + } catch (err) { + reject(err instanceof ProtoError ? err : new ProtoError('badRequest', err.message)); + return; + } + this.ws.send(text); + const timer = this.setTimeout(() => { + this.pending.delete(id); + reject(new ProtoError('timeout', `No reply to ${name}`)); + }, this.opTimeoutMs); + this.pending.set(id, { resolve: resolve, reject: reject, timer: timer, text: text, resends: 0 }); + }); + } + // Feeds stay subscribed across reconnects. + subscribe(feed) { + if (typeof this.schema.feedNumbers[feed] === 'undefined') return Promise.reject(new ProtoError('badRequest', `The device has no feed ${feed}`)); + this.feeds.add(feed); + return this.op('subscribe', { feed: this.schema.feedNumbers[feed] }); + } + unsubscribe(feed) { + this.feeds.delete(feed); + if (typeof this.schema.feedNumbers[feed] === 'undefined') return Promise.resolve(); + return this.op('unsubscribe', { feed: this.schema.feedNumbers[feed] }); + } + // The shade model and status again, without the schema. + resync() { + this.model.beginSync(); + return this.op('sync').catch((err) => { + this.model.cancelSync(); + throw err; + }); + } + + receive(text) { + let frame; + try { + frame = JSON.parse(text); + } catch (err) { + return; + } + if (frame.v !== ProtoClient.VERSION) { + this.emit('versionMismatch', { device: frame.v, client: ProtoClient.VERSION }); + return; + } + const d = frame.d || {}; + // These have fixed numbers: they come before the schema. + switch (frame.t) { + case ProtoClient.HELLO: this.hello(d); return; + case ProtoClient.SYNC: this.syncFrame(d); return; + case ProtoClient.SYNC_END: this.syncEnd(); return; + default: break; + } + // A frame the client can't read yet waits for the schema. + if (!this.schemaReady) this.held.push(frame); + else this.dispatch(frame); + } + hello(d) { + this.fw = d.fw; + this.helloHash = d.sh; + // A schema the client kept for this one needn't come again; any other + // is no use, and the device sends the one it has. + if (this.schema.hash !== d.sh) { + this.schema = new this.Schema(); + this.model.schema = this.schema; + } + this.model.beginSync(); + this.emit('hello', d); + if (this.schema.hash === d.sh) this.readable(); + } + syncFrame(d) { + this.schema.add(d); + const device = this.Schema.withoutRows(d); + // The schema's rows come first, so a frame with the device's sections + // has the whole of it. + if (Object.keys(device).length) { + this.readable(); + this.model.applySync(this.schema.expand(device)); + } + this.ws.send(JSON.stringify({ v: ProtoClient.VERSION, t: ProtoClient.NEXT })); + } + // The schema is whole: frames that waited for it go, in the order they + // came and ahead of the sync frames formatted after them. + readable() { + if (this.schemaReady) return; + this.schemaReady = true; + const held = this.held; + this.held = []; + for (const frame of held) this.dispatch(frame); + } + syncEnd() { + this.readable(); + this.model.endSync(); + if (!this.ready) { + this.ready = true; + // Only a whole schema is kept, so a sync cut short gets it again. + this.schema.hash = this.helloHash; + this.saveSchema(); + for (const feed of this.feeds) this.op('subscribe', { feed: this.schema.feedNumbers[feed] }).catch(() => {}); + } + this.emit('synced', this.model); + } + dispatch(frame) { + const d = this.schema.expand(frame.d || {}); + if (frame.t === ProtoClient.REPLY) this.reply(frame.id, d); + else { + const name = this.schema.types[frame.t]; + if (!name) return; + this.model.applyEvent(name, d); + this.emit(name, d); + } + } + reply(id, d) { + const err = d.ok ? null : new ProtoError(this.schema.errors[d.code] || 'internal', d.desc, d); + const p = typeof id !== 'undefined' ? this.pending.get(id) : null; + if (p) { + this.pending.delete(id); + this.clearTimeout(p.timer); + if (err) p.reject(err); + else p.resolve(d); + return; + } + if (!err) return; + // A long message the device couldn't take while it put another one + // together is refused without its id: the long ones waiting go again. + if (err.code === 'busy' && this.resendLong()) return; + this.emit('error', err); + } + resendLong() { + let any = false; + for (const [, p] of this.pending) { + if (p.text.length < ProtoClient.LONG_MESSAGE || p.resends >= 3) continue; + p.resends++; + any = true; + this.setTimeout(() => { + if (this.ws && [...this.pending.values()].includes(p)) this.ws.send(p.text); + }, 200 * p.resends); + } + return any; + } + + loadSchema() { + if (!this.storage) return null; + try { + return this.Schema.load(JSON.parse(this.storage.getItem(ProtoClient.SCHEMA_KEY))); + } catch (err) { + return null; + } + } + saveSchema() { + if (!this.storage) return; + try { + this.storage.setItem(ProtoClient.SCHEMA_KEY, JSON.stringify(this.schema.save())); + } catch (err) { /* Private windows may have no storage: the device sends the schema each time. */ } + } +} +ProtoClient.VERSION = 2; +// The types a client reads before it has the schema, and next, which it sends +// during the sync. +ProtoClient.HELLO = 1; +ProtoClient.REPLY = 2; +ProtoClient.NEXT = 3; +ProtoClient.SYNC = 4; +ProtoClient.SYNC_END = 5; +// A message longer than a TCP segment reaches the device in pieces +// (docs/PROTOCOL.md). +ProtoClient.LONG_MESSAGE = 1400; +ProtoClient.SCHEMA_KEY = 'espsomfyProtoSchema'; +if (typeof module !== 'undefined' && module.exports) module.exports = { ProtoClient, ProtoError }; diff --git a/data-src/js/model.js b/data-src/js/model.js new file mode 100644 index 0000000..2411996 --- /dev/null +++ b/data-src/js/model.js @@ -0,0 +1,159 @@ +// The shade model as socket protocol 2 keeps a client up to date with it +// (docs/PROTOCOL.md): rooms, shades, groups and repeaters from the sync, then +// changed by the device's events. Items are inserted or updated by id, so an +// event during the sync does no harm. It takes frames already expanded to +// names (ProtoSchema.expand) and fills in what a frame leaves out at its +// default. The minify step joins this file into index.js; Node loads it on +// its own for the tests (test/js). +class ProtoModel { + constructor(schema) { + this.schema = schema; + this.rooms = new Map(); + this.shades = new Map(); + this.groups = new Map(); + this.repeaters = []; + this.header = {}; + this.status = {}; + this.listeners = []; + this.seen = null; + } + // cb(kind, id, item): kind is room, shade or group for an item added or + // changed; roomRemoved, shadeRemoved or groupRemoved; roomOrder, + // shadeOrder or groupOrder (item: the ids in order); repeaters, header or + // status. + onChange(cb) { this.listeners.push(cb); } + changed(kind, id, item) { for (const cb of this.listeners) cb(kind, id, item); } + + // A sync: what it doesn't list is gone once it ends, the repeaters too, + // which it leaves out when there are none. + beginSync() { this.seen = { rooms: new Set(), shades: new Set(), groups: new Set(), repeaters: false }; } + // A sync that won't come after all. + cancelSync() { this.seen = null; } + applySync(d) { + if (d.header) { + this.header = this.schema.fill(Object.assign({}, d.header), ProtoModel.FIELDS.header); + this.changed('header', 0, this.header); + } + for (const kind of ProtoModel.ITEMS) for (const item of d[kind.list] || []) this.put(kind, item); + if (d.repeaters) this.putRepeaters(d.repeaters); + if (d.status) { + this.putStatus(d.status, ProtoModel.FIELDS.memory); + this.putStatus(d.status, this.header.connType === 'Ethernet' ? ProtoModel.FIELDS.ethernet : ProtoModel.FIELDS.wifi); + } + } + endSync() { + if (!this.seen) return; + for (const kind of ProtoModel.ITEMS) { + const map = this[kind.list]; + for (const id of [...map.keys()]) { + if (this.seen[kind.list].has(id)) continue; + map.delete(id); + this.changed(kind.removed, id); + } + } + if (!this.seen.repeaters && this.repeaters.length) this.putRepeaters([]); + this.seen = null; + } + // An event by its type's name; false for one that isn't about the model, + // or that changed nothing. + applyEvent(type, d) { + for (const kind of ProtoModel.ITEMS) { + const id = d[kind.id] || 0; + switch (type) { + case kind.name: this.put(kind, d); return true; + case kind.state: return this.mergeState(kind, id, d); + case kind.removed: return this.remove(kind, id); + case kind.order: return this.order(kind, d.ids || []); + default: break; + } + } + switch (type) { + case 'repeaters': this.putRepeaters(d.repeaters || []); return true; + case 'memory': this.putStatus(d, ProtoModel.FIELDS.memory); return true; + case 'wifi': this.putStatus(d, ProtoModel.FIELDS.wifi); return true; + case 'ethernet': this.putStatus(d, ProtoModel.FIELDS.ethernet); return true; + default: return false; + } + } + + // The lists in their sort order. + roomList() { return ProtoModel.sorted(this.rooms); } + shadeList() { return ProtoModel.sorted(this.shades); } + groupList() { return ProtoModel.sorted(this.groups); } + static sorted(map) { return [...map.values()].sort((a, b) => a.sortOrder - b.sortOrder); } + + // A whole item: what it had before is replaced. + put(kind, item) { + const id = item[kind.id] || 0; + const whole = this.schema.fill(Object.assign({}, item), ProtoModel.FIELDS[kind.name]); + // A shade's linked remotes leave out their defaults too. + if (kind.name === 'shade') + whole.linkedRemotes = whole.linkedRemotes.map((r) => this.schema.fill(Object.assign({}, r), ProtoModel.FIELDS.linkedRemote)); + this[kind.list].set(id, whole); + if (this.seen) this.seen[kind.list].add(id); + this.changed(kind.name, id, whole); + } + // Part of an item: only its state. A state of an item not synced yet + // waits for the item. + mergeState(kind, id, d) { + const item = this[kind.list].get(id); + if (!item) return false; + Object.assign(item, this.schema.fill(Object.assign({}, d), ProtoModel.FIELDS[kind.state])); + this.changed(kind.name, id, item); + return true; + } + remove(kind, id) { + if (!this[kind.list].delete(id)) return false; + this.changed(kind.removed, id); + return true; + } + order(kind, ids) { + ids.forEach((id, i) => { + const item = this[kind.list].get(id); + if (item) item.sortOrder = i; + }); + this.changed(kind.order, 0, ids); + return true; + } + putRepeaters(list) { + this.repeaters = list.slice(); + if (this.seen) this.seen.repeaters = true; + this.changed('repeaters', 0, this.repeaters); + } + putStatus(d, fields) { + const part = {}; + for (const name of fields) part[name] = typeof d[name] === 'undefined' ? this.schema.defaultOf(name) : d[name]; + Object.assign(this.status, part); + this.changed('status', 0, this.status); + } +} +// Rooms, shades and groups: their list, id, and the events about them. Rooms +// have no state of their own. +ProtoModel.ITEMS = [ + { name: 'room', list: 'rooms', id: 'roomId', state: null, removed: 'roomRemoved', order: 'roomOrder' }, + { name: 'shade', list: 'shades', id: 'shadeId', state: 'shadeState', removed: 'shadeRemoved', order: 'shadeOrder' }, + { name: 'group', list: 'groups', id: 'groupId', state: 'groupState', removed: 'groupRemoved', order: 'groupOrder' } +]; +// The fields of each kind of item, as the device writes them +// (src/ProtoSync.cpp, src/outputs/ProtoSocket.cpp): what a frame that leaves +// one out means by it. The schema has each field's default, not which items +// have it. +ProtoModel.FIELDS = { + header: ['maxRooms', 'maxShades', 'maxGroups', 'maxGroupedShades', 'maxLinkedRemotes', 'startingAddress', 'bitLength', + 'proto', 'serverId', 'hostname', 'model', 'chipModel', 'fw', 'connType'], + room: ['roomId', 'name', 'sortOrder'], + shadeState: ['shadeId', 'position', 'target', 'direction', 'myPos', 'tiltPosition', 'tiltTarget', 'tiltDirection', + 'myTiltPos', 'flags', 'lastRollingCode'], + groupState: ['groupId', 'flags', 'direction'], + linkedRemote: ['remoteAddress', 'lastRollingCode'], + group: ['groupId', 'roomId', 'name', 'remoteAddress', 'lastRollingCode', 'bitLength', 'proto', 'sunSensor', + 'flipCommands', 'flags', 'repeats', 'sortOrder', 'linkedShades'], + memory: ['freeHeap', 'maxHeap', 'minHeap', 'totalHeap', 'uptime', 'loopRate', 'loopMaxUs'], + wifi: ['ssid', 'strength', 'channel'], + ethernet: ['connected', 'speed', 'fullDuplex'] +}; +ProtoModel.FIELDS.shade = ProtoModel.FIELDS.shadeState.concat(['roomId', 'name', 'remoteAddress', 'upTime', 'downTime', + 'tiltTime', 'stepSize', 'paired', 'tiltType', 'shadeType', 'bitLength', 'proto', 'flipCommands', 'flipPosition', + 'inGroup', 'sunSensor', 'light', 'simMy', 'repeats', 'sortOrder', 'gpioUp', 'gpioDown', 'gpioMy', 'gpioLLTrigger', + 'linkedRemotes']); +if (typeof module !== 'undefined' && module.exports) module.exports = { ProtoModel }; diff --git a/data-src/js/schema.js b/data-src/js/schema.js new file mode 100644 index 0000000..f0cf0f2 --- /dev/null +++ b/data-src/js/schema.js @@ -0,0 +1,101 @@ +// Socket protocol 2's schema (docs/PROTOCOL.md): the device's table of message +// types, fields, error codes and feeds, as the sync sends it. It turns the +// short keys of a frame into names and back. The minify step joins this file +// into index.js; Node loads it on its own for the tests (test/js). +class ProtoSchema { + constructor() { + this.hash = null; + this.types = {}; // number -> name + this.typeNumbers = {}; // name -> number + this.fields = {}; // key -> { name, kind, def } + this.keys = {}; // name -> key + this.errors = {}; + this.errorNumbers = {}; + this.feedNumbers = {}; + this.rows = { T: [], F: [], E: [], Q: [] }; + } + // A sync frame's payload without the schema's rows: the device's sections. + static withoutRows(d) { + const out = {}; + for (const key of Object.keys(d)) if (!ProtoSchema.ROWS.includes(key)) out[key] = d[key]; + return out; + } + // The schema's rows in a sync frame's payload: T types, F fields, E error + // codes, Q feeds. They may span several frames. + add(d) { + for (const [number, name] of d.T || []) { + this.types[number] = name; + this.typeNumbers[name] = number; + } + for (const [key, name, kind, def] of d.F || []) { + this.fields[key] = { name: name, kind: kind, def: def }; + this.keys[name] = key; + } + for (const [number, name] of d.E || []) { + this.errors[number] = name; + this.errorNumbers[name] = number; + } + for (const [number, name] of d.Q || []) this.feedNumbers[name] = number; + for (const k of ProtoSchema.ROWS) if (d[k]) this.rows[k].push(...d[k]); + } + get empty() { return Object.keys(this.fields).length === 0; } + // What a field left out of a frame is: its default. + defaultOf(name) { + const f = this.fields[this.keys[name]]; + if (!f) return undefined; + switch (f.kind) { + case 'b': return f.def !== 0; + case 's': return ''; + case 'l': return []; + case 'o': return {}; + default: return f.def; + } + } + // Short keys to names, and 1/0 to true/false, all the way down. A field + // left out stays out; fill() puts the defaults in. + expand(value) { + if (Array.isArray(value)) return value.map((v) => this.expand(v)); + if (value === null || typeof value !== 'object') return value; + const out = {}; + for (const key of Object.keys(value)) { + const f = this.fields[key]; + let v = value[key]; + if (f && f.kind === 'b' && typeof v === 'number') v = v !== 0; + out[f ? f.name : key] = this.expand(v); + } + return out; + } + // Names to short keys, and booleans to 1/0, for an op's payload. A name + // the schema doesn't have is an error: the device would refuse it anyway. + pack(value) { + if (Array.isArray(value)) return value.map((v) => this.pack(v)); + if (value === null || typeof value !== 'object') return typeof value === 'boolean' ? (value ? 1 : 0) : value; + const out = {}; + for (const name of Object.keys(value)) { + if (typeof value[name] === 'undefined') continue; + const key = this.keys[name]; + if (typeof key === 'undefined') throw new Error(`The device has no field ${name}`); + out[key] = this.pack(value[name]); + } + return out; + } + // Sets each of names that obj lacks to its default, as a frame leaves out + // a field at its default. Returns obj. + fill(obj, names) { + for (const name of names) if (typeof obj[name] === 'undefined') obj[name] = this.defaultOf(name); + return obj; + } + // What a cache keeps, and the schema back from it. + save() { return { hash: this.hash, rows: this.rows }; } + static load(saved) { + if (!saved || typeof saved.hash !== 'string' || !saved.rows) return null; + const s = new ProtoSchema(); + s.add(saved.rows); + s.hash = saved.hash; + return s.empty ? null : s; + } +} +// The keys of the schema's rows in a sync frame, fixed as a client needs them +// before it has the schema. +ProtoSchema.ROWS = ['T', 'F', 'E', 'Q']; +if (typeof module !== 'undefined' && module.exports) module.exports = { ProtoSchema }; diff --git a/data-src/js/views.js b/data-src/js/views.js new file mode 100644 index 0000000..e1719b6 --- /dev/null +++ b/data-src/js/views.js @@ -0,0 +1,80 @@ +// What the web UI's panels bind, made from socket protocol 2's items, events +// and settings (docs/PROTOCOL.md), and back. The UI kept its names where they +// differ from the protocol's: a frame's address and rcode, a scan's RSSI, the +// network panel's wifi, ethernet and ip objects, the radio's type. The minify +// step joins this file into index.js; Node loads it on its own for the tests +// (test/js). +class ProtoViews { + // A settings section's reply with what the device left out at its default + // filled in, so a form shows what is saved rather than what it showed + // before. + static settings(schema, section, d) { + return schema.fill(Object.assign({}, d), ProtoViews.SETTINGS[section]); + } + // A group with its shades whole, where the device sends their ids. + static group(model, group) { + if (!group) return group; + const view = Object.assign({}, group); + view.linkedShades = group.linkedShades.map((id) => model.shades.get(id) || { shadeId: id, name: `Shade ${id}`, remoteAddress: 0 }); + return view; + } + // A received frame as the frames list and remote linking read it. + static frame(schema, d) { + const f = schema.fill(Object.assign({}, d), ['encKey', 'remoteAddress', 'lastRollingCode', 'command', 'rawCmd', 'rssi', 'bits', 'proto', + 'valid', 'pulses']); + return { encKey: f.encKey, address: f.remoteAddress, rcode: f.lastRollingCode, command: f.command, rawCmd: f.rawCmd, rssi: f.rssi, + bits: f.bits, proto: f.proto, valid: f.valid, stepSize: d.stepSize, pulses: f.pulses }; + } + static scan(schema, d) { + const s = schema.fill(Object.assign({}, d), ['scanning', 'testFreq', 'testRssi', 'frequency', 'rssi']); + return { scanning: s.scanning, testFreq: s.testFreq, testRSSI: s.testRssi, frequency: s.frequency, RSSI: s.rssi }; + } + // The network section as the panel binds it: WiFi, Ethernet and the + // address each in an object of their own, the connection as connType. + static network(schema, d) { + const n = ProtoViews.settings(schema, 'network', d); + const view = { connType: n.connMode, hasEthernet: n.hasEthernet, wifi: {}, ethernet: {}, ip: {} }; + for (const name of ProtoViews.WIFI) view.wifi[name] = n[name]; + for (const name of ProtoViews.ETHERNET) view.ethernet[name] = n[name]; + for (const name of ProtoViews.IP) view.ip[name] = n[name]; + return view; + } + // The radio section as the panel binds it, where the bit length is the + // radio's type. + static radio(schema, d) { + const config = ProtoViews.settings(schema, 'radio', d); + config.type = config.bitLength; + delete config.bitLength; + return config; + } + // A save of the radio panel's config: everything but what is only shown. + static radioSave(config) { + const fields = { section: 'radio', bitLength: config.type }; + for (const name of ProtoViews.SETTINGS.radio) { + if (name !== 'bitLength' && name !== 'radioInit') fields[name] = config[name]; + } + return fields; + } + // An op's refusal as the UI's error box shows it. A shade whose settings + // don't add up carries the reason's number, which the errors table + // describes. + static opError(name, err) { + const e = { htmlError: err.code, service: name, desc: err.desc }; + if (err.data && typeof err.data.validation === 'number' && err.data.validation !== 0) e.code = err.data.validation; + return e; + } +} +ProtoViews.WIFI = ['ssid', 'hasPassphrase', 'roaming', 'hidden']; +ProtoViews.ETHERNET = ['boardType', 'phyType', 'CLKMode', 'phyAddress', 'PWRPin', 'MDCPin', 'MDIOPin']; +ProtoViews.IP = ['dhcp', 'ip', 'gateway', 'subnet', 'dns1', 'dns2']; +// The fields of each settings section, as getSettings sends them +// (src/DeviceOps.cpp). +ProtoViews.SETTINGS = { + general: ['hostname', 'ssdpBroadcast', 'ntpServer', 'posixZone'], + network: ['connMode', 'hasEthernet'].concat(ProtoViews.WIFI, ProtoViews.ETHERNET, ProtoViews.IP), + mqtt: ['enabled', 'pubDisco', 'protocol', 'hostname', 'port', 'username', 'hasPassword', 'rootTopic', 'discoTopic'], + security: ['securityType', 'username', 'hasPassword', 'hasPin'], + radio: ['bitLength', 'proto', 'enabled', 'TXPin', 'RXPin', 'SCKPin', 'MOSIPin', 'MISOPin', 'CSNPin', 'frequency', 'rxBandwidth', + 'deviation', 'txPower', 'noiseDetection', 'radioInit'] +}; +if (typeof module !== 'undefined' && module.exports) module.exports = { ProtoViews }; diff --git a/data-src/login.html b/data-src/login.html deleted file mode 100644 index 32623f1..0000000 --- a/data-src/login.html +++ /dev/null @@ -1,53 +0,0 @@ - - - - - - - - - - - - -
-
-
-
-
-
diff --git a/data-src/main.css b/data-src/main.css
index 25d716b..a35c803 100644
--- a/data-src/main.css
+++ b/data-src/main.css
@@ -868,3 +868,14 @@ div.frame-pulses {
padding-right:14px;
}
}
+/* Shown when the device speaks another protocol version than this page. */
+.version-banner {
+ position: sticky;
+ top: 0;
+ z-index: 100;
+ padding: 8px 12px;
+ background: orangered;
+ color: white;
+ font-size: 14px;
+ text-align: center;
+}
diff --git a/docs/adr/0005-one-websocket-protocol.md b/docs/adr/0005-one-websocket-protocol.md
index 9f862fd..8d008fb 100644
--- a/docs/adr/0005-one-websocket-protocol.md
+++ b/docs/adr/0005-one-websocket-protocol.md
@@ -22,6 +22,7 @@ We decided that the web UI and the Home Assistant integration do everything exce
- **The send queue stays at 32 messages per client.** A full queue closes the client, which reconnects and syncs again. Dropping messages would leave a shade showing the wrong position with no way to notice.
- **A JSON envelope that a binary encoding can reuse.** Every frame is `{"v":2,"t":
-
-
-
-
-