Wj1 d Z ddlZddlZddlZddlZddlZddlZddlZddlm Z ddl
m Z ddl m
Z
ddlmZ n# e$ r d ZY nw xY wdd lmZ dd
lmZ dd lmZ dd lmZ ej d
ZdZdZ dZ de fdZ G d d Z dS )zG
This module contains a wrapper around `clwpos-user get` local utility
N)Optionalbuild_clwpos_user_cmd)CloudlinuxSummary)is_wpos_visiblec d S )N usernames N/opt/cloudlinux/venv/lib64/python3.11/site-packages/xray/adviser/clwpos_get.pyr
s t )
get_client)NginxUserCache)get_plugin_status)any_suite_allowed_on_server clwpos_utili x returnc | dnt | }t | t k r|S |dt dz S )zLReturn a bounded, redaction-marked snippet of subprocess output for logging.N z...[truncated])strlen_CLWPOS_LOG_SNIPPET_MAX)outputtexts r _log_snippetr 4 sD 22S[[D
4yy+++ ((( ),< < > >44444 LLW $A
C
C
C4 ?? LLX J V0D0D
F
F
F4 :fllnn-- -# LLS L$8$8
:
:
:44 sA A
A<"A77A< B C"6!C C"%E- -=F.-F.cmdc t j t z }t j | t j t j d }t }d} |j }|J |t j z
}|dk rt j | t t j
|gg g | \ }}}|st j | t t j |
d } | snAt | t | z t k rd}n| | |rd|j df| | | d n# t j $ r Y nw xY w|j |j S S | t- d
|t j z
}
| | | d n# t j $ r Y nw xY w|j |j n{# | | | d n# t j $ r Y nw xY w|j |j w w xY w| d d
|
dfS )u Run ``cmd`` capping stdout at ``_CLWPOS_SCAN_MAX_OUTPUT_BYTES`` and
wall-clock time at ``_CLWPOS_SCAN_TIMEOUT`` seconds.
Returns ``(stdout, returncode, overflow)`` where ``stdout`` is decoded
text. On overflow the child is killed and ``overflow`` is True so the
caller refuses to parse the partial/oversized payload. On timeout the
child is killed and ``subprocess.TimeoutExpired`` is raised, reusing the
existing SubprocessError failure path.
Cleanup is in an explicit ``finally`` rather than ``with proc:`` on
purpose: ``Popen.__exit__`` performs a blocking ``wait()`` with no
timeout, so a child that hangs without closing its stdout would stall
there forever — defeating the wall-clock cap. We always kill a
still-running child BEFORE any wait, and every wait is itself bounded,
so no exit path can block indefinitely.
r )rE stderrbufsizeFNTi r )timeoutg zutf-8replace)errors)time monotonic_CLWPOS_SCAN_TIMEOUTr< PopenPIPEDEVNULL bytearrayrE TimeoutExpiredselectr5 readfilenor r> extendrF pollkillwaitclosemaxdecode) rI deadlineprocbufrG rE remainingreadable_chunkrF s r r: z ClWposGetter._run_scan_bounded s $ >##&:: JO(2(:AG G Gkk& $[F%%%
" $t~'7'7 7 >>$3C9MNNN "( xR!K!K!Q O$3C9MNNN
77 s88c%jj(+HHH #H
5!!!#
"$
14?D0 yy{{"
! $$$$ ,
{& !!#### ' 3sHt~?O?O4O+P+PQQJ yy{{"
! $$$$ ,
{& !!### yy{{"
! $$$$ ,
{& !!#### 'zz')z44j%GGs[ C0I. 2F FF 8I. !H8 8I
I
.)K&J/.K&/K>K& K%K&c ( fd| D S )zp
Iterate through advices and return only those which relate to current
user-domain-site
c g | ]:}|d d k r&|d d k r|d d k 8|;S )metadatar r" websiter ).0advicer" userrm s r
z8ClWposGetter.get_advices_for_website.. sd
j!*-55j!(+v55j!),77
877r r )advicesrp r" rm s ```r get_advices_for_websitez$ClWposGetter.get_advices_for_website s:
!
r c 6 i }| || }|s|S g }|d D ]\ }}d| } |d |g }
| |||| } t ||| |
| } | t
| |
| nN# t $ rA t d | t
| |
Y nw xY w||||
d}|S )zP
For getting extended metadata which will be sent daily by cron
issues/)r6 ru wp_plugin_statusz)Getting Smart Advice plugin status failedr6 ru r r" websitesserver_load_rate) rH itemsgetrs r appenddict Exceptionr% exceptionr{ )
r+ r r" current_advicesfinal_metadatawebsites_metadatarz siteru r6 website_issuesadvice_for_websitesmart_advice_plugin_statuss
r get_updated_extended_metadataz*ClWposGetter.get_updated_extended_metadata s LL6 : : "! ! -h 7 = = ? ? LD& t::D .x 8 < xHNHLHVHZ .\ .\* $,:6P!R !R !R S S S S
=
=
= !LMMM$,:!< !< !< = = = = =
= % $$($9$9$;$; NN s 8B11AC<;C<c d}| || =||fdd D | d}|S )zX
Ensure format accepted by Smart Advice POST requests/metadata endpoint
Nc r g | ]3\ }}t d | d |g 4S )rv ru rx )r r} )rn r ru datas r rq z3ClWposGetter.construct_metadata.. s^ !# !# !#%1T6 "&:t::-1(^-?-?b-I-I"K "K "K !# !# !#r ru ry )rH r| r{ )r+ r r0 dummy_resultr s @r r' z ClWposGetter.construct_metadata s ||Hj11 (0&0!# !# !# !#59(^5I5I5K5K!# !# !# 150E0E0G0G I IL r c t j } n@# t $ r3}t dt | Y d}~dS d}~ww xY wt
j pd}| |z S )r z%Unable to get domains_total stats: %sNg g ?)r _get_total_domains_amountr r% r* r multiprocessing cpu_count)
domains_totalrD r s r r{ z ClWposGetter.server_load_rate
s~ - G I IMM LL@#a&& I I I44444 $-//63 y((s
A(AAstatc t | d r/t d } | | dS dS )zo
Send gathered metadata to adviser miscroservice.
Ignore sending if websites are empty
rz adviser)r N)r send_stat)r clients r r) zClWposGetter.send sK
* **F FHH D ) ) ) ) ) * *r c ` t s t j | j dgd dS dS )z
Needed to save PHP info to work without clwpos_monitoring demon
when AccelerateWP is turned off completely
z--forceT)capture_outputN)r r< runawp_info_collector)r+ s r save_clwpos_infoz ClWposGetter.save_clwpos_info& sC
+,, V ND 3Y?PT U U U U U U V Vr )__name__
__module__ __qualname__r8 r r r- staticmethodboolr$ listr3 r r rH r: rs r r' floatr{ r) r r r r r! r! < s !DB
cc
c3
c4
c
c
c
c 3s 3t 3 3 3 \3 R3 RC RD R R R R, , ,$ , , , ,\ =Ht =H =H =H \=H~
\
% % % N 3 C D & )e ) ) ) \ ) *4 *D * * * \*V V V V Vr r! )!__doc__r? loggingr5 rY r< rQ r typingr xray.internal.utilsr clsummary.summaryr clwpos.papir ImportError apiclientr internal.nginx_utilsr xray.smart_advice_plugin_helpersr !xray.internal.clwpos_safe_importsr getLoggerr% r> rS r r r r! r r r r s
5 5 5 5 5 5 / / / / / /,+++++++ , , ,++OOO, # " " " " " 1 1 1 1 1 1 > > > > > > I I I I I I = ) ) !0
=C = = = =pV pV pV pV pV pV pV pV pV pVs 9 AA