Merge pull request #442 from josephdadams/fix-vmix-emulator

josephdadams · May 11, 2022 · 4ac32d0 · 4ac32d0
2 parents 32518bd + c97a24c
commit 4ac32d0
Show file tree

Hide file tree

Showing 4 changed files with 8 additions and 6 deletions.
diff --git a/src/_modules/TSL.ts b/src/_modules/TSL.ts
@@ -11,8 +11,8 @@ import { Device } from "../_models/Device";
 export class TSLListenerProvider extends ListenerProvider {
     public tsl_clients: TSLClient[] = [];
 
-    constructor() {
-        super();
+    public start() {
+        logger('Starting TSL Listener Service.', 'info-quiet');
         logger(`Initiating ${currentConfig.tsl_clients.length} TSL Client Connections.`, 'info');
         for (const tslClient of currentConfig.tsl_clients) {
             logger(`TSL Client: ${tslClient.ip}:${tslClient.port} (${tslClient.transport})`, 'info-quiet');

diff --git a/src/_modules/VMix.ts b/src/_modules/VMix.ts
@@ -15,7 +15,8 @@ export class VMixEmulator extends ListenerProvider {
     public vmix_clients = []; // Clients currently connected to the VMix Emulator
     public vmix_client_data = []; // array of connected Vmix clients
 
-    public startVMixEmulator() {
+    public start() {
+        logger('Starting VMix Emulation Service.', 'info-quiet');
         this.server = net.createServer();
 
         this.server.on('connection', (socket) => this.handleConnection(socket));

diff --git a/src/_modules/_ListenerProvider.ts b/src/_modules/_ListenerProvider.ts
@@ -1,5 +1,5 @@
 import { EventEmitter } from "events";
 
-export class ListenerProvider extends EventEmitter {
-
+export abstract class ListenerProvider extends EventEmitter {
+    public start(): void {}
 }
diff --git a/src/index.ts b/src/index.ts
@@ -915,7 +915,7 @@ function initialSetup() {
 
 	logger('Socket.IO Setup Complete.', 'info-quiet');
 
-	logger('Starting VMix Emulation Service.', 'info-quiet');
+	logger('Starting Listener Providers.', 'info-quiet');
 
 	vMixEmulator = new VMixEmulator();
 	tslListenerProvider = new TSLListenerProvider();
@@ -927,6 +927,7 @@ function initialSetup() {
 			UpdateSockets(type);
 			UpdateCloud(type);
 		});
+		provider.start();
 	}
 
 	if (cloud_destinations.length > 0) {