aseclient fix

This commit is contained in:
CakeCN
2025-12-09 16:38:18 +08:00
parent c3ca3f83f6
commit 3b4bebba6c
2 changed files with 5 additions and 3 deletions

View File

@@ -46,6 +46,7 @@ class ASEngineClient:
print(f"Connected to server. SID: {self.sid}") print(f"Connected to server. SID: {self.sid}")
if self._on_connect_callback is not None: if self._on_connect_callback is not None:
self._on_connect_callback( self._on_connect_callback(
self,
entry=self._on_connect_callback_entry, entry=self._on_connect_callback_entry,
init_data=self._on_connect_callback_initData init_data=self._on_connect_callback_initData
) )
@@ -139,7 +140,7 @@ class ASEngineClient:
cb = route_info['callback'] # 已经绑定过 entry cb = route_info['callback'] # 已经绑定过 entry
init = route_info.get('init_data') init = route_info.get('init_data')
try: try:
cb(data=data, init_data=init) # 传递关键字参数 cb(self, entry=entry, data=data, init_data=init) # 传递关键字参数
except Exception as e: except Exception as e:
print(f"Callback error on route '{_route}': {e}") print(f"Callback error on route '{_route}': {e}")
@@ -177,6 +178,7 @@ class ASEngineClient:
if 'callback' in self.routes[route]: if 'callback' in self.routes[route]:
try: try:
self.routes[route]['callback']( self.routes[route]['callback'](
self,
entry=None, entry=None,
data=data, data=data,
init_data=init_data init_data=init_data

View File

@@ -2,11 +2,11 @@ import requests
from flask_socketio import Namespace from flask_socketio import Namespace
def on_connect_to_ase(client_entry, entry, init_data, **kwargs): def on_connect_to_ase(client, entry, init_data, **kwargs):
''' '''
此时刚刚建立好aseclient连接并向前端发送打开code-server-like指令。 此时刚刚建立好aseclient连接并向前端发送打开code-server-like指令。
''' '''
print(f"on_connect_to_ase {client_entry}, {namespace_entry}, {init_data}") print(f"on_connect_to_ase{namespace_entry}, {init_data}")
namespace_entry, ase_client = entry namespace_entry, ase_client = entry
namespace_entry.emit('open-iframe',"", room=init_data['room'], namespace='/agent') namespace_entry.emit('open-iframe',"", room=init_data['room'], namespace='/agent')
namespace_entry.emit('message', "Agents服务已连接, 加载教案中", room=init_data['room'], namespace='/agent') namespace_entry.emit('message', "Agents服务已连接, 加载教案中", room=init_data['room'], namespace='/agent')