From 380299295d839f478a61dc175c02a71e1b2e45d7 Mon Sep 17 00:00:00 2001
From: set <set>
Date: Mon, 16 Mar 2026 19:25:28 +0200
Subject: [PATCH] =?UTF-8?q?=D0=98=D1=81=D0=BF=D1=80=D0=B0=D0=B2=D0=BB?=
 =?UTF-8?q?=D0=B5=D0=BD=D0=B8=D0=B5=20=D1=84=D0=BE=D1=80=D0=B2=D0=B0=D1=80?=
 =?UTF-8?q?=D0=B4=D0=B8=D0=BD=D0=B3=D0=B0=20RTP?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 sfu/forwarding.go | 13 ++++++++++---
 1 file changed, 10 insertions(+), 3 deletions(-)

diff --git a/sfu/forwarding.go b/sfu/forwarding.go
index aaa7a70..f1e985b 100644
--- a/sfu/forwarding.go
+++ b/sfu/forwarding.go
@@ -92,6 +92,13 @@ func BindPeerLifecycle(roomID, peerID string, pc *webrtc.PeerConnection) {
 		timer         *time.Timer
 	)
 
+	room, exists := GetRoom(roomID)
+	if !exists {
+		logger.LogWarnMessage("BindPeerLifecycle: tried to bind non existing room " + roomID)
+		return
+	}
+	server := room.Server
+
 	startTimer := func() {
 		mu.Lock()
 		defer mu.Unlock()
@@ -109,7 +116,7 @@ func BindPeerLifecycle(roomID, peerID string, pc *webrtc.PeerConnection) {
 			}
 			_ = LeaveRoom(roomID, peerID)
 			if OnPeerDisconnected != nil {
-				OnPeerDisconnected(roomID, peerID)
+				OnPeerDisconnected(roomID, peerID, server)
 			}
 		})
 	}
@@ -134,7 +141,7 @@ func BindPeerLifecycle(roomID, peerID string, pc *webrtc.PeerConnection) {
 			cancelTimer()
 			_ = LeaveRoom(roomID, peerID)
 			if OnPeerDisconnected != nil {
-				OnPeerDisconnected(roomID, peerID)
+				OnPeerDisconnected(roomID, peerID, server)
 			}
 		}
 	})
@@ -149,7 +156,7 @@ func BindPeerLifecycle(roomID, peerID string, pc *webrtc.PeerConnection) {
 			cancelTimer()
 			_ = LeaveRoom(roomID, peerID)
 			if OnPeerDisconnected != nil {
-				OnPeerDisconnected(roomID, peerID)
+				OnPeerDisconnected(roomID, peerID, server)
 			}
 		}
 	})