Fixed NATSManager

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@ulms/api-clients",
-  "version": "7.23.0",
+  "version": "7.23.1",
   "description": "JavaScript API clients for ULMS platform",
   "keywords": [],
   "homepage": "https://github.com/foxford/ulms-api-clients-js#readme",

src/common.js

@@ -53,6 +53,10 @@ export function enterRoom(client, roomId, agentId, timeout = 5000) {
   })
 }
 
+export function generateRandomId() {
+  return Math.random().toString(36).slice(2, 8)
+}
+
 export const sleep = async (ms) =>
   new Promise((resolve) => {
     setTimeout(resolve, ms)

src/nats-manager.js

@@ -1,12 +1,13 @@
 /* eslint-disable no-await-in-loop */
 import Backoff from './backoff'
-import { sleep, timeout } from './common'
+import { generateRandomId, sleep, timeout } from './common'
 
 class NatsManager {
   constructor(client, gatekeeper, nsm, vsm) {
     this.client = client
     this.gatekeeper = gatekeeper
     this.gatekeeperBackoff = new Backoff()
+    this.id = undefined // local connection identifier (prevent simultaneous connections)
     this.nsm = nsm // NetworkStatusMonitor instance
     this.vsm = vsm // VisibilityStateMonitor instance
 
@@ -48,6 +49,9 @@ class NatsManager {
   }
 
   async start(classId, name, accountLabel) {
+    const rid = generateRandomId()
+
+    this.id = rid
     this.forcedStop = false
 
     // eslint-disable-next-line no-constant-condition
@@ -86,6 +90,11 @@ class NatsManager {
       if (this.forcedStop) {
         break
       }
+
+      // prevent multiple connections
+      if (this.id !== rid) {
+        break
+      }
     }
   }
 

src/ws-transport.js

@@ -1,11 +1,9 @@
 import Debug from 'debug'
 
-import { makeDeferred } from './common'
+import { generateRandomId, makeDeferred } from './common'
 
 const debug = Debug('ws-transport')
 
-const generateRandomId = () => Math.random().toString(36).slice(2, 8)
-
 const KEEP_ALIVE_MESSAGE = '-'
 const KEEP_ALIVE_TIMED_OUT_ERROR_PAYLOAD = {
   payload: {