mirror of
https://github.com/stagehacks/Cue-View.git
synced 2026-08-04 13:27:46 +00:00
sparks-alec
297 lines
10 KiB
JavaScript
297 lines
10 KiB
JavaScript
const _ = require('lodash');
|
|
const fs = require('fs');
|
|
const path = require('path');
|
|
|
|
exports.config = {
|
|
defaultName: 'QLab',
|
|
connectionType: 'osc',
|
|
defaultPort: 53000,
|
|
mayChangePort: true,
|
|
heartbeatInterval: 100,
|
|
heartbeatTimeout: 5000,
|
|
searchOptions: {
|
|
type: 'Bonjour',
|
|
bonjourName: 'qlab',
|
|
},
|
|
fields: [
|
|
{
|
|
key: 'passcode',
|
|
label: 'Pass',
|
|
type: 'textinput',
|
|
value: '',
|
|
action(device) {
|
|
device.send('/workspaces');
|
|
},
|
|
},
|
|
],
|
|
};
|
|
|
|
const valuesForKeysString =
|
|
'["uniqueID","number","name","listName","isBroken","isRunning","isLoaded","isFlagged",' +
|
|
'"type","children","preWait","postWait","duration","colorName","continueMode",' +
|
|
'"mode","parent","cartRows","cartColumns","cartPosition","displayName","preWaitElapsed",' +
|
|
'"actionElapsed","postWaitElapsed","isPaused","currentCueTarget","isRunning","armed"]';
|
|
|
|
exports.ready = function ready(_device) {
|
|
const device = _device;
|
|
device.send(`/version`);
|
|
device.send('/workspaces');
|
|
device.data.workspaces = {};
|
|
device.data.cueKeys = {};
|
|
device.data.somethingPlaying = false;
|
|
|
|
device.templates = {
|
|
cue: _.template(fs.readFileSync(path.join(__dirname, `cue.ejs`))),
|
|
tile: _.template(fs.readFileSync(path.join(__dirname, `tile.ejs`))),
|
|
cart: _.template(fs.readFileSync(path.join(__dirname, `cart.ejs`))),
|
|
cuelist: _.template(fs.readFileSync(path.join(__dirname, `cuelist.ejs`))),
|
|
};
|
|
};
|
|
|
|
exports.data = function data(_device, oscData) {
|
|
const device = _device;
|
|
|
|
const msgAddr = oscData.address.split('/');
|
|
msgAddr.shift();
|
|
|
|
let json = [];
|
|
try {
|
|
json = JSON.parse(oscData.args[0]);
|
|
} catch (err) {
|
|
// a handful of messages don't respond with JSON
|
|
}
|
|
|
|
if (Object.keys(json).length > 0) {
|
|
if (json.status === 'denied') {
|
|
if (device.data.workspaces[json.workspace_id]) {
|
|
device.data.workspaces[json.workspace_id].permission = 'denied';
|
|
}
|
|
return;
|
|
}
|
|
if (json.status === 'error') {
|
|
device.send('/workspaces');
|
|
return;
|
|
}
|
|
}
|
|
|
|
if (oscData.address === '/reply/workspaces') {
|
|
for (let i = 0; i < json.data.length; i++) {
|
|
device.data.workspaces[json.data[i].uniqueID] = {
|
|
version: json.data[i].version,
|
|
displayName: json.data[i].displayName,
|
|
port: json.data[i].port,
|
|
udpReplyPort: json.data[i].udpReplyPort,
|
|
cueLists: [],
|
|
selected: [],
|
|
};
|
|
device.data.workspaces[json.data[i].uniqueID].permission = 'ok';
|
|
device.send(`/workspace/${json.data[i].uniqueID}/connect`, device.fields.passcode);
|
|
}
|
|
this.deviceInfoUpdate(device, 'status', 'ok');
|
|
} else if (/reply\/workspace\/.*\/connect/.test(oscData.address)) {
|
|
if (json.data === 'badpass') {
|
|
device.data.workspaces[json.workspace_id].permission = 'badpass';
|
|
} else {
|
|
device.data.workspaces[json.workspace_id].permission = 'ok';
|
|
device.send(`/workspace/${msgAddr[2]}/cueLists`);
|
|
device.send(`/workspace/${msgAddr[2]}/updates`, [{ type: 'i', value: 1 }]);
|
|
}
|
|
} else if (/reply\/workspace\/.*\/cueLists/.test(oscData.address)) {
|
|
device.data.workspaces[msgAddr[2]].cueLists = json.data;
|
|
device.data.somethingPlaying = false;
|
|
processCueList(device.data.workspaces[msgAddr[2]].cueLists, Object.keys(device.data.cueKeys), device, []);
|
|
device.draw();
|
|
} else if (/reply\/cue_id\/.*\/valuesForKeys/.test(oscData.address)) {
|
|
const keyValues = json.data;
|
|
let cue = device.data.cueKeys[msgAddr[2]];
|
|
|
|
if (cue === undefined) {
|
|
device.data.cueKeys[msgAddr[2]] = {};
|
|
cue = device.data.cueKeys[msgAddr[2]];
|
|
}
|
|
cue.uniqueID = keyValues.uniqueID;
|
|
cue.number = keyValues.number;
|
|
cue.listName = keyValues.listName;
|
|
cue.isBroken = keyValues.isBroken;
|
|
cue.isRunning = keyValues.isRunning;
|
|
cue.isLoaded = keyValues.isLoaded;
|
|
cue.isFlagged = keyValues.isFlagged;
|
|
cue.type = keyValues.type;
|
|
cue.cues = keyValues.children;
|
|
cue.preWait = keyValues.preWait;
|
|
cue.postWait = keyValues.postWait;
|
|
cue.duration = keyValues.duration;
|
|
cue.colorName = keyValues.colorName;
|
|
cue.continueMode = keyValues.continueMode;
|
|
cue.mode = keyValues.mode;
|
|
cue.parent = keyValues.parent;
|
|
cue.cartRows = keyValues.cartRows;
|
|
cue.cartColumns = keyValues.cartColumns;
|
|
cue.cartPosition = keyValues.cartPosition;
|
|
cue.displayName = keyValues.displayName;
|
|
cue.preWaitElapsed = keyValues.preWaitElapsed;
|
|
cue.actionElapsed = keyValues.actionElapsed;
|
|
cue.postWaitElapsed = keyValues.postWaitElapsed;
|
|
cue.isPaused = keyValues.isPaused;
|
|
cue.currentCueTarget = keyValues.currentCueTarget;
|
|
cue.armed = keyValues.armed;
|
|
|
|
if (keyValues.isRunning) {
|
|
device.data.somethingPlaying = true;
|
|
}
|
|
|
|
let testCue = device.data.cueKeys[msgAddr[2]];
|
|
let nestedGroupModes;
|
|
|
|
if (cue.type === 'Group') {
|
|
nestedGroupModes = [testCue.mode];
|
|
} else if (cue.parent !== '[root group of cue lists]') {
|
|
nestedGroupModes = [device.data.cueKeys[cue.parent].mode];
|
|
}
|
|
|
|
while (testCue.parent !== '[root group of cue lists]') {
|
|
testCue = device.data.cueKeys[testCue.parent];
|
|
if (testCue === undefined) {
|
|
break;
|
|
}
|
|
|
|
nestedGroupModes.unshift(testCue.mode);
|
|
cue.nestedGroupModes = nestedGroupModes;
|
|
}
|
|
if (cue.type === 'Cue List' || cue.type === 'Group' || cue.type === 'Cart') {
|
|
if (device.data.cueKeys[msgAddr[2]].cueInWorkspace) {
|
|
device.data.cueKeys[msgAddr[2]].cueInWorkspace.cues = [...keyValues.children];
|
|
}
|
|
}
|
|
if (cue.type !== 'Cue List' && cue.type !== 'Cart') {
|
|
device.update('updateCueRow', { cue, workspace: device.data.workspaces[json.workspace_id] });
|
|
}
|
|
if (cue.type === 'Cart') {
|
|
device.draw();
|
|
}
|
|
} else if (/reply\/cue_id\/active\/.*Elapsed/.test(oscData.address)) {
|
|
const addrParts = json.address.split('/');
|
|
const cueID = addrParts[4];
|
|
const keyName = addrParts[5];
|
|
device.data.cueKeys[cueID][keyName] = json.data;
|
|
device.data.somethingPlaying = true;
|
|
device.draw();
|
|
} else if (/reply\/workspace\/.*\/selectedCues/.test(oscData.address)) {
|
|
const workspace = device.data.workspaces[msgAddr[2]];
|
|
if (!workspace) {
|
|
return;
|
|
}
|
|
workspace.selected = [];
|
|
for (let i = 0; i < json.data.length; i++) {
|
|
workspace.selected.push(json.data[i].uniqueID);
|
|
}
|
|
device.update('updatePlaybackAndSelected', { workspace: device.data.workspaces[json.workspace_id] });
|
|
} else if (/update\/workspace\/.*\/cue_id\/.*/.test(oscData.address)) {
|
|
if (device.data.cueKeys[msgAddr[4]] && device.data.cueKeys[msgAddr[4]].type === 'Group') {
|
|
device.send(`/workspace/${msgAddr[2]}/cueLists`);
|
|
} else if (device.data.cueKeys[msgAddr[4]] && device.data.cueKeys[msgAddr[4]].type === 'Cue List') {
|
|
device.send(`/workspace/${msgAddr[2]}/cueLists`);
|
|
} else if (device.data.cueKeys[msgAddr[4]] && device.data.cueKeys[msgAddr[4]].type === 'Cart') {
|
|
device.send(`/workspace/${msgAddr[2]}/cueLists`);
|
|
} else {
|
|
device.send(`/cue_id/${msgAddr[4]}/valuesForKeys`, [{ type: 's', value: valuesForKeysString }]);
|
|
}
|
|
} else if (/update\/workspace\/.*\/cueList\/.*\/playbackPosition/.test(oscData.address)) {
|
|
const workspace = device.data.workspaces[msgAddr[2]];
|
|
if (workspace) {
|
|
workspace.playbackPosition = oscData.args[0];
|
|
device.update('updatePlaybackAndSelected', { workspace: device.data.workspaces[msgAddr[2]] });
|
|
}
|
|
} else if (/update\/workspace\/.*\/dashboard/.test(oscData.address)) {
|
|
device.send(`/workspace/${msgAddr[2]}/selectedCues`);
|
|
device.send(`/cue_id/active/preWaitElapsed`);
|
|
}
|
|
};
|
|
|
|
function processCueList(list, knownCueIDs, _device, _nestedIndex) {
|
|
const nestedIndex = _nestedIndex;
|
|
const device = _device;
|
|
|
|
for (let i = 0; i < list.length; i++) {
|
|
const cue = list[i];
|
|
nestedIndex[nestedIndex.length - 1] = list.length - i - 1;
|
|
|
|
// if (!knownCueIDs.includes(cue.uniqueID)) {
|
|
device.send(`/cue_id/${cue.uniqueID}/valuesForKeys`, [{ type: 's', value: valuesForKeysString }]);
|
|
// }
|
|
|
|
if (cue.cues.length > 0) {
|
|
const nest2 = [..._nestedIndex];
|
|
nest2.push(cue.cues.length);
|
|
processCueList(cue.cues, knownCueIDs, device, nest2);
|
|
for (let j = 0; j < nestedIndex.length; j++) {
|
|
nestedIndex[j]++;
|
|
}
|
|
}
|
|
|
|
if (!knownCueIDs.includes(cue.uniqueID)) {
|
|
device.data.cueKeys[cue.uniqueID] = {
|
|
nestedGroupPosition: [...nestedIndex],
|
|
};
|
|
} else {
|
|
device.data.cueKeys[cue.uniqueID].nestedGroupPosition = [...nestedIndex];
|
|
}
|
|
|
|
device.data.cueKeys[cue.uniqueID].cueInWorkspace = list[i];
|
|
}
|
|
}
|
|
|
|
exports.update = function update(device, doc, updateType, data) {
|
|
if (updateType === 'updateCueRow') {
|
|
const $elem = doc.getElementById(data.cue.uniqueID);
|
|
if ($elem) {
|
|
if (device.data.cueKeys[data.cue.parent].type === 'Cart') {
|
|
$elem.outerHTML = device.templates.tile({
|
|
allCues: device.data.cueKeys,
|
|
cue: data.cue,
|
|
workspace: data.workspace,
|
|
});
|
|
} else {
|
|
$elem.outerHTML = device.templates.cue({
|
|
allCues: device.data.cueKeys,
|
|
cue: data.cue,
|
|
workspace: data.workspace,
|
|
});
|
|
}
|
|
}
|
|
} else if (updateType === 'updatePlaybackAndSelected') {
|
|
Array.from(doc.querySelectorAll('.selected')).forEach(($el) => {
|
|
$el.classList.remove('selected');
|
|
});
|
|
Array.from(doc.querySelectorAll('.playback-position')).forEach(($el) => {
|
|
$el.classList.remove('playback-position');
|
|
});
|
|
for (let i = 0; i < data.workspace.selected.length; i++) {
|
|
const $elem = doc.getElementById(data.workspace.selected[i]);
|
|
if ($elem) {
|
|
$elem.classList.add('selected');
|
|
}
|
|
}
|
|
if (data.workspace.playbackPosition) {
|
|
const $elem = doc.getElementById(data.workspace.playbackPosition);
|
|
if ($elem) {
|
|
$elem.classList.add('playback-position');
|
|
$elem.scrollIntoView({ behavior: 'smooth', block: 'center' });
|
|
}
|
|
}
|
|
}
|
|
};
|
|
|
|
let ticks = 0;
|
|
exports.heartbeat = function heartbeat(device) {
|
|
ticks++;
|
|
if (ticks % 10 === 0) {
|
|
device.send(`/thump`);
|
|
}
|
|
if (device.data.somethingPlaying) {
|
|
device.send(`/cue_id/active/preWaitElapsed`);
|
|
device.send(`/cue_id/active/postWaitElapsed`);
|
|
device.send(`/cue_id/active/actionElapsed`);
|
|
}
|
|
};
|