j>
6 d Z ddlZddlZddlZddlZddlZddlZddlmc m Z
ddl m Z ddl
mZ ddlmZmZ ddlmZ ddlmZmZmZmZmZmZmZ ddlmZm Z dd l m Z ddl Z dd
l m!Z! dd l"m#Z# dd l$m%Z% dd
l&m'Z'm(Z(m)Z)m*Z* ddl+m,Z,m-Z- ddl.m/Z/ ddl0m1Z1 ddl+m2Z2 ddl3m4Z4 ddl5m6Z6 ej7 d Z8 e dddg Z9de:de9fdZ;dee: fd ZdGd e:d!e?de:fd"Z@d#e:de:fd$ZAdHd&e:d'eBdd(fd)ZCde:fd*ZDdId,e:de:fd-ZEde:fd.ZFd/eBdeGfd0ZHd1e:dee: fd2ZIde?fd3ZJde?fd4ZKde?fd5ZLd6e?ddfd7ZMde?fd8ZNde:fd9ZOd:e:d;e e:ef de?fd<ZPd= ZQedJd>eBddfd? ZRe dKdBeBdCeBd>eBddfdD ZSdAZTdE ZUdS )Lz>
This module contains helpful utility functions for SSA Agent
N)
namedtuple)contextmanager)date timedelta) LooseVersion)socketfromfdAF_UNIX SOCK_STREAMAF_INETAF_INET6
SOCK_DGRAM)OptionalUnion)urlparse)AtexitIntegration)LoggingIntegration)Feature)is_panel_feature_supportedget_cp_descriptionis_throttling_supportedis_wp2_environment)get_kmodlve_module_version get_username)get_cl_edition_readable) get_hostname)get_rhn_systemid_value )
sentry_dsn)SSAErrorutilsURL domain_nameuri_pathurlreturnc t | }|j r
d|j nd}|j r |j | nd}t |j dd | S )z
Split URL into domain_name and uripath including query string
:param url: URL of format protocol://domain/path;parameters?query#fragment
:return: namedtuple URL(domain_name, uripath)
? /zwww.)r querypathr" netlocreplace)r% fragmentsqsuris I/opt/cloudlinux/venv/lib64/python3.11/site-packages/ssa/internal/utils.py url_splitr3 4 sl
I"+/ 9 Y_ rB%.^
s r2 add_infoz sentry_init..add_infoU s& g }l ;<<< r4 c t | t 5 }| |df | d cddd S # 1 swxY w Y dS # t $ r t
d Y dS w xY w)aI
address_family - we can choose constants represent the address
(and protocol) families
(AF_INET for ipv4 and AF_INET6 for ipv6)
private_ip - specify some private ip address. For instance:
ipv4 -> 10.255.255.255 or ipv6 -> fc00::
r r NzCannot retrieve IP address)r r connect getsockname Exceptionloggerinfo)address_family
private_ipss r2
try_get_ipz sentry_init..try_get_ip_ s 6
33
*q :q/***}}q)
*
*
*
*
*
*
*
*
*
*
*
*
*
*
*
*
*
* 6 6 6 KK4 5 5 5 5 5 5 6s4 A" 1A A" AA" A A" "$B
B
c ` t dft dff} | D ]\ }} || }|r|c S dS )zq
We are trying to get an IPv4 or IPv6 address.
In case of failure we'll return 127.0.0.1
z10.255.255.255zfc00::z 127.0.0.1)r r
)
ipversionsaddr_fampriv_ipiprL s r2 get_ipzsentry_init..get_ipn sZ
/08X2FF
!+ HgHg..B
{r4 c t }|r| d nd }|r| d nd }t rdnd }dt pdfd|fd|fd|fd t j fd
t
d fd t fd
t
d fd fdt ff
}|D ] } | j |
d S )NversionnameWP2z alt-php-xrayUNKNOWNzControl Panel NamezControl Panel VersionzControl Panel ProductkernelzCloudLinux version
os_releasezCloudlinux edition Architecture architecture
ip_addressusername)
r getr r; platformreleaser r r set_tag) sentry_scopecp_description
cp_versioncp_name
cp_producttagstagrR s r2 set_tagsz sentry_init..set_tagsz s +--6DN^'' 222$
0>H.$$V,,,D 0 2 2'@'@A !7!G!GH vvxx(\^^,
' 'C L # & & & ' 'r4 Nc d S Nr8 )pendingtimeouts r2 nopezsentry_init..nope s r4 zalt-php-ssa@0.4-26.el9)level event_level)callbacki' )dsn before_sendr` max_value_length integrationsid system_idr& N)dictr9 r loggingINFOWARNINGr
sentry_sdkinitr configure_scoper r r userrF ) rB ri rn ssa_versentry_logging
silent_atexitscoperR rL s @@r2 sentry_initr I s D T
6
6
6
' ' ' ' ', -,,, mm7 7G'gl4;OE E EN%t444MO
#%*"0-!@B B B B
# % % (55ee\^^eWcWeWe
HUOOOO D
s6 %=D # C/.D /
C<9D ;C<<D DDFfnameas_errorc L t j | t j dd t j | d n# t
$ r Y nw xY w| S # t $ rL}t |r t j n t j dt | Y d}~dS d}~ww xY w)zz
Try to configure logging into given fname
If as_error True, log the exception as ERROR, otherwise -- as INFO
z%(asctime)s %(message)sz%m/%d/%Y %I:%M:%S %p)filenamero formatdatefmti z$No logging configuration applied: %sN) rz basicConfigr{ oschmodPermissionErrorOSErrorrG logERRORstr)r r es r2 set_logging_into_filer s
U',#<$: < < < < HUE " " " " D
H>7==',9q66 s8 "A
; A
AA
AA
B#AB B#lognamec H t t | t j t j | n@# t $ r3}t dt | Y d}~dS d}~ww xY wt | d } | S )zP
Configure logging
:param logname: path to log
:return: logpath
NzFailed to create logdir %sr) T)r )
r r r makedirsr, dirnamerF rG warningr )r r s r2 configure_loggingr s MMM W%%- K00 1 1 1 1 NN7Q @ @ @22222 ($??? Ns 1A
B(B B
sock_locationbacklogz
socket objectc t t j dd }|dk rft d 5 t t }| | | | ddd n # 1 swxY w Y n0t dt t }| | |S )a
Create socket in given sock_location with restricted permissions
or reuse existing one
:param sock_location: socket address
:param backlog: maximum number of queued connections (default 2048 for high-traffic servers)
:return: socket object
LISTEN_FDSr I N ) intr environr^ umask_0r r
bindlistenr r )r r r sockobjs r2
create_socketr s RZ^^L!4455JQ
U^^ $ $ WooG LL ' ' ' NN7 # # # $ $ $ $ $ $ $ $ $ $ $ $ $ $ $
G[11w Ns ?BBBc t t j t d z
} | d S )zC
Returns date of previous day in a format "day.month.year"
r )days%d.%m.%Y)r todayr strftime) yesterdays r2 previous_day_dater s3
ya 0 0 00I j ) ))r4 r datestrc l t j | | }| d S )z+
Convert date to format YYYY-mm-dd
z%Y-%m-%d)datetimestrptimer )r formatstr_dates r2 format_dater s.
& &w : :E >>* % %%r4 c t j d } | }| d j }t j 5 }| d| ddd n # 1 swxY w Y | d S # t t j
f$ r3}t dt | Y d}~dS d}~ww xY w)ze
Obtain system ID from /etc/sysconfig/rhn/systemid
:return: system ID without ID- prefix
z/etc/sysconfig/rhn/systemidz(.//member[name='system_id']/value/stringrw NzID-z Failed to retrieve system_id: %s)ETparsegetrootfindtextr} r ra lstripr
ParseErrorrG r r )treerootwhole_idr r s r2 read_sys_idr s
Cx566||~~99 GHHM
'
)
) 1U MM+x 0 0 0 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1u%%% R] # C C C93q66BBBBBBBBBCs< AB A:. B :A>>B A>B C#0(C C#durationc B t t | dz d S )zQ
Cast duration from microseconds to seconds leaving 2 digits after point
i@B z0.2f)floatr )r s r2
duration_castr s! (&11 2 22r4 filepathc & t | 5 }| }ddd n # 1 swxY w Y n# t $ r Y dS w xY wd | d dd pdS )zDGet version of package from file. alt-php-ssa/alt-php-xray supportedN. z0.0-0)openreadstripr joinsplit)r v_filerT s r2 r7 r7 s
(^^ ,v kkmm))++G , , , , , , , , , , , , , , , 88GMM#&&rr* + + 6w6s3 A 'A A AA A A
A A c t } | dS t | t d k S # t t f$ r Y dS w xY w)zb
Check version of alt-php-xray package.
Autotracing in X-Ray is supported since 0.4-1
NFz0.4-1)r; r TypeErrorAttributeError)version_numbers r2 is_xray_version_supportedr s_
"^^N uN++|G/D/DDD ~ & uus 4 A A c d} t t t 5 } | | n## t t
f$ r Y ddd dS w xY w ddd n # 1 swxY w Y dS )z Check if User Agent is listeningz$/opt/alt/php-xray/run/xray-user.sockNFT)r r
r rD ConnectionErrorr )user_agent_sockrK s r2 is_xray_user_agent_activer s >, - - t
X(#
.
. /*z(())Q. / / / / / / / / / / / / / / / / / / 9 uus4 A9 %A, A9 ,A00A9 3A04A9 9B B enabledc t t j sdS t d| t ddd 5 }| | rdnd t d ddd dS # 1 swxY w Y dS # t $ r4}t d
| t | Y d}~dS d}~ww xY w) zb
Switch on/off throttle statistics gathering by kmodlve
:param enabled: True or False
NzSwitching schedstats: %sz!/proc/sys/kernel/sched_schedstatswbr )mode buffering 1 0zDone OKz(Failed to set sched_schedstats to %s: %s) r r LVErG rH r writer r )r fr s r2 switch_schedstatsr : sD
&gk 2 2
KK*G444%
5D #"#
GGG-DD . . . KK " " " # # # # # # # # # # # # # # # # # # % % % >SVV % % % % % % % % %%s; B
4B > B BB BB
C")CCc t d } t d }t }|rt || S t t | S )z
Check kmodlve module version or kernel version in order to determine
if it provides the detection of IO throttling
z2.0-23z1.5.58)r r compare_versions_geextract_kernel_version)kmod_min_versionkernel_min_version kmod_currents r2 $is_io_throttling_detection_availabler N s]
$H--%h//-//L C"<1ABBB 5 7 79K L LLr4 c t j d } t j } | | d }n# t $ r Y dS w xY w|S )zO
Get kernel version in the form of "major-minor" from current platform
zlve([0-9]+(\.[0-9]+)+)\.elr z0.0.0)recompiler_ r` searchgroupr )patternr` version_nums r2 r r [ sp j677G G nnW--33A66 ww s (A
A A
first_versionsecond_versionc r t | |k S # t $ r t d| d| d w xY w)zE
Comparing two versions using the greater or equal operator.
zAUnable to compare required versions: unexpected versions format "z" and "")r r r )r r s r2 r r h sg yM**n<< y y y wP] w wft w w wy y yys !6c > t sdS t S )zR
General check of kernel support (IO throttling availability is required)
T)r r r8 r4 r2 is_kernel_version_supportedr s s# # $ $ t / 1 11r4 maskc # b K t j | }dV t j | dS )z,
Context manager for dropping umask
N)r umask)r prevs r2 r r s/
8D>>D EEEHTNNNNNr4 r T
target_uid
target_gidc # K t j }t j } t j | }n# t $ r d}Y nw xY w| ||} n|j } | ||}n|j }|t j | }||k rWt j | t
d| |r&t j |k rt d || k rqt j
| t
d| |r@t j | k r)||k rt j | t d dV || k r/t j
| t
d| ||k r/t j | t
d| |t j | dS dS )aH
Context manager to drop privileges during some operation
and then restore them back.
If target_uid or target_gid are given, use input values.
Otherwise, stat target_uid and target_gid from given target_path.
If no target_path given, use current directory.
Use mask if given.
:param target_uid: uid to set
:param target_gid: gid to set
:param target_path: directory or file to stat for privileges,
default -- current directory
:param mask: umask to use
:param with_check: check the result of switching privileges
NzDropped GID privs to %sz6Unable to execute required operation: permission issuezDropped UID privs to %szRestored UID privs to %szRestored GID privs to %s)r getuidgetgidstatr st_uidst_gidr setegidrG debuggetegidr seteuidgeteuid) r r target_pathr
with_checkprev_uidprev_gid stat_infor s r2 set_privilegesr s " y{{Hy{{HGK(( !JJ")J !JJ")J x~~:
: .
;;; J"*,,*44HJ J
J:
: .
;;; J"*,,*44:%%
8$$$HJ J
J EEE:
8 /::::
8 /:::
s ? A
Ac 2 G d d } || S )Nc e Zd ZdZd Zd ZdS ) singleton..__Singletonzm
A singleton wrapper class. Its instances would be created
for each decorated class.
c " || _ d | _ d S rk )_wrapped _instance)self_clss r2 __init__z'singleton..__Singleton.__init__ s DM !DNNNr4 c P | j t s | j |i || _ | j S )z,Returns a single instance of decorated class)r IS_SINGLETON_ENABLEDr )r! argskwargss r2 __call__z'singleton..__Singleton.__call__ s0 ~%-A%!. !?!?!?> !r4 N)__name__
__module__ __qualname____doc__r# r( r8 r4 r2 __Singletonr s<
" " " " " " " "r4 r- r8 )some_clsr- s r2 singletonr/ s< " " " " " " " " ;x r4 rx )F)r )r )r )NNr NT)Vr, r r rz r r_ r xml.etree.ElementTreeetree ElementTreer collectionsr
contextlibr r r distutils.versionr r r r
r r r
r typingr r urllib.parser r} sentry_sdk.integrations.atexitr sentry_sdk.integrations.loggingr clcommon.constr clcommon.cpapir r r r clcommon.utilsr r clcommon.lib.cleditionr clcommon.lib.networkr r constantsr
exceptionsr getLoggerrG r" r r3 r9 r; r boolr r r r r r r r r r7 r r r r r r r r r r r% r/ r8 r4 r2 rC s
" " " " " " " " " " " " " " " % % % % % % $ $ $ $ $ $ $ $ * * * * * * " " " " " " " " ! ! ! ! ! ! < < < < < < > > > > > > " " " " " " D C C C C C C C : : : : : : - - - - - - 1 1 1 1 1 1 ! ! ! ! ! ! 7 # #j
344
:3
:3
:
:
:
:6Xc] 6 6 6 6:hsm : : : :
Z Z Z Zz (s s " s o (*3 * * * *& & &s & & & &
CS
C
C
C
C 3C 3E 3 3 3 37# 7(3- 7 7 7 7 4 4
d
%t % % % % %(
Md
M
M
M
M
ys yE#|BS