hjkhjkjhkhjkgjghjhgjhgjghjhghjghjhgjjnbvnvbnvk
bnmbnmbnhjkhjkhjkhjktyutyutyuytutyutyutyhgjgjghjgjghjguytutyry
/
opt
/
alt
/
python37
/
lib
/
python3.7
/
site-packages
/
xray
/
continuous
/
__pycache__
/
Upload FileeE
HOME
B �'Ud� � @ sH d Z ddlmZ ddlmZ ddlmZ ddlmZ G dd � d e�Z d S ) zR This module contains continuous tracing manager, aimed to enable|disable tracing � )�urlparse� )�ContinuousCommon� )� XRayError)� timestampc @ s� e Zd ZdZeeed�dd��Zeeedd�dd�Zedd �d d �Zedd �d d �Z edd �dd�Z eedd�dd�Z dd� Z dS )�ContinuousManagerz; enable|disable|start|stop|list continuous tracing )�url�returnc C s4 t | �}|j�dd�}|�d�d }|j� d|� �S )zW Leaves only domain path of URL, without www. prefix and :port postfix zwww.� �:r z://)r �netloc�replace�split�scheme)r Z fragmentsZ_no_www_netlocZ_no_port_netloc� r �H/opt/alt/python37/lib/python3.7/site-packages/xray/continuous/manager.py� url_sanitize s z ContinuousManager.url_sanitizeN)�domainr �emailr c C sd || j kr,t� || �|�|ddd�| j |< n,| jjd|| j | d�d� td|� d���| �� d S ) z+ Enable continuous tracing r �running)Z creation_timer Z original_urlr Zexecution_count�statusz(Continuous monitoring is already enabled)r � tracing_entry)�extrazContinuous monitoring for z is already enabledN)� tracing_confr r �logger�errorr �dump_tracing_configuration)�selfr r r r r r �enable" s zContinuousManager.enable)r r c C s | � |� dS )z, Disable continuous tracing N)Z remove_tracing_configuration)r r r r r �disable8 s zContinuousManager.disablec C s | � |d� dS )z- Start continuous monitoring r N)� update_status)r r r r r �start> s zContinuousManager.startc C s | � |d� dS )z, Stop continuous monitoring �stoppedN)r! )r r r r r �stopD s zContinuousManager.stop)r r r c C s� yH| j | d |krF| jjd||| j | d�d� td|� d|� ���W n< tk r� | jjd|| j d�d� td|� d ���Y nX || j | d< | �� d S ) z; Set given 'status' for requested 'domain' r z#Continuous monitoring is already %s)r r )r zContinuous monitoring for z is already z$Continuous monitoring is not enabled)r Ztracing_entriesz is not enabledN)r r r r �KeyErrorr )r r r r r r r! J s" z ContinuousManager.update_statusc C s t | j�� �S )z5 Return all continuous tracing tasks )�listr �values)r r r r �get_tracing_lista s z"ContinuousManager.get_tracing_list) �__name__� __module__� __qualname__�__doc__� staticmethod�strr r r r" r$ r! r( r r r r r s r N) r, � urllib.parser �commonr �internal.exceptionsr �internal.utilsr r r r r r �<module> s