Update stt/stt_google.py

stt/stt_google.py

@@ -367,10 +367,6 @@ class GoogleCloudSTT(STTInterface):
                             log_info(f"📤 First chunk - size: {len(chunk)} bytes")
                             if len(chunk) >= 4 and chunk[:4] == b'\x1a\x45\xdf\xa3':
                                 log_info("✅ Valid WEBM header detected")
-                            else:
-                                log_error(f"❌ Invalid audio format, first 4 bytes: {chunk[:4].hex()}")
-                                # Format hatalıysa devam et, Google STT düzeltebilir
-                                # break
     
                         # Her 50 chunk'ta durum raporu
                         if chunk_count % 50 == 0:
@@ -391,6 +387,7 @@ class GoogleCloudSTT(STTInterface):
             log_info("🎤 Creating Google STT streaming client...")
     
             try:
+                # Start streaming
                 responses = self.client.streaming_recognize(
                     self.streaming_config,
                     requests,
@@ -402,52 +399,68 @@ class GoogleCloudSTT(STTInterface):
                 # Process responses
                 response_count = 0
                 result_count = 0
+                last_log_time = time.time()
     
-                for response in responses:
-                    response_count += 1
-                    
-                    if response_count == 1:
-                        log_info(f"📨 First response received from Google STT")
+                # Response iterator'ı başlat
+                try:
+                    for response in responses:
+                        response_count += 1
+                        
+                        # İlk response'u logla
+                        if response_count == 1:
+                            log_info(f"📨 First response received from Google STT")
     
-                    if self.stop_event.is_set():
-                        log_info("🛑 Stop event detected")
-                        break
+                        # Her 5 saniyede bir durum logu
+                        if time.time() - last_log_time > 5:
+                            log_info(f"📊 Still listening... Responses: {response_count}, Results: {result_count}")
+                            last_log_time = time.time()
     
-                    # Process results
-                    if not response.results:
-                        log_debug(f"📭 Response #{response_count} has no results")
-                        continue
+                        if self.stop_event.is_set():
+                            log_info("🛑 Stop event detected")
+                            break
     
-                    for result in response.results:
-                        result_count += 1
-                        
-                        if not result.alternatives:
+                        # Process results
+                        if not response.results:
+                            log_debug(f"📭 Response #{response_count} has no results")
                             continue
     
-                        alternative = result.alternatives[0]
-                        
-                        if alternative.transcript.strip():
-                            # Create transcription result
-                            transcription = TranscriptionResult(
-                                text=alternative.transcript,
-                                is_final=result.is_final,
-                                confidence=getattr(alternative, 'confidence', 0.0),
-                                timestamp=datetime.now().timestamp()
-                            )
-    
-                            # Put result in queue
-                            self._put_result(transcription)
-    
-                            if result.is_final:
-                                log_info(f"🎯 FINAL TRANSCRIPT: '{alternative.transcript}'")
-                                
-                                # Single utterance modunda Google STT otomatik kapanır
-                                if self.streaming_config.single_utterance:
-                                    log_info("✅ Single utterance mode - Stream will end")
-                                    # Google stream'i kapatacak, biz de çıkalım
-                                    return
-                            else:
-                                log_debug(f"📝 Interim: '{alternative.transcript}'")
+                        for result in response.results:
+                            result_count += 1
+                            
+                            if not result.alternatives:
+                                continue
+    
+                            alternative = result.alternatives[0]
+                            
+                            # Log all transcripts, even empty ones
+                            log_debug(f"📝 Transcript: '{alternative.transcript}' (is_final: {result.is_final})")
+                            
+                            if alternative.transcript.strip():
+                                # Create transcription result
+                                transcription = TranscriptionResult(
+                                    text=alternative.transcript,
+                                    is_final=result.is_final,
+                                    confidence=getattr(alternative, 'confidence', 0.0),
+                                    timestamp=datetime.now().timestamp()
+                                )
+    
+                                # Put result in queue
+                                self._put_result(transcription)
+    
+                                if result.is_final:
+                                    log_info(f"🎯 FINAL TRANSCRIPT: '{alternative.transcript}'")
+                                    
+                                    # Single utterance modunda Google STT otomatik kapanır
+                                    if self.streaming_config.single_utterance:
+                                        log_info("✅ Single utterance completed - Stream ending")
+                                        return
+                                else:
+                                    log_debug(f"📝 Interim: '{alternative.transcript}'")
+    
+                except StopIteration:
+                    log_info("✅ Google STT stream ended (StopIteration)")
+                except Exception as e:
+                    log_error(f"❌ Error processing responses: {e}")
     
                 log_info(f"📊 Google STT stream ended. Responses: {response_count}, Results: {result_count}")
     
@@ -459,6 +472,8 @@ class GoogleCloudSTT(STTInterface):
                     log_info("✅ Stream ended normally")
                 elif "Exceeded maximum allowed stream duration" in error_msg:
                     log_warning("⚠️ Stream duration limit (5 min)")
+                elif "InvalidArgument" in error_msg:
+                    log_error(f"❌ Invalid STT configuration: {error_msg}")
                 else:
                     log_error(f"❌ Google STT error: {error_msg}")