ear_agent.cpython-312.pyc•5.63 kB
�
n��g� � �f � d Z ddlZddlmZmZ ddlZddlmZ ddl m
Z
ddl m Z m
Z
G d� de
� Zy) u
听觉智能体
� N)�Dict�Any)�SPEECH_RECOGNITION)� BaseAgent)� AudioMessage� TextMessagec �F � � e Zd Zdededef� fd� Z� fd�Z� fd�Zd� Z� xZ S )�EarAgent�agent_id�host�portc �j �� t �| � |d||� t j � | _ d| _ y )N� audio_inputF)�super�__init__�sr�
Recognizer�
recognizer� is_listening)�selfr r r
� __class__s ��,D:\AIProject\mcpTest\src\agents\ear_agent.pyr zEarAgent.__init__ s+ �� �
����=�$��=� �-�-�/��� !��� c � � �K � t �| � � � d{ ��� d| _ t j | j � � y7 �/�w)u 启动听觉智能体NT)r �startr �asyncio� create_task� _listen_loop�r r s �r r zEarAgent.start s: �� �� ��g�m�o� � � ������D� -� -� /�0� �s �A�A�0Ac � �L �K � d| _ t �| � � � d{ ��� y7 ��w)u 停止听觉智能体FN)r r �stopr s �r r! z
EarAgent.stop s �� �� � !����g�l�n� � �s �$�"�$c
� �� K � | j r� d}t |� D ]� } t j � 5 }| j j |d�� | j j d� t j | j j |t d t d �� � d{ ��� } ddd� n | j r��yy7 � # 1 sw Y nxY wnd# t $ rX}| j j d |d
z � d |� d |� �� ||d
z
k( r� t j d
� � d{ ���7 Y d}~nd}~ww xY wt d
}t |� D ]� } t j | j j t d �� � d{ ���7 } nH# t j $ r1 ||d
z
k( r� t j t d � � d{ ���7 Y ��w xY w t# | j$ d�� } | j' d| j) � � � d{ ���7 ddlm}
d| j$ |d�} |
| � � d{ ���7 ddd|id�} |
| � � d{ ���7 ��D# t $ r)}
| j j/ d|
� �� Y d}
~
��qd}
~
ww xY w# t j0 $ r | j j d� Y ��
t j $ rG}
| j j/ d |
� �� t j d � � d{ ���7 Y d}
~
��^d}
~
wt $ rG}
| j j/ d |
� �� t j d
� � d{ ���7 Y d}
~
���d}
~
ww xY w�w) u 持续监听音频的循环� g �?)�durationz Listening...�timeout�phrase_time_limit)r% r& Nu 麦克风访问错误 (尝试 � �/z): � retry_count�language)r* � retry_delay�brain)� sender_id� receiver_id�textr )�broadcast_message�audio)�typer- �content�chat�userr/ u 发送消息到Web界面失败: zCould not understand audioz'Error with speech recognition service: � zError in listen loop: )r �ranger �
Microphoner �adjust_for_ambient_noise�logger�infor � to_thread�listenr � Exception�warning�sleep�recognize_google� RequestErrorr r � send_message�to_dict�src.web.serverr0 �error�UnknownValueError)r �max_mic_retries� mic_attempt�sourcer1 � mic_error� max_retries�attemptr/ �messager0 � web_message� chat_message�es r r zEarAgent._listen_loop s( � �� �� � �J
'�"#��#(� �#9� >R�K�/� �]�]�_�
"�� �O�O� D� D�V�VY� D� Z� �K�K� ,� ,�^� <�*1�*;�*;� $��� 6� 6� &�(:�9�(E�2D�EX�2Y� + � % �E� "�
"�
"�>R� � � �% ��
"�
"��
"�� %� /� � � �+�+�.L�[�YZ�]�O�[\�]l�\m�mp�qz�p{�,|�}�&�/�A�*=�=� !� %�m�m�A� .�.�.�� /�� #5�]�"C�K�#(��#5� S��
S�)0�):�):� $��� @� @� %�);�J�)G�* � $ � $ �D�
"�� !��� S� &�+��/� 9� %�")�-�-�0B�=�0Q�"R� R� R�S�� S� *�"&�-�-�$+� !� �G�
�+�+�G�W�_�_�5F�G�G�G�R�D�$+�)-� � �'+�'� �
0� � <�<�<� %+�)/� &��( �(� � 0� � =�=�=��$� R� � � �)�)�,L�Q�C�*P�Q�Q��R�� �'�'�
?�� � � � �!=�>��?�?�
'�� � �!�!�$K�A�3�"O�P� �m�m�A�&�&�&�� �
'�� � �!�!�$:�1�#�">�?� �m�m�A�&�&�&��
'�sZ �
M1�J �C�A7C�,C �-C�2C�:J �= M1�
M1� C�C �C�J � D<�$AD7�,D/�-D7�2J �7D<�<J �6F�
F�F�J �;G�G
�G�J �G�?J �H�J � !I!� I�I!�I �I!� J �! J�* J�J �J�J �.M.�M1�M.�6L�L�L�M1� M.�'6M)� M � M)�#M1�)M.�.M1)
�__name__�
__module__� __qualname__�str�intr r r! r �
__classcell__)r s @r r
r
s- �� �"�� "�C� "�s� "�
1� �
M'r r
)�__doc__�speech_recognitionr �typingr r r �configr �src.agents.base_agentr �src.utils.mcp_protocolr r r
� r r �<module>r_ s, ��� � � � %� +� <�^'�y� ^'r