Update main.py

main.py

@@ -558,18 +558,15 @@ HTML_TEMPLATE = '''
             color: white;
         }
         
-        .debug-info {
-            position: fixed;
-            bottom: 10px;
-            left: 10px;
-            background: rgba(0,0,0,0.7);
+        .webrtc-status {
+            position: absolute;
+            bottom: 120px;
+            left: 0;
+            right: 0;
+            text-align: center;
             color: white;
-            padding: 10px;
-            border-radius: 5px;
-            font-size: 12px;
-            max-width: 300px;
-            display: none;
-            z-index: 3000;
+            font-size: 14px;
+            z-index: 10;
         }
     </style>
 </head>
@@ -579,9 +576,6 @@ HTML_TEMPLATE = '''
         Подключение...
     </div>
 
-    <!-- Debug Info -->
-    <div id="debugInfo" class="debug-info"></div>
-
     <!-- Login Screen -->
     <div id="loginScreen" class="login-screen">
         <div style="text-align: center; margin-bottom: 30px;">
@@ -606,7 +600,6 @@ HTML_TEMPLATE = '''
             </div>
             <div class="call-buttons">
                 <button class="header-btn" onclick="toggleUsersSidebar()" title="Пользователи">👥</button>
-                <button class="header-btn" onclick="toggleDebug()" title="Отладка">🐛</button>
             </div>
         </div>
         
@@ -644,7 +637,9 @@ HTML_TEMPLATE = '''
             <div class="call-info">
                 <div class="call-status" id="callStatus">Звонок...</div>
                 <div class="call-timer" id="callTimer">00:00</div>
-                <div id="callDebug" style="font-size: 12px; margin-top: 5px;"></div>
+            </div>
+            <div class="webrtc-status" id="webrtcStatus">
+                Установка соединения...
             </div>
             <div class="call-controls">
                 <button class="call-control-btn" id="muteBtn" onclick="toggleMute()">🎤</button>
@@ -690,9 +685,8 @@ HTML_TEMPLATE = '''
         let isVideoEnabled = true;
         let reconnectAttempts = 0;
         const MAX_RECONNECT_ATTEMPTS = 5;
-        let debugEnabled = false;
 
-        // Упрощенная конфигурация WebRTC - только STUN серверы
+        // WebRTC configuration - только STUN серверы
         const rtcConfig = {
             iceServers: [
                 { urls: 'stun:stun.l.google.com:19302' },
@@ -701,9 +695,7 @@ HTML_TEMPLATE = '''
                 { urls: 'stun:stun3.l.google.com:19302' },
                 { urls: 'stun:stun4.l.google.com:19302' }
             ],
-            iceCandidatePoolSize: 10,
-            bundlePolicy: 'max-bundle',
-            rtcpMuxPolicy: 'require'
+            iceCandidatePoolSize: 10
         };
 
         function initializeSocket() {
@@ -722,7 +714,7 @@ HTML_TEMPLATE = '''
 
             // Socket events
             socket.on('connect', () => {
-                logDebug('Connected to server');
+                console.log('Connected to server');
                 updateConnectionStatus(true);
                 reconnectAttempts = 0;
                 
@@ -732,7 +724,7 @@ HTML_TEMPLATE = '''
             });
 
             socket.on('disconnect', (reason) => {
-                logDebug('Disconnected from server: ' + reason);
+                console.log('Disconnected from server:', reason);
                 updateConnectionStatus(false);
                 
                 if (reason === 'io server disconnect') {
@@ -746,7 +738,7 @@ HTML_TEMPLATE = '''
             });
 
             socket.on('connect_error', (error) => {
-                logDebug('Connection error: ' + error);
+                console.error('Connection error:', error);
                 updateConnectionStatus(false);
             });
 
@@ -755,13 +747,11 @@ HTML_TEMPLATE = '''
                 document.getElementById('loginScreen').style.display = 'none';
                 document.getElementById('chatScreen').style.display = 'flex';
                 updateConnectionStatus(true);
-                logDebug('Registered as: ' + data.username);
             });
 
             socket.on('user_list_update', (data) => {
                 document.getElementById('onlineCount').textContent = data.count;
                 updateUsersList(data.users || []);
-                logDebug('Users updated: ' + data.count + ' online');
             });
 
             socket.on('new_message', (message) => {
@@ -773,12 +763,10 @@ HTML_TEMPLATE = '''
             });
 
             socket.on('incoming_call', (data) => {
-                logDebug('Incoming call from: ' + data.from_user);
                 showIncomingCall(data.from_user, data.call_id, data.isVideo);
             });
 
             socket.on('call_answered', (data) => {
-                logDebug('Call answered: ' + data.answer);
                 if (data.answer) {
                     startCall(data.isVideo, false);
                 } else {
@@ -788,20 +776,21 @@ HTML_TEMPLATE = '''
             });
 
             socket.on('call_ended', () => {
-                logDebug('Call ended by remote');
                 alert('Звонок завершен');
                 endCall();
             });
 
             socket.on('webrtc_offer', async (data) => {
-                logDebug('Received WebRTC offer');
-                updateCallDebug('Получен WebRTC offer');
+                console.log('Received WebRTC offer from', data.from_user);
+                updateWebRTCStatus('Получен запрос на соединение');
                 
                 if (!peerConnection) {
                     await createPeerConnection(false);
                 }
                 try {
                     await peerConnection.setRemoteDescription(new RTCSessionDescription(data.offer));
+                    updateWebRTCStatus('Создание ответа...');
+                    
                     const answer = await peerConnection.createAnswer();
                     await peerConnection.setLocalDescription(answer);
                     
@@ -810,74 +799,41 @@ HTML_TEMPLATE = '''
                         to_user: data.from_user,
                         call_id: data.call_id
                     });
-                    logDebug('Sent WebRTC answer');
-                    updateCallDebug('Отправлен WebRTC answer');
+                    
+                    updateWebRTCStatus('Ответ отправлен');
                 } catch (error) {
                     console.error('Error handling WebRTC offer:', error);
-                    logDebug('WebRTC offer error: ' + error);
-                    updateCallDebug('Ошибка WebRTC offer: ' + error);
+                    updateWebRTCStatus('Ошибка: ' + error.message);
                 }
             });
 
             socket.on('webrtc_answer', async (data) => {
-                logDebug('Received WebRTC answer');
-                updateCallDebug('Получен WebRTC answer');
+                console.log('Received WebRTC answer from', data.from_user);
+                updateWebRTCStatus('Получен ответ на соединение');
                 
                 if (peerConnection) {
                     try {
                         await peerConnection.setRemoteDescription(new RTCSessionDescription(data.answer));
-                        logDebug('Remote description set');
-                        updateCallDebug('Remote description установлен');
+                        updateWebRTCStatus('Соединение установлено');
                     } catch (error) {
                         console.error('Error setting remote description:', error);
-                        logDebug('Remote description error: ' + error);
-                        updateCallDebug('Ошибка remote description: ' + error);
+                        updateWebRTCStatus('Ошибка установки соединения');
                     }
                 }
             });
 
             socket.on('webrtc_ice_candidate', async (data) => {
-                logDebug('Received ICE candidate');
-                updateCallDebug('Получен ICE candidate');
-                
                 if (peerConnection && data.candidate) {
                     try {
                         await peerConnection.addIceCandidate(new RTCIceCandidate(data.candidate));
-                        logDebug('ICE candidate added');
-                        updateCallDebug('ICE candidate добавлен');
+                        console.log('Added remote ICE candidate');
                     } catch (error) {
                         console.error('Error adding ICE candidate:', error);
-                        logDebug('ICE candidate error: ' + error);
-                        updateCallDebug('Ошибка ICE candidate: ' + error);
                     }
                 }
             });
         }
 
-        function logDebug(message) {
-            if (debugEnabled) {
-                console.log('DEBUG:', message);
-                const debugElement = document.getElementById('debugInfo');
-                const timestamp = new Date().toLocaleTimeString();
-                debugElement.innerHTML = timestamp + ': ' + message + '<br>' + debugElement.innerHTML;
-            }
-        }
-
-        function updateCallDebug(message) {
-            if (debugEnabled) {
-                const callDebug = document.getElementById('callDebug');
-                const timestamp = new Date().toLocaleTimeString();
-                callDebug.innerHTML = timestamp + ': ' + message + '<br>' + callDebug.innerHTML;
-            }
-        }
-
-        function toggleDebug() {
-            debugEnabled = !debugEnabled;
-            document.getElementById('debugInfo').style.display = debugEnabled ? 'block' : 'none';
-            document.getElementById('callDebug').style.display = debugEnabled ? 'block' : 'none';
-            logDebug('Debug mode: ' + (debugEnabled ? 'ON' : 'OFF'));
-        }
-
         function updateConnectionStatus(connected) {
             const statusElement = document.getElementById('connectionStatus');
             statusElement.style.display = 'block';
@@ -890,6 +846,14 @@ HTML_TEMPLATE = '''
             }
         }
 
+        function updateWebRTCStatus(message) {
+            const statusElement = document.getElementById('webrtcStatus');
+            if (statusElement) {
+                statusElement.textContent = message;
+                console.log('WebRTC Status:', message);
+            }
+        }
+
         // UI Functions
         function registerUser() {
             const username = document.getElementById('usernameInput').value.trim();
@@ -932,7 +896,6 @@ HTML_TEMPLATE = '''
             container.appendChild(messageDiv);
             container.scrollTop = container.scrollHeight;
             
-            // Remove placeholder if exists
             const placeholder = container.querySelector('div[style*="text-align: center"]');
             if (placeholder) {
                 placeholder.remove();
@@ -1004,14 +967,14 @@ HTML_TEMPLATE = '''
                     audio: {
                         echoCancellation: true,
                         noiseSuppression: true,
-                        sampleRate: 44100
+                        channelCount: 1
                     } 
                 });
                 
-                // Используем более совместимый формат
+                // Используем формат, который поддерживается большинством браузеров
                 const options = { 
-                    mimeType: 'audio/webm; codecs=opus',
-                    audioBitsPerSecond: 128000
+                    audioBitsPerSecond: 128000,
+                    mimeType: 'audio/webm;codecs=opus' 
                 };
                 
                 mediaRecorder = new MediaRecorder(stream, options);
@@ -1029,7 +992,7 @@ HTML_TEMPLATE = '''
                     const duration = Math.round((Date.now() - startTime) / 1000);
                     const audioBlob = new Blob(audioChunks, { type: 'audio/webm' });
                     
-                    // Конвертируем в base64
+                    // Конвертируем в base64 для передачи
                     const reader = new FileReader();
                     reader.onload = function() {
                         const base64Audio = reader.result.split(',')[1];
@@ -1040,21 +1003,19 @@ HTML_TEMPLATE = '''
                                 sender: currentUser.username,
                                 duration: duration
                             });
-                            logDebug('Voice message sent, duration: ' + duration + 's');
                         } else {
                             alert('Нет подключения для отправки голосового сообщения');
                         }
                     };
                     reader.readAsDataURL(audioBlob);
 
-                    // Освобождаем ресурсы
+                    // Останавливаем все треки
                     stream.getTracks().forEach(track => track.stop());
                 };
 
-                mediaRecorder.start(100); // Собираем данные каждые 100мс
+                mediaRecorder.start(100); // Записываем chunks каждые 100ms
                 isRecording = true;
                 
-                // Show recording overlay
                 document.getElementById('recordingOverlay').style.display = 'flex';
                 
             } catch (error) {
@@ -1093,8 +1054,6 @@ HTML_TEMPLATE = '''
                 isInitiator: true
             };
             
-            logDebug('Starting call with ' + targetUser + ', video: ' + isVideo);
-            
             socket.emit('call_request', {
                 call_id: currentCall.id,
                 from_user: currentUser.username,
@@ -1115,7 +1074,6 @@ HTML_TEMPLATE = '''
             
             document.getElementById('callerName').textContent = fromUser;
             document.getElementById('incomingCallOverlay').style.display = 'flex';
-            logDebug('Showing incoming call from: ' + fromUser);
         }
 
         function acceptCall() {
@@ -1129,7 +1087,6 @@ HTML_TEMPLATE = '''
                 });
                 
                 startCall(currentCall.isVideo, true);
-                logDebug('Call accepted');
             } else {
                 alert('Нет подключения к серверу');
             }
@@ -1142,7 +1099,6 @@ HTML_TEMPLATE = '''
                     answer: false,
                     to_user: currentCall.target
                 });
-                logDebug('Call rejected');
             }
             
             document.getElementById('incomingCallOverlay').style.display = 'none';
@@ -1152,43 +1108,33 @@ HTML_TEMPLATE = '''
         async function startCall(isVideo, isInitiator) {
             try {
                 showCallScreen(isVideo, isInitiator ? 'Звонок...' : 'Разговор...');
+                updateWebRTCStatus('Получение медиа-потока...');
                 
-                // Получаем медиапоток с оптимальными настройками
+                // Получаем медиа-поток
                 const constraints = {
                     audio: {
                         echoCancellation: true,
                         noiseSuppression: true,
-                        autoGainControl: true,
-                        channelCount: 1,
-                        sampleRate: 48000
+                        autoGainControl: true
                     },
                     video: isVideo ? {
-                        width: { ideal: 640 },
-                        height: { ideal: 480 },
-                        frameRate: { ideal: 24 }
+                        width: { min: 640, ideal: 1280, max: 1920 },
+                        height: { min: 480, ideal: 720, max: 1080 },
+                        frameRate: { ideal: 30, max: 60 }
                     } : false
                 };
                 
-                logDebug('Requesting media with constraints: ' + JSON.stringify(constraints));
-                
                 localStream = await navigator.mediaDevices.getUserMedia(constraints);
                 document.getElementById('localVideo').srcObject = localStream;
-                logDebug('Local media stream obtained');
+                updateWebRTCStatus('Медиа-поток получен');
                 
                 // Создаем peer connection
                 await createPeerConnection(isInitiator);
-                logDebug('Peer connection created');
                 
                 if (isInitiator) {
-                    // Создаем и отправляем offer
-                    const offerOptions = {
-                        offerToReceiveAudio: true,
-                        offerToReceiveVideo: isVideo
-                    };
-                    
-                    const offer = await peerConnection.createOffer(offerOptions);
+                    updateWebRTCStatus('Создание предложения...');
+                    const offer = await peerConnection.createOffer();
                     await peerConnection.setLocalDescription(offer);
-                    logDebug('Local description set');
                     
                     if (socket && socket.connected) {
                         socket.emit('webrtc_offer', {
@@ -1196,42 +1142,38 @@ HTML_TEMPLATE = '''
                             to_user: currentCall.target,
                             call_id: currentCall.id
                         });
-                        logDebug('WebRTC offer sent');
+                        updateWebRTCStatus('Предложение отправлено');
                     }
                 }
                 
-                // Запускаем таймер звонка
                 startCallTimer();
-                logDebug('Call timer started');
                 
             } catch (error) {
                 console.error('Error starting call:', error);
-                logDebug('Call start error: ' + error.message);
+                updateWebRTCStatus('Ошибка: ' + error.message);
                 alert(`Ошибка начала звонка: ${error.message}`);
                 endCall();
             }
         }
 
         async function createPeerConnection(isInitiator) {
+            updateWebRTCStatus('Создание PeerConnection...');
+            
             peerConnection = new RTCPeerConnection(rtcConfig);
-            logDebug('PeerConnection created with config: ' + JSON.stringify(rtcConfig));
 
             // Добавляем локальные треки
             localStream.getTracks().forEach(track => {
                 peerConnection.addTrack(track, localStream);
-                logDebug('Added local track: ' + track.kind);
+                console.log('Added local track:', track.kind);
             });
 
-            // Обрабатываем входящие потоки
+            // Обработка входящих потоков
             peerConnection.ontrack = (event) => {
-                logDebug('Received remote track: ' + event.track.kind);
-                updateCallDebug('Получен remote track: ' + event.track.kind);
-                
+                console.log('Received remote track:', event.track.kind);
                 remoteStream = event.streams[0];
                 const remoteVideo = document.getElementById('remoteVideoContainer');
                 
                 if (event.track.kind === 'video') {
-                    // Создаем video элемент для удаленного потока
                     const videoElement = document.createElement('video');
                     videoElement.srcObject = remoteStream;
                     videoElement.autoplay = true;
@@ -1240,90 +1182,98 @@ HTML_TEMPLATE = '''
                     
                     remoteVideo.innerHTML = '';
                     remoteVideo.appendChild(videoElement);
-                    logDebug('Remote video element created');
+                    updateWebRTCStatus('Видео соединение установлено');
                 } else if (event.track.kind === 'audio') {
-                    // Для аудио показываем сообщение
                     if (!document.querySelector('.remote-video video')) {
                         remoteVideo.innerHTML = '<div>Аудиозвонок</div>';
                         remoteVideo.className = 'no-video remote-video';
-                        logDebug('Audio call UI updated');
                     }
+                    updateWebRTCStatus('Аудио соединение установлено');
                 }
             };
 
-            // Обрабатываем ICE кандидаты
+            // Обработка ICE кандидатов
             peerConnection.onicecandidate = (event) => {
                 if (event.candidate && currentCall && socket && socket.connected) {
                     socket.emit('webrtc_ice_candidate', {
                         candidate: event.candidate,
                         to_user: currentCall.target
                     });
-                    logDebug('ICE candidate sent: ' + event.candidate.type);
-                    updateCallDebug('Отправлен ICE candidate: ' + event.candidate.type);
+                    console.log('Sent ICE candidate');
                 } else if (!event.candidate) {
-                    logDebug('All ICE candidates sent');
-                    updateCallDebug('Все ICE candidates отправлены');
+                    console.log('All ICE candidates have been sent');
                 }
             };
 
             peerConnection.onconnectionstatechange = () => {
                 const state = peerConnection.connectionState;
-                logDebug('Connection state: ' + state);
-                updateCallDebug('Состояние соединения: ' + state);
+                console.log('Connection state:', state);
+                updateWebRTCStatus('Состояние: ' + state);
                 
                 if (state === 'connected') {
                     document.getElementById('callStatus').textContent = 'Разговор';
-                    logDebug('WebRTC connection established');
-                    updateCallDebug('WebRTC соединение установлено');
+                    updateWebRTCStatus('Соединение установлено!');
                 } else if (state === 'failed' || state === 'disconnected') {
-                    logDebug('WebRTC connection failed');
-                    updateCallDebug('WebRTC соединение потеряно');
-                    setTimeout(() => {
-                        if (peerConnection.connectionState !== 'connected') {
-                            alert('Соединение потеряно');
-                            endCall();
-                        }
-                    }, 2000);
+                    updateWebRTCStatus('Соединение прервано: ' + state);
                 }
             };
 
             peerConnection.oniceconnectionstatechange = () => {
                 const state = peerConnection.iceConnectionState;
-                logDebug('ICE connection state: ' + state);
-                updateCallDebug('Состояние ICE: ' + state);
+                console.log('ICE connection state:', state);
+                
+                if (state === 'connected') {
+                    updateWebRTCStatus('ICE соединение установлено');
+                } else if (state === 'failed') {
+                    updateWebRTCStatus('ICE соединение не удалось');
+                    // Попробуем пересоздать соединение
+                    setTimeout(() => {
+                        if (peerConnection.iceConnectionState === 'failed') {
+                            restartIce();
+                        }
+                    }, 1000);
+                }
             };
 
-            peerConnection.onsignalingstatechange = () => {
-                logDebug('Signaling state: ' + peerConnection.signalingState);
-                updateCallDebug('Signaling state: ' + peerConnection.signalingState);
+            peerConnection.onnegotiationneeded = async () => {
+                console.log('Negotiation needed');
+                updateWebRTCStatus('Требуется переговоры...');
             };
         }
 
+        async function restartIce() {
+            if (!peerConnection) return;
+            
+            try {
+                updateWebRTCStatus('Перезапуск ICE...');
+                await peerConnection.restartIce();
+            } catch (error) {
+                console.error('Error restarting ICE:', error);
+            }
+        }
+
         function showCallScreen(isVideo, status) {
             document.getElementById('callScreen').style.display = 'flex';
             document.getElementById('callStatus').textContent = status;
+            updateWebRTCStatus('Настройка звонка...');
             
             const remoteVideo = document.getElementById('remoteVideoContainer');
             if (!isVideo) {
                 remoteVideo.innerHTML = '<div>Аудиозвонок</div>';
                 remoteVideo.className = 'no-video remote-video';
             }
-            
-            logDebug('Call screen shown: ' + status);
         }
 
         function hideCallScreen() {
             document.getElementById('callScreen').style.display = 'none';
             document.getElementById('remoteVideoContainer').innerHTML = '<div>Ожидание подключения...</div>';
             document.getElementById('remoteVideoContainer').className = 'no-video remote-video';
-            document.getElementById('callDebug').innerHTML = '';
+            document.getElementById('webrtcStatus').textContent = 'Установка соединения...';
             
             if (callTimerInterval) {
                 clearInterval(callTimerInterval);
                 callTimerInterval = null;
             }
-            
-            logDebug('Call screen hidden');
         }
 
         function startCallTimer() {
@@ -1339,18 +1289,14 @@ HTML_TEMPLATE = '''
         }
 
         function endCall() {
-            logDebug('Ending call');
-            
             if (peerConnection) {
                 peerConnection.close();
                 peerConnection = null;
-                logDebug('Peer connection closed');
             }
             
             if (localStream) {
                 localStream.getTracks().forEach(track => track.stop());
                 localStream = null;
-                logDebug('Local stream stopped');
             }
             
             if (currentCall && socket && socket.connected) {
@@ -1358,15 +1304,12 @@ HTML_TEMPLATE = '''
                     to_user: currentCall.target,
                     call_id: currentCall.id
                 });
-                logDebug('Call end signal sent');
             }
             
             hideCallScreen();
             currentCall = null;
             isMuted = false;
             isVideoEnabled = true;
-            
-            logDebug('Call completely ended');
         }
 
         function toggleMute() {
@@ -1377,7 +1320,6 @@ HTML_TEMPLATE = '''
                     audioTracks[0].enabled = !isMuted;
                     document.getElementById('muteBtn').classList.toggle('active', isMuted);
                     document.getElementById('muteBtn').textContent = isMuted ? '🎤🚫' : '🎤';
-                    logDebug('Microphone ' + (isMuted ? 'muted' : 'unmuted'));
                 }
             }
         }
@@ -1391,9 +1333,7 @@ HTML_TEMPLATE = '''
                     document.getElementById('videoBtn').classList.toggle('active', !isVideoEnabled);
                     document.getElementById('videoBtn').textContent = isVideoEnabled ? '📹' : '📹🚫';
                     
-                    // Скрываем/показываем локальное видео
                     document.getElementById('localVideo').style.display = isVideoEnabled ? 'block' : 'none';
-                    logDebug('Video ' + (isVideoEnabled ? 'enabled' : 'disabled'));
                 }
             }
         }
@@ -1413,7 +1353,7 @@ HTML_TEMPLATE = '''
             }
         });
 
-        // Закрываем sidebar при клике вне его
+        // Close sidebar when clicking outside
         document.addEventListener('click', (e) => {
             const sidebar = document.getElementById('usersSidebar');
             if (sidebar.classList.contains('open') && 
@@ -1423,12 +1363,12 @@ HTML_TEMPLATE = '''
             }
         });
 
-        // Инициализируем socket при загрузке
+        // Initialize socket on load
         window.addEventListener('load', function() {
             initializeSocket();
         });
 
-        // Обрабатываем изменения видимости страницы
+        // Handle page visibility changes
         document.addEventListener('visibilitychange', function() {
             if (!document.hidden && (!socket || !socket.connected)) {
                 initializeSocket();
@@ -1455,12 +1395,10 @@ def handle_connect():
 def handle_disconnect():
     print(f'Client disconnected: {request.sid}')
     
-    # Находим и удаляем отключившегося пользователя
     disconnected_user = None
     for user_id, user_data in list(users.items()):
         if user_data.get('sid') == request.sid:
             disconnected_user = user_data['username']
-            # Завершаем активные звонки
             for call_id, call_data in list(active_calls.items()):
                 if call_data['from_user'] == disconnected_user or call_data['to_user'] == disconnected_user:
                     try:
@@ -1658,7 +1596,7 @@ if __name__ == '__main__':
     try:
         print("Запуск мобильного мессенджера...")
         print("Порт: 7860")
-        print("WebRTC: Только STUN серверы (без TURN)")
+        print("Используются только STUN серверы")
         socketio.run(
             app, 
             host='0.0.0.0',