MCP Agent Platform

o ��g� �@sTdZd
dl
Zd
dlmZmZ
d
dlZd
dlmZ
d
dl m Z mZ
Gdd�de�ZdS)u 听觉智能体 �N)�Dict�Any)
� BaseAgent)�AudioMessage�TextMessagecsJeZ
dZd
ededef�f
dd�Z�f
dd�Z�f
dd �Zd d�Z�Z S)�EarAgent�agent_id�host�portcs&t��
|
d
||�
t��|_d|_dS)N�audio_inputF)�super�__init__�srZ Recognizer� recognizer�is_listening)�selfrr r �
� __class__��4D:\DeepSeek\MCPAgent\mcpTest\src\agents\ear_agent.pyr s


zEarAgent.__init__c

�s*�
t��
�Id
H
d|_t�|���

d
S)u启动听觉智能体NT)r�startr�asyncio�create_task�_listen_loop�
rrrrrs�

zEarAgent.startc

�s�
d
|_t
���IdH
dS)u停止听觉智能体FN)rr�stoprrrrrs�
z EarAgent.stopc
 �s�
�
|jr�zot
���a}
|j�d
�

tj|jj|
ddd�IdH}d}t |�
D]+}ztj|jj |dd�IdH}W
nt
jyO


||d krE�t�d �
IdH
Yq$wt |jd |d�}|�d |���IdH
Wd�
n1smw



Y
WnUt
jy�


|j�d�

YnFt
jy�
}
z|j�d |���

t�d�
IdH
WYd}~n'd}~w
ty�
}
z|j�d|���

t�d �
IdH
WYd}~nd}~w
w|jsdSdS)u持续监听音频的循环zListening...�� )�timeoutZphrase_time_limitN�zzh-CN)
�language�
�brain)� sender_id�receiver_id�textzCould not understand audioz'Error with speech recognition service: �zError in listen loop: )rrZ Microphone�logger�infor� to_threadr�listen�rangeZrecognize_google�RequestError�sleeprr�send_message�to_dictZUnknownValueError�error� Exception)r�source�audio�max_retries�attemptr%�message�
errrrsZ�







�





�



�


��� 



�


���zEarAgent._listen_loop) �__name__� __module__�__qualname__�str�intr rrr� __classcell__rrrrrs 
r) �__doc__Zspeech_recognitionr�typingrrr�src.agents.base_agentr�src.utils.mcp_protocolrrrrrrr�<module>
s