fj>
f d Z ddlmZ ddlmZ ddlmZ ddlm Z m
Z
ddl m Z G d d
e Z
d S ) zR
This module contains continuous tracing manager, aimed to enable|disable
tracing
)urlparse)gettext )ContinuousCommon ) XRayErrorXRayManagerExit) timestampc e Zd ZdZededefd ZdedededdfdZdeddfd Zdeddfd
Z deddfd Z
ded eddfd
Z d Z dS )ContinuousManagerz;
enable|disable|start|stop|list continuous tracing
urlreturnc t | }|j d r|j dd }n|j }| d d }|j d| S )zW
Leaves only domain path of URL, without www. prefix and :port postfix
zwww. N:r z://)r netloc
startswithsplitscheme)r
fragments_no_www_netloc_no_port_netlocs N/opt/cloudlinux/venv/lib64/python3.11/site-packages/xray/continuous/manager.py url_sanitizez ContinuousManager.url_sanitize sr
SMM & &v . . . & -abb 1NN & -N(..s33A6"88888 domainemailNc || j vr1t || | |ddd| j |< n t t d |z | dS )z+
Enable continuous tracing
r running)
creation_timer original_urlr execution_countstatusz8Continuous monitoring for domain "%s" is already enabledN) tracing_confr
r r _dump_tracing_configuration)selfr r
r s r enablezContinuousManager.enable& s * * *!* $ 1 1# 6 6 #$#
) )D f % % "LMMPVVX X
X '')))))r c 0 | | dS )z,
Disable continuous tracing
N) remove_tracing_configurationr' r s r disablezContinuousManager.disable8 s
))&11111r c 2 | |d dS )z-
Start continuous monitoring
r N
update_statusr+ s r startzContinuousManager.start>
69-----r c 2 | |d dS )z,
Stop continuous monitoring
stoppedNr. r+ s r stopzContinuousManager.stopD r1 r r# c | j | d |k r[| j d||| j | d t t d || nQ# t $ rD | j d|| j d t t d |z w xY w|| j | d< | d S )
z;
Set given 'status' for requested 'domain'
r# z#Continuous monitoring is already %s)r
tracing_entry)extraz*Continuous monitoring for {} is already {}z$Continuous monitoring is not enabled)r tracing_entriesz+Continuous monitoring for %s is not enabledN)r$ loggererrorr r% formatKeyErrorr& )r' r r# s r r/ z ContinuousManager.update_statusJ sH K (2f<< !!"G"(39:>:K-3;5)6 )6 " 7 7 7
BII&RXYYZZ\ \ \
= K K K K D/58<8I%K %K
L
L
L ?@@6IK K
K K /5&!(+ '')))))s
A2A5 5ACc N t | j S )z5
Return all continuous tracing tasks
)listr$ values)r' s r get_tracing_listz"ContinuousManager.get_tracing_lista s! D%,,..///r )
__name__
__module__ __qualname____doc__ staticmethodstrr r( r, r0 r4 r/ r@ r r r r s
9#
9#
9
9
9 \
9*S *s *3 *4 * * * *$2c 2d 2 2 2 2 .C .D . . . . .3 .4 . . . . *C * * * * * *.0 0 0 0 0r r N)rD urllib.parser xrayr r% commonr internal.exceptionsr r internal.utilsr
r rG r r rM s " ! ! ! ! ! $ $ $ $ $ $ < < < < < < < < & & & & & &Q0 Q0 Q0 Q0 Q0( Q0 Q0 Q0 Q0 Q0r