Fixed retrying after mqtt disconnect

foxford · Mar 20, 2023 · a37b1ce · a37b1ce
1 parent 0109a29
commit a37b1ce
Show file tree

Hide file tree

Showing 3 changed files with 12 additions and 3 deletions.
diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@ulms/api-clients",
-  "version": "5.16.0",
+  "version": "5.16.1",
   "description": "JavaScript API clients for ULMS platform",
   "keywords": [],
   "homepage": "https://github.com/foxford/ulms-api-clients-js#readme",

diff --git a/src/common.js b/src/common.js
@@ -66,6 +66,7 @@ export async function enterServiceRoom(
   serviceName
 ) {
   const EVENT_NAME = 'room.enter'
+  const isTransportConnected = () => client.mqtt.connected
   let enterRoomSuccess = false
   let response
 
@@ -82,9 +83,17 @@ export async function enterServiceRoom(
   try {
     // eslint-disable-next-line no-constant-condition
     while (true) {
+      if (!isTransportConnected()) {
+        throw new Error('MQTT client disconnected')
+      }
+
       // eslint-disable-next-line no-await-in-loop
       response = await httpClient.enterRoom(roomId, label)
 
+      if (!isTransportConnected()) {
+        throw new Error('MQTT client disconnected')
+      }
+
       if (enterRoomSuccess) break
 
       // eslint-disable-next-line no-await-in-loop