Backup latest state. Note that this is no longer actively developed!

Author: chrisspiegl

ControlThemAll.js

@@ -1,10 +1,12 @@
+import process from 'node:process'
 import { find, isEmpty, difference, flatten } from 'lodash-es'
 import got from 'got'
 import delay from 'delay'
 import merge from 'deepmerge'
 import { Enums } from 'atem-connection'
 
-import beforeShutdown from './beforeShutdown.js'
+import exitHook from 'exit-hook'
+// import beforeShutdown from './beforeShutdown.js'
 import { ControllerWebServer } from './ControllerWebServer.js'
 import { ControllerAtem } from './ControllerAtem.js'
 import { ControllerMidi } from './ControllerMidi.js'
@@ -36,19 +38,16 @@ export class ControlThemAll {
 
   async setup() {
     console.log('Setting up ControlThemAll Backend')
-    // // Do something when app is closing
-    // process.on('exit', this.exitHandler.bind(this, { exit: true }))
-    // // catches ctrl+c event
-    // process.on('SIGINT', this.exitHandler.bind(this, {cleanup: true}));
-    // // Catches "kill pid" (for example: nodemon restart)
-    // process.on('SIGUSR1', this.exitHandler.bind(this, {exit: true}));
-    // process.on('SIGUSR2', this.exitHandler.bind(this, {exit: true, cleanup: true}));
-    // // Catches uncaught exceptions
-    // process.on('uncaughtException', this.exitHandler.bind(this, {exit: true}));
-    // process.on('uncaughtException', (reason) => console.log('UNHANDLED EXCEPTION:', reason))
-    // process.on('unhandledRejection', reason => console.log('UNHANDLED REJECTION:', reason));
-
-    beforeShutdown(this.exitHandler.bind(this, { cleanup: true, exit: true }))
+
+    process.on('exit', (t) => console.log('process.on : exit:', t))
+    process.on('SIGINT', (t) => console.log('process.on : SIGINT:', t))
+    process.on('SIGUSR1', (t) => console.log('process.on : SIGUSR1:', t))
+    process.on('SIGUSR2', (t) => console.log('process.on : SIGUSR2:', t))
+    process.on('uncaughtException', (t) => console.log('process.on : uncaughtException:', t))
+    process.on('uncaughtException', (t) => console.log('process.on : uncaughtException:', t))
+    process.on('unhandledRejection', (t) => console.log('process.on : unhandledRejection:', t))
+
+    exitHook(this.exitHandler.bind(this))
 
     this.controllerConfig = new ControllerConfig()
     this.config = await this.controllerConfig.getConfig()
@@ -1092,57 +1091,43 @@ export class ControlThemAll {
     }
   }
 
-  async exitHandler(options, exitCode) {
-    console.log(`exitHandler with exitCode: ${exitCode || 'NONE'}`)
-
-    // SetTimeout(error => {
-    // 	// Force close server after timeout (this is if the cleanUp takes too long)
-    // 	console.log('gentle took too long exiting hard');
-    // 	process.exit(1);
-    // }, 10 * 1000); // 10 seconds
+  exitHandler() {
+    console.log(`running exitHandler for cleanup`)
 
-    if (options.cleanup) {
-      console.log('ControlThemAll: Doing the cleanup.')
-
-      if (this.controllerMidi && this.controllerMidi.isConnected()) {
-        this.switchButtonLightOff(flatten(this.config.buttons.map((element) => [element.note])))
-        this.controllerMidi.updateButtonsViaState(this.config.buttons)
-        this.updateControllerState(this.config.controllers.map((element) => merge(element, { state: 'cc', value: 0 })))
-        this.controllerMidi.updateControllersViaState(this.config.controllers)
-      }
-
-      if (this.controllerWebServer) {
-        console.log('before web server disconnect')
-        console.log(await this.controllerWebServer.disconnect())
-        console.log('after web server disconnect')
-      }
-
-      if (this.controllerMidi) {
-        console.log('before midi disconnect')
-        console.log(await this.controllerMidi.disconnect())
-        console.log('after midi disconnect')
-      }
+    if (this.controllerMidi && this.controllerMidi.isConnected()) {
+      this.switchButtonLightOff(flatten(this.config.buttons.map((element) => [element.note])))
+      this.controllerMidi.updateButtonsViaState(this.config.buttons)
+      this.updateControllerState(this.config.controllers.map((element) => merge(element, { state: 'cc', value: 0 })))
+      this.controllerMidi.updateControllersViaState(this.config.controllers)
+    }
 
-      if (this.controllerStreamDeck) {
-        console.log('before stream deck disconnect')
-        console.log(await this.controllerStreamDeck.disconnect())
-        console.log('after stream deck disconnect')
-      }
+    if (this.controllerWebServer) {
+      console.log('before web server disconnect')
+      this.controllerWebServer.disconnect()
+      delete this.controllerWebServer
+      console.log('after web server disconnect')
+    }
 
-      if (this.controllerAtem) {
-        console.log('before atem disconnect')
-        console.log(await this.controllerAtem.disconnect())
-        console.log('after atem disconnect')
-      }
-      // Await this.controllerHotkeys.disconnect()
+    if (this.controllerMidi) {
+      console.log('before midi disconnect')
+      this.controllerMidi.disconnect()
+      delete this.controllerMidi
+      console.log('after midi disconnect')
+    }
 
-      console.log('ControlThemAll closed, cleaned, and shutting down!')
+    if (this.controllerAtem) {
+      console.log('before atem disconnect')
+      this.controllerAtem.disconnect()
+      delete this.controllerAtem
+      console.log('after atem disconnect')
     }
 
-    // if (options.exit) {
-    //   console.log('ControlThemAll closed all connections successfully… shuting down…')
-    //   process.exit()
-    // }
+    if (this.controllerStreamDeck) {
+      console.log('before stream deck disconnect')
+      this.controllerStreamDeck.disconnect()
+      delete this.controllerStreamDeck
+      console.log('after stream deck disconnect')
+    }
   }
 }
 

ControllerStreamDeck.js

@@ -82,12 +82,19 @@ export class ControllerStreamDeck extends EventEmitter {
   }
 
   async disconnect() {
-    console.log('stream deck disconnecting?!')
-    await this._streamDeck.resetToLogo()
-    this._streamDeck.removeAllListeners()
-    await this._streamDeck.close()
-    delete this._streamDeck
-    this.emit('disconnect', { sessionId: this.sessionId })
+    try {
+      this._streamDeck.resetToLogo()
+      this._streamDeck.removeAllListeners()
+      if (this._streamDeck) {
+        this._streamDeck.close()
+        delete this._streamDeck
+      }
+
+      this.emit('disconnect', { sessionId: this.sessionId })
+      return { sessionId: this.sessionId }
+    } catch (error) {
+      console.log('error while closing stream deck', error)
+    }
   }
 
   async send(options) {

beforeShutdown.js

@@ -132,7 +132,7 @@ streamDeck:
 
 atem:
   enabled: false
-  address: 192.168.10.240
+  address: 192.168.178.240
 
 hotkeys:
   enabled: false
@@ -499,14 +499,17 @@ buttons:
     noteOff:
       action: ChangeProgramSource
       programInput: cam2
+      withUpstreamKeyer: true
   - note: 10
     noteOff:
       action: ChangeProgramSource
       programInput: cam3
+      withUpstreamKeyer: true
   - note: 11
     noteOff:
       action: ChangeProgramSource
       programInput: cam4
+      withUpstreamKeyer: true
   - note: 12
     noteOff:
       action: ChangeDveStyle
@@ -572,17 +575,14 @@ buttons:
     noteOff:
       action: ChangeProgramSource
       programInput: cam2
-      withUpstreamKeyer: true
   - note: 18
     noteOff:
       action: ChangeProgramSource
       programInput: cam3
-      withUpstreamKeyer: true
   - note: 19
     noteOff:
       action: ChangeProgramSource
       programInput: cam4
-      withUpstreamKeyer: true
   - note: 20
     noteOff:
       action: ChangeUpstreamKeyerFillSource
@@ -653,12 +653,12 @@ buttons:
   - note: 34
     noteOff:
       action: ChangeProgramSource
-      programInput: cam4
+      programInput: cam2
       withUpstreamKeyer: true
   - note: 35
     noteOff:
       action: ChangeProgramSource
-      programInput: cam2
+      programInput: cam4
       withUpstreamKeyer: true
   - note: 36
     noteOff:
@@ -681,7 +681,12 @@ buttons:
       action: SwitchProgramAndUpstreamKeyerFillSource
   - note: 39
     noteOff:
-      action: FadeToBlack
+      # action: FadeToBlack'
+      action: ToggleAudioSourceMixOption
+      audioIndex: 1301
+      channels: ['-65280'] # stereo split channels: ['-255', '-256'] | joined channel: ['-65280']
+      defaultValue: on
+      toggle: ['on', 'off']
   # LAYER B - BUTTONS LOWER ROW
   - note: 40
     noteOff:
@@ -694,11 +699,11 @@ buttons:
   - note: 42
     noteOff:
       action: ChangeProgramSource
-      programInput: cam4
+      programInput: cam2
   - note: 43
     noteOff:
       action: ChangeProgramSource
-      programInput: cam2
+      programInput: cam4
   - note: 44
     noteOff:
       action: ChangeUpstreamKeyerFillSource
@@ -754,18 +759,18 @@ feedback:
 
   buttonsForProgramInputWithoutDve:
     cam1: [16, 40]
-    cam2: [9, 43]
-    cam3: [10, 41]
-    cam4: [11, 42]
+    cam2: [17, 42]
+    cam3: [18, 41]
+    cam4: [19, 43]
 
   buttonsForProgramInputWithDve:
     cam1: [8, 32]
-    cam2: [17, 35]
-    cam3: [18, 33]
-    cam4: [19, 34]
+    cam2: [9, 34]
+    cam3: [10, 33]
+    cam4: [11, 35]
 
   buttonsForActiveUpstreamKeyerFillSource:
     cam1: [20, 44]
-    cam2: [21, 47]
+    cam2: [21, 46]
     cam3: [22, 45]
-    cam4: [23, 46]
+    cam4: [23, 47]

config.default.yaml

@@ -2,10 +2,12 @@ webServer:
   enabled: false
 
 midi:
-  enabled: false
+  enabled: true
 
 atem:
-  enabled: false
+  enabled: true
 
 streamDeck:
   enabled: false
+  model: 'original-mk2'
+  serialNumber: 'DL42K1A08814'

config.user.yaml

@@ -27,6 +27,7 @@
     "delay": "^5.0.0",
     "detect-port": "^1.3.0",
     "easymidi": "^2.1.0",
+    "exit-hook": "^3.0.0",
     "express": "^4.17.2",
     "fabric": "^4.6.0",
     "got": "^12.0.1",