j :
p d dl mZ d dl mZ d dl mZ d dlZd dlZd dlZd dlmZ d dl m
Z
d dl m Z m
Z
d dlmZmZ d d
lmZ d d lmZ d d lmZmZmZ d d
lmZm Z d dl m Z m Z m Z m!Z!m"Z"m#Z#m$Z$ d Z%d Z&d Z'd Z(d Z)d Z*d Z+d Z,dZ-dZ.dZ/dZ0dd d d d d Z1d!d"d#d$d%d&d'd(d)d*d+d,d- Z2d. Z3d/ Z4d0 Z5d1Z6d2 Z7d3 Z8d4 Z9dS )5 )print_function)division)absolute_importN) defaultdict) iteritems)get_suEXEC_statusget_suPHP_status)CageFsCageFsException ) ClUserSelect)ClSelect)"interpreter_versions_short_summaryserver_applications_summary-server_nodejs_applications_with_shared_status)OptionalDict)!_is_acceptable_php_handler_cpanel$_get_php_selector_domains_for_cpanel#_get_php_selector_domains_for_plesk _get_php_selector_domains_for_da!_get_php_vhosts_for_current_panel#get_php_selector_compatible_domains(get_all_selector_compatible_domains_flatc t | S )zd
Return list of InterpreterSummary objects
:rtype: list[clselectctl.InterpreterSummary]
)r interpreters R/opt/cloudlinux/venv/lib64/python3.11/site-packages/clselect/clselectstatistics.py_iter_versionsr . s
.k : :: c t | S )zd
Return list of ApplicationSummary objects
:rtype: list[clselectctl.ApplicationSummary]
)r r s r iter_server_applicationsr" 6 s
'{ 3 33r c ddl m} t }d |D }d |D }d |D } | t | t | f }||fS )zACollect Node application and Shared Store aggregates in one scan.r ) get_shared_node_modules_summaryc g | ]\ }}|S r& ).0 application_actives r
z>get_nodejs_applications_and_shared_summary..C s DDD$8KKDDDr c g | ] \ }}||
S r& r& )r' r( actives r r* z>get_nodejs_applications_and_shared_summary..D s1 & & &+>; $&; & & &r c h | ] }|j
S r& )user)r' r( s r z=get_nodejs_applications_and_shared_summary..F s LLLK$LLLr )
active_counts) clselector.node_modules_storager$ r len)r$ records applicationsactive_applications active_userssnapshots r *get_nodejs_applications_and_shared_summaryr8 > s OOOOOO;==GDDGDDDL& &' & & &LL8KLLLL..<((#.A*B*BCE E EH !!r c @ t | }| d |D S d S )Nc D i | ] }|j |j |j |j d S )) full_versionenabled installed)version version_fullr< r= )r' its r
z+get_versions_statistics..P sE
J " : \
r )r )r interpreters_versionss r get_versions_statisticsrC L sA *; 7 7 (
.
)(r c t } | sdS | n# t $ r Y dS w xY wt t t
f sdS t }|dS t }t t }t t }t | D ]n\ }}| | s|
|d d }|| | || | o||dS )z+Get users and domains that use php selectorNF)show_native_versionr )domains_by_php_versionusers_by_php_version)r
is_cagefs_present
_load_infor anyr r r r
r setr get_user_status get_versionupdateadd)cagefs
php_vhostsphprF rG r. user_domainsr> s r get_php_selector_usagerT Y sb
XXF # # % % t tt !##%5%7%78 9 9 t 344Jt
..C ( - -&s++ '
3 3 0 0l%%d++ //$E/BB1E w'..|<<< W%))$//// #9 4 s ;
A A c b t } | d }||S |d S )z7
Safely get native version, or None if not set
F)verboseNr ) ClSelectPhpget_native_version)rR vs r get_native_version_saferZ s6 --C u --Ay Q4Kr c J t rdndS )z=
Get state of PHP selector: without CageFS or normal
without_cagefsnormal)rW work_without_cagefsr& r r get_mode_of_php_selectorr_ s% +}} @ @ B B P Pr c N t d S )z-
Get default version of PHP selector
r )rW rM r& r r get_default_php_versionra s == $ $ & &q ))r z./var/cloudlinux/multiphp-sync/_last-check.jsonz'/var/cloudlinux/multiphp-sync/sync.confz-/var/cloudlinux/multiphp-sync/_telemetry.jsonz2/opt/cloudlinux/flags/opt-out.d/multiphp-sync.flag) crash_engine
crash_hook
crash_door crash_report write_failedwrite_rejectedhandback_failed slow_hook pass_abortedselector_unreadablelisting_unreadabledefault_unreadableweb_server_unreadablerecord_unusablereports_cappedother) modifying restoringro rm
no_listingpin_kept_cascadepin_kept_docrootpin_kept_unknownpin_kept_otherrh
change_capchange_unrecordedchange_in_flight pass_heldrn rq )fpmhandlercascade
arrival_moved
unroutable
unknown_abovestalerq )
rs rr change
new_domain pass_requestwithdraw_pendingflag_withdraw_pendingstanding_while_offcheck_not_runningrq ) no_event listener_offrestorerenamedefault_changehandler_changeown_write_failedunknownrq )failuresrefusals
deviationsstuckunexplained_causes mirrored_okmirrored_unrecorded stale_mirrorselector_unmirroredowned_ok owned_driftowned_unrecordedout_of_coveragenot_in_userdata unexplainedreleasedr ) z mirrored-okzmirrored-unrecordedz stale-mirrorzselector (unmirrored)zowned-okz DRIFT(owned)zowned-unrecordedzout-of-coverageznot-in-userdata UNEXPLAINEDr r c L i } t t 5 }|D ]X}| d \ }}}|r)| | | < Y ddd n # 1 swxY w Y n# t t
f$ r Y nw xY w| S )z{switch: value} from the sync's switches file; {} without one, which
reads as both directions off, as it does to the engine.=N)openMULTIPHP_SYNC_CONFstrip partitionOSError
ValueError)switchesflinekeysepvalues r _sync_switchesr s H
$
%
% :
:
:"&**,,"8"8"="=S% :,1KKMMHSYY[[)
: : : : : : : : : : : : : : : :
Z
Os5 B
A B5 B
BB
B B
B! B!c j t | t r t | t s| dk r| ndS )Nr )
isinstanceintboolr s r _sync_countr s= uc** :eT3J3J QJJ 5 r c t t 5 } t j | }ddd n # 1 swxY w Y t |t
r| d dk ri S t j t j t | d d }n # t t t f$ r i cY S w xY wt dt t j |z
dz t! | d d }t" D ]\ }}t
|d }| | }t |t
r| nd
D ](\ }} |||v r|nd xx t! | z
cc< )|||< |S ) zThe daily report's counters (MULTIPHP_SYNC_TELEMETRY), every key of
each set, and their age; {} before the first report, and for a file of
another schema or shape, whose counts would be guesses.Nschemar generated%Y-%m-%d %H:%M:%Sr apache_restarts)telemetry_age_hoursr r& rq )r MULTIPHP_SYNC_TELEMETRYjsonloadr dictgettimemktimestrptimestrr r
OverflowErrormaxr r _SYNC_TELEMETRY_KEYSitemsfromkeys)
r datar resultnamekeyscountsfoundr r s
r _sync_telemetryr s
)
*
* a9Q<t t* d } | D ];\ } }
t* | }|rt
|
t r|
| |< Selector agreement counters, from the drift
checker's last snapshot: per-domain pin classes and drift verdicts,
plus account coverage, and the switches as they are now. None when
there is no usable snapshot (the checker never ran — it runs only
while the sync is on — or one of an unknown schema or shape): the
summary then carries no sync fields at all, which is distinguishable
from a fleet with zero domains. A snapshot that has aged is still
reported, with its age in snapshot_age_hours.Nr r r r r r usersverdictsc 3 K | ]o}t |t oUt | d g t o,t d | d g D V pdS )domainsc 3 @ K | ]}t |t V d S )N)r r )r' r s r z4get_multiphp_sync_stats...P sH C C#& *#t 4 4 C C C C C Cr N)r r r listall)r' r. s r r z*get_multiphp_sync_stats..N s * * "$-- C%dhhy"&=&=tDDC C C*.((9b*A*A C C C C C* * * * * *r r r suspendedselector_to_multiphponmultiphp_to_selectorc 3 D K | ]}| d dV dS )answeredr N)r )r' us r r z*get_multiphp_sync_stats..g s3 J Jaj8I8I J J J J J J Jr
enabled_by disabled_by) r mirror_enabledlistener_enabledsnapshot_age_hoursr users_unansweredpinsr r r flag_opted_out)#r MULTIPHP_SYNC_LAST_CHECKr r r r r r r r r r r r r r r r r _SYNC_PIN_CLASSESr _SYNC_VERDICT_KEYSvaluesr r r r2 sum _sync_actorospathexistsMULTIPHP_SYNC_FLAG_OPT_OUTrN r )r reportr age_hoursr totalsr r r. r pin_classr verdictcountr r r s r get_multiphp_sync_statsr , s
*
+
+ "qYq\\F " " " " " " " " " " " " " " " Z tt fd # # vzz(';';q'@'@tK
c&**[2I2I.J.J.A!C !C D D
& tt AsDIKK) 3<==>>I JJw # #E
ZZ
B
'
'F eT " " *VT*B*B * * $) * * * * * t**]++K ==*A . .D % %88Ir** % %C'[99I
%Y1$ % }} / 6 6 8 8!<#>?? bgnn-G H HII F MM/##$$$ Ms? A 7 A ;A ;A AA AC C)(C)c | dv r| ndS )z2`admin`, `remote`, or empty: nothing else is sent.)adminremote r& r s r r r t s 00055b8r ):
__future__r r r r r r collectionsr future.utilsr cldetectlibr r cllimitsr
r cluserselectr
clselectr rW clselectctlr r r typingr r clselectdomainsr r r r r r r r r" r8 rC rT rZ r_ ra r r r r r r r r r r r r r r& r r r s & % % % % % & & & & & & # # # # # # " " " " " " ; ; ; ; ; ; ; ; , , , , , , , , & & & & & & - - - - - -
" ! ! ! ! ! ! !
; ; ;4 4 4 " " "
# # #L Q Q Q* * * L
? J 9 , DBC% 8 !0" 2!*((
! (
2& .E E EP9 9 9 9 9r