Update app.py

app.py

@@ -190,12 +190,20 @@ def room(token):
 
         // Добавление видео в сетку
         function addVideoStream(stream, user, muted = false) {
-            console.log(`Добавление видео для ${user}`);
+            console.log('Добавление видео для', user);
             const existingVideo = document.querySelector(`video[data-user="${user}"]`);
             if (existingVideo) return;
+
             const video = document.createElement('video');
             video.srcObject = stream;
-            video.addEventListener('loadedmetadata', () => video.play());
+            // Важно для мобильных устройств:
+            video.setAttribute('playsinline', '');
+            video.setAttribute('autoplay', '');
+            // По умолчанию autoplay может блокироваться, поэтому вызываем play() явно
+            video.addEventListener('loadedmetadata', () => {
+                video.play().catch(e => console.error('Autoplay error:', e));
+            });
+
             if (muted) video.muted = true;
             video.dataset.user = user;
             document.getElementById('video-grid').appendChild(video);
@@ -204,7 +212,7 @@ def room(token):
         // Создание соединения с другим пользователем
         function connectToUser(user) {
             if (user === username || peers[user]) return;
-            console.log(`Инициирую соединение с ${user}`);
+            console.log('Инициирую соединение с', user);
             const peer = new RTCPeerConnection({
                 iceServers: [{ urls: 'stun:stun.l.google.com:19302' }]
             });
@@ -213,13 +221,18 @@ def room(token):
             localStream.getTracks().forEach(track => peer.addTrack(track, localStream));
 
             peer.ontrack = event => {
-                console.log(`Получен поток от ${user}`);
+                console.log('Получен поток от', user);
                 addVideoStream(event.streams[0], user);
             };
 
             peer.onicecandidate = event => {
                 if (event.candidate) {
-                    socket.emit('signal', { token: token, from: username, to: user, signal: { type: 'candidate', candidate: event.candidate } });
+                    socket.emit('signal', {
+                        token: token,
+                        from: username,
+                        to: user,
+                        signal: { type: 'candidate', candidate: event.candidate }
+                    });
                 }
             };
 
@@ -227,7 +240,12 @@ def room(token):
                 peer.createOffer()
                     .then(offer => peer.setLocalDescription(offer))
                     .then(() => {
-                        socket.emit('signal', { token: token, from: username, to: user, signal: peer.localDescription });
+                        socket.emit('signal', {
+                            token: token,
+                            from: username,
+                            to: user,
+                            signal: peer.localDescription
+                        });
                     })
                     .catch(err => console.error('Ошибка создания предложения:', err));
             };
@@ -235,19 +253,27 @@ def room(token):
 
         // Обработка входящих сигналов
         socket.on('signal', data => {
+            // Если сигнал пришёл от нас же, игнорируем
             if (data.from === username) return;
-            console.log(`Получен сигнал от ${data.from}: ${data.signal.type}`);
+            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) {
-                        socket.emit('signal', { token: token, from: username, to: data.from, signal: { type: 'candidate', candidate: event.candidate } });
+                        socket.emit('signal', {
+                            token: token,
+                            from: username,
+                            to: data.from,
+                            signal: { type: 'candidate', candidate: event.candidate }
+                        });
                     }
                 };
             }
@@ -256,7 +282,12 @@ def room(token):
                 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 }))
+                    .then(() => socket.emit('signal', {
+                        token: token,
+                        from: username,
+                        to: data.from,
+                        signal: peer.localDescription
+                    }))
                     .catch(err => console.error('Ошибка обработки предложения:', err));
             } else if (data.signal.type === 'answer') {
                 peer.setRemoteDescription(new RTCSessionDescription(data.signal))
@@ -268,7 +299,7 @@ def room(token):
         });
 
         socket.on('user_joined', data => {
-            console.log(`Пользователь ${data.username} присоединился`);
+            console.log('Пользователь', data.username, 'присоединился');
             document.getElementById('users').innerText = 'Пользователи: ' + data.users.join(', ');
             if (data.username !== username) {
                 connectToUser(data.username);
@@ -276,7 +307,7 @@ def room(token):
         });
 
         socket.on('user_left', data => {
-            console.log(`Пользователь ${data.username} покинул комнату`);
+            console.log('Пользователь', data.username, 'покинул комнату');
             document.getElementById('users').innerText = 'Пользователи: ' + data.users.join(', ');
             if (peers[data.username]) {
                 peers[data.username].close();
@@ -296,7 +327,9 @@ def room(token):
         function leaveRoom() {
             socket.emit('leave', { token: token, username: username });
             localStream.getTracks().forEach(track => track.stop());
-            for (let user in peers) peers[user].close();
+            for (let user in peers) {
+                peers[user].close();
+            }
             window.location.href = '/dashboard';
         }
     </script>
@@ -330,6 +363,7 @@ def handle_leave(data):
 
 @socketio.on('signal')
 def handle_signal(data):
+    # Пересылаем сигнал всем в комнате, кроме отправителя
     emit('signal', data, room=data['token'], skip_sid=request.sid)
 
 if __name__ == '__main__':