Update stt/stt_google.py

stt/stt_google.py

@@ -290,21 +290,36 @@ class GoogleSTT(STTInterface):
     
     def _audio_generator(self):
         """Generator that yields audio chunks for streaming"""
-        while not self.stop_event.is_set():
-            try:
-                # Get audio chunk with timeout
-                chunk = self.audio_queue.get(timeout=0.1)
-                
-                if chunk is None:  # Sentinel value
-                    break
+        chunk_count = 0
+        try:
+            while not self.stop_event.is_set():
+                try:
+                    # Get audio chunk with timeout
+                    chunk = self.audio_queue.get(timeout=0.1)
                     
-                yield chunk
-                
-            except queue.Empty:
-                continue
-            except Exception as e:
-                log_error(f"❌ Audio generator error: {str(e)}")
-                break
+                    if chunk is None:  # Sentinel value
+                        log_debug("🔚 Audio generator received sentinel, stopping")
+                        break
+                    
+                    # ✅ Debug için chunk bilgisi
+                    chunk_count += 1
+                    if chunk_count <= 5:  # İlk 5 chunk için detaylı log
+                        log_debug(f"🎵 Audio generator yielding chunk #{chunk_count}, size: {len(chunk)} bytes")
+                        # Chunk'ın byte tipinde olduğundan emin ol
+                        if not isinstance(chunk, bytes):
+                            log_error(f"❌ Chunk is not bytes! Type: {type(chunk)}")
+                            continue
+                    
+                    # ✅ Google API'nin beklediği format
+                    yield chunk
+                    
+                except queue.Empty:
+                    continue
+                except Exception as e:
+                    log_error(f"❌ Audio generator error: {str(e)}")
+                    break
+        finally:
+            log_debug(f"🎙️ Audio generator stopped after {chunk_count} chunks")
     
     async def stream_audio(self, audio_chunk: bytes) -> AsyncIterator[TranscriptionResult]:
         """Stream audio chunk and get transcription results"""
@@ -312,6 +327,15 @@ class GoogleSTT(STTInterface):
             raise RuntimeError("Streaming not started. Call start_streaming() first.")
         
         try:
+            # ✅ Audio chunk tipini kontrol et
+            if not isinstance(audio_chunk, bytes):
+                log_error(f"❌ Audio chunk is not bytes! Type: {type(audio_chunk)}")
+                raise TypeError(f"Expected bytes, got {type(audio_chunk)}")
+            
+            # ✅ Chunk boyutunu logla
+            if self.total_chunks < 5:
+                log_debug(f"📦 Adding audio chunk #{self.total_chunks} to queue, size: {len(audio_chunk)} bytes")
+            
             # Add audio to queue for background thread
             self.audio_queue.put(audio_chunk)