CakeCN/hsa
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

ack-client

Browse Source
This commit is contained in:
CakeCN
2025-12-02 22:31:34 +08:00
parent 6c48d79076
commit 788fbb07da
1 changed files with 2 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
Html/apps/sockets/namespaces.py
View File

@@ -106,6 +106,7 @@ class AgentNamespace(Namespace):
chatmanager.init(user_uuid, user_uuid2ase_client[user_uuid], fmd, fmdp, fsp, course_id, chapter_name, lesson_name, max_iter=5, app=current_app, socketio=self) chatmanager.init(user_uuid, user_uuid2ase_client[user_uuid], fmd, fmdp, fsp, course_id, chapter_name, lesson_name, max_iter=5, app=current_app, socketio=self)
backboard_manager.add_backboard(user_uuid, user_id, course_id, lesson_name, root_path=f'/home/{user_id}/{course_id}/{chapter_name}/{lesson_name}') backboard_manager.add_backboard(user_uuid, user_id, course_id, lesson_name, root_path=f'/home/{user_id}/{course_id}/{chapter_name}/{lesson_name}')
chatmanager.bb = backboard_manager.get_backboard(user_uuid) chatmanager.bb = backboard_manager.get_backboard(user_uuid)
if not progress:
chatmanager.next_chapter() chatmanager.next_chapter()
# 如果有保存的进度，需要跳过已经完成的章节 # 如果有保存的进度，需要跳过已经完成的章节
@@ -212,25 +213,17 @@ class AgentNamespace(Namespace):
namespace_entry, ase_client = namespace_entry namespace_entry, ase_client = namespace_entry
namespace_entry.emit('open-iframe',"", room=init_data['room'], namespace='/agent') namespace_entry.emit('open-iframe',"", room=init_data['room'], namespace='/agent')
# 将异步emit改为同步requests.post请求
try: try:
# 构建请求URL，使用配置中的ASE_ENGINE_URL
base_url = current_app.config['ASE_ENGINE_URL'] base_url = current_app.config['ASE_ENGINE_URL']
clear_url = f"{base_url}/clear_user_session" clear_url = f"{base_url}/clear_user_session"
# 准备请求参数
payload = { payload = {
'namespace_url': current_app.config['ASE_ENGINE_URL_TOKEN'], # WebSocket命名空间URL 'namespace_url': current_app.config['ASE_ENGINE_URL_TOKEN'], # WebSocket命名空间URL
'user_id': init_data['room'], # 用户ID，对应session_info.id 'user_id': init_data['room'], # 用户ID，对应session_info.id
'clear_type': 'all' # 清理类型，默认为全部 'clear_type': 'all' # 清理类型，默认为全部
} }
# 添加token认证头
headers = { headers = {
'Content-Type': 'application/json' 'Content-Type': 'application/json'
} }
# 发送同步POST请求
response = requests.post(clear_url, json=payload, headers=headers) response = requests.post(clear_url, json=payload, headers=headers)
response.raise_for_status() # 检查请求是否成功 response.raise_for_status() # 检查请求是否成功
print(f"Clear user session successful: {response.json()}") print(f"Clear user session successful: {response.json()}")
@@ -278,7 +271,6 @@ class AgentNamespace(Namespace):
else: chatmanager.scores.append(data.get('data', None)) else: chatmanager.scores.append(data.get('data', None))
user.set_course_progress(chatmanager.chat_historys, chatmanager.scores, chatmanager.course_id, chatmanager.chapter_name, chatmanager.lesson_name) user.set_course_progress(chatmanager.chat_historys, chatmanager.scores, chatmanager.course_id, chatmanager.chapter_name, chatmanager.lesson_name)
chatmanager.load_next_chapter() chatmanager.load_next_chapter()
time.sleep(0.5)
chatmanager.ase_client.send_text("chapter-start", "") chatmanager.ase_client.send_text("chapter-start", "")