Update websocket_handler.py

websocket_handler.py

@@ -153,6 +153,7 @@ class RealtimeSession:
     def __init__(self, session: Session):
         self.session = session
         self.state = ConversationState.IDLE
+        self.is_websocket_active = True  # Yeni flag
         
         # Get settings from config
         config = ConfigProvider.get().global_config.stt_provider.settings
@@ -252,13 +253,13 @@ class RealtimeSession:
     async def cleanup(self):
         """Clean up resources"""
         try:
+            self.is_websocket_active = False  # WebSocket kapanıyor
             if self.stt_manager:
                 await self.stt_manager.stop_streaming()
             log_info(f"Cleaned up realtime session", session_id=self.session.session_id)
         except Exception as e:
             log_warning(f"Cleanup error", error=str(e), session_id=self.session.session_id)
 
-
 # ========================= MAIN HANDLER =========================
 async def websocket_endpoint(websocket: WebSocket, session_id: str):
     """Main WebSocket endpoint for real-time conversation"""
@@ -442,6 +443,10 @@ async def websocket_endpoint(websocket: WebSocket, session_id: str):
 async def handle_audio_chunk(websocket: WebSocket, session: RealtimeSession, message: Dict[str, Any]):
     """Handle incoming audio chunk with barge-in support"""
     try:
+        # WebSocket kapandıysa işlem yapma
+        if not session.is_websocket_active:
+            return
+            
         audio_data = message.get("data")
         if not audio_data:
             log_warning(f"⚠️ Empty audio chunk received", session_id=session.session.session_id)