cn/com allow all
This commit is contained in:
@@ -113,8 +113,14 @@ class AgentNamespace(Namespace):
|
||||
callback=self.receive_ase_chapter_score,
|
||||
entry=(get_or_load_current_user(),chatmanager),
|
||||
init_data={'room': user_uuid}
|
||||
)
|
||||
user_uuid2ase_client[user_uuid].connect()
|
||||
)
|
||||
user_uuid2ase_client[user_uuid].register_route_with_entry(
|
||||
route='process',
|
||||
callback=self.receive_ase_process,
|
||||
entry=self,
|
||||
init_data={'room': user_uuid}
|
||||
)
|
||||
user_uuid2ase_client[user_uuid].connect()
|
||||
|
||||
|
||||
|
||||
@@ -185,6 +191,9 @@ class AgentNamespace(Namespace):
|
||||
user.set_course_progress(chatmanager.chat_historys, chatmanager.scores, chatmanager.material_id, chatmanager.chapter_name, chatmanager.lesson_name)
|
||||
chatmanager.load_next_chapter()
|
||||
|
||||
def receive_ase_process(client_entry: HSAEngineClient, namespace_entry: Namespace, data, init_data):
|
||||
# namespace_entry.emit('process', data['data'], room=init_data['room'], namespace='/agent')
|
||||
pass
|
||||
|
||||
def on_initiative(self,data): # 主动call
|
||||
print("User active function call")
|
||||
|
||||
Reference in New Issue
Block a user