MCP Agent Platform

o ��g;�@sF
dd
lm
Z
mZmZ
ddlmZ
ddlmZ
ddlm Z
ddlm Z
ddlZddlZddl Z e
�Ze j�e j�e�
�
Ze j�e j�e j�e�
�
�
Ze j�edd�Ze jed d �
e j�edd�Ze jed d �
ejdeed �
dd�
eed �
Ze�Zd ae�d�
dd��
Ze�d�
dd��
Z e�!d�
defdd��
Z"de#fdd�Z$dS)�)�FastAPI� WebSocket�WebSocketDisconnect)
�Jinja2Templates)
�StaticFiles)
�HTMLResponse)
�RequestNZmcpTest�staticT)
�exist_ok� templatesz/static)
� directory)
�name�startupc���
d
at
d�

dS)NTzWeb server started��server_running�print�rr�.D:\DeepSeek\MCPAgent\mcpTest\src\web\server.py� startup_event!��
r�shutdownc�r)NFzWeb server shutting downrrrrr�shutdown_event'rrz/ws� websocketc
 �s�
|��IdH
t
�|�

td
tt
�
���

z�z�|�t�ddd��
�
IdH
z�|��IdH}
t� |
�
}td|���

|� d�
dkr�z7d d lm}
|red|ddi
|d|d dd�}|� |�
IdH
ntd�

ddddi
d�}t|�
IdH
Wn-ty�
}
z!td|���

ddddt|�
��i
d�}t|�
IdH
WYd}~nd}~w
wWnty�
}
z td|���

WYd}~nd}~w
wq'Wnty�
}
z td|���

WYd}~nd}~w
wW|t
vr�t
�|�

tdtt
�
���

dS|t
vr�t
�|�

tdtt
�
���

w)Nu,WebSocket连接已建立，当前连接数: �status� connected)�type�contentTu收到客户端消息: r�textr
)
�brain_instancer� sender_id�receiver_id)rr r!�message_typeu未找到大脑智能体实例Zchat�systemu-大脑智能体未启动，无法处理消息)rr ru处理大脑消息时出错: u处理消息时出错: u 处理WebSocket消息时出错: uWebSocket错误: u,WebSocket连接已关闭，剩余连接数: )�accept�websocket_connections�addr�len� send_text�json�dumps�receive_text�loads�getZsrc.brain.brain_agentrZ_handle_text_message�broadcast_message� Exception�str�remove)r�data�messagerZ brain_message� error_message�
errr�websocket_endpoint.sz�



�







�
���


�����

���2
���

�

r6r3c
�s��
tsd
Sd
}
t
t�
D]3}z|�t�|�
�
IdH
d}
Wqty>
}
ztd|���

|tvr4t�|�

WYd}~qd}~w
w|
S)u$广播消息到所有WebSocket连接FNTu发送消息失败: )r%�listr(r)r*r/rr1)r3Zsuccess� connectionr5rrrr.ws�






��r.)%�fastapirrr�fastapi.templatingr�fastapi.staticfilesr�fastapi.responsesrr�asyncior)�os�app�path�dirname�abspath�__file__�current_dir�base_dir�join� static_dir�makedirs� templates_dir�mountr�setr%r�on_eventrrrr6�dictr.rrrr�<module>
s4













H