o
��g�
� @ sT d Z ddlZddlmZmZ ddlZddlmZ ddl m
Z
m Z G dd� de�Z dS )u
听觉智能体
� N)�Dict�Any)� BaseAgent)� AudioMessage� TextMessagec sJ e Zd Zdededef� fdd� Z� fdd�Z� fdd �Zd
d � Z� Z S ) �EarAgent�agent_id�host�portc s& t � �|d||� t�� | _d| _d S )N� audio_inputF)�super�__init__�srZ
Recognizer�
recognizer� is_listening)�selfr r r
�� __class__� �4D:\DeepSeek\MCPAgent\mcpTest\src\agents\ear_agent.pyr
s
zEarAgent.__init__c � s* �t � �� I dH d| _t�| �� � dS )u 启动听觉智能体NT)r �startr �asyncio� create_task� _listen_loop�r r r r r s �zEarAgent.startc � s �d| _ t� �� I dH dS )u 停止听觉智能体FN)r r �stopr r r r r s �z
EarAgent.stopc
� s� �| j r�zot�� �a}| j�d� tj| jj|ddd�I dH }d}t |�D ]+}ztj| jj
|dd�I dH }W n tj yO ||d krE� t� d �I dH Y q$w t
| jd
|d �}| �d
|�� �I dH W d � n1 smw Y W nU tjy� | j�d � Y nF tj y� } z| j�d
|� �� t� d�I dH W Y d}~n'd}~w ty� } z| j�d|� �� t� d �I dH W Y d}~nd}~ww | j sdS dS )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: )r r Z
Microphone�logger�infor � to_threadr �listen�rangeZrecognize_google� RequestError�sleepr r � send_message�to_dictZUnknownValueError�error� Exception)r �source�audio� max_retries�attemptr% �message�er r r r sZ �
� � �� �� � ���zEarAgent._listen_loop)
�__name__�
__module__� __qualname__�str�intr
r r r �
__classcell__r r r r r s
r )
�__doc__Zspeech_recognitionr �typingr r r �src.agents.base_agentr �src.utils.mcp_protocolr r r r r r r �<module> s
MCP directory API
We provide all the information about MCP servers via our MCP API.
curl -X GET 'https://glama.ai/api/mcp/v1/servers/rolenet/McpAgentRobot'
If you have feedback or need assistance with the MCP directory API, please join our Discord server