Update stt/stt_google.py

stt/stt_google.py

@@ -105,44 +105,83 @@ class GoogleCloudSTT(STTInterface):
             raise
 
     async def stop_streaming(self) -> Optional[TranscriptionResult]:
-        """Stop streaming and get final result"""
-        if not self.is_streaming:
+        """Stop streaming and clean up all resources"""
+        if not self.is_streaming and not self.stream_thread:
+            log_debug("Already stopped, nothing to do")
             return None
-            
+    
         try:
-            log_info("🛑 Stopping Google STT streaming...")
-            
+            log_info(f"🛑 Stopping Google STT streaming session #{self.session_id}")
+    
+            # Flag'i hemen kapat
             self.is_streaming = False
             self.stop_event.set()
-            
-            # Send poison pill to queue
-            self.audio_queue.put(None)
-            
-            # Wait for thread to finish
-            if self.stream_thread:
-                self.stream_thread.join(timeout=5.0)
-            
-            # Clear queues
-            while not self.audio_queue.empty():
+    
+            # Send poison pill to stop request generator
+            if self.audio_queue:
                 try:
-                    self.audio_queue.get_nowait()
-                except queue.Empty:
-                    break
-                    
+                    self.audio_queue.put(None)
+                except:
+                    pass
+    
+            # Thread'i durdur
+            if self.stream_thread and self.stream_thread.is_alive():
+                log_info("⏳ Waiting for stream thread to finish...")
+                self.stream_thread.join(timeout=5.0)
+    
+                if self.stream_thread.is_alive():
+                    log_warning("⚠️ STT thread did not stop gracefully after 5s")
+                else:
+                    log_info("✅ Stream thread finished")
+    
+            # Final result'ı al - ✅ BURADA DÜZELTME
             final_result = None
-            while not self.responses_queue.empty():
+            if self.responses_queue:
+                while not self.responses_queue.empty():
+                    try:
+                        result = self.responses_queue.get_nowait()  # ✅ await değil, get_nowait()
+                        if result.is_final:
+                            final_result = result
+                    except queue.Empty:  # ✅ queue.Empty kullan
+                        break
+    
+            # Client'ı kapat
+            if self.client:
                 try:
-                    result = self.responses_queue.get_nowait()  # ✅ get_nowait() kullan, await değil
-                    if result.is_final:
-                        final_result = result
-                except queue.Empty:
-                    break
-            
-            log_info("✅ Google STT streaming stopped")
+                    if hasattr(self.client, 'transport') and hasattr(self.client.transport, 'close'):
+                        self.client.transport.close()
+                        log_debug("✅ Client transport closed")
+    
+                    if hasattr(self.client, '_transport') and hasattr(self.client._transport, '_grpc_channel'):
+                        self.client._transport._grpc_channel.close()
+                        log_debug("✅ gRPC channel closed")
+                except Exception as e:
+                    log_warning(f"⚠️ Error closing Google client: {e}")
+                finally:
+                    self.client = None
+    
+            # Queue'ları None yap
+            self.audio_queue = None
+            self.responses_queue = None
+    
+            # Diğer değişkenleri resetle
+            self.stream_thread = None
+            self.streaming_config = None
+            self.stop_event.clear()
+    
+            log_info(f"✅ Google STT streaming session #{self.session_id} stopped and cleaned")
             return final_result
-            
+    
         except Exception as e:
-            log_error(f"❌ Failed to stop Google STT streaming", error=str(e))
+            log_error(f"❌ Error during stop_streaming", error=str(e))
+            # Force cleanup on error
+            self.is_streaming = False
+            self.stream_thread = None
+            self.client = None
+            self.streaming_config = None
+            self.stop_event.clear()
+            self.audio_queue = None
+            self.responses_queue = None
             return None
     
     def supports_realtime(self) -> bool: