Update websocket_manager.py

websocket_manager.py

@@ -269,6 +269,62 @@ class WebSocketManager:
         message_type = message.get("type")
         
         if message_type == "audio_chunk":
+            # Audio data from client
+            audio_data_base64 = message.get("data")
+            
+            if audio_data_base64:
+                # Debug için audio analizi
+                try:
+                    import base64
+                    import struct
+                    
+                    # Base64'ten binary'ye çevir
+                    audio_data = base64.b64decode(audio_data_base64)
+                    
+                    # Session için debug counter
+                    if not hasattr(self, 'audio_debug_counters'):
+                        self.audio_debug_counters = {}
+                    
+                    if session_id not in self.audio_debug_counters:
+                        self.audio_debug_counters[session_id] = 0
+                    
+                    # İlk 5 chunk için detaylı log
+                    if self.audio_debug_counters[session_id] < 5:
+                        log_info(f"🔊 Audio chunk analysis #{self.audio_debug_counters[session_id]}", 
+                                session_id=session_id,
+                                size_bytes=len(audio_data),
+                                base64_size=len(audio_data_base64))
+                        
+                        # İlk 20 byte'ı hex olarak göster
+                        if len(audio_data) >= 20:
+                            log_debug(f"  First 20 bytes (hex): {audio_data[:20].hex()}")
+                            
+                            # Linear16 (little-endian int16) olarak yorumla
+                            samples = struct.unpack('<10h', audio_data[:20])
+                            log_debug(f"  First 10 samples: {samples}")
+                            log_debug(f"  Max amplitude (first 10): {max(abs(s) for s in samples)}")
+                            
+                            # Tüm chunk'ı analiz et
+                            total_samples = len(audio_data) // 2
+                            if total_samples > 0:
+                                all_samples = struct.unpack(f'<{total_samples}h', audio_data[:total_samples*2])
+                                max_amp = max(abs(s) for s in all_samples)
+                                avg_amp = sum(abs(s) for s in all_samples) / total_samples
+                                
+                                # Sessizlik kontrolü
+                                silent = max_amp < 100  # Linear16 için düşük eşik
+                                
+                                log_info(f"  Audio stats - Max: {max_amp}, Avg: {avg_amp:.1f}, Silent: {silent}")
+                                
+                                # Eğer çok sessizse uyar
+                                if max_amp < 50:
+                                    log_warning(f"⚠️ Very low audio level detected! Max amplitude: {max_amp}")
+                        
+                        self.audio_debug_counters[session_id] += 1
+                    
+                except Exception as e:
+                    log_error(f"Error analyzing audio chunk: {e}")
+            
             # Audio data from client
             await self.event_bus.publish(Event(
                 type=EventType.AUDIO_CHUNK_RECEIVED,