Add WebSocket diagnostic script for debugging audio issues

app.py

@@ -119,14 +119,14 @@ def start_services():
         # Test détaillé des services
         logger.info("🔍 Test détaillé des services...")
         try:
-            result = subprocess.run([sys.executable, "test_websocket.py"], 
+            result = subprocess.run([sys.executable, "debug_websocket.py"], 
                                   capture_output=True, text=True, timeout=30)
             if result.stdout:
-                logger.info(f"Résultats des tests:\n{result.stdout}")
+                logger.info(f"Résultats des tests WebSocket:\n{result.stdout}")
             if result.stderr:
-                logger.error(f"Erreurs des tests:\n{result.stderr}")
+                logger.error(f"Erreurs des tests WebSocket:\n{result.stderr}")
         except Exception as e:
-            logger.warning(f"Impossible d'exécuter les tests détaillés: {e}")
+            logger.warning(f"Impossible d'exécuter les tests WebSocket: {e}")
         
         logger.info("✅ Services backend démarrés et testés")
         return True

debug_websocket.py

@@ -0,0 +1,48 @@
+#!/usr/bin/env python3
+"""
+Script de diagnostic pour le problème WebSocket
+"""
+
+import asyncio
+import aiohttp
+import json
+import sys
+
+async def test_websocket_connection():
+    """Teste la connexion WebSocket"""
+    print("🔍 Test de connexion WebSocket...")
+    
+    try:
+        # Test de connexion WebSocket
+        async with aiohttp.ClientSession() as session:
+            async with session.ws_connect("ws://localhost:5003/live_stream/test_user?lang=fr&room_id=test") as ws:
+                print("✅ Connexion WebSocket établie")
+                
+                # Envoyer un message de test
+                test_message = {"type": "start", "user_id": "test_user"}
+                await ws.send_str(json.dumps(test_message))
+                print("✅ Message de test envoyé")
+                
+                # Attendre une réponse
+                try:
+                    async with asyncio.timeout(5):
+                        msg = await ws.receive()
+                        print(f"✅ Réponse reçue: {msg}")
+                except asyncio.TimeoutError:
+                    print("⚠️ Aucune réponse reçue dans les 5 secondes")
+                
+                await ws.close()
+                print("✅ Connexion WebSocket fermée")
+                
+    except Exception as e:
+        print(f"❌ Erreur WebSocket: {e}")
+        import traceback
+        print(f"Traceback: {traceback.format_exc()}")
+
+async def main():
+    print("🚀 Démarrage du diagnostic WebSocket...")
+    await test_websocket_connection()
+    print("✅ Diagnostic terminé")
+
+if __name__ == "__main__":
+    asyncio.run(main())