fjms b d Z ddlZddlZddlZddlZddlZddlZddlZddl m
Z
ddl m Z m
Z
mZ ddlmZmZ ddlmZ ddlmZ ddlmZ dd lmZmZ dd
lm Z m Z d d l m Z m!Z! dd
l"m#Z$ ddl%m&Z&m'Z'm(Z( ddl)m*Z* ddl+m,Z, d dl-m.Z.m/Z/m0Z0 d dl1m2Z2m3Z3m4Z4 d dl5m6Z6 d dl7m8Z8 d dl9m:Z:m;Z; d dlm?Z? G d d Z@ G d d ZA G d d e@eA ZB G d d e@ ZC G d d!e@eA ZD G d" d#e@ ZE G d$ d%e@ ZF G d& d'e@ ZG G d( d)e@ ZHdS )*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)
is_wp_path)docroot)
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 efdZ d de
ded e
fdZ d dede
dededed e
f dZ d dededefdZd ded e
fdZ d!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__9 s "& ' 55 +4eV_+E+E,5ooo,F,F*+- - -
*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_endpointr9 rA s rD __repr__zClient.__repr__H s* .)aaT-?aaSWS_aaarF c . | j j d| j S )NrH )rI rJ r9 rL s rD __str__zClient.__str__K s .);;T\;;;rF returnc : t t d )z
Base endpoint
z$instances are to set their endpoint!)NotImplementedError_rL s rD rK zClient.main_endpointN s
"!$J"K"KLLLrF c " dt iS )zL
Updated request headers
:return: dict with headers
zX-Authr# rL s rD _headerszClient._headersU s
n&&
rF c d| j i}|r| | t j | S )ze
Construct query string
:return: string including system_id and given kwargs
r+ )r+ updateurllibparse urlencode)rA kwargsinitials rD
_query_stringzClient._query_string_ s@
/ # NN6 " " "|%%g...rF Tresponsewith_status_checkc |j sY| j d|j |j d|j }t
t d |z 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_dataextraz [%s:%s] Response received %s statusokz"Received unsuccessful response: %s) rg r< debugtext status_codereasonr rS infourljsonstr)rA r^ r_ request_dataresults rD _preprocess_responsezClient._preprocess_responsei s {
+ K 4hm D D D & 2FFX_FFL 788<G"HM24 4 4
4
K ; % 18? %\
+
+
+
3 & & ]]__FF %F Zh 4''"1%I#J#JSQW[[#XYYY
rF 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_ rq z [%s] Received response data %sN)rq )rr r< rl rj r KeyErrordict)rA r^ r_ rq datas rD _process_responsezClient._process_response s **8=N + P P (#D K = % 14
9
9
9|*&9999K 66MMM s postr
_give_xray_exceptionrS rx ) rA ry rz r{ r_ r| r respes rD _postz Client._post s.
5! # # # C C K 8' B B B a
- |((7(CC|((.5wPR ) T T a a a++Ax ,-.W,X,XZ Z_`
a a %%d8I & K K Ks 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 serverrt ) r< rl r> deleterU r
r rS rx )rA ry r{ r_ r r s rD _deletezClient._delete s 7! # # # c<&&x &GGDD c c c++Ax ,-.Y,Z,Z\ \ab
c c %%d8I & K K Ks !?
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)
rK r] r< rl r> getrU r
r rS rA ry r r s rD _raw_getzClient._raw_get s ,EEt/A/A/C/CEEH 4h??? b<##Hdm#DDDD b b b++Ax ,-.X,Y,Y[ [`a
b b 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
rt )r rr )rA ry r_ r s rD _get_fullzClient._get_full s: }}X&&((;L ) N N NrF 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
)r9 N)r rx r r r9 r s rD _getz Client._get sl }}X&& ))$// /# #
s ,
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 %sry rc r z: z%s. Please, try again later)r< errorargsrk
IndexErrorAttributeErrorr rS )rA exc api_endpoint log_message exc_messageexc_infoexception_datas rD r zClient._give_xray_exception s
, S!+\ : < < < x{)HHN+ HHH (55855
+ , ,~ =? ? ?s 5 A
A T)NTTT)TTN)NT)rJ
__module__ __qualname____doc__ro rE rM rO propertyrK rv rU r] r boolr rr rx r r r r r r rF rD r' r' 4 s
)6
I
I
IS
I"%
I
I
I
I b b b< < < Ms M M M XM
$
X
/ / / / / 8< X 04 @C @ 59 ( -1=A & KOBF K Kc KD K4 K!% K;? KKO K K K K< 7;*.
K
K
Kt
K#'
K
K
K
K )-,0
N
N#
N%)
N58
N
N
N
N S D ? ? ? ? ?rF r' c > e Zd ZdZedefd ZdedefdZ dS ) TaskMixinz1
A mixin class with Task related methods
rP c dS )z(
Limit processed fields
) rm rf client_ip
tracing_by
tracing_count starttime ini_location
initial_count
request_count auto_taskuserr rL s rD task_fieldszTaskMixin.task_fields s
% %rF 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 .0kvrA s rD
z#TaskMixin._task.. s6 , , ,da$*** ***rF r* r9 r )itemsr )rA r task_views ` rD _taskzTaskMixin._task sX , , , ,ioo&7&7 , , , (): ; ) i rF N)
rJ r r r r tupler rv r r r rF rD r r sg %U % % % X%!t ! ! ! ! ! ! !rF r c ` e Zd ZdZedefd Zdef fd Zdee f fd Z
xZ S ) TasksClientz!
'tasks' endpoint client
rP c & t dt dS )z&
Base endpoint: tasks
r6 z/api/xray/tasksr r rL s rD rK zTasksClient.main_endpoint! s
77J7777rF 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] rA r[ rI s rD r] zTasksClient._query_string( s ww$$&$111rF c b t } fd|D S )z#
Get list of Tasks
c : g | ]} | S r )r )r itemrA s rD
z)TasksClient.get_tasks..5 s% 222T
4 222rF )r r )rA rw rI s ` rD get_taskszTasksClient.get_tasks0 s1 ww||~~2222T2222rF ) rJ r r r r ro rK r] r r r
__classcell__rI s @rD r r s 8s 8 8 8 X8 2 2 2 2 2 2 234: 3 3 3 3 3 3 3 3 3 3rF 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 rE task_object_db_open_db)rA r+ r* rI s rD rE zDBMClient.__init__= s;
9oNNN ==??rF c 8 | j d S r )r closerL s rD __del__zDBMClient.__del__C s rF rP gdbm objectc , t j dd S )zC
Open dbm DB
:return: corresponding object
z/root/local_mongoc)dbmopenr rF rD r zDBMClient._db_openF s x+S111rF post_dataNc H t j | | j | j < dS )z3
Update a DBM task with given data
N)rn dumpsr r9 )rA r s rD r zDBMClient._postN s" "&I!6!6 rF 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) rn loadsr r9 decoderu JSONDecodeErrorr rS )rA r s rD r zDBMClient._getT sq
@:dht| 4 ; ; = =>> >$./ @ @ @ q!6 7 788a ? @s 58 A0 A++A0c 2 t j j S r )uuiduuid1hexr rF rD _idz
DBMClient._id^ s z|| rF c n | }| j |d< t di || _ | j S )1
Get saved task
:return:
r9 r )r r9 r r )rA
saved_tasks rD get_taskzDBMClient.get_taskb s<
YY[[
$
9 --*-- rF 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 r9 rf r as_dictr rA r s rD createzDBMClient.createl sM xxzz |
4<<>>""" |rF r c | j | d| j _ || j _ | | j dS )z
Update started|continued task
status --> running
starttime --> new timestamp
:return:
Nrunning)r r rf r r r rA r s rD rW zDBMClient.update sW # MMOOO"+ %."
4#++--.....rF countc | j | d| j _ || j _ | | j dS )}
Update stopped task
status --> stopped
tracing_count --> new value
:return:
Nstopped)r r rf r r r rA r s rD stopzDBMClient.stop sW # MMOOO"+ ).&
4#++--.....rF c | j | d| j _ | | j dS )Y
Complete tracing task
status --> completed
:return:
N completed)r r rf r r rL s rD completezDBMClient.complete sL # MMOOO"-
4#++--.....rF c | j | j = dS z6
Delete tracing task
:return:
N)r r9 rL s rD r zDBMClient.delete s
HT\ " " "rF )rP r rP N)rJ r r r ro rE r staticmethodr rv r r r r r r intrW r r r r r s @rD r r 8 s
)6# # #S #"%# # # # # # 2 2 2 \27t 7 7 7 7 7 @d @ @ @ @ \ $ 4 C & / / / / / / /# /$ / / / / / / / /# # # # # # # #rF 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
rP c & t dt dS )z%
Base endpoint: task
r6 z/api/xray/taskr rL s rD rK zAPIClient.main_endpoint s
66J6666rF 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) )r9 r r] r s rD r] zAPIClient._query_string sE <= ( (77(( (FF Fww$$&&&rF 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 rD r z*APIClient._post_create.. s2 $6 $6 $6TQ$%$4$4 %&q$4$4$4rF r* N)rK r] r r r9 )rA r ry
response_datas rD _post_createzAPIClient._post_create ss (HH$2D2D2F2FHH
8$6 $6Y__5F5F $6 $6 $67 7
%%67 rF 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?NrK r] r )rA r ry s rD _post_updatezAPIClient._post_update s@
(HH$2D2D2F2FHH
8Y'''''rF c | j dd }| d| }| | dS )z<
GET request to "share a task" API endpoint
Nz/share-request?rK r] r )rA share_endpointry s rD _sharezAPIClient._share sL +CRC0$KKT5G5G5I5IKK (rF c l | j d| }| | dS )z>
POST request to "delete a task" API endpoint
z/delete?Nr )rA ry s rD r zAPIClient._delete s> (HH$2D2D2F2FHH
8 rF c P | | S )r )r r rL s rD r zAPIClient.get_task s zz$))++&&&rF 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 rD r z$APIClient.create.. s6 2 2 2DAq 000 a000rF )rf r r r r9 r s ` rD r zAPIClient.create se 2 2 2 2DLLNN,@,@,B,B 2 2 2 3 3 3|rF r c 6 | d|d dS )z
Update started|continued task
status --> running
starttime --> new timestamp
:param starttime: time of starting the Task
r )rf r Nr r s rD rW zAPIClient.update s5
Y(13 3 4 4 4 4 4rF r c 4 | d|i dS )zw
Update tracing_count only. No status updated
tracing_count --> new value
:return:
r Nr r s rD update_count_onlyzAPIClient.update_count_only s#
?E233333rF )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 )rA r r rw s rD update_counts_onlyz APIClient.update_counts_only sB #]3DD%2%24 4D $ rF c 6 | d|d dS )r r )rf r Nr r s rD r zAPIClient.stop s5
Y,13 3 4 4 4 4 4rF c 4 | ddi dS )r rf r Nr rL s rD r zAPIClient.complete* s#
8[122222rF c . | dS )z5
Share tracing task
:return:
N)r rL s rD sharezAPIClient.share2 s
rF c . | dS r )r rL s rD r zAPIClient.delete9 s
rF r )rJ r r r r ro rK r] rv r r r r r" r r r r rW r r r r r$ r r r s @rD r r s 7s 7 7 7 X7 ' ' ' ' ' ' '
8d
8t
8
8
8
8(d (t ( ( ( ( '$ ' ' ' ' 4 D "4 4 4 4 4 44s 4t 4 4 4 4 15 3 *- 9= 4# 4$ 4 4 4 43 3 3 3 rF r c > e Zd ZdZedefd ZdeddfdZdS )
SendClientz)
X-Ray requests API client class
rP c & t dt dS ))
Base endpoint: requests
r6 z/api/xray/requestsr rL s rD rK zSendClient.main_endpointF s
::J::::rF rw Nc r | j d| }| ||d dS )zS
Send given data to ClickHouse
:param data: dict with data
r F)r{ Nr rA rw ry s rD __call__zSendClient.__call__M sD
(AA4+=+=+?+?AA
8TE
22222rF ) rJ r r r r ro rK rv r, r rF rD r' r' A sg ;s ; ; ; X; 3T 3d 3 3 3 3 3 3rF r' c t e Zd ZdZedefd Zdef fd ZdefdZ dedefdZ
dede defd Z xZ
S )
UIAPIClientz,
X-Ray User plugin API client class
rP c & t dt dS )r) r6 z /api/xrayr rL s rD rK zUIAPIClient.main_endpoint[ s
11J1111rF 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 rD r z-UIAPIClient._query_string..h s IIIA1=1===rF r )r r r] )rA r[ filter_emptyrI s rD r] zUIAPIClient._query_stringb s> JI III $uww$44|444rF 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?rq rf r r* r7 ) digest_sizer timer r r N)
r] r! rK r hashlibblake2bencode hexdigestr processed_requests)rA qsry r^ r fake_idstorages rD
get_task_listzUIAPIClient.get_task_listk sW
%7%9%9
:
:(5555>>(++ X& C CD H~,, od+<&=&D&D&F&F246 6 66?ikk
#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$ r9 c p | | }| j d| }| | S )zG
Get list of requests collected for given tracing task
r) z
/requests?r] rK r )rA r9 r; ry s rD get_request_listz UIAPIClient.get_request_list sB
8
8(88B88~~h'''rF
request_idc r | || }| j d| }| | S )zU
Get collected statistics for given request ID of given tracing task
)r* rB z /request?r@ )rA r9 rB r; ry s rD get_request_dataz UIAPIClient.get_request_data sK
+5 7 7(77277~~h'''rF )rJ r r r r ro rK r] rv r> rA r rD r r s @rD r. r. V s 2s 2 2 2 X2 5 5 5 5 5 5 5t ,( ( ( ( ( (( ( ( ( ( ( ( ( ( ( (rF 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 rE rA rI s rD rE z SmartAdviceAPIClient.__init__ $
<00000rF rw schemarP 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 rS ro )rA rw rN r msgs rD _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 rL s rD rK z"SmartAdviceAPIClient.main_endpoint
3,2222rF c dS )z3
Limit fields available for update
)rf sourcerk r rL s rD fields_allowedz#SmartAdviceAPIClient.fields_allowed s
.-rF 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 rD r z6SmartAdviceAPIClient._query_string.. s AAABFB<AAArF usernamec g | ] \ }}|||f S r r r s rD r z6SmartAdviceAPIClient._query_string.. s% ???41aQ?A???rF ,)safe)supported_advice_typesr! appendextendr rX rY rZ )rA r[ r\ user_contexts rD r] z"SmartAdviceAPIClient._query_string s
BA*@AAA)++ 7 NNJ 5 6 6 6??6<<>>???@@@|%%gC%888rF Nc L | j d}| ||dd dS )z]
Send given data to Adviser microservice
:param data: dict with data
z
/requests/addFr{ r_ NrK r r+ s rD r, z SmartAdviceAPIClient.__call__ sC
(777
8TE%* , , , , ,rF ry rz 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)rn r z PATCH failedz/Failed to PATCH data to Smart Advice API serverNFrt ) r< rl r> patchrU r
r rS rr )rA ry rz r r s rD _patchzSmartAdviceAPIClient._patch s
6! # # # i<%%h+2.2m & = =DD i i i++Ax ,-._,`,`b bgh
i i (((GGGs "A
A5
&A00A5c J | j d}| ||d dS )z9
Send statistics to Adviser microservice
z/requests/metadataFrt Nrj r+ s rD send_statz SmartAdviceAPIClient.send_stat s3 (<<<
8TU
;;;;;rF 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 metadatar` )r% r r module_namer re )rA rp visible_advicesfilteredr advice_instances rD _filter_advice_listz(SmartAdviceAPIClient._filter_advice_list s *;77 - -D 1$x.2H I IO!/"="&z"2:">@ @
-5o6QRR
- &&t,,, rF TFrv 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?)ry Frt rw rN )rK r] r rU r rx )rA rv ry ry r^ s rD rp z SmartAdviceAPIClient.advice_list s (^^t7I7IS[7I7\7\^^>>(e>DD>>% " ' ' ://99HrF c | j d| }| |d }| |t S )z>
Get urls/advices information per user`s site
z/advice/site_info/Frt r{ )rK r rU r )rA r` ry r^ s rD site_infoz SmartAdviceAPIClient.site_info sP (FFHFF>>(e>DD~~) + + +rF advice_idc | j d| d}| |d }| |t S )z=
Get details of an advice by given advice_id
z /v2/advice/z/detailsFrt r{ )rK r rU r )rA r~ ry r^ s rD advice_detailsz#SmartAdviceAPIClient.advice_details sS (HHYHHH>>(e>DD~~) + + +rF 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 rD r z6SmartAdviceAPIClient.update_advice..! s6 * * *AT((( 1(((rF z/advice/)r rK rm )rA r~ r[ rw ry s ` rD
update_advicez"SmartAdviceAPIClient.update_advice s\
* * * * * * *(==)=={{8T***rF c H | j d}| ||dd S )z:
Sends analytics data to the microservice
z/analytics/eventsF)r_ r| rj r+ s rD reportzSmartAdviceAPIClient.report& s/ (;;;zz(DEuzUUUrF r )TF) rJ r r r rE r r rU r ro rK r r\ r] rv r, rm ro r rx r rp r} r r r r r r s @rD rF rF s- 1 1 1 1 1Kc K6 Kc K K K K 3s 3 3 3 X3 . . . . X.
9
9
9
9
9,T ,d , , , ,H Hs HT HS H H H H*>>zz(\:$>#(,1 3 3 3rF c l | j d| | }| | S )Nz /cdn/usage?)r r r s rD get_usagez AWPProvisionAPIClient.get_usageg s< (``T5G5GS]5G5^5^``yy"""rF r )rJ r r r rE ro r] r rK r r rv rx r r r r r r r r s @rD r r . sv 1 1 1 1 1. . . . . 3s 3 3 3 X3 59N N( N-1N=AN N N N
,c ,3 , , , , ,5# 5s 5S 5 5 5 53# 3s 3S 3 3 3 33x} 3 3 3 3 #C # # # # # # # #rF r )Ir r r6 pwdrn r: urllib.parserX r functoolsr typingr r r requestsr r requests.adaptersr requests.exceptionsr
$requests.packages.urllib3.util.retryr rN r r
!xray.internal.clwpos_safe_importsr r adviser.advice_typesr rd r xrayr rS xray.apiclient.schemasr r r clcommon.clwpos_libr clcommon.cpapir 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. rF r r rF rD r s
& & & & & & & & & & & & & & & & & & ) ) ) ) ) ) 0 0 0 0 0 0 6 6 6 6 6 6 & & & & & & & &
\ [ [ [ [ [ [ [
+ * * * * * " " " " " " 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 ! ! ! ! ! ! , + + + + + ? ? ? ? ? ?M? M? M? M? M? M? M? M?`! ! ! ! ! ! ! !03 3 3 3 3&) 3 3 38q# q# q# q# q# q# q# q#hR R R R R R R Rj3 3 3 3 3 3 3 3*:( :( :( :( :(& :( :( :(zXV XV XV XV XV6 XV XV XVv;# ;# ;# ;# ;#F ;# ;# ;# ;# ;#rF