From 92fbecc36a39e8bb5239710e465d60891eb0fb9f Mon Sep 17 00:00:00 2001
From: Sergiu Toma <sergiu.toma@safemobile.com>
Date: Tue, 13 Dec 2022 13:04:43 +0200
Subject: [PATCH] Set initiatorSocketId to be dispatcher

---
 app.js | 13 ++++++++-----
 1 file changed, 8 insertions(+), 5 deletions(-)

diff --git a/app.js b/app.js
index 73e8418..4115016 100644
--- a/app.js
+++ b/app.js
@@ -200,9 +200,9 @@ peers.on('connection', async socket => {
           console.log('[createRoom] callId', callId);
           videoCalls[callId] = { router: await worker.createRouter({ mediaCodecs }) }
           console.log(`[createRoom] Router ID: ${videoCalls[callId].router.id}`);
-          videoCalls[callId].initiatorSockerId = socket.id
-        } else {
           videoCalls[callId].receiverSocketId = socket.id
+        } else {
+          videoCalls[callId].initiatorSockerId = socket.id
         }
         socketDetails[socket.id] = callId;
         // rtpCapabilities is set for callback
@@ -453,6 +453,10 @@ const consumeAudio = async (callId, rtpCapabilities) => {
     console.log('producer of consumer closed', callId);
     closeCall(callId);
   });
+  
+  if(isInitiator(callId, sockId)) {
+
+  }
   return {
     id: videoCalls[callId].consumerAudio.id,
     producerId: videoCalls[callId].producerAudio.id,
@@ -461,9 +465,8 @@ const consumeAudio = async (callId, rtpCapabilities) => {
   }
 }
 
-const isInitiator = async (callId, socketId) => {
-  if (videoCalls[callId].initiatorSockerId === socketId) return true;
-  else return false
+const isInitiator = (callId, socketId) => {
+  return (videoCalls[callId].initiatorSockerId === socketId);
 }
 
 /*