- <% Object.entries(data.source).forEach(([sourceID, state])=>{ %>
- <% if (state.tally && state.tally.program) { %>
-
-
- <%= state.abbreviation %>
+<% if (data.video.mixEffects) { %>
+
+<% Object.entries(data.video.mixEffects).forEach(([meIndex, state])=>{ %>
+
+
ME<%= Number(meIndex) + 1 %>
+
+
Program
+
+ <% Object.entries(data.inputs).forEach(([inputId, state])=>{ %>
+
-
- <% } else { %>
-
+
+
+
Preview
+
+ <% Object.entries(data.inputs).forEach(([inputId, state])=>{ %>
+
-
- <% } %>
- <% }) %>
+ <% }) %>
+
+
+
+
+
+
+
+
+
+
-
+<% }) %>
+<% } %>
-
-
Preview
-
- <% Object.entries(data.source).forEach(([sourceID, state])=>{ %>
- <% if (state.tally && state.tally.preview) { %>
-
- <% } else { %>
-
- <% } %>
- <% }) %>
-
-
-
+<% if (data.video.downstreamKeyers) { %>
+ <% Object.entries(data.video.downstreamKeyers).forEach(([dskIndex, state])=>{ %>
+
+
DSK<%= Number(dskIndex) + 1 %>
+
+
+ <% }) %>
+<% } %>
+
diff --git a/src/device.js b/src/device.js
index 924878a..f098a97 100644
--- a/src/device.js
+++ b/src/device.js
@@ -2,7 +2,7 @@ const { v4: uuid } = require('uuid');
const osc = require('osc');
const net = require('net');
const udp = require('dgram');
-const Atem = require('atem');
+const { Atem } = require('atem-connection');
const PLUGINS = require('./plugins.js');
const VIEW = require('./view.js');
const SAVESLOTS = require('./saveSlots.js');
@@ -194,45 +194,24 @@ function initDeviceConnection(id) {
device.send = (data) => {};
} else if (plugins[type].config.connectionType === 'atem') {
- device.connection = new Atem(device.addresses[0]);
- device.connection.on('connectionStateChange', (state) => {
- plugins[type].ready(device);
+ device.connection = new Atem({
+ // this gets around the no workers nodejs error
+ disableMultithreaded: true,
+ });
+ device.connection.connect(device.addresses[0]);
+
+ device.connection.on('connected', () => {
infoUpdate(device, 'status', 'ok');
- const msg = {
- event: 'connectionStateChange',
+ plugins[type].ready(device);
+ });
+
+ device.connection.on('stateChanged', (state, pathToChange) => {
+ device.lastMessage = Date.now();
+ plugins[type].data(device, {
+ pathToChange,
state,
- };
- plugins[type].data(device, msg);
- });
-
- device.connection.on('sourceTally', (sourceID, state) => {
- const msg = {
- event: 'sourceTally',
- sourceID,
- state,
- };
- plugins[type].data(device, msg);
- });
-
- device.connection.on('sourceConfiguration', (sourceID, sourceConfiguration) => {
- const msg = {
- event: 'sourceConfiguration',
- sourceID,
- sourceConfiguration,
- };
- plugins[type].data(device, msg);
- });
-
- device.connection.on('rawCommand', (cmd) => {
- const msg = {
- event: 'rawCommand',
- cmd,
- };
- plugins[type].data(device, msg);
- });
-
- device.connection.on('connectionLost', () => {
- console.log('connection lost');
+ });
+ infoUpdate(device, 'status', 'ok');
});
}