tool_manager.cpython-312.pyc•8.89 kB
�
b�'h� � � � d dl mZmZmZmZmZmZmZmZ d dl Z d dl
m Z d dl m
Z
d dlmZ d dlZd dlZ G d� dej$ � Z ej( ej* d ej, ej. � � g�
� ej0 j2 D ]- Z eeej, � s�ej9 ed� � �/ ej: d � Z G d � d
e � Z e
G d� d� � Z G d� d� Z! e!� Z"y)� )�Dict�List�Callable�Any�Optional�Union�TypeVar�GenericN)�Enum)� dataclass)�wrapsc �* � � e Zd Zd� fd� Z� fd�Z� xZS )�
JsonFormatterc �( �� t �| � |||� y �N)�super�__init__)�self�fmt�datefmt�style� __class__s �� F:\NetBrainMCP\tool_manager.pyr zJsonFormatter.__init__ s �� �
����g�u�-� c �f �� t �| � |� }|j dd�� j d� S )Nzutf-8�replace)�errors)r �format�encode�decode)r �record�
log_recordr s �r r zJsonFormatter.format s2 �� ��W�^�F�+�
�� � ��� �;�B�B�7�K�Kr )NN�%)�__name__�
__module__� __qualname__r r �
__classcell__)r s @r r r
s �� �.�L� Lr r z4%(asctime)s - %(name)s - %(levelname)s - %(message)s)�stream)�levelr �handlers� tool_managerc �( � e Zd ZdZdZdZdZdZdZdZ y) � ToolCategoryu 工具分类枚举�general�network_device�
configuration�topology�
diagnostic�securityN)
r$ r% r& �__doc__�GENERAL�NETWORK_DEVICE�
CONFIGURATION�TOPOLOGY�
DIAGNOSTIC�SECURITY� r r r- r- " s# � � ��G�%�N�#�M��H� �J��Hr r- c �b � e Zd ZU dZeed< eed< eed< eed< eeeee f f ed< eed< y) �ToolInfou 工具信息数据类�name�func� description�category�
parameters� return_typeN)
r$ r% r& r4 �str�__annotations__r r- r r r; r r r= r= + s9 � � �
�I�
�N������S�$�s�C�x�.�(�)�)��r r= c � � e Zd ZdZd� Zddej fdee dee dede fd�Z
d dee de e ee
f fd �Zdedee fd
�Zdede
fd �Zy)
� ToolManageru0 工具管理器，负责工具的注册和调用c �z � i | _ t D �ci c] }|g �� c}| _ t j d� y c c}w )Nu 工具管理器初始化完成)�toolsr- �
categories�logger�info)r �cats r r zToolManager.__init__8 s6 � �*,��
�MY�9Z�\�c�#�r�'�\�9Z���� � �4�5�� :[s �
8Nr> r@ rA �returnc �8 � ���� dt dt f���� fd� }|S )u1
工具注册装饰器
Args:
name: 工具名称，默认使用函数名
description: 工具描述，默认使用函数文档字符串
category: 工具分类，默认为通用类
Returns:
装饰器函数
r? rN c �| �� � � �xs � j � �
xs � j xs d}t j � � }i }|j j � D ]� \ }}|j t j j k7 r |j nt }|j t j j k( rd n |j }t |� ||j t j j k( d�||< �� |j t j j k7 rt |j � nd}t � � |� ||�� } | �j � < �j � j# � � t$ j' d� � d� j( � d�� t+ � � � � fd�� }
|
S ) Nu 无描述)�type�default�requiredr )r> r? r@ rA rB rC � 工具 'u ' 已注册到类别 '�'c � �� t j d�� �� �| i |��}|S # t $ r*}t j d�� dt |� � �� � d }~ww xY w)Nu 调用工具: rT � ' 执行错误: )rK rL � Exception�errorrD )�args�kwargs�result�er? � tool_names ��r �wrapperz=ToolManager.register_tool.<locals>.decorator.<locals>.wrappert s` �� �� � �n�Y�K� 8�9�� !�4� 2�6� 2�F�!�M�� � ��L�L�8�I�;�6F�s�1�v�h�!O�P����s � % � A�%A�A)r$ r4 �inspect� signaturerB �items�
annotation� Parameter�emptyr rR rD �return_annotation� Signaturer= rI rJ �appendrK rL �valuer
)r? �tool_description�sig�params�
param_name�param�
param_type�
param_defaultrC � tool_infor_ r^ rA r@ r> r s ` @����r � decoratorz,ToolManager.register_tool.<locals>.decoratorL s� �� � �-��
�
�I� +� I�d�l�l� I�k� � �#�#�D�)�C� �F�%(�^�^�%9�%9�%;�!�
�E�16�1A�1A�W�EV�EV�E\�E\�1\�U� -� -�be�
�(-�
�
��9J�9J�9P�9P�(P��V[�Vc�Vc�
� �
�O� ,� %�
�
��1B�1B�1H�1H� H�&��z�"� &<� 9<�8M�8M�QX�Qb�Qb�Qh�Qh�8h�#�c� 3� 3�4�ns�K� !� �� ,�!�!� '�
�I� %.�D�J�J�y� !� �O�O�H� %� ,� ,�Y� 7� �K�K�(�9�+�-C�H�N�N�CS�ST�U� V�
�4�[�
� �
� �Nr )r )r r> r@ rA rr s ```` r �
register_toolzToolManager.register_tool= s$ �� � 2 �H� 2 �� 2 � 2 �h �r c �l � g }|r | j j |g � }n| j j � }|D ]s }| j j |� }|s�!|j |j
|j |j j |j |j d�� �u |S )u�
列出已注册的工具
Args:
category: 可选的工具分类过滤器
Returns:
工具信息列表
)r> r@ rA rB rC ) rJ �getrI �keysrh r> r@ rA ri rB rC )r rA r\ �
tool_namesr> �tools r �
list_toolszToolManager.list_tools� s� � � �� � � � �,�,�X�r�:�J� ��� � �*�J� �D��:�:�>�>�$�'�D���
�
� �I�I�#'�#3�#3� $�
�
� 3� 3�"&�/�/�#'�#3�#3� � � � �
r c �8 � | j j |� S )u�
获取工具信息
Args:
name: 工具名称
Returns:
工具信息或None
)rI ru )r r> s r �get_toolzToolManager.get_tool� s � � �z�z�~�~�d�#�#r c � � | j |� }|st d|� d�� �t j d|� �� |j |i |��S # t
$ r*}t j
d|� dt |� � �� � d}~ww xY w)u
执行工具
Args:
name: 工具名称
args: 位置参数
kwargs: 关键字参数
Returns:
工具执行结果
Raises:
ValueError: 如果工具不存在
rT u ' 不存在u 执行工具: rW N)r{ �
ValueErrorrK rL r? rX rY rD )r r> rZ r[ rx r] s r � execute_toolzToolManager.execute_tool� s� � � �}�}�T�"��� �x��v�[� 9�:� :�� � �n�T�F�+�,� � �4�9�9�d�-�f�-� -��� � �L�L�8�D�6�)9�#�a�&��B� C� �� �s �A � B�%A<�<Br )r$ r% r& r4 r r- r5 r rD r rs r r r ry r= r{ r~ r; r r rG rG 5 s� � �:�6� -1�37�/;�/C�/C�C� $�S�M�C�#+�C�=�C� !-�C� IQ�C�J �8�L�#9� �T�$�s�TW�x�.�EY� �<
$�S�
$�X�h�%7�
$��� �#� r rG )#�typingr r r r r r r r
r` �enumr � dataclassesr � functoolsr
�logging�sys� Formatterr � basicConfig�INFO�
StreamHandler�stdout�rootr* �handler�
isinstance� setFormatter� getLoggerrK r- r= rG r+ r; r r �<module>r� s� �� O� O� O� � � !� � �
�L�G�%�%� L� �� � �
�,�,� A� �� � �S�Z�Z�0��� �|�|�$�$�G��'�7�0�0�1�� � �]�+a� b�c� %�
�� � �>� *���4� � �� � ��O� O�d �}� r