From 6c48d79076a3f6735b264ba03db78aa799eb9e1f Mon Sep 17 00:00:00 2001
From: CakeCN <cakebaker.0308@gmail.com>
Date: Tue, 18 Nov 2025 23:32:41 +0800
Subject: [PATCH] change clear to sync

---
 Html/apps/sockets/namespaces.py | 30 ++++++++++++++++++++++++++++--
 1 file changed, 28 insertions(+), 2 deletions(-)

diff --git a/Html/apps/sockets/namespaces.py b/Html/apps/sockets/namespaces.py
index 58998ac..eb1cd6d 100644
--- a/Html/apps/sockets/namespaces.py
+++ b/Html/apps/sockets/namespaces.py
@@ -1,8 +1,10 @@
 # myapp/sockets/namespaces.py
 import json
 import time
-from flask import current_app, request, session
+import requests
+from flask import current_app, request, session, url_for
 from flask_socketio import Namespace, join_room, leave_room, emit
+from ..config import Config
 
 from ..function_tools import judge
 from ..function_tools import next_chapter
@@ -209,9 +211,33 @@ class AgentNamespace(Namespace):
         print(f"on_connect_to_ase {client_entry}, {namespace_entry}, {init_data}")
         namespace_entry, ase_client = namespace_entry
         namespace_entry.emit('open-iframe',"", room=init_data['room'], namespace='/agent')
+        
+        # 将异步emit改为同步requests.post请求
+        try:
+            # 构建请求URL，使用配置中的ASE_ENGINE_URL
+            base_url = current_app.config['ASE_ENGINE_URL']
+            clear_url = f"{base_url}/clear_user_session"
+            
+            # 准备请求参数
+            payload = {
+                'namespace_url': current_app.config['ASE_ENGINE_URL_TOKEN'],  # WebSocket命名空间URL
+                'user_id': init_data['room'],  # 用户ID，对应session_info.id
+                'clear_type': 'all'  # 清理类型，默认为全部
+            }
+            
+            # 添加token认证头
+            headers = {
+                'Content-Type': 'application/json'
+            }
+            
+            # 发送同步POST请求
+            response = requests.post(clear_url, json=payload, headers=headers)
+            response.raise_for_status()  # 检查请求是否成功
+            print(f"Clear user session successful: {response.json()}")
+        except Exception as e:
+            print(f"Error clearing user session: {e}")
         ase_client.chatmanager.load_next_chapter()
         ase_client.send_text("chapter-start", "")
-        ase_client.send_text("clear","")
         namespace_entry.emit('message', "Multi-Agents服务已连接", room=init_data['room'], namespace='/agent')
 
     #接受消息回来直接让message监听发送