feat: Support for openMediaHotStandby disable heartbeat on secondary …

…when not used

packages/connector/src/MosConnection.ts

@@ -92,7 +92,7 @@ export class MosConnection extends EventEmitter<MosConnectionEvents> implements
 			this._debug,
 			this.mosTypes.strict
 		)
-		let secondary = null
+		let secondary: NCSServerConnection | null = null
 		this._ncsConnections[connectionOptions.primary.host] = primary
 
 		primary.on('rawMessage', (type: string, message: string) => {
@@ -174,6 +174,19 @@ export class MosConnection extends EventEmitter<MosConnectionEvents> implements
 					false
 				)
 			}
+			// Handle that openMediaHotStandby should not check for heartbeats on
+			// the secondary connection when the primary is connected
+			if (connectionOptions.secondary?.openMediaHotStandby) {
+				primary.on('connectionChanged', () => {
+					if (secondary) {
+						if (primary.connected) {
+							secondary.disableHeartbeats()
+						} else {
+							secondary.enableHeartbeats()
+						}
+					}
+				})
+			}
 		}
 
 		return this._registerMosDevice(

packages/connector/src/api.ts

@@ -663,5 +663,11 @@ export interface IMOSDeviceConnectionOptions {
 		 * Set this to true to not use that port (will cause some methods to stop working)
 		 */
 		dontUseQueryPort?: boolean
+
+		/** (Optional) OpenMedia has a term called hot standby.
+		 *  Set this to true to treat the secondary server as OpenMedia hot-standby.
+		 *  And thus ignore the standby state unless the primary server is down.
+		 */
+		openMediaHotStandby?: boolean
 	}
 }

packages/connector/src/connection/NCSServerConnection.ts

@@ -106,6 +106,20 @@ export class NCSServerConnection extends EventEmitter<NCSServerConnectionEvents>
 		delete this._clients[clientID]
 	}
 
+	/** */
+	disableHeartbeats(): void {
+		for (const i in this._clients) {
+			this._clients[i].useHeartbeats = false
+		}
+	}
+
+	/** */
+	enableHeartbeats(): void {
+		for (const i in this._clients) {
+			this._clients[i].useHeartbeats = true
+		}
+	}
+
 	connect(): void {
 		for (const i in this._clients) {
 			// Connect client