File: //usr/local/lib/python3.8/dist-packages/pyzabbix/__pycache__/api.cpython-38.pyc
U
�o�e;& � @ s� d dl Z d dlmZmZmZmZmZ d dlmZ d dl m
Z
d dl m Z dddd d
gZ
e �e�Ze�e �� � e
d �Ze
d �ZG d
d� de�ZG dd� d�ZG dd� d�ZG dd � d �ZG dd
� d
e�ZdS )� N)�Mapping�Optional�Sequence�Tuple�Union)�warn)�Version)�Session� ZabbixAPI�ZabbixAPIException�ZabbixAPIMethod�ZabbixAPIObject�ZabbixAPIObjectClassz5.4.0z6.4.0c s e Zd ZdZ� fdd�Z� ZS )r a� Generic Zabbix API exception
Codes:
-32700: invalid JSON. An error occurred on the server while
parsing the JSON text (typo, wrong quotes, etc.)
-32600: received JSON is not a valid JSON-RPC Request
-32601: requested remote-procedure does not exist
-32602: invalid method parameters
-32603: Internal JSON-RPC error
-32400: System error
-32300: Transport error
-32500: Application error
c s t � j|� |�dd �| _d S )N�error)�super�__init__�getr ��self�args�kwargs�� __class__� �0/tmp/pip-unpacked-wheel-3fqz2ouq/pyzabbix/api.pyr ( s zZabbixAPIException.__init__)�__name__�
__module__� __qualname__�__doc__r �
__classcell__r r r r r s c @ s� e Zd Zd%eee eeeee e
e e f f ed�dd�Z d d�d d
�Z d d � Z
d&eeee dd�dd�Zdd� Zeed�dd��Zd'eeeed�dd�Zed�dd�Zd(eeeeef ed�dd �Zed d �d d �Zed d �d!d"�Zed d �d#d$�ZdS ))r
�http://localhost/zabbixNFT)�server�session�use_authenticate�timeout�detect_versionc C s| |pt � | _| jj�dddd�� || _d| _d| _d| _|| _|� d�sX|�
d �d }|| _ t �
d
| j � d | _|| _d S ) aR
:param server: Base URI for zabbix web interface (omitting /api_jsonrpc.php)
:param session: optional pre-configured requests.Session instance
:param use_authenticate: Use old (Zabbix 1.8) style authentication
:param timeout: optional connect and read timeout in seconds, default: None
If you're using Requests >= 2.4 you can set it as
tuple: "(connect, read)" which is used to set individual
connect and read timeouts.
:param detect_version: autodetect Zabbix API version
zapplication/json-rpczpython/pyzabbixzno-cache)z Content-Typez
User-Agentz
Cache-ControlF� r z/api_jsonrpc.php�/z JSON-RPC Server Endpoint: %sN)r r" �headers�updater# �
use_api_token�auth�idr$ �endswith�rstrip�url�logger�info�version�_detect_version)r r! r" r# r$ r% r r r r 1 s$ ��
zZabbixAPI.__init__)�returnc C s | S �Nr �r r r r � __enter__] s zZabbixAPI.__enter__c C s0 t |ttd �f�r,| jr(| js(| j�� dS d S )NT)�
isinstancer �type�is_authenticatedr* �userZlogout)r �exception_typeZexception_value� tracebackr r r �__exit__a s
zZabbixAPI.__exit__r& )r; �password� api_tokenr4 c C s� | j r"t| �� �| _t�d| j� |dk r:d| _|| _dS d| _| jrZ| j j
||d�| _n6| jr~| jt kr~| j j ||d�| _n| j j ||d�| _dS )a� Convenience method for calling user.authenticate
and storing the resulting auth token for further commands.
If use_authenticate is set, it uses the older (Zabbix 1.8)
authentication command
:param password: Password used to login into Zabbix
:param user: Username used to login into Zabbix
:param api_token: API Token to authenticate with
zZabbix API version is: %sNTr& )r; r? )�usernamer? )
r3 r � api_versionr2 r0 r1 r* r+ r# r; Z authenticate� ZABBIX_5_4_0�login)r r; r? r@ r r r rD i s zZabbixAPI.loginc C s | j r
dS | jj| jd�S )NT�Z sessionid)r* r; �checkAuthenticationr+ r6 r r r �check_authentication� s z ZabbixAPI.check_authenticationc C s: | j r
dS z| jj| jd� W n tk
r4 Y dS X dS )NTrE F)r* r; rF r+ r r6 r r r r: � s zZabbixAPI.is_authenticated)�
confformat�source�rulesr4 c C s t dtd� | jd |||d�S )z�Alias for configuration.import because it clashes with
Python's import reserved keyword
:param rules:
:param source:
:param confformat:
z�ZabbixAPI.confimport(format, source, rules) has been deprecated, please use ZabbixAPI.configuration['import'](format=format, source=source, rules=rules) instead� �import)�formatrI rJ )r �DeprecationWarning�
configuration)r rH rI rJ r r r �
confimport� s ��zZabbixAPI.confimportc C s
| j �� S r5 )Zapiinfor2 r6 r r r rB � s zZabbixAPI.api_version)�method�paramsr4 c
C sX d||p
i | j d�}i }dddh}| jr\||kr\| jrR| jtkrRd| j� �|d< n
| j|d< t�d |� | jj| j||| j d
�}t�d |j
� |� � |j s�t
d ��z |�� }W n4 tk
r� } zt
d
|j � ��|�W 5 d }~X Y nX t�d|� | j d7 _ d|k�rT|d } d| k�r$d| d< t
d| d � d| d � d| d � �| d | d��|S )Nz2.0)ZjsonrpcrQ rR r, zapiinfo.versionzuser.checkAuthenticationz
user.loginzBearer �
Authorizationr+ z Sending: %s)�jsonr( r$ zResponse Code: %szReceived empty responsezUnable to parse json: zResponse Body: %s� r �datazNo datazError �codez: �messagez, )r )r, r+ r2 � ZABBIX_6_4_0r0 �debugr" �postr/ r$ � status_code�raise_for_status�textr rT �
ValueError)
r rQ rR �payloadr( Zanonymous_methods�resp�response� exceptionr r r r �
do_request� sZ ��
�
��
�zZabbixAPI.do_requestr
��attrr4 c C s
t || �S )z-Dynamically create an object class (ie: host))r
�r rf r r r �_object s zZabbixAPI._objectc C s
| � |�S r5 �rh rg r r r � __getattr__ s zZabbixAPI.__getattr__c C s
| � |�S r5 ri rg r r r � __getitem__ s zZabbixAPI.__getitem__)r NFNT)r& r& N)r& r& r& )N)r r r �strr r �boolr �float�intr r r7 r> rD rG �propertyr: �dictrP rB r r rd rh rj rk r r r r r
/ sZ �� ,
�� %
�� �� Dc @ s$ e Zd Zeed�dd�Zdd� ZdS )r )rQ �parentc C s || _ || _d S r5 )�_method�_parent)r rQ rr r r r r s zZabbixAPIMethod.__init__c O s( |r|rt d��| j�| j|p |�d S )NzFound both args and kwargs�result)� TypeErrorrt rd rs r r r r �__call__ s zZabbixAPIMethod.__call__N)r r r rl r
r rw r r r r r
s c @ sL e Zd Zeed�dd�Zeed�dd�Zeed�dd�Zeed�d d
�Z d S ) r
)�namerr c C s || _ || _d S r5 )�_namert )r rx rr r r r r s zZabbixAPIObject.__init__re c C s t | j� d|� �| j�S )z%Dynamically create a method (ie: get)�.)r ry rt rg r r r rs s zZabbixAPIObject._methodc C s
| � |�S r5 �rs rg r r r rj # s zZabbixAPIObject.__getattr__c C s
| � |�S r5 r{ rg r r r rk & s zZabbixAPIObject.__getitem__N)
r r r rl r
r r rs rj rk r r r r r
s c s e Zd Z� fdd�Z� ZS )r c s t dtd� t� j||� d S )Nz8ZabbixAPIObjectClass has been renamed to ZabbixAPIObjectrK )r rN r r r r r r r + s �z ZabbixAPIObjectClass.__init__)r r r r r r r r r r * s )�logging�typingr r r r r �warningsr Zpackaging.versionr �requestsr �__all__� getLoggerr r0 �
addHandler� NullHandlerrC rY � Exceptionr r
r r
r r r r r �<module> s( �
_