Merge branch 'main' into stream_mode

Author: fengju0213

README.md

@@ -317,13 +317,10 @@ For more information please contact info@eigent.ai
 
 - **X (Twitter):** Follow for updates, AI insights, and key announcements. [Follow us][social-x-link]
 
-- **WeChat Community:** Scan the QR codes below to join our WeChat community groups.
+- **WeChat Community:** Scan the QR code below to add our WeChat assistant, and join our WeChat community group.
 
 <div align="center">
-  <img src="./src/assets/wechat_qr_1.jpg" width="200" style="display: inline-block; margin: 10px;">
-  <img src="./src/assets/wechat_qr_2.jpg" width="200" style="display: inline-block; margin: 10px;">
-  <img src="./src/assets/wechat_qr_3.jpg" width="200" style="display: inline-block; margin: 10px;">
-  <img src="./src/assets/wechat_qr_4.jpg" width="200" style="display: inline-block; margin: 10px;">
+  <img src="./src/assets/wechat_qr.jpg" width="200" style="display: inline-block; margin: 10px;">
 </div>
 
 

README_CN.md

@@ -310,13 +310,10 @@ Eigent 基于 [CAMEL-AI.org][camel-ai-org-github] 的研究和基础设施构建
 
 - **X (Twitter)：** 关注更新、AI 见解和重要公告。[关注我们][social-x-link]  
 
-- **微信社区：** 扫描下方二维码加入我们的微信社区群。
+- **微信社区：** 扫描下方二维码添加我们的微信助手，加入我们的微信社区群。
 
 <div align="center">
-  <img src="./src/assets/wechat_qr_1.jpg" width="200" style="display: inline-block; margin: 10px;">
-  <img src="./src/assets/wechat_qr_2.jpg" width="200" style="display: inline-block; margin: 10px;">
-  <img src="./src/assets/wechat_qr_3.jpg" width="200" style="display: inline-block; margin: 10px;">
-  <img src="./src/assets/wechat_qr_4.jpg" width="200" style="display: inline-block; margin: 10px;">
+  <img src="./src/assets/wechat_qr.jpg" width="200" style="display: inline-block; margin: 10px;">
 </div>
 
 

backend/app/controller/chat_controller.py

@@ -204,14 +204,19 @@ def supplement(id: str, data: SupplementChat):
 @traceroot.trace()
 def stop(id: str):
     """stop the task"""
-    chat_logger.warning("Stopping chat session", extra={"task_id": id})
+    chat_logger.info("=" * 80)
+    chat_logger.info("🛑 [STOP-BUTTON] DELETE /chat/{id} request received from frontend")
+    chat_logger.info(f"[STOP-BUTTON] project_id/task_id: {id}")
+    chat_logger.info("=" * 80)
     try:
         task_lock = get_task_lock(id)
+        chat_logger.info(f"[STOP-BUTTON] Task lock retrieved, task_lock.id: {task_lock.id}, task_lock.status: {task_lock.status}")
+        chat_logger.info(f"[STOP-BUTTON] Queueing ActionStopData(Action.stop) to task_lock queue")
         asyncio.run(task_lock.put_queue(ActionStopData(action=Action.stop)))
-        chat_logger.info("Chat stop signal sent", extra={"task_id": id})
+        chat_logger.info(f"[STOP-BUTTON] ✅ ActionStopData queued successfully, this will trigger workforce.stop_gracefully()")
     except Exception as e:
         # Task lock may not exist if task is already finished or never started
-        chat_logger.info("Task lock not found or already stopped", extra={"task_id": id, "error": str(e)})
+        chat_logger.warning(f"[STOP-BUTTON] ⚠️  Task lock not found or already stopped, task_id: {id}, error: {str(e)}")
     return Response(status_code=204)
 
 
@@ -282,18 +287,33 @@ def remove_task(project_id: str, task_id: str):
 @router.post("/chat/{project_id}/skip-task", name="skip task in workforce")
 @traceroot.trace()
 def skip_task(project_id: str):
-    """Skip a task in the workforce"""
-    chat_logger.info(f"Skipping task in workforce for project_id: {project_id}")
+    """
+    Skip/Stop current task execution while preserving context.
+    This endpoint is called when user clicks the Stop button.
+
+    Behavior:
+    - Stops workforce gracefully
+    - Marks task as done
+    - Preserves conversation_history and last_task_result in task_lock
+    - Sends 'end' event to frontend
+    - Keeps SSE connection alive for multi-turn conversation
+    """
+    chat_logger.info("=" * 80)
+    chat_logger.info(f"🛑 [STOP-BUTTON] SKIP-TASK request received from frontend (User clicked Stop)")
+    chat_logger.info(f"[STOP-BUTTON] project_id: {project_id}")
+    chat_logger.info("=" * 80)
     task_lock = get_task_lock(project_id)
+    chat_logger.info(f"[STOP-BUTTON] Task lock retrieved, task_lock.id: {task_lock.id}, task_lock.status: {task_lock.status}")
 
     try:
-        # Queue the skip task action
+        # Queue the skip task action - this will preserve context for multi-turn
         skip_task_action = ActionSkipTaskData(project_id=project_id)
+        chat_logger.info(f"[STOP-BUTTON] Queueing ActionSkipTaskData (preserves context, marks as done)")
         asyncio.run(task_lock.put_queue(skip_task_action))
 
-        chat_logger.info(f"Task skip request queued for project_id: {project_id}")
+        chat_logger.info(f"[STOP-BUTTON] ✅ Skip request queued - task will stop gracefully and preserve context")
         return Response(status_code=201)
 
     except Exception as e:
-        chat_logger.error(f"Error skipping task for project_id: {project_id}: {e}")
+        chat_logger.error(f"[STOP-BUTTON] ❌ Error skipping task for project_id: {project_id}: {e}")
         raise UserException(code.error, f"Failed to skip task: {str(e)}")