大段粘贴检测

Html/apps/sockets/namespaces.py

@@ -126,6 +126,12 @@ class AgentNamespace(Namespace):
                                             entry=self,
                                             init_data={'room': user_uuid}
                                         )
+        user_uuid2ase_client[user_uuid].register_route_with_entry(
+                                            route='paste_detected',
+                                            callback=self.receive_ase_paste_detected,
+                                            entry=self,
+                                            init_data={'room': user_uuid}
+                                        )
         user_uuid2ase_client[user_uuid].connect()
         
         
@@ -179,6 +185,12 @@ class AgentNamespace(Namespace):
         ase_client.send_text("chapter-start", "")
         namespace_entry.emit('message', "Multi-Agents服务已连接", room=init_data['room'], namespace='/agent')
 
+    #接受消息回来直接让message监听发送
+    def receive_ase_paste_detected(client_entry: HSAEngineClient, namespace_entry: Namespace, data, init_data):
+        print("receive_ase_paste_detected", data)
+        client_entry.chatmanager.chat_historys.append({'role': 'assistant', 'content': data['data']})
+        namespace_entry.emit('message', data['data'], room=init_data['room'], namespace='/agent')
+
     def receive_ase_dialog(client_entry: HSAEngineClient, namespace_entry: Namespace, data, init_data):
         print("receive_ase_dialog", data)
         client_entry.chatmanager.chat_historys.append({'role': 'assistant', 'content': data['data']})
@@ -195,7 +207,6 @@ class AgentNamespace(Namespace):
     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')
 
-
     def receive_ase_judge(client_entry: HSAEngineClient, namespace_entry: Namespace, data, init_data):
         print("receive_ase_judge", data)
         namespace_entry.emit('request_function', data, room=init_data['room'], namespace='/agent')  # data 是一个列表 /dict也支持