Added backoff delay to enterServiceRoom function

foxford · Aug 28, 2023 · b36a7e8 · b36a7e8
1 parent 6223979
commit b36a7e8
Show file tree

Hide file tree

Showing 3 changed files with 15 additions and 5 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.27.0",
+  "version": "5.28.0",
   "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
@@ -1,3 +1,4 @@
+import Backoff from './backoff'
 import { TimeoutError } from './error'
 
 // eslint-disable-next-line default-param-last
@@ -61,10 +62,11 @@ export async function enterServiceRoom(
   roomId,
   id,
   label,
-  delay,
+  minDelay,
   trackEvent,
   serviceName
 ) {
+  const backoff = new Backoff(minDelay)
   const EVENT_NAME = 'room.enter'
   const isTransportConnected = () => client.mqtt.connected
   let enterRoomSuccess = false
@@ -97,16 +99,24 @@ export async function enterServiceRoom(
       if (enterRoomSuccess) break
 
       // eslint-disable-next-line no-await-in-loop
-      await sleep(delay)
+      await sleep(backoff.value)
+
+      backoff.next()
+
+      if (enterRoomSuccess) break
 
       trackEvent('Debug', `${serviceName}.Subscription.Retry`)
     }
   } catch (error) {
     client.off(EVENT_NAME, handler)
 
+    backoff.reset()
+
     throw error
   }
 
+  backoff.reset()
+
   return response
 }