perf: webchat 主动信息

2025-01-16 11:19:02 +08:00
parent 2ee4b431d4
commit f1599e26b3
1 changed files with 3 additions and 1 deletions
@@ -38,11 +38,13 @@ class WebChatAdapter(Platform):
        )
        
    async def send_by_session(self, session: MessageSesion, message_chain: MessageChain):
+        # abm.session_id = f"webchat!{username}!{cid}"
        plain = ""
+        cid = session.session_id.split("!")[-1]
        for comp in message_chain.chain:
            if isinstance(comp, Plain):
                plain += comp.text
-        web_chat_back_queue.put_nowait(plain)
+        web_chat_back_queue.put_nowait((plain, cid))
        
        await super().send_by_session(session, message_chain)