Use app monitoring instead of polling to establish websocket connection

Fixes #366

com.neil-enns.trackaudio.sdPlugin/manifest.json

@@ -130,6 +130,10 @@
       ]
     }
   ],
+  "ApplicationsToMonitor": {
+    "mac": ["com.vatsim.trackaudio"],
+    "windows": ["trackaudio.exe"]
+  },
   "Category": "TrackAudio",
   "CategoryIcon": "images/plugin/categoryIcon",
   "CodePath": "bin/plugin.js",

src/events/action/removed.ts

@@ -1,21 +1,14 @@
 import actionManager from "@managers/action";
 import vatsimManager from "@managers/vatsim";
 import svgManager from "@managers/svg";
-import trackAudioManager from "@managers/trackAudio";
 
 export const handleRemoved = (count: number) => {
   if (count === 0) {
-    trackAudioManager.disconnect();
     svgManager.reset();
   }
 
   // If there are no more ATIS letter actions then stop polling VATSIM.
   if (actionManager.getAtisLetterControllers().length === 0) {
     vatsimManager.stop();
   }
-
-  // If there are no more actions at all stop trying to connect to TrackAudio
-  if (actionManager.getActions().length === 0) {
-    trackAudioManager.disconnect();
-  }
 };

src/events/streamDeck/applicationDidLaunch.ts

@@ -0,0 +1,10 @@
+import { ApplicationDidLaunchEvent } from "@elgato/streamdeck";
+import trackAudioManager from "@managers/trackAudio";
+import mainLogger from "@utils/logger";
+
+const logger = mainLogger.child({ service: "applicationDidLaunch" });
+
+export const handleOnApplicationDidLaunch = (ev: ApplicationDidLaunchEvent) => {
+  logger.info("Received applicationDidLaunch event", ev.application);
+  trackAudioManager.connect();
+};

src/events/streamDeck/applicationDidTerminate.ts

@@ -0,0 +1,14 @@
+import { ApplicationDidTerminateEvent } from "@elgato/streamdeck";
+import mainLogger from "@utils/logger";
+import trackAudioManager from "@managers/trackAudio";
+import vatsimManager from "@managers/vatsim";
+
+const logger = mainLogger.child({ service: "handleOnApplicationDidTerminate" });
+
+export const handleOnApplicationDidTerminate = (
+  ev: ApplicationDidTerminateEvent
+) => {
+  logger.info("Received applicationDidTerminate event", ev.application);
+  trackAudioManager.disconnect();
+  vatsimManager.stop();
+};

src/events/streamDeck/atisLetter/addAtisLetter.ts

@@ -17,5 +17,4 @@ export const handleAddAtisLetter = (
 
   actionManager.add(controller);
   actionManager.emit("atisLetterAdded", controller);
-  actionManager.emit("actionAdded", controller);
 };

src/events/streamDeck/hotline/addHotline.ts

@@ -18,5 +18,4 @@ export const handleAddHotline = (
   // Force buttons to refresh so the newly added button shows the correct state.
   actionManager.add(controller);
   actionManager.emit("hotlineAdded", controller);
-  actionManager.emit("actionAdded", controller);
 };

src/events/streamDeck/mainVolume/addMainVolume.ts

@@ -17,5 +17,4 @@ export const handleAddMainVolume = (
 
   actionManager.add(controller);
   actionManager.emit("mainVolumeAdded", controller);
-  actionManager.emit("actionAdded", controller);
 };

src/events/streamDeck/pushToTalk/addPushToTalk.ts

@@ -15,5 +15,4 @@ import actionManager from "@managers/action";
   actionManager.add(controller);
 
   actionManager.emit("pushToTalkAdded", controller);
-  actionManager.emit("actionAdded", controller);
 };

src/events/streamDeck/stationStatus/addStation.ts

@@ -17,5 +17,4 @@ export const handleAddStation = (
 
   actionManager.add(controller);
   actionManager.emit("stationStatusAdded", controller);
-  actionManager.emit("actionAdded", controller);
 };

src/events/streamDeck/stationVolume/addStationVolume.ts

@@ -17,5 +17,4 @@ export const handleAddStationVolume = (
 
   actionManager.add(controller);
   actionManager.emit("stationVolumeAdded", controller);
-  actionManager.emit("actionAdded", controller);
 };

src/events/streamDeck/trackAudioStatus/addTrackAudioStatus.ts

@@ -17,5 +17,4 @@ export const handleAddTrackAudioStatus = (
 
   actionManager.add(controller);
   actionManager.emit("trackAudioStatusAdded", controller);
-  actionManager.emit("actionAdded", controller);
 };

src/managers/action.ts

@@ -279,7 +279,6 @@ class ActionManager extends EventEmitter {
    */
   public add(controller: Controller): void {
     this.actions.push(controller);
-    this.emit("actionAdded", controller);
   }
 
   /**

src/plugin.ts

@@ -18,31 +18,32 @@ import { StationVolume } from "@actions/stationVolume";
 import { TrackAudioStatus } from "@actions/trackAudioStatus";
 
 // Event handlers
-import { MainVolume } from "@actions/mainVolume";
-import { handleActionAdded } from "@events/action/actionAdded";
 import { handleAtisLetterAdded } from "@events/action/atisLetterAdded";
 import { handleAtisLetterUpdated } from "@events/action/atisLetterUpdated";
-import { handleHotlineSettingsUpdated } from "@events/action/hotlineSettingsUpdated";
-import { handleMainVolumeAdded } from "@events/action/mainVolumeAdded";
-import { handleRemoved } from "@events/action/removed";
-import { handleStationStatusAdded } from "@events/action/stationStatusAdded";
-import { handleStationStatusSettingsUpdated } from "@events/action/stationStatusSettingsUpdated";
-import { handleStationVolumeAdded } from "@events/action/stationVolumeAdded";
-import { handleTrackAudioStatusAdded } from "@events/action/trackAudioStatusAdded";
-import { handleImageChanged } from "@events/svg/imageChanged";
 import { handleConnected } from "@events/trackAudio/connected";
 import { handleDisconnected } from "@events/trackAudio/disconnected";
 import { handleFrequencyRemoved } from "@events/trackAudio/frequencyRemoved";
+import { handleHotlineSettingsUpdated } from "@events/action/hotlineSettingsUpdated";
+import { handleImageChanged } from "@events/svg/imageChanged";
+import { handleMainVolumeAdded } from "@events/action/mainVolumeAdded";
 import { handleMainVolumeChange } from "@events/trackAudio/mainVolumeChange";
+import { handleOnApplicationDidLaunch } from "@events/streamDeck/applicationDidLaunch";
+import { handleOnApplicationDidTerminate } from "@events/streamDeck/applicationDidTerminate";
+import { handleRemoved } from "@events/action/removed";
 import { handleRxBegin } from "@events/trackAudio/rxBegin";
 import { handleRxEnd } from "@events/trackAudio/rxEnd";
 import { handleStationAdded } from "@events/trackAudio/stationAdded";
 import { handleStationStates } from "@events/trackAudio/stationStates";
 import { handleStationStateUpdate } from "@events/trackAudio/stationStateUpdate";
+import { handleStationStatusAdded } from "@events/action/stationStatusAdded";
+import { handleStationStatusSettingsUpdated } from "@events/action/stationStatusSettingsUpdated";
+import { handleStationVolumeAdded } from "@events/action/stationVolumeAdded";
+import { handleTrackAudioStatusAdded } from "@events/action/trackAudioStatusAdded";
 import { handleTxBegin } from "@events/trackAudio/txBegin";
 import { handleTxEnd } from "@events/trackAudio/txEnd";
-import { handleVoiceConnectedState } from "@events/trackAudio/voiceConnectedState";
 import { handleVatsimDataReceived } from "@events/vatsim/vatsimDataReceived";
+import { handleVoiceConnectedState } from "@events/trackAudio/voiceConnectedState";
+import { MainVolume } from "@actions/mainVolume";
 
 const logger = mainLogger.child({ service: "plugin" });
 
@@ -54,7 +55,7 @@ process.on("uncaughtException", (error) => {
   logger.error("Uncaught Exception:", error);
 });
 
-// Register all the event handlers
+// Register all the actions
 streamDeck.actions.registerAction(new AtisLetter());
 streamDeck.actions.registerAction(new Hotline());
 streamDeck.actions.registerAction(new PushToTalk());
@@ -63,6 +64,10 @@ streamDeck.actions.registerAction(new TrackAudioStatus());
 streamDeck.actions.registerAction(new StationVolume());
 streamDeck.actions.registerAction(new MainVolume());
 
+// Register the event handlers
+streamDeck.system.onApplicationDidLaunch(handleOnApplicationDidLaunch);
+streamDeck.system.onApplicationDidTerminate(handleOnApplicationDidTerminate);
+
 trackAudioManager.on("connected", () => {
   disconnectHandled = false;
   handleConnected();
@@ -99,7 +104,6 @@ actionManager.on("trackAudioStatusAdded", handleTrackAudioStatusAdded);
 actionManager.on("trackAudioStatusUpdated", handleTrackAudioStatusAdded);
 actionManager.on("atisLetterAdded", handleAtisLetterAdded);
 actionManager.on("atisLetterUpdated", handleAtisLetterUpdated);
-actionManager.on("actionAdded", handleActionAdded);
 actionManager.on("stationVolumeAdded", handleStationVolumeAdded);
 actionManager.on("mainVolumeAdded", handleMainVolumeAdded);