Update chat_session/websocket_manager.py

chat_session/websocket_manager.py

@@ -137,23 +137,30 @@ class WebSocketManager:
         if connection:
             await connection.close()
             del self.connections[session_id]
-
+    
         # Remove message queue
         if session_id in self.message_queues:
             del self.message_queues[session_id]
-
+    
         log_info(
             f"🔌 WebSocket disconnected",
             session_id=session_id,
             total_connections=len(self.connections)
         )
-
+    
         # Publish disconnection event
         await self.event_bus.publish(Event(
             type=EventType.WEBSOCKET_DISCONNECTED,
             session_id=session_id,
             data={}
         ))
+        
+        # ✅ Session'ı da sonlandır
+        await self.event_bus.publish(Event(
+            type=EventType.SESSION_ENDED,
+            session_id=session_id,
+            data={"reason": "websocket_disconnected"}
+        ))
 
     async def handle_connection(self, websocket: WebSocket, session_id: str):
         """Handle WebSocket connection lifecycle"""