2026-04-11 11:51:54 +08:00
|
|
|
|
o
|
2026-04-12 00:47:48 +08:00
|
|
|
|
{Úi—8 ã @ sž d Z ddlZddlZddlZddlmZmZ ddlmZm Z m
|
2026-04-11 22:36:05 +08:00
|
|
|
|
Z
|
|
|
|
|
|
ddl m Z m
|
|
|
|
|
|
Z
|
2026-04-11 21:39:04 +08:00
|
|
|
|
mZmZmZ ddlmZ ddlmZ e e¡ZdZd ZG d
|
2026-04-11 22:36:05 +08:00
|
|
|
|
d „ d ƒZeƒ ZdS ) uH
|
2026-04-11 22:38:47 +08:00
|
|
|
|
Matrix Bot æœ�务 - 使用 nio 库处ç�†æ¶ˆæ�¯æ”¶å�‘（支æŒ�åŠ å¯†ï¼‰
|
|
|
|
|
|
é N)ÚOptionalÚCallable)Ú AsyncClientÚRoomMessageTextÚ MegolmEvent)Ú SessionLocalÚUserÚ ConversationÚMessageÚ SystemConfig)ÚConversationService)Ú
|
2026-04-12 00:26:04 +08:00
|
|
|
|
ai_serviceÚ main_userz?/home/xian/.openclaw/workspace-coder/works/ai-chat/matrix_storec @ sf e Zd Zdd„ Zdd„ Zddefdd„Zd d
|
2026-04-11 21:39:04 +08:00
|
|
|
|
„ Zd d „ Zd
|
2026-04-12 00:26:04 +08:00
|
|
|
|
d„ Z dd„ Z
|
2026-04-11 22:36:05 +08:00
|
|
|
|
de de fdd„Z dd„ Z
|
2026-04-12 00:26:04 +08:00
|
|
|
|
dS )Ú MatrixBotc C s6 d | _ d| _d| _d| _d| _d | _d| _tƒ | _d S )NÚ F) ÚclientÚ
|
|
|
|
|
|
homeserverÚuser_idÚpasswordÚ
|
2026-04-11 22:36:05 +08:00
|
|
|
|
is_runningÚon_message_callbackÚ last_room_idÚsetÚprocessed_events©Úself© r úM/home/xian/.openclaw/workspace-coder/works/ai-chat/services/matrix_service.pyÚ__init__ s zMatrixBot.__init__c à sÞ �t ƒ }zedd„ | t¡ ¡ D ƒ}| dd¡| _| dd¡| _| dd¡| _t d | j› d
|
2026-04-12 00:26:04 +08:00
|
|
|
|
| j› �¡ | jr\| jrct
|
2026-04-11 22:36:05 +08:00
|
|
|
|
j t d d � t
|
|
|
|
|
|
| j| jt d
|
|
|
|
|
|
�| _d | _t dt › �¡ W | ¡ d S W | ¡ dS W | ¡ dS | ¡ w )u 从数æ�®åº“é…�ç½®åˆ�始化c S s i | ]}|j |j“qS r )ÚkeyÚvalue)Ú.0Úcr r r Ú
|
|
|
|
|
|
<dictcomp># s z.MatrixBot.init_from_config.<locals>.<dictcomp>Úmatrix_homeserverzhttp://matrix.tphai.comÚmatrix_usernamez@tester:matrix.tphai.comÚmatrix_passwordz
|
|
|
|
|
|
tester12345@!u Matrixé…�ç½®: homeserver=z, user=T)Úexist_ok)Ú
|
2026-04-12 00:26:04 +08:00
|
|
|
|
store_pathu1 Matrix nio 客户端已åˆ�始化，å˜å‚¨è·¯å¾„: F)r Úqueryr ÚallÚgetr r r ÚloggerÚinfoÚosÚmakedirsÚ
|
2026-04-11 22:36:05 +08:00
|
|
|
|
STORE_PATHr r r Úclose)r ÚdbÚconfigsr r r Úinit_from_config s4 € ý òñ
|
2026-04-12 00:26:04 +08:00
|
|
|
|
ÿzMatrixBot.init_from_configNÚmessage_handlerc
|
|
|
|
|
|
à s �| j r| jst d¡ dS || _zN| j | j¡I dH }t d|› �¡ t d¡ | jjdd�I dH }t d|j › �¡ | j
|
|
|
|
|
|
| j t ¡ | j
|
2026-04-11 22:36:05 +08:00
|
|
|
|
| j
|
|
|
|
|
|
t¡ t d¡ t | ¡ ¡ t d ¡ W dS ty… } zt d
|
2026-04-11 23:00:19 +08:00
|
|
|
|
|› �¡ d dl}t | ¡ ¡ W Y d}~dS d}~ww ) u 开始å�Œæ¥æ¶ˆæ�¯u Matrix未连接Nu Matrix登录æˆ�功: u åŠ è½½åŠ å¯†å˜å‚¨...T)Ú
|
2026-04-12 00:26:04 +08:00
|
|
|
|
full_stateu åˆ�始å�Œæ¥å®Œæˆ�: next_batch=u Matrix消æ�¯å›žè°ƒå·²æ³¨å†Œu' Matrix nio sync_forever 任务已å�¯åŠ¨u Matrixå�¯åŠ¨å¤±è´¥: r )r r r, Úwarningr Úloginr r- ÚsyncÚ
|
2026-04-11 23:49:15 +08:00
|
|
|
|
next_batchÚadd_event_callbackÚ_handle_nio_messager Ú_handle_encrypted_messager ÚasyncioÚ create_taskÚ_run_sync_foreverÚ ExceptionÚerrorÚ tracebackÚ
|
|
|
|
|
|
format_exc)r r5 Ú
|
|
|
|
|
|
login_respÚ sync_respÚerC r r r Ú
|
|
|
|
|
|
start_sync; s, €
|
2026-04-12 00:26:04 +08:00
|
|
|
|
|
2026-04-11 23:49:15 +08:00
|
|
|
|
|
2026-04-12 00:26:04 +08:00
|
|
|
|
€ýzMatrixBot.start_syncc
|
2026-04-11 22:36:05 +08:00
|
|
|
|
à sz �zt d¡ | jjdd�I dH W dS ty< } z t d|› �¡ ddl}t | ¡ ¡ d| _W Y d}~dS d}~ww )u. è¿�è¡Œ sync_forever，自动处ç�†æ‰€æœ‰äº‹ä»¶u 开始 Matrix sync_forever...i0u )ÚtimeoutNu sync_forever 错误: r F) r, r- r Ú sync_foreverrA rB rC rD r )r rG rC r r r r@ ^ s €
|
2026-04-12 00:34:30 +08:00
|
|
|
|
۟zMatrixBot._run_sync_foreverc
|
2026-04-12 00:47:48 +08:00
|
|
|
|
à s8 �t d|j› d|j› �¡ t d|j› �¡ zÝd}|j}|jrst d|j› �¡ z/| |j¡}|rWt dt|ƒ› �¡ t|dƒrW|j }t|dƒrL|jn|j}t d |› �¡ W n t
|
|
|
|
|
|
yr } zt d
|
2026-04-12 00:34:30 +08:00
|
|
|
|
|› �¡ W Y d}~nd}~ww |s¦t|d ƒr¦|j r¦|j
|
|
|
|
|
|
d i ¡}d|v r¦|
|
2026-04-12 00:47:48 +08:00
|
|
|
|
dd
|
2026-04-12 00:26:04 +08:00
|
|
|
|
¡}|j
|
2026-04-12 00:47:48 +08:00
|
|
|
|
d|j¡}t d|r¡|dd… nd› �¡ |s¿t|dƒr¿|j r¿|j }t d|dd… › �¡ |rßt d|› d|dd… › �¡ | ||||j¡I dH W dS t d|j› �¡ t d|j› d�¡ W dS t
|
2026-04-12 00:26:04 +08:00
|
|
|
|
�y } zt d|› �¡ ddl}t | ¡ ¡ W Y d}~dS d}~ww )u# 处ç�†åŠ 密消æ�¯ï¼ˆMegolmEvent）u æ”¶åˆ°åŠ å¯†æ¶ˆæ�¯: [z ] event_id=zevent.decrypted: Nu 消æ�¯å·²è§£å¯†: u 解密事件类型: ÚbodyÚsenderu 从 decrypted 获å�–: u parse_decrypted_event 失败: ÚsourceÚcontentr u 从source.content获å�–: é2 Úemptyu 从event.body获å�–: u 解密æˆ�功: sender=z, body=u# åŠ å¯†æ¶ˆæ�¯æ— 法解密: event_id=zevent.decrypted=u , 需è¦�密钥u 处ç�†åŠ 密消æ�¯å¤±è´¥: r )r, r- Úroom_idÚevent_idÚ decryptedrL Úparse_decrypted_eventÚtypeÚhasattrrK rA r7 rM r+ Ú_process_messagerB rC rD ) r ÚroomÚeventrK rL Údecrypted_eventrG rN rC r r r r= j sR €
|
2026-04-12 00:47:48 +08:00
|
|
|
|
€ €ÿ €ýz#MatrixBot._handle_encrypted_messagec à sj �|j }|| jkrt d|› �¡ dS |j ¡ }t d|j› d|› d|› �¡ | ||||j ¡I dH dS )u, 处ç�† nio 收到的消æ�¯ï¼ˆæ™®é€šæ–‡æœ¬ï¼‰õ 忽略自己å�‘é€�的消æ�¯: Nu Matrix收到文本消æ�¯: [z] z: )
|
|
|
|
|
|
rL r r, ÚdebugrK Ústripr- rQ rW rR )r rX rY rL Ú message_textr r r r< ž s €
|
|
|
|
|
|
|
2026-04-11 23:49:15 +08:00
|
|
|
|
z MatrixBot._handle_nio_messagec
|
|
|
|
|
|
|
|
|
|
|
|
à s\ �|| j v rt d|› �¡ dS | j |¡ t d|› �¡ t| j ƒdkr1tt| j ƒdd… ƒ| _ || jkr@t d|› �¡ dS |j | _
|
2026-04-12 00:47:48 +08:00
|
|
|
|
t ƒ }zázŠt |ƒ}|j
|
2026-04-11 23:49:15 +08:00
|
|
|
|
tddd �}|d
|
|
|
|
|
|
krŠ| |j¡}| |j d ¡I dH t d |j› �¡ | jr‚| jd
|
|
|
|
|
|
|j|j d�I dH W W | ¡ dS | |j¡} | s™| |j¡}n| d }|j|jd|d||j |dœd�}
|
2026-04-12 00:26:04 +08:00
|
|
|
|
| jrÁ| jd|j||j |
|
2026-04-12 00:47:48 +08:00
|
|
|
|
j|d�I dH | jrÑ| jd|j|j d�I dH W nH t�y } z;t d| › �¡ ddl} t | ¡ ¡ | |j dt| ƒ› �¡I dH z| j j |j dd�I dH W n Y W Y d} ~ n d} ~ ww W | ¡ dS W | ¡ dS | ¡ w )u 处ç�†æ¶ˆæ�¯çš„æ ¸å¿ƒé€»è¾‘u 忽略已处ç�†çš„事件: Nu 处ç�†æ¶ˆæ�¯: event_id=éd iÎÿÿÿr[ u 主用户Úweb)Ú display_nameÚ user_typez/newu ✅ 已创建新会è¯�u Matrix创建新会è¯�: Únew_conversation)ÚactionÚconversation_idrQ r ÚuserÚmatrix)rR rQ rL )re ÚrolerN rM Ú
|
2026-04-11 22:38:47 +08:00
|
|
|
|
extra_dataÚ user_message)rd re rj rQ Ú
|
2026-04-12 00:47:48 +08:00
|
|
|
|
message_idrL Úgenerate_ai_responseu 处ç�†Matrix消æ�¯å¤±è´¥: u 处ç�†æ¶ˆæ�¯æ—¶å‡ºé”™: F)Ú typing_state) r r, r\ Úaddr- Úlenr Úlistr rQ r r r Úget_or_create_userÚ MAIN_USER_IDÚcreate_conversationÚidÚ send_messagere r r1 Úget_user_conversationsÚ add_messagerA rB rC rD Ústrr Ú room_typing)
|
|
|
|
|
|
r rX rL r^ rR r2 Ú conv_servicer Ú conversationÚ
|
|
|
|
|
|
conversationsÚuser_msgrG rC r r r rW sš €
|
2026-04-12 00:26:04 +08:00
|
|
|
|
|
2026-04-11 22:38:47 +08:00
|
|
|
|
ý ý 3 Ðýû
|
2026-04-12 00:47:48 +08:00
|
|
|
|
ú
|
