Update app.py

app.py

@@ -172,12 +172,14 @@ def room(token):
 
     <script src="https://cdnjs.cloudflare.com/ajax/libs/socket.io/4.5.1/socket.io.js"></script>
     <script>
-        // Используем относительный путь для подключения сокетов
         const socket = io();
         const token = '{{ token }}';
         const username = '{{ session['username'] }}';
         let localStream;
         const peers = {};
+        const iceConfig = {
+            iceServers: [{ urls: 'stun:stun.l.google.com:19302' }]
+        };
 
         // Получение локального видео/аудио потока
         navigator.mediaDevices.getUserMedia({ video: true, audio: true })
@@ -196,10 +198,8 @@ def room(token):
 
             const video = document.createElement('video');
             video.srcObject = stream;
-            // Важно для мобильных устройств:
             video.setAttribute('playsinline', '');
             video.setAttribute('autoplay', '');
-            // По умолчанию autoplay может блокироваться, поэтому вызываем play() явно
             video.addEventListener('loadedmetadata', () => {
                 video.play().catch(e => console.error('Autoplay error:', e));
             });
@@ -209,24 +209,28 @@ def room(token):
             document.getElementById('video-grid').appendChild(video);
         }
 
-        // Создание соединения с другим пользователем
-        function connectToUser(user) {
-            if (user === username || peers[user]) return;
-            console.log('Инициирую соединение с', user);
-            const peer = new RTCPeerConnection({
-                iceServers: [{ urls: 'stun:stun.l.google.com:19302' }]
-            });
-            peers[user] = peer;
 
-            localStream.getTracks().forEach(track => peer.addTrack(track, localStream));
 
-            peer.ontrack = event => {
+        // Создание соединения с другим пользователем (используется и при инициации, и при ответе)
+        function createPeerConnection(user) {
+            if (peers[user]) {
+                return peers[user].peerConnection; // Return existing connection
+            }
+
+            console.log('Создание RTCPeerConnection для', user);
+            const peerConnection = new RTCPeerConnection(iceConfig);
+            peers[user] = { peerConnection: peerConnection, iceCandidates: [] };
+
+            localStream.getTracks().forEach(track => peerConnection.addTrack(track, localStream));
+
+            peerConnection.ontrack = event => {
                 console.log('Получен поток от', user);
                 addVideoStream(event.streams[0], user);
             };
 
-            peer.onicecandidate = event => {
+            peerConnection.onicecandidate = event => {
                 if (event.candidate) {
+                    console.log('Отправка ICE-кандидата для', user);
                     socket.emit('signal', {
                         token: token,
                         from: username,
@@ -235,82 +239,94 @@ def room(token):
                     });
                 }
             };
-
-            peer.onnegotiationneeded = () => {
-                peer.createOffer()
-                    .then(offer => peer.setLocalDescription(offer))
-                    .then(() => {
-                        socket.emit('signal', {
-                            token: token,
-                            from: username,
-                            to: user,
-                            signal: peer.localDescription
-                        });
-                    })
-                    .catch(err => console.error('Ошибка создания предложения:', err));
-            };
+            return peerConnection;
         }
 
-        // Обработка входящих сигналов
+          // Обработка входящих сигналов
         socket.on('signal', data => {
-            // Если сигнал пришёл от нас же, игнорируем
             if (data.from === username) return;
             console.log('Получен сигнал от', data.from, ':', data.signal.type);
 
-            let peer = peers[data.from];
-            if (!peer) {
-                peer = new RTCPeerConnection({
-                    iceServers: [{ urls: 'stun:stun.l.google.com:19302' }]
-                });
-                peers[data.from] = peer;
-
-                localStream.getTracks().forEach(track => peer.addTrack(track, localStream));
-                peer.ontrack = event => addVideoStream(event.streams[0], data.from);
-                peer.onicecandidate = event => {
-                    if (event.candidate) {
+            let peerEntry = peers[data.from];
+            if (!peerEntry) {
+                 createPeerConnection(data.from);
+                 peerEntry = peers[data.from];
+            }
+            let peerConnection = peerEntry.peerConnection;
+
+            if (data.signal.type === 'offer') {
+                console.log('Обработка предложения от', data.from);
+                peerConnection.setRemoteDescription(new RTCSessionDescription(data.signal))
+                    .then(() => peerConnection.createAnswer())
+                    .then(answer => peerConnection.setLocalDescription(answer))
+                    .then(() => {
                         socket.emit('signal', {
                             token: token,
                             from: username,
                             to: data.from,
-                            signal: { type: 'candidate', candidate: event.candidate }
+                            signal: peerConnection.localDescription
                         });
-                    }
-                };
-            }
-
-            if (data.signal.type === 'offer') {
-                peer.setRemoteDescription(new RTCSessionDescription(data.signal))
-                    .then(() => peer.createAnswer())
-                    .then(answer => peer.setLocalDescription(answer))
-                    .then(() => socket.emit('signal', {
-                        token: token,
-                        from: username,
-                        to: data.from,
-                        signal: peer.localDescription
-                    }))
+                        //Добавление ICE-кандидатов из буффера
+                        while (peerEntry.iceCandidates.length > 0) {
+                            const candidate = peerEntry.iceCandidates.shift();
+                            peerConnection.addIceCandidate(new RTCIceCandidate(candidate))
+                            .catch(err => console.error("Error adding ice candidate from buffer", err));
+                        }
+                    })
                     .catch(err => console.error('Ошибка обработки предложения:', err));
+
             } else if (data.signal.type === 'answer') {
-                peer.setRemoteDescription(new RTCSessionDescription(data.signal))
-                    .catch(err => console.error('Ошибка установки ответа:', err));
+                console.log('Обработка ответа от', data.from);
+                peerConnection.setRemoteDescription(new RTCSessionDescription(data.signal))
+                 .then(() => {
+                     //Добавление ICE-кандидатов из буффера
+                    while (peerEntry.iceCandidates.length > 0) {
+                        const candidate = peerEntry.iceCandidates.shift();
+                        peerConnection.addIceCandidate(new RTCIceCandidate(candidate))
+                        .catch(err => console.error("Error adding ice candidate from buffer", err));
+                    }
+                 })
+                .catch(err => console.error('Ошибка установки ответа:', err));
+
             } else if (data.signal.type === 'candidate') {
-                peer.addIceCandidate(new RTCIceCandidate(data.signal.candidate))
-                    .catch(err => console.error('Ошибка добавления кандидата:', err));
+                console.log('Обработка ICE-кандидата от', data.from);
+                if (peerConnection.remoteDescription) {
+                    peerConnection.addIceCandidate(new RTCIceCandidate(data.signal.candidate))
+                        .catch(err => console.error('Ошибка добавления ICE-кандидата:', err));
+                } else {
+                    // Если remote description еще не установлен, добавляем в буфер
+                    peerEntry.iceCandidates.push(data.signal.candidate);
+                    console.log("Ice candidate buffered for", data.from)
+                }
             }
         });
-
         socket.on('user_joined', data => {
             console.log('Пользователь', data.username, 'присоединился');
             document.getElementById('users').innerText = 'Пользователи: ' + data.users.join(', ');
+
             if (data.username !== username) {
-                connectToUser(data.username);
+                const peerConnection = createPeerConnection(data.username);
+                // Создание предложения (offer), только если мы инициатор
+                peerConnection.createOffer()
+                    .then(offer => peerConnection.setLocalDescription(offer))
+                    .then(() => {
+                        socket.emit('signal', {
+                            token: token,
+                            from: username,
+                            to: data.username,
+                            signal: peerConnection.localDescription
+                        });
+                    })
+                    .catch(err => console.error('Ошибка создания п��едложения:', err));
             }
         });
 
+
         socket.on('user_left', data => {
             console.log('Пользователь', data.username, 'покинул комнату');
             document.getElementById('users').innerText = 'Пользователи: ' + data.users.join(', ');
             if (peers[data.username]) {
-                peers[data.username].close();
+                peers[data.username].peerConnection.close();
                 delete peers[data.username];
                 const video = document.querySelector(`video[data-user="${data.username}"]`);
                 if (video) video.remove();
@@ -320,15 +336,16 @@ def room(token):
         socket.on('init_users', data => {
             console.log('Инициализация пользователей:', data.users);
             data.users.forEach(user => {
-                if (user !== username) connectToUser(user);
+                if (user !== username) {
+                   createPeerConnection(user);  // Создаем RTCPeerConnection для всех, *кроме себя*
+                }
             });
         });
-
         function leaveRoom() {
             socket.emit('leave', { token: token, username: username });
             localStream.getTracks().forEach(track => track.stop());
             for (let user in peers) {
-                peers[user].close();
+                peers[user].peerConnection.close();
             }
             window.location.href = '/dashboard';
         }