From c370a455bde9e41a52b4a8fff323ea362cf1ccae Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=D0=9D=D0=B8=D0=BA=D0=B8=D1=82=D0=B0=20=D0=9A=D1=80=D1=83?=
 =?UTF-8?q?=D0=B3=D0=BB=D0=B8=D1=86=D0=BA=D0=B8=D0=B9?= <nvkrug@mts.ru>
Date: Sun, 5 Oct 2025 07:29:41 +0600
Subject: [PATCH] #4

---
 server/sockets/webrtc.ts | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/server/sockets/webrtc.ts b/server/sockets/webrtc.ts
index e63e736..5e76a41 100644
--- a/server/sockets/webrtc.ts
+++ b/server/sockets/webrtc.ts
@@ -126,8 +126,10 @@ export default function (io: SocketServer, router: types.Router) {
     socket.data.consumers = new Map()
 
     socket.on('join', async ({ username, rtpCapabilities }, cb) => {
-      if (socket.data.joined)
-        throw new Error('Already joined')
+      if (socket.data.joined) {
+        consola.error('[WebRtc]', 'Already joined')
+        cb({ error: 'Already joined' })
+      }
 
       socket.data.joined = true
       socket.data.username = username