9Mjo B d Z ddlZddlZddlZddlZddlZddlZddlm Z ddl
m Z m Z m
Z
ddlmZmZ ddlmZ ddlmZ ddlmZ dd lmZmZ dd
lmZm Z d d l m Z m Z dd
l!m"Z# ddl$m%Z%m&Z&m'Z' d dl(m)Z)m*Z*m+Z+ d dl,m-Z-m.Z.m/Z/ d dl0m1Z1 d dl2m3Z3 d dl4m5Z5m6Z6 d dl7m8Z8 ddl9m:Z: G d d Z; G d d Z< G d de;e< Z= G d d e; Z> G d d e;e< Z? G d d!e; Z@ G d" d#e; ZA G d$ d%e; ZB G d& d'e; ZCdS )(zA
This module contains class implementing MongoDB API interaction
N)partial)ListAnyIterable)SessionResponse) HTTPAdapter)RequestException)Retry)Schema SchemaError)is_feature_visible is_feature_hidden_server_wide ) supportedget_advice_instance)gettext)detailed_advice_schemauser_sites_info_schemaadvice_list_schema)
api_serverprotoadviser_api_server) XRayAPIErrorXRayAPIEmptyResponseTaskNotFoundError)open_local_storage)Task)get_xray_exec_useruser_mode_verificationread_jwt_token)filter_by_non_existencec
$ e Zd ZdZdddedefdZd Zd Zed efd
Z ed e
fd Z d efd Z d de
ded efdZd de
ded e
fdZ d dede
dededed e
f dZd dededefdZd ded e
fdZd!deded efdZd ded e
fdZd ZdS )"Clientz
Base client class
unavailabletracing_task_id system_idr( c || _ || _ t j d | _ t dt
ddg t
g d d }t | }t | _ | j
t d| t | j j
d
| j _
d S ) N
api_client GETPOST)i i i )totalallowed_methodsstatus_forcelistbackoff_factor) max_retries://
)timeout)r) task_idlogging getLoggerloggerr frozensetr r sessionmountr r request)selfr) r(
retry_confadapters P/opt/cloudlinux/venv/lib64/python3.11/site-packages/xray/apiclient/api_client.py__init__zClient.__init__0 s "& ' 55 %ufo 6 6 & 7 7
*555 yy e==='222 &t|';R H H H c > | j j d| j d| j S )N::z::tracing_task_id=) __class____name__
main_endpointr7 r? s rB __repr__zClient.__repr__@ s* .)aaT-?aaSWS_aaarD c . | j j d| j S )NrF )rG rH r7 rJ s rB __str__zClient.__str__C s .);;T\;;;rD returnc : t t d )z
Base endpoint
z$instances are to set their endpoint!)NotImplementedError_rJ s rB rI zClient.main_endpointF s
"!$J"K"KLLLrD c " dt iS )zL
Updated request headers
:return: dict with headers
zX-Authr! rJ s rB _headerszClient._headersM s .**++rD c d| j i}|r| | t j | S )ze
Construct query string
:return: string including system_id and given kwargs
r) )r) updateurllibparse urlencode)r? kwargsinitials rB
_query_stringzClient._query_stringU s@
/ # NN6 " " "|%%g...rD Tresponsewith_status_checkc |j s_| j d|j |j d|j }t
t d |z |j d|j i | j d|j |j |j |j dk r|
}ndd i}|r8|d d k r,t
t d
t | z |S ) z
Perform preprocessing checks of received Response:
- is it OK, e.g. 200 OK
- was it successful, e.g. status == ok
and extract JSON from the Response object
:return: full JSON representation of response
zServer responded: %s:z#Unable to connect to server with %s resp_data)errnoextraz [%s:%s] Response received %s statusokz"Received unsuccessful response: %s) re r: debugtext status_codereasonr rQ infourljsonstr)r? r\ r] request_dataresults rB _preprocess_responsezClient._preprocess_response_ s {
r K 4hm D D D & 2FFX_FFL 788<G *"HM2
K ;X=QS[Sbdldp q q q 3 & & ]]__FF %F Zh 4''"1%I#J#JSQW[[#XYYY
rD c | || } |d }| j d|j | |t | |S # t
$ r t
cY S w xY w)z
Check received response
:param response: a requests.Response object
:return: 'result' dict from JSON representation of response
r] ro z [%s] Received response data %sN)ro )rp r: rj rh r KeyErrordict)r? r\ r] ro datas rB _process_responsezClient._process_response} s **8GX*YY (#D K =x?SUY Z Z Z|*&9999K 66MMM s O%PPPs A B
B;&B66B;c | j d| | j || j }n8# t
$ r+}| ||dt d |d }~ww xY w| || S )Nz Sending DELETE request to %sr| z
DELETE failedz)Failed to DELETE data to X-Ray API serverrr ) r: rj r< deleterS r
r rQ rv )r? rw ry r] r r s rB _deletezClient._delete s 7BBB <&&x &GGDD ++8_a0[.\.\
%%d>O%PPPs !?
A4 &A//A4c 2 | | j d| }| j d| | j || j }n8# t $ r+}| ||dt d |d}~ww xY w|S )z
GET request to endpoint or to main endpoint if no endpoint given
:param endpoint: target URL
:return: a requests Response object
N?zSending GET request to %sr| z
GET failedz(Failed to GET data from X-Ray API server)
rI r[ r: rj r< getrS r
r rQ r? rw r r s rB _raw_getzClient._raw_get s ,EEt/A/A/C/CEEH 4h??? <##Hdm#DDDD ++8\1-W+X+X
s !A
B)&BBc Z | | }| || S )z
GET request to endpoint or to main endpoint if no endpoint given
:param endpoint: target URL
:return: full dict from JSON representation of response without any
processing
rr )r rp )r? rw r] r s rB _get_fullzClient._get_full s/ }}X&&((AR(SSSrD c | | } | | S # t $ r}t | j |d}~ww xY w)z
GET request to endpoint or to main endpoint if no endpoint given
:param endpoint: target URL
:return: 'result' dict from JSON representation of response
)r7 N)r rv r r r7 r s rB _getz Client._get sg }}X&& A))$// /# A A A#DL999q @ As ,
AA Ac | j d||d|i |j d j }n# t t
f$ r |}Y nw xY w| d| }t
t d |z S )z
Process received exception
:param exc: original exception
:param api_endpoint: requested endpoint
:param log_message: text for logging the error
:param exc_message: text for internal exception
z
%s with %srw )rb r z: z%s. Please, try again later)r: errorargsri
IndexErrorAttributeErrorr rQ )r? exc api_endpoint log_message exc_messageexc_infoexception_datas rB r zClient._give_xray_exception s
, S\@Z[[[ x{)HHN+ HHH (55855A ; < <~ MNNNs 5 A
A T)NTTT)TTN)NT)rH
__module__ __qualname____doc__rm rC rK rM propertyrI rt rS r[ r boolr rp rv r r r r r r rD rB r% r% + s BO I I IS I3 I I I I b b b< < < Ms M M M XM ,$ , , , X,/ / / / / X $ Z] < ( t W[ & "&
Q Q Q Q Q
Q
Q
Q Q Q QDQ Q Qt Qt Q Q Q Q "T T# T TQT T T T T
A
AS
AD
A
A
A
AO O O O OrD r% c > e Zd ZdZedefd ZdedefdZ dS ) TaskMixinz1
A mixin class with Task related methods
rN c dS )z(
Limit processed fields
) rk rd client_ip
tracing_by
tracing_count starttime ini_location
initial_count
request_count auto_taskuserr rJ s rB task_fieldszTaskMixin.task_fields s
rD dict_viewc r fd| D }|d |d< t di |S )z@
Turn dictionary structure into valid Task type
c . i | ]\ }}|j v ||S r r .0kvr? s rB
z#TaskMixin._task.. s, QQQda1@P;P;PQ;P;P;PrD r( r7 r )itemsr )r? r task_views ` rB _taskzTaskMixin._task
sM RQQQioo&7&7QQQ (): ; ) i rD N)
rH r r r r tupler rt r r r rD rB r r sg
U
X
$!t ! ! ! ! ! ! !rD r c ` e Zd ZdZedefd Zdef fd Zdee f fd Z
xZ S ) TasksClientz!
'tasks' endpoint client
rN c & t dt dS )z&
Base endpoint: tasks
r4 z/api/xray/tasksr r rJ s rB rI zTasksClient.main_endpoint s
77J7777rD c H t d S )z
Construct query string.
Aimed to get auto tasks only
:return: string including system_id and type=auto
autotype)superr[ r? rY rG s rB r[ zTasksClient._query_string s ww$$&$111rD c b t } fd|D S )z#
Get list of Tasks
c : g | ]} | S r )r )r itemr? s rB
z)TasksClient.get_tasks.., s% 222T
4 222rD )r r )r? ru rG s ` rB get_taskszTasksClient.get_tasks' s1 ww||~~2222T2222rD ) rH r r r r rm rI r[ r r r
__classcell__rG s @rB r r s 8s 8 8 8 X8 2 2 2 2 2 2 234: 3 3 3 3 3 3 3 3 3 3rD r c e Zd ZdZdddedef fdZd Zedd
Zd e dd fd
Z
de fdZ edefd Z de
fdZde
defdZdedd fdZdedd fdZddZddZ xZS ) DBMClientzD
Client class using local dbm storage instead of remote API
r& r' r) r( c t || d | _ | | _ d S )N)r) r( )r rC task_object_db_open_db)r? r) r( rG s rB rC zDBMClient.__init__4 s;
9oNNN ==??rD c 8 | j d S r )r closerJ s rB __del__zDBMClient.__del__9 s rD rN
dbm._Databasec , t j dd S )zC
Open dbm DB
:return: corresponding object
z/root/local_mongoc)dbmopenr rD rB r zDBMClient._db_open< s x+S111rD post_dataNc H t j | | j | j < dS )z3
Update a DBM task with given data
N)rl dumpsr r7 )r? r s rB r zDBMClient._postD s" "&I!6!6 rD c t j | j | j S # t
t j f$ r"}t t d |d}~ww xY w)z:
Get saved DBM data
:return: dict
zFailed to load taskN) rl loadsr r7 decoders JSONDecodeErrorr rQ )r? r s rB r zDBMClient._getJ sq
@:dht| 4 ; ; = =>> >$./ @ @ @ q!6 7 788a ? @s 58 A0 A++A0c 2 t j j S r )uuiduuid1hexr rD rB _idz
DBMClient._idT s z|| rD c n | }| j |d< t di || _ | j S )1
Get saved task
:return:
r7 r )r r7 r r )r?
saved_tasks rB get_taskzDBMClient.get_taskX s<
YY[[
$
9 --*-- rD taskc | | _ | j |_ d|_ | | || _ | j S )a:
Create new task and get unique ID
url --> URL
client_ip --> IP
tracing_by --> time|request_qty
tracing_count --> COUNT
ini_location --> PATH
status --> processing
:param task: a Task instance
:return: task ID
hold)r r7 rd r as_dictr r? r s rB createzDBMClient.createb sM xxzz |
4<<>>""" |rD r c | j | d| j _ || j _ | | j dS )z
Update started|continued task
status --> running
starttime --> new timestamp
:return:
Nrunning)r r rd r r r r? r s rB rU zDBMClient.updateu sW # MMOOO"+ %."
4#++--.....rD countc | j | d| j _ || j _ | | j dS )}
Update stopped task
status --> stopped
tracing_count --> new value
:return:
Nstopped)r r rd r r r r? r s rB stopzDBMClient.stop sW # MMOOO"+ ).&
4#++--.....rD c | j | d| j _ | | j dS )Y
Complete tracing task
status --> completed
:return:
N completed)r r rd r r rJ s rB completezDBMClient.complete sL # MMOOO"-
4#++--.....rD c | j | j = dS z6
Delete tracing task
:return:
N)r r7 rJ s rB r zDBMClient.delete s
HT\ " " "rD )rN r rN N)rH r r r rm rC r staticmethodr rt r r r r r r intrU r r r r r s @rB r r / s BO # # #S #3 # # # # # #
2 2 2 \27t 7 7 7 7 7 @d @ @ @ @ \ $ 4 C & / / / / / / /# /$ / / / / / / / /# # # # # # # #rD r c e Zd ZdZedefd Zdef fd ZdeddfdZ deddfdZ
dd Z dd
Z e
defd Zd edefd
ZdeddfdZdeddfdZdddededdfdZdeddfdZddZddZddZ xZS ) APIClientz%
X-Ray task API client class
rN c & t dt dS )z%
Base endpoint: task
r4 z/api/xray/taskr rJ s rB rI zAPIClient.main_endpoint s
66J6666rD c | j dk r't | j S t S )z
Construct query string
:return: string either including system_id and task_id
or system_id only
r& r' )r7 r r[ r s rB r[ zAPIClient._query_string sE <= ( (77(( (FF Fww$$&&&rD r Nc | j d| }| |d | D }|d | _ dS )z
POST request to "create a task" API endpoint with given data
Obtains a task ID
:param post_data: dict with POST data
z/create?c & i | ]\ }}|d k ||S )r r r r r s rB r z*APIClient._post_create.. s* -e-e-etq!TUYdTdTdaTdTdTdrD r( N)rI r[ r r r7 )r? r rw
response_datas rB _post_createzAPIClient._post_create sc (HH$2D2D2F2FHH
8-e-ey?P?P-e-e-eff
$%67 rD c n | j d| }| || dS )z|
POST request to "update a task" API endpoint with given data
:param post_data: dict with POST data
z/update?NrI r[ r )r? r rw s rB _post_updatezAPIClient._post_update s@
(HH$2D2D2F2FHH
8Y'''''rD c | j dd }| d| }| | dS )z<
GET request to "share a task" API endpoint
Nz/share-request?rI r[ r )r? share_endpointrw s rB _sharezAPIClient._share sL +CRC0$KKT5G5G5I5IKK (rD c l | j d| }| | dS )z>
POST request to "delete a task" API endpoint
z/delete?Nr )r? rw s rB r zAPIClient._delete s> (HH$2D2D2F2FHH
8 rD c P | | S )r )r r rJ s rB r zAPIClient.get_task s zz$))++&&&rD r c d|_ fd| D j S )aH
Create new task and get unique ID
url --> URL
client_ip --> IP
tracing_by --> time|request_qty
tracing_count --> COUNT
ini_location --> PATH
status --> processing
:param task: a Task instance
:return: updated Task instance
r c . i | ]\ }}|j v ||S r r r s rB r z$APIClient.create.. s, \\\DAqa4K[F[F[1aF[F[F[rD )rd r r r r7 r s ` rB r zAPIClient.create sQ \\\\DLLNN,@,@,B,B\\\]]]|rD r c 6 | d|d dS )z
Update started|continued task
status --> running
starttime --> new timestamp
:param starttime: time of starting the Task
r )rd r Nr r s rB rU zAPIClient.update s&
YYGGHHHHHrD r c 4 | d|i dS )zw
Update tracing_count only. No status updated
tracing_count --> new value
:return:
r Nr r s rB update_count_onlyzAPIClient.update_count_only s#
?E233333rD )r r r c H |d|i}n||d}| | dS )a
Update tracing_count only. No status updated
request_count --> new value
tracing_count --> new value if given
:param request_count: number of requests already traced
:param tracing_count: number of requests left to trace
Nr )r r r )r? r r ru s rB update_counts_onlyz APIClient.update_counts_only s= #]3DD%2]SSD $ rD c 6 | d|d dS )r r )rd r Nr r s rB r zAPIClient.stop s&
YGGHHHHHrD c 4 | ddi dS )r rd r Nr rJ s rB r zAPIClient.complete s#
8[122222rD c . | dS )z5
Share tracing task
:return:
N)r rJ s rB sharezAPIClient.share! s
rD c . | dS r )r rJ s rB r zAPIClient.delete( s
rD r )rH r r r r rm rI r[ rt r r r r r r r r r rU r r r r r" r r r s @rB r r s 7s 7 7 7 X7 ' ' ' ' ' ' '8d 8t 8 8 8 8(d (t ( ( ( ( '$ ' ' ' ' 4 D I I I I I I4s 4t 4 4 4 4 NR 3 s VZ I# I$ I I I I3 3 3 3 rD r c > e Zd ZdZedefd ZdeddfdZdS )
SendClientz)
X-Ray requests API client class
rN c & t dt dS ))
Base endpoint: requests
r4 z/api/xray/requestsr rJ s rB rI zSendClient.main_endpoint5 s
::J::::rD ru Nc r | j d| }| ||d dS )zS
Send given data to ClickHouse
:param data: dict with data
r F)ry Nr r? ru rw s rB __call__zSendClient.__call__< sD
(AA4+=+=+?+?AA
8TE
22222rD ) rH r r r r rm rI rt r* r rD rB r% r% 0 sg ;s ; ; ; X; 3T 3d 3 3 3 3 3 3rD r% c e Zd ZdZedefd Zdef fd ZdefdZ ddede
d e
defd
Z dedefd Z ded e
defd
Z
xZS ) UIAPIClientz,
X-Ray User plugin API client class
rN c & t dt dS )r' r4 z /api/xrayr rJ s rB rI zUIAPIClient.main_endpointJ s
11J1111rD c r d | D } t j di |S )z
Construct query string
:return: string including system_id
and given kwargs, filtered by non-empty values
c i | ]
\ }}||| S r r r
s rB r z-UIAPIClient._query_string..W s IIIA1=1===rD r )r r r[ )r? rY filter_emptyrG s rB r[ zUIAPIClient._query_stringQ s> JI III $uww$44|444rD c | t }| j d| }| | }|d D ]}|d dk rt j |d d }t | 5 }|d d
k r|d |j z
|d < |j |d
< ddd n # 1 swxY w Y |S )zd
Get list of tasks and return not processed (full) response
from API server
)r z/tasks?ro rd r r( r5 ) digest_sizer timer r r N)
r[ r rI r hashlibblake2bencode hexdigestr processed_requests)r? qsrw r\ r fake_idstorages rB
get_task_listzUIAPIClient.get_task_listZ sQ
%7%9%9
:
:(5555>>(++ X&
C
CD H~,, od+<&=&D&D&F&FTVWWWaaccG#G,,
C %//,0 ,AGD^,^D )(/(B_%
C
C
C
C
C
C
C
C
C
C
C
C
C
C
C s **C C$ 'C$ Nr7 time_fromtime_toc t | ||| }| j d| }| | S )zG
Get list of requests collected for given tracing task
)r( r= r> z
/requests?r[ rI r )r? r7 r= r> r9 rw s rB get_request_listz UIAPIClient.get_request_listo sG
9V]
^
^(88B88~~h'''rD c p | | }| j d| }| | S )zB
Get hourly requests stats for given tracing task
r' z/requests_stats_by_hour?r@ )r? r7 r9 rw s rB get_requests_stats_by_hourz&UIAPIClient.get_requests_stats_by_hourw sB
8
8(FF"FF~~h'''rD
request_idc r | || }| j d| }| | S )zU
Get collected statistics for given request ID of given tracing task
)r( rD z /request?r@ )r? r7 rD r9 rw s rB get_request_dataz UIAPIClient.get_request_data sD
J
O
O(77277~~h'''rD )NN)rH r r r r rm rI r[ rt r< r rA rC rF r r s @rB r, r, E s 2s 2 2 2 X2 5 5 5 5 5 5 5t *( ( ( (S (\` ( ( ( ((# ($ ( ( ( (( ( ( ( ( ( ( ( ( ( (rD r, c e Zd ZdZ fdZdededefdZede fd Z
ede fd Z de fd Z
dedd
fd Zd d e d
edefdZdedd
fdZdee fdZd dededefdZdefdZdedefdZdedefdZdedefdZ xZS ) SmartAdviceAPIClient(
X-Ray Adviser API client class
c L t d d S N
not_needed)r) r rC r? rG s rB rC z SmartAdviceAPIClient.__init__ $
<00000rD ru schemarN c | | S # t $ rf}| j d| |j d p |j d }t
t d t | z d}~ww xY w)z&Validate given data using given schemaz#Failed to validate API response: %szMalformed API response: %sN) validater
r: r errorsautosr rQ rm )r? ru rP r msgs rB _validatez SmartAdviceAPIClient._validate s K??4(( ( K K K K CT J J J(2,-!'"+C q!= > >S IJJ J Ks
BA!BBc dt dS )r' https://z/apir rJ s rB rI z"SmartAdviceAPIClient.main_endpoint
3,2222rD c dS )z3
Limit fields available for update
)rd sourceri r rJ s rB fields_allowedz#SmartAdviceAPIClient.fields_allowed s
.-rD c d t D }t }|r| d|f | d | D t
j |d S )za
Construct query string
:return: string including types and given kwargs
c g | ]}d |fS r r )r _ts rB r z6SmartAdviceAPIClient._query_string.. s AAABFB<AAArD usernamec g | ] \ }}|||f S r r r
s rB r z6SmartAdviceAPIClient._query_string.. s% ???41aQ?A???rD ,)safe)supported_advice_typesr appendextendr rV rW rX )r? rY rZ user_contexts rB r[ z"SmartAdviceAPIClient._query_string s
BA*@AAA)++ 7 NNJ 5 6 6 6??6<<>>???@@@|%%gC%888rD Nc L | j d}| ||dd dS )z]
Send given data to Adviser microservice
:param data: dict with data
z
/requests/addFry r] NrI r r) s rB r* z SmartAdviceAPIClient.__call__ s5
(777
8TEU
KKKKKrD rw rx c | j d| | j ||| j }n8# t
$ r+}| ||dt d |d}~ww xY w| |d S )z
Perform PATCH request to given endpoint.
Add payload as JSON.
:param endpoint: target URL
:param payload: dict with data to PATCH
:return: full response
zSending PATCH request to %s)rl r} z PATCH failedz/Failed to PATCH data to Smart Advice API serverNFrr ) r: rj r< patchrS r
r rQ rp )r? rw rx r r s rB _patchzSmartAdviceAPIClient._patch s
6AAA <%%hWdm%TTDD ++8^Q/`-a-a
(((GGGs "A
A5
&A00A5c J | j d}| ||d dS )z9
Send statistics to Adviser microservice
z/requests/metadataFrr Nrl r) s rB send_statz SmartAdviceAPIClient.send_stat s3 (<<<
8TU
;;;;;rD advice_listc g }t | }|D ]g}t |d d }t |j |d d r)t |j s| | h|S )z
Loop over advices and remove those which have
non-existing users and those which are invisible.
:param advice_list: list of advices received from API
advicer metadatarb )r# r r module_namer rg )r? rr visible_advicesfilteredr advice_instances rB _filter_advice_listz(SmartAdviceAPIClient._filter_advice_list s *;77 - -D 1$x.2H I IO! +T*-=j-I
-3O4OPP
- &&t,,, rD TFrx show_allc | j d| | }| |d }| |t }|r| | }|S )z
Get list of advice
:param filtered: Automatically removes invisible advices
and those which are inked to non-existing users.
z
/advice/list?)r{ Frr ru rP )rI r[ r rW r rz )r? rx r{ rw r\ s rB rr z SmartAdviceAPIClient.advice_list sw (^^t7I7IS[7I7\7\^^>>(e>DD>>x8J>KK ://99HrD c | j d| }| |d }| |t S )z>
Get urls/advices information per user`s site
z/advice/site_info/Frr r} )rI r rW r )r? rb rw r\ s rB site_infoz SmartAdviceAPIClient.site_info sF (FFHFF>>(e>DD~~84J~KKKrD advice_idc | j d| d}| |d }| |t S )z=
Get details of an advice by given advice_id
z /v2/advice/z/detailsFrr r} )rI r rW r )r? r rw r\ s rB advice_detailsz#SmartAdviceAPIClient.advice_details sI (HHYHHH>>(e>DD~~84J~KKKrD c fd| D } j d| } || S )z
Partial update of an advice by given advice_id.
Fields allowed for update are limited by fields_allowed property
c . i | ]\ }}|j v ||S r )r^ r s rB r z6SmartAdviceAPIClient.update_advice.. s, LLLA18K3K3K13K3K3KrD z/advice/)r rI ro )r? r rY ru rw s ` rB
update_advicez"SmartAdviceAPIClient.update_advice sQ
MLLL LLL(==)=={{8T***rD c J | j d}| ||ddd S )z:
Sends analytics data to the microservice
z/analytics/eventsF)r] rz ry rl r) s rB reportzSmartAdviceAPIClient.report s2 (;;;zz(DEu_dzeeerD r )TF) rH r r r rC r r rW r rm rI r r^ r[ rt r* ro rq r rz r rr r r r r r r r s @rB rH rH s> 1 1 1 1 1Kc K6 Kc K K K K 3s 3 3 3 X3 . . . . X.
9
9
9
9
9LT Ld L L L LH Hs HT HS H H H H&>>zz(\:$>bgzhhhrD c l | j d| | }| | S )Nz /cdn/usage?)r r r s rB get_usagez AWPProvisionAPIClient.get_usageQ s< (``T5G5GS]5G5^5^``yy"""rD r )rH r r r rC rm r[ r rI r r rt rv r r r r r r r r s @rB r r su 1 1 1 1 1. . . . . 3s 3 3 3 X3 X X( Xt XW[ X X X X
c
3
#
s
S
#
s
S
ix} i i i i#C # # # # # # # #rD r )Dr r r4 rl r8 urllib.parserV r functoolsr typingr r r requestsr r requests.adaptersr requests.exceptionsr
$requests.packages.urllib3.util.retryr rP r r
!xray.internal.clwpos_safe_importsr r adviser.advice_typesr rf r xrayr rQ xray.apiclient.schemasr r r internal.constantsr r r internal.exceptionsr r r internal.local_countersr internal.typesr internal.user_plugin_utilsr r internal.utilsr" xray.adviser.advice_helpersr# r% r r r r r% r, rH r r rD rB r s
& & & & & & & & & & & & & & & & & & ) ) ) ) ) ) 0 0 0 0 0 0 6 6 6 6 6 6 & & & & & & & &
\ [ [ [ [ [ [ [ e e e e e e e e e e F F F F F F F F F F W W W W W W W W W W 8 8 8 8 8 8 ! ! ! ! ! ! S S S S S S S S + + + + + + ? ? ? ? ? ?DO DO DO DO DO DO DO DON ! ! ! ! ! ! ! !B3 3 3 3 3&) 3 3 38p# p# p# p# p# p# p# p#fK K K K K K K K\3 3 3 3 3 3 3 3*@( @( @( @( @(& @( @( @(FMf Mf Mf Mf Mf6 Mf Mf Mf`;# ;# ;# ;# ;#F ;# ;# ;# ;# ;#rD