Update chat_session/websocket_manager.py

chat_session/websocket_manager.py

@@ -462,10 +462,20 @@ class WebSocketManager:
 
     async def _handle_stt_stopped(self, event: Event):
         """Send STT stopped signal to client"""
-        await self.send_message(event.session_id, {
+        session_id = event.session_id
+        stop_recording = event.data.get("stop_recording", False)
+        
+        message = {
             "type": "stt_stopped",
-            "message": "STT stopped, please stop sending audio"
-        })
+            "message": "STT stopped",
+            "stop_recording": stop_recording
+        }
+        
+        if stop_recording:
+            message["message"] = "STT stopped, please stop sending audio immediately"
+            log_info(f"📤 Sending stop recording command to frontend", session_id=session_id)
+        
+        await self.send_message(session_id, message)
 
     async def _handle_stt_result(self, event: Event):
         """Send STT result to client"""