kK< x d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlmZm Z m
Z
m Z d dl m
Z
mZ d dlmZ d dlmZmZ d dlmZ d dlmZ d dlmZ d d lm Z d d
l m Z d Z d d l m!Z! d d
l"m#Z# n# e$$ r e Z!e Z#Y nw xY wdZ%dZ&dZ'dZ(ej) * e(d Z+dZ,da-dZ.dZ/ G d d Z0d Z1d Z2d5dZ3d Z4d Z5d6d e6d e7d!e7fd"Z8d e6d#e7d!dfd$Z9d!e7fd%Z:d!e7fd&Z;d'e7d!dfd(Zd+ Z?d, Z@d- ZAd. ZBd/ ZCd0 ZDd1 ZEd6d!ee e
e e
e7f f fd2ZFd3 ZGd!ee
fd4ZHdS )7 N)OptionalDictAnyStrUnion)decode
exceptions)DEFAULT_JWT_ES_TOKEN_PATH)
WhmApiRequest WhmApiError)mkdir)process_is_running)check_cagefs_initialized)CL_CONFIG_FILE)write_file_via_tempfilec d S )N )akws py/clsummary/utils.pydummy_none_functionr s 4 "interpreter_versions_short_summary)is_clpassenger_active
license_checkcl_statistics_enabledcl_statistics_rpm_enabledz/var/lvezsummary_status.jsonz%/var/run/cloudlinux_summary.send.lockz./usr/share/cloudlinux/cl_plus/clplus_sender.pyz#/opt/cloudlinux/venv/bin/virtualenvc e Zd ZdZdZdZdZdS )
SummaryStatusz
Status of both, collecting and sending statistics
If process still collects statistics -> IN_PROGRESS
If statistics collected and sent correctly -> SUCCESS
If any error during collecting or sending -> FAILED
success in_progressfailedN)__name__
__module__ __qualname____doc__SUCCESS IN_PROGRESSFAILEDr r r r r 4 s) G K
FFFr r c J t j t S )zS
Checks is virtualenv installed
:return: True/False - installed or not
)ospathexistsALT_PYTHON_VIRTUALENV_BINr r r is_virtualenv_installedr/ @ s
7>>3 4 44r c t j dt j ddddd } t j | t j | }t j d| d }n# t t f$ r Y dS w xY w|t j k S )a$
Check if file is locked by another process without acquiring lock.
IMPORTANT! This function should NOT be used to check lock acquired by the
same process that executes the is_locked() function. For example, when
process executes fcntl.lockf(LOCK_FILE), and then the same process executes
is_locked(LOCK_FILE), the is_locked(LOCK_FILE) call returns False.
Use is_locked() function to check lock acquired by another process only.
:param lock_file: file to check lock on
:type lock_file: file object or descriptor
hhllhhr F) structpackfcntlF_WRLCKF_GETLKunpackOSErrorIOErrorF_UNLCK) lock_file lock_data
lock_query lock_statuss r is_lockedr? H s HemQ1aCCI[EM9EE
mHj99!< W uu %- ''s ;A" "A76A7Fc t t dd a| st t S t j t t j t j z n# t t f$ r Y dS w xY wdS )z
Check if processes collecting stats are running already (with --send option in command line)
:param acquire_lock: True = acquire lock when possible
:type acquire_lock: bool
:return bool: True = Processes are running
wutf-8encodingTF)
open_CL_STATISTICS_LOCK_PATH_CL_STATISTICS_LOCK_FILEr? r4 lockfLOCK_EXLOCK_NBr8 r9 ) acquire_locks r is_sending_process_runningrL ] s $ # 31222
,emem.KLLLL W tt 5s 1A! !A65A6c ~ t j dd } t | _ | t
| S )zW
Retrieves ConfigParser object for /etc/sysconfig/cloudlinux file
:return:
NT)
interpolationstrict) configparser ConfigParserstr optionxformreadr )configs r _get_configrV q s?
&T.24 4 4F F
KK Mr c t j }| | | }t |t
dd n# t t f$ r Y dS w xY wdS )z
write config to /etc/sysconfig/cloudlinux file
:param config: configParser object to write
return boolean: True|False
i cloudlinux_prefixFT)ioStringIOwritegetvaluer r r8 r9 )rU string_fpcontents r
_write_configra } s{ KMM Y $$&& }UUUUU W uu 4s AA A,+A,T parameterdefaultreturnc t }|} | t | }n'# t j t j t f$ r Y nw xY w|S )zi
Retrieves parameter's value from /etc/sysconfig/cloudlinux file, _CL_STATISTICS_SECTION section
)rV
getboolean_CL_STATISTICS_SECTIONrP NoSectionError
NoOptionError
ValueError)rb rc rU ress r _get_config_valuerl sc ]]F
C
6 BB ' )CZ P
Js . !AAvaluec t }| t | t t | t | dS )zb
Sets parameter's value to /etc/sysconfig/cloudlinux file, _CL_STATISTICS_SECTION section
N)rV setrg rR intra )rb rm rU s r _set_config_valuerq sD ]]F
JJ%y#c%jj//BBB&r c * t t S )z~
Retrieves statistic collection status from /etc/sysconfig/cloudlinux file
:return: True/False - enabled/disabled
)rl #_CL_STATISTICS_COLLECT_STATE_OPTIONr r r is_statistic_enabledrt s
@ A AAr c * t t S )z
Retrieves rpm statistic collection status from /etc/sysconfig/cloudlinux file
:return: True/False - enabled/disabled
)rl '_CL_STATISTICS_COLLECT_RPM_STATE_OPTIONr r r is_statistic_rpm_enabledrw s
D E EEr
is_enabledc 0 t t | dS )z
Set statistic collection status to /etc/sysconfig/cloudlinux file
:param is_enabled: True/False - enabled/disabled
N)rq rs rx s r set_statistic_collection_enabledr{ s
9:FFFFFr c 0 t t | dS )z
Set rpm statistic collection status to /etc/sysconfig/cloudlinux file
:param is_enabled: True/False - enabled/disabled
N)rq rv rz s r $set_statistic_rpm_collection_enabledr} s
=zJJJJJr c t j t st t t j | }t |t dd dS # t t f$ r Y dS w xY w)z
Writes statistics send status to file /var/lve/summary_status.json
:param status_dict: status dictionary for write to file
:return:
i rX rY N) r+ r, r- _CL_STATISTICS_DIRmkdir_pjsondumpsr _CL_STATISTICS_SEND_STATUS_FILEr8 r9 ) status_dictr` s r $write_statistics_send_status_to_filer s
w~~ 011 ( & ' ' '*[)) )H%Xeffffff W
s A$A( (A=<A=c | d} t t d 5 }| }ddd n # 1 swxY w Y t j | } | d t
j k r"t st
j | d< d| d< n)# t t t t t f$ r Y nw xY w| S )z
Retrieves statistics send status from file /var/lve/summary_status.json
:return: Dictionary with last send status. None if any error
NrB rC resultzaCollecting statistics was failed. Error report has been sent to developers and will be fixed soonreason)rE r rT r loadsr r( rL r) r8 r9 rj AttributeError TypeError)r f s_contents r $get_statistics_send_status_from_filer s
K
1G
D
D
D !I ! ! ! ! ! ! ! ! ! ! ! ! ! ! !j++ x M$= = =244 > %2$8K !%`K ! Wj.) D
s/ B ; B ?B ?AB #B98B9c 4 d t | D S )z
Returns list of installed interpreters
:param interpreter: str - name of interpreter
:rtype: List of InterpreterSummary
c g | ] }|j | S r ) installed).0is r
z/installed_interpreters_list.. s V V V!!+ VA V V Vr r ) interpreters r installed_interpreters_listr s" W V9+FF V V VVr c : t o
t S )z
Checks that python selector is installed
Installed if:
- ea-apache24-mod-alt-passenger or alt-mod-passenger is installed
- alt-python-virtualenv is installed
:rtype: bool
r r/ r r r is_python_selector_installedr ! " " @'>'@'@@r c : t o
t S )z
Checks that ruby selector is installed
Installed if:
- ea-apache24-mod-alt-passenger or alt-mod-passenger is installed
- alt-python-virtualenv is installed
:rtype: bool
r r r r is_ruby_selector_installedr r r c V t ot t d S )z
Checks that nodejs selector is installed
Installed if:
- ea-apache24-mod-alt-passenger or alt-mod-passenger is installed
- At least one version is installed
:rtype: bool
nodejs)r boolr r r r is_nodejs_selector_installedr s& ! " " Rt,G,Q,Q'R'RRr c 8 t t S )zn
Checks that php selector is installed
Installed if:
- CageFS is initialized
:rtype: bool
)r r r r r is_php_selector_installedr s (** + ++r c t d } n# t $ r g cY S w xY wd | d D }|S )z9
Gets packages with set lve limits via extension
listpkgsc > g | ]}d |v |d dk |d S )_PACKAGE_EXTENSIONSlvenamer )r items r r z4get_packages_with_lve_extensions..% sD j j j"74"?"?DI^D_chDhDh $F|DhDhDhr pkg)r
callr )r lve_extensions_packagess r get_packages_with_lve_extensionsr ss z**//11 j ju
j j j ""s !$ 33c B t t d 5 }| }ddd n # 1 swxY w Y n# t t
f$ r Y dS w xY w t
|dgd| dddd }|S # t j $ r Y dS w xY w)
z
Gets (if any) fields cl_plus and client_id from jwt token
:return: decoded jwt_token value, None if error
jwt_token: result of the successful decoding
rb)modeNHS256TF) require_exp
verify_exp
verify_issverify_signature
CloudLinux)
algorithmsoptionsissuer) rE r rT stripr8 r9 r r
PyJWTError)check_expirationfile file_content jwt_tokens r get_client_data_from_jwt_tokenr * s
+$
7
7
7 /4 99;;,,..L / / / / / / / / / / / / / / / W tt
>% t ty{{ c*.."7"7 8 8 88r c ` t t d } n# t $ r d} Y nw xY w| rdndS )z
Retrieves data from status of cl_plus_sender service
:return: status of service, Optional[AnyStr]
- 'active'
- 'inactive'
Factiveinactive)r
CL_PLUS_SENDER_FILE_PATHFileNotFoundError)r s r get_cl_plus_sender_statusr N sL #$r s
0 0 0 0 0 0 0 0 0 0 0 0 " " " " " " " " 9 9 9 9 9 9 > > > > > > > > / / / / / / - - - - - - F F F F F F & & & & & & , , , , , , 0GGGGGGFFFFFFF 0 0 0)<& /0
) &= #*E ' "$',,/ACX"Y"Y B K A 5 5 5( ( (* (
t t T d Bd B B B BF$ F F F FG G$ G G G GKT Kd K K K K
*W W WA A AA A AS S S, , ,
#
#
# Xd6SXY_aeYeSfKfFg=h 29 9 9 .8F#3 . . . . . .s ! A. . A:9A: