cleanup sacn variables/logic

This commit is contained in:
2022-11-28 19:36:58 -06:00
parent eabc05bef3
commit 4f302bcdf5
2 changed files with 43 additions and 70 deletions
+37 -64
View File
@@ -28,72 +28,67 @@ exports.ready = function ready(device) {
};
exports.data = function data(_device, buf) {
exports.data = function data(device, buf) {
const universeIndex = buf.readUInt16BE(113);
const device = _device;
const univ = buf.readUInt16BE(113);
const d = device;
let universe = device.data.universes[universeIndex];
let u = d.data.universes[univ];
if(!u){
d.data.universes[univ] = {};
u = d.data.universes[univ];
if(!universe){
device.data.universes[universeIndex] = {};
universe = device.data.universes[universeIndex];
}
u.sequence = buf.readUInt8(111);
u.priority = buf.readUInt8(108);
u.cid = buf.toString('hex', 22, 38);
u.slots = Array.prototype.slice.call(buf, 126);
universe.sequence = buf.readUInt8(111);
universe.priority = buf.readUInt8(108);
universe.cid = buf.toString('hex', 22, 38);
universe.slots = buf.slice(126);
if(buf.readUInt8(125) !== 0){
u.startCode = buf.readUInt8(125);
universe.startCode = buf.readUInt8(125);
}
device.data.source = buf.toString('utf8', 44, 108);
device.displayName = `${device.data.source} sACN`;
device.data.ip = device.addresses[0];
d.data.source = buf.toString('utf8', 44, 108);
d.displayName = `${d.data.source} sACN`;
d.data.ip = d.addresses[0];
if(!_.includes(d.data.orderedUniverses, univ)){
d.data.orderedUniverses.push(univ);
d.data.orderedUniverses.sort();
u.slotElems = [];
u.slotElemsSet = false;
d.draw();
updateElementsCache(d, d.data.universes, d.data.orderedUniverses);
if(!_.includes(device.data.orderedUniverses, universeIndex)){
device.data.orderedUniverses.push(universeIndex);
device.data.orderedUniverses.sort();
universe.slotElems = [];
universe.slotElemsSet = false;
device.draw();
device.update("elementCache")
}
d.update("universeData", {
u: univ,
universe: u,
startCode: u.startCode
device.update("universeData", {
universeIndex,
universe,
startCode: universe.startCode
});
};
exports.heartbeat = function heartbeat(device) {
};
let lastUpdate = Date.now();
exports.update = function update(device, doc, updateType, updateData){
exports.update = function update(_device, doc, updateType, updateData){
const d = device;
const device = _device;
const data = updateData;
if(updateType === "universeData" && data.universe){
if(Date.now() - lastUpdate > 1000){
lastUpdate = Date.now();
updateElementsCache(d, d.data.universes, d.data.orderedUniverses);
device.update("elementCache")
}
const $elem = doc.getElementById(`universe-${data.u}`);
const $elem = doc.getElementById(`universe-${data.universeIndex}`);
if($elem && data.universe.slotElemsSet){
@@ -102,7 +97,7 @@ exports.update = function update(device, doc, updateType, updateData){
data.universe.slotElems[i].innerText = data.universe.slots[i];
}
const $code = doc.getElementById(`universe-${data.u}-code`);
const $code = doc.getElementById(`universe-${data.universeIndex}-code`);
if(data.startCode === 0xDD){
$code.innerText = "Net3"
}else if(data.startCode === 0x17){
@@ -112,47 +107,25 @@ exports.update = function update(device, doc, updateType, updateData){
}else if(data.startCode === 0xCC){
$code.innerText = "RDM"
}
}
}else{
d.draw();
updateElementsCache(d, d.data.universes, d.data.orderedUniverses);
device.draw();
device.update("elementCache")
}
}else if(updateType === "elementCache"){
data.orderedUniverses.forEach(univ => {
device.data.orderedUniverses.forEach(universeIndex => {
for(let i = 0; i < 512; i++){
data.universes[univ].slotElems[i] = doc.getElementById(`${univ}-${i}`);
device.data.universes[universeIndex].slotElems[i] = doc.getElementById(`${universeIndex}-${i}`);
}
data.universes[univ].slotElemsSet = true;
device.data.universes[universeIndex].slotElemsSet = true;
});
}
}
function updateElementsCache(device, univ, ordered){
device.update("elementCache", {
universes: univ,
orderedUniverses: ordered
});
}
// From https://github.com/hhromic/e131-node/blob/master/lib/e131.js
function getMulticastGroup(universe) {
if (universe < 1 || universe > 63999) {
throw new RangeError('universe should be in the range [1-63999]');
}
return `239.255.${universe >> 8}.${universe & 0xff}`;
}
+6 -6
View File
@@ -4,15 +4,15 @@
<div id="universes">
<% data.orderedUniverses.forEach(univ => {
let universe = data.universes[univ];
<% data.orderedUniverses.forEach(universeIndex => {
let universe = data.universes[universeIndex];
%>
<table id="universe-<%= univ %>">
<table id="universe-<%= universeIndex %>">
<tr>
<td class="data" colspan="2">
Universe
<br><em><%= univ %></em>
<br><em><%= universeIndex %></em>
</td>
<td class="data" colspan="2">
Priority
@@ -28,7 +28,7 @@
</td>
<td class="data" colspan="2">
Flavor
<br><em id="universe-<%= univ %>-code">0</em>
<br><em id="universe-<%= universeIndex %>-code">0</em>
</td>
</tr>
@@ -45,7 +45,7 @@
<th><%= row*16+1 %></th>
<% for(col=0; col<16; col++){ %>
<% slot++%>
<td id="<%= univ %>-<%= row*16+col %>" title="<%= univ %>/<%= slot %>"><%= universe.slots[slot-1] %></td>
<td id="<%= universeIndex %>-<%= row*16+col %>" title="<%= universeIndex %>/<%= slot %>"><%= universe.slots[slot-1] %></td>
<% } %>
</tr>
<% } %>