LINXD-2209: Check queue length

2022-09-13 20:09:25 +03:00
parent b834016dcb
commit 782b749ea3
2 changed files with 8 additions and 6 deletions
--- a/app.js
+++ b/app.js
@ -118,11 +118,13 @@ const mediaCodecs = [
  }

  setInterval(async () => {
-    const { callId, callback } = queue.shift();
-    if (router[callId] === undefined) {
-      router[callId] = await worker.createRouter({ mediaCodecs })
-      console.log(`[createRoom] Router ID: ${router[callId].id}`)
-      getRtpCapabilities(callId, callback)
+    if (queue.length > 0) {
+      const { callId, callback } = queue.shift();
+      if (router[callId] === undefined) {
+        router[callId] = await worker.createRouter({ mediaCodecs })
+        console.log(`[createRoom] Router ID: ${router[callId].id}`)
+        getRtpCapabilities(callId, callback)
+      }
    }
  }, 2000);