From 53d51d446a52547c41b381722b2e2ace53540c15 Mon Sep 17 00:00:00 2001
From: benyamin <benman@duck.com>
Date: Fri, 4 Aug 2023 16:07:47 +0330
Subject: [PATCH] fix: handshake mutex was keeping the room mutex in locked
 state

---
 repositories/room.go | 17 ++++++++++-------
 1 file changed, 10 insertions(+), 7 deletions(-)

diff --git a/repositories/room.go b/repositories/room.go
index 573eed5..8b00a13 100644
--- a/repositories/room.go
+++ b/repositories/room.go
@@ -25,6 +25,7 @@ type Peer struct {
 	Conn          *webrtc.PeerConnection
 	CanPublish    bool
 	HandshakeLock *sync.Mutex
+	didOnce       bool
 }
 
 type Room struct {
@@ -237,7 +238,7 @@ func (r *RoomRepository) updatePCTracks(roomId string) {
 		return
 	}
 	room := r.Rooms[roomId]
-	defer r.Unlock()
+	r.Unlock()
 	room.Lock()
 	defer room.Unlock()
 	for _, peer := range room.Peers {
@@ -278,17 +279,19 @@ func (r *RoomRepository) updatePCTracks(roomId string) {
 		for trackId, rtpSender := range alreadySentTracks {
 			if _, exists := room.Tracks[trackId]; !exists {
 				println("[PC] remove track", trackId, "from", peer.ID)
-				_ = rtpSender.Stop()
+				//_ = rtpSender.Stop()
 				_ = peer.Conn.RemoveTrack(rtpSender)
 			}
 		}
 		room.trackLock.Unlock()
 		if renegotiate {
-			err := r.offerPeer(peer, roomId)
-			if err != nil {
-				println(`[E]`, err.Error())
-				return
-			}
+			go func(peer *Peer, roomId string) {
+				err := r.offerPeer(peer, roomId)
+				if err != nil {
+					println(`[E]`, err.Error())
+					return
+				}
+			}(peer, roomId)
 		}
 	}
 }