j d dl mZ d dl mZ d dl mZ d dlZd dlZd dlZd dlZd dlZd dl m
Z
d dl Z d dl Z d dl
Z
d dlZd dlZd dlmZ d dlmZ d dlmZ d dlmZ d d lmZ d d
lmZ d d l m Z d d l m Z d d
l m!Z!m"Z"m#Z# d dl$m%Z%m&Z& d dl'm(Z(m)Z) d dl*m+Z+ d dl,m-Z- d dl.m/Z/ d dl0m1Z1 d dl2m3Z3 d dl4m5Z5 ddl6m7Z7 ddl8m9Z9m:Z:m;Z; ddl8mZ>m?Z?m@Z@ d dlAmBZB d d lCm@ZD d ZEd ZF G d d eG ZHdS )! )print_function)absolute_import)divisionN)AnyStr) iteritems)ClPwd)FormattedException)
MailHelper)is_ascii_string)CloudlinuxLicenseLib) clselectctl) get_abs_relmkdir_prun_process_in_cagefs)BaseSelectorErrorAcquireApplicationLockError)print_dictionaryreplace_params)
CONFIG_DIR)
PkgManager)is_clpassenger_active) defaultdict)MIMEText)mkstemp )bun_delivery_hook)NODEJSPYTHONPHP) parse_cloudlinux_selector_opts)CloudlinuxSelectorLib OK_RES_DICTClSelectExcept)Website)r# z.lockc " t | | S N)open) file_namemodes M/opt/cloudlinux/venv/lib64/python3.11/site-packages/clselector/cl_selector.py_openr+ > s 4 c e Zd Zd Zd Z d5dZd Zd Zd Zd Z e
d Z d
Z d Z
d Zd
Zd Zd Zd Zd Zd Zd Zd Zd Zd Zd Zd Zd Zd Z d Z d Z d6d Z e
d Z d7d!Z!e"d" Z#e"d# Z$ e%j& d$ Z'e(d% Z)d& Z*e+j, d' Z-d( Z.d) Z/d* Z0d+ Z1d, Z2d- Z3d. Z4d/ Z5d0 Z6d1 Z7d2 Z8e
d3 Z9d4S )8CloudlinuxSelectorc d| _ i | _ d | _ t j dk | _ d | _ d| _ d| _ d| _ d| _
t j t d | _ d S )NFr z --background zcloudlinux-selector_bkg.pid)_is_json_opts
_selector_libosgeteuid
_is_root_user_lock_node_install_lock_handoff_is_bkg_option_present _bkg_option_nj_ver_move_frompathjoinr _pid_file_nameselfs r* __init__zCloudlinuxSelector.__init__D sq
! Z\\Q .
*/'&+#)!# gll:7T U Ur, c H | j d t t fvrdS t | j d | j d g rdS t | j d | j d | j d | j d o| j d t k | j d | j d
| j d | j d | j d
| j d | j d | j d | j d | j d | j d g rdS dS )zx
Check if cloudlinux-selector called with application operations
:return: True if lock is need
--interpreterFchange-version-multiplecreatestartrestartdestroymigratestopinstall-modulesuninstall-modules
run-script
--app-mode
--env-vars--new-app-root --new-domain
--new-app-uri
--new-version--startup-fileT)r2 r r anyr? s r* is_app_lock_neededz%CloudlinuxSelector.is_app_lock_neededQ s :o &vv.> > >5
45tz(7KL M M 5 Jw Jy ! Jy ! Jy ! Kdj &AV&K Jv J( ) J* + J| $ J| $ J| $ J' ( J~ & J ' J ' J' ( * + + 4ur, Fc | sdS | j d | j d }}| j j ||| | \ }}t
j | sdS t
j |t } t |d | _ t j
| j t j t j z dS # t" $ r<}|j t$ j k rd} t) || t) | d}~ww xY w)z[
Acquire lock for application if this lock is needed
:return: None
N--user
--app-root) chk_app_rootchk_envza+z6Disk quota exceeded. Please, free space and try again.)reason)rV r2 r3 apps_managerget_app_foldersr4 r< existsr= LOCKr' r7 fcntlflockfilenoLOCK_EXLOCK_NBIOErrorerrnoEDQUOTr )
r@ ignore_missing_app_rootignore_missing_doc_rootusernameapp_root_app_venv lock_fileer\ s
r* acquire_app_lock_if_neededz-CloudlinuxSelector.acquire_app_lock_if_neededo s7 &&(( F !Z 14:l3K((5EE h1H-H// F 1 1 8 w~~h'' F GLL400 8 i..DJ K
))++U]U]-J K K K K K 8 8 8w%,&&Q1(6JJJJ-h77 7 8s AC: :
E 7D;;E c | j r#| j d t k sdS | j dS | j }t
j |d d| _ |S )a Pass the continuously held Selector lock descriptor through npm.
This process's own app lock (acquire_app_lock_if_needed, above) is
held across the whole `run()` call for any non-root install-modules.
The Node.js npm subprocess receives a duplicate of that same open-file
description: Shared node_modules Store keeps it through resolve,
delivery and rebuild, and classic npm keeps it through unshare and the
final mutation. Reasserting flock on that description does not create
a second lock or release the Selector parent's ownership.
Root callers never hit this: they take the bun_delivery_hook branch
in run() and never reach acquire_app_lock_if_needed() at all. This
marks the existing descriptor inheritable immediately before the npm
child is spawned. The callback after npm merely clears inheritable;
the Selector copy remained locked through Passenger restart and the
health check.
rC NT) r3 r2 getr r7 rc r4 set_inheritabler8 )r@ fds r* ,_release_app_lock_for_bun_delivery_if_neededz?CloudlinuxSelector._release_app_lock_for_bun_delivery_if_needed sl $ " tz~~o'F'F&'P'P F : F
Z
2t$$$*.' r, c | j sdS | j ,t j | j d d| _ dS )z@Finish descriptor handoff; the Selector lock was never released.NF)r8 r7 r4 rt rc r? s r* &_reacquire_app_lock_after_node_installz9CloudlinuxSelector._reacquire_app_lock_after_node_install sI . F : ! tz 0 0 2 2E : : :*/'''r, c ^ | j r#| j d r| d S d S d S )NrS )r6 r2 send_notificationr? s r* send_notification_if_neededz.CloudlinuxSelector.send_notification_if_needed sG %$*_"= % " " $ $ $ $ $ % % % %r, c d S r& )
r r2 cpapicpinfor
sendmail
IndexErrorKeyErrorcpapiexceptions NotSupported)r@ MSG_TEMPmsgme cp_userinfouser_data_email
mailhelpers r* rz z$CloudlinuxSelector.send_notification s r, c l | sdS d | d D S )N c g | ]}||S r r ).0modules r*
z4CloudlinuxSelector.parse_modules.. s RRR66RRRRr, ,)stripsplit)modules_optionss r*
parse_modulesz CloudlinuxSelector.parse_modules s= 2RR_%:%:%<%<%B%B3%G%GRRRRr, c d|v | _ | j |v | _ | j r| | j t }| sGd| _ | ddi | j r" t j | j S # Y S xY wS | | | _
t | j
d | _ | j
| j
d r| j
d t k rw| j s| ddi | }| d d v rd
nd | j r" t j | j S # Y S xY wS | j | j
r| 5 t) j | j
| j
d t } |ot) j }n~# t( j j $ rg | t5 t( j Y d
d
d
| j r$ t j | j d S # Y d S xY wd S w xY w|rt) j | j
d | j
d | j
d }|t( j u rn|r\| t5 | d
d
d
| j r$ t j | j d S # Y d S xY wd S | | t5 d d
d
d
| j r$ t j | j d
S # Y d
S xY wd
S t? | j
d | j j | }|d }| ! |d | d
d
d
n # 1 swxY w Y || j r" t j | j S # Y S xY wS | j " | j
rdd| j
d | j j g|z }| 5 tG j$ |i } | % | d
d
d
n # 1 swxY w Y | j& | j r" t j | j S # Y S xY wS | ' | j
d | j
d | j
d rc| ( | j
d | j
d \ }
} |
dk r | | j
d< n#| t5 |
| j
d r| ) n
| j
d r| n| j
d r| * n| j
d r| + n| j
d r| , n| j
d r| - n^| j
d r| . n;| j
d! r| / n| j
d" r| 0 n| j
d# r| 1 n| j
d$ rZ| 2 rD| j
d t k r. | j r$ t j | j d S # Y d S xY wd S nk| j
d% r| 3 nH| j
d& s
| j
d' r| 4 n| j
d( s
| j
d) r| 5 n| j
d* r]| | j 6 | j
d | j
d | j
d+ | j
d, n| j
d- r| 7 n]| j
d. r| j 8 n6| j
d/ r| 9 n| : n!# tv j< tv j= tv j> f$ r;} | t5 t | Y d
} ~ nd
} ~ wtv j@ tv jA f$ rU} | j
d. s.| t5 | jB | jC 0 t d
Y d
} ~ nWd
} ~ wtv jE $ r.} | t5 | Y d
} ~ n d
} ~ wt $ rt} | jG r5| t5 | jB | jC | jG 1 n.| t5 | jB | jC 0 Y d
} ~ nd
} ~ wt $ r}
t jJ }t jK t |
|
}t |t rd2O | }n|}| t5 ||3 Y d
}
~
nd
}
~
ww xY w| j r" t j | j n6# Y n2xY wn.# | j r" t j | j w # Y w xY ww xY wd
S )4z$
Run command action
--jsonTresultz Cloudlinux license isn't validrC rI z"Node.js migration must run as rootstateeligiblemigratedr r r NrX rY --skip-web-check)skip_web_checksuccess
returncodeoutputz
/usr/bin/sudoz-u)envrH )ri rj --passenger-log-fileOKsetimport-applicationsrE rF rG rJ z read-configz save-configrK rL install-versionzuninstall-versionenable-versionzdisable-versionrM z
--script-namez
rD zmake-defaults-configsetupr context)r r details
)r r )Pr1 r: r9 remover get_license_status_error_and_exitr4 r> _parse_argsr2 r! r3 check_selector_is_availabler r6 run_migrate_applicationrs should_be_runned_as_user_lock_interpreter_if_neededr is_deliverable
is_enablednode_modules_storage StorageError _print_datadictCAPABILITY_UNAVAILABLEdeliver_modulesCLASSIC_NPM_FALLBACKr{ r CLOUDLINUX_SELECTOR_UTILITY_print_raw_data should_run_user_without_cagefs
subprocessPopen communicater rq !_passenger_log_filename_validatorrun_setrun_import_applications
run_create run_destroy run_start run_restartrun_stoprun_read_configrun_save_configrun_install_modulesrun_uninstall_modulesrun_manage_version run_disable_or_enable_version
run_script _start_change_all_apps_versionsreplace_mysqli run_setuprun_getClSelectExcept_oldConfigNotFound WrongDataNoSuchAlternativeVersionstrNativeNotInstalledMissingCagefsPackagemessager exitFileProcessErrorr r Exception traceback
format_excformat_exception_onlytype
isinstancelistr= )r@ argvlicencer deliverableshared_store_enabledfailurer user_run_cmdprocessr log_filenamerp errr list_err_msgerr_msgs r* runzCloudlinuxSelector.run sX
!D(
&*&6$&># & * KK( ) ) )i *,,G--//
Z $
++X7W,XYY@ *
Id 12222D
{ ))$//DJ!6tz/7R!S!SD : : < < < z)$
SO)D)N)N) [(((4X)YZZZ 5577 "JJw / /3K K KqqQRR` *
Id 12222D
_ !::4:FF 4
*5577 *7 *7 #4"B
DJ$?#I #IK!0; 1S4E4P4R4R -,,AN ! ! ! ((#4#K*M *M *M N N N +*7 *7 *7 *7 *7 *7\ *
Id 122222DD
y! , %"3"C Jx 0$*\2J+/:6H+I#K #K #K #&7&LLL $ % , ,T-A-A-A B B B#$=*7 *7 *7 *7 *7 *7\ *
Id 122222DD
] ! < < > > > , ,T-C-C-C D D D#$E*7 *7 *7 *7 *7 *7\ *
Id 122222DD
W 3
8, *F F
"( !5J(()9:::44666U*7 *7 *7 *7 *7 *7 *7 *7 *7 *7 *7 *7 *7 *7 *7V "F *
Id 12222D
E #BB4:NN
* /tz(7K $ 2 N PRV W 5577 7 7 ( .| D D DG'')))446667 7 7 7 7 7 7 7 7 7 7 7 7 7 7 )v *
Id 12222D
s
+ +(,
9(=(,
9(=
,
z01
?(,(N(NtzZbOcOSzZpOq)s )s% d??9EDJ 566((W)=)=)=>>>z% ,
I& *
,,.... 12 (
,,....H% &
!!!!I& $
""""G$ "
I&
""""F#
M*
$$&&&&M*
$$&&&& -.
,,.. J 76 A A j *
Id 122222DD
i /0
**,,,, -.
$*=P2Q
'')))) ,-
>tz.?Y[_[efq[rtxt~ uC uC DO uP uP Q Q
R
R
R
R
R
Z
$
0TZ 5L5X T / ; ;DJ{
@
@
@
@
@ @ @r, c 8 | j d S r& )r3 setup_selectorr? s r* r z CloudlinuxSelector.run_setup s ))+++++r, c
D || ddi |e| j ||| }|}|d dk r)| | t j d ||d| j |||| }|d dk r)| | t j d t ||| | | du|
duf r| 9d | d D } | j
| | j ||||| | | |
}|d dk r)| | t j d |d| j ||||
}|d dk r)| | t j d | i dS ) a
Call selectorctl to change application parameter
:param config_files: names of config files (such as requirements.txt or etc) (only for python)
:param entry_point: the specified entrypoint for application (only for python)
:param user: application owner
:param app_root: application main directory (application name)
:param app_mode: application mode
:param env_vars: dict with environment variables
:param new_app_root: new application main directory (new application name)
:param new_domain: new application domain
:param new_app_uri: new application uri
:param new_version: new version for nodejs interpreter
:param startup_file: new startup file for application
:param skip_web_check: skip check web application after change it's properties
:param passenger_log_file: Passenger log filename
:return: None
Nr z ERROR: User is not specifiedstatusr r c g | ]
}|d k | S )r0 r )r items r* r z1CloudlinuxSelector.run_change.. s W W WDTVJJJJJr, r )
r r3 relocateupperr sysr transitrU r validate_config_file_names
set_variableschange_version)r@ userrl app_modeenv_vars new_app_root
new_domain new_app_uri new_version startup_filer entry_point config_filespassenger_log_filers r* r z CloudlinuxSelector.run_change s? ( < 8":
;
;
; #"++D(LIIA#H{ ""d** ### "j&<"**4;
SSA{ ""d** ### (L+|SW?W"$.0 1 1 ' W W 1C1CC1H1H W W W "==lKKK"00x81={LZln nA{ ""d** ### ""11$+~^^A{ ""d** ### r, c ^ | | j d S r& )r r3 r r? s r* r z*CloudlinuxSelector.run_import_applications s+ +CCEEFFFFFr, c ^ | j | j d | j d | j dd | j dd }| d dv rd n| dd
}| || |S ) NrX rY r Fz --dry-run)r dry_runr r r rollback_failedr )r3 r r2 rs r )r@ r outcomes r* r z*CloudlinuxSelector.run_migrate_application s #;; Jx $*\": :>>*> 000
r, c | j d r.| | j d S | j d r.| | j d S | j d r.| | j d S | j d rF| | j | j d | j d d S | j d t k rG| | j | j d d S d t i}| j d t k r^| | j
| j d | \ }}| |
||d
< ||d < nN| j d t k r8| | j
| j d d |v r | ||d
d S | | d S )Nz--get-default-versionz--get-selector-statusz--get-supported-versionsz--get-current-versionrX r rC r passenger_activeremaining_apps_counttotal_apps_countr r )r2 r r3 get_default_versionget_selector_statusget_supported_versionsget_current_versionr get_fullrs r r updateget_apps_users_info _get_apps_count_from_pid_filer )r@ resr$ r% s r* r zCloudlinuxSelector.run_get sc :- . & T / C C E E F F F F F
Z/
0 & T / C C E E F F F F F
Z2
3 & T / F F H H I I I I I
Z/
0 & T / C CDJxDXDHJzDZ \ \
]
]
]
]
]
Z
(C
/
/ T / 8 8 9T9T U U V V V V V%'<'>'>?Cz/*f44
4-AA$*XBVWWXXX9=9[9[9]9]6$&6'38H8T2FC./.>C*+O,66
4-AA$*XBVWWXXX3 S] ;;;;; %%%%%r, c ^ | | j d r%| dd| j d id t s5| j d t k rd}nd}| dd |id | | j | j d
| j d | j d | j d | j d
| j d | j d | j d | j d | j d
d S )Nr zTCan't create application: Nodejs version %(version)s is locked by background processversionr rC z9https://docs.cloudlinux.com/python_selector/#installationz8https://docs.cloudlinux.com/index.html?installation.htmlz`Application creation not allowed, Phusion Passenger seems absent, please see %(url)s for detailsurlrY z --app-urirX r rN rT rO r r )(_is_version_locked_by_background_processr2 r r r r r3
create_app)r@ r1 s r* r z CloudlinuxSelector.run_create sU 8 8K9P Q Q q %tz+'>?" "
%&& z/*f44QP [ 3 " "
) )
<(
;'
;'
8$
:&
<(
+,
<(
?+
12
r, c | | j | j d | j d d S NrY rX )r r3 destroy_appr2 r? s r* r z CloudlinuxSelector.run_destroy5 S +77
<8P8<
88LN N O O O O Or, c | | j | j d | j d d S r5 )r r3 start_appr2 r? s r* r z CloudlinuxSelector.run_start9 sS +55dj 6N6:j6JL L M M M M Mr, c | | j | j d | j d d S r5 )r r3 restart_appr2 r? s r* r z CloudlinuxSelector.run_restart= r7 r, c | | j | j d | j d d S r5 )r r3 stop_appr2 r? s r* r zCloudlinuxSelector.run_stopA sS +44TZ 5M59Z5IK K L L L L Lr, c | | j | j d | j d | j d d S )NrY
--config-filerX )r r3 read_app_configr2 r? s r* r z"CloudlinuxSelector.run_read_configE sX . .
<(
?+
8$
&
& ' ' ' ' 'r, c | | j | j d | j d | j d | j d d S )NrY r? z --contentrX )r r3 save_app_configr2 r? s r* r z"CloudlinuxSelector.run_save_configL sb . .
<(
?+
;'
8$
&
& ' ' ' ' 'r, c | j | j d | j d | j d | j d | j d | | j d | j | j }| | t |t o8t |
dd d
k S ) NrY rX r r z--requirements-file --modules)r domainr spec_filemodulesbefore_install
after_installr r0 ok) r3 install_modulesr2 r rv rx r r r r rs lower)r@ r s r* r z&CloudlinuxSelector.run_install_modulesT s #33 J| $H%:j) :&89j!67&&tz+'>?? L E 4
vt,, FFJJx 4 455;;==EG Gr, c
| | j | j d | | j d | j d | j d | j d d S )NrY rD rX r r )rG r rE r )r r3 uninstall_modulesr2 r r? s r* r z(CloudlinuxSelector.run_uninstall_modulesf s 0 0
<( **4:k+BCCZ)z*- #z*< =
1
r, c | j d }| j d } | | j || dS # t $ r/}| dt
| i Y d}~dS d}~ww xY w)zM
Disable or enable interpreter version
:return: None
r r r N)r2 r r3 set_version_statusr r r )r@ r0 target_version_statusrp s r* r z0CloudlinuxSelector.run_disable_or_enable_versionq s *[) $
+; < T / B BCXZa b b c c c c c #a&&"
s .A
B$B Bc t | j d } | j d r | j j | }n | j j | }n&# t $ r}t | }Y d }~nd }~ww xY w| | t d S t |t r| | d S | d|i d S )Nr r r ) r r2 r3 selector_managerinstall_versionuninstall_versionr r r" r r r )r@ verr. rp s r* r z%CloudlinuxSelector.run_manage_version s $*[)** z+,
Q(9II#NN(9KKCPP a&&CCCCCC ; [ ) ) ) ) )
T
"
" 2 % % % % % (C 1 1 1 1 1s A A) )
B 3BB c d t || j | j \ }}|s"| t | |d dk r|d rX t }| |d n-# t
j $ r t dd|d id w xY wd}|d rT t j
|d |d \ }}|r||d< t |d |
}n# t $ r Y nw xY w||d < |S t j
d s9|d
s|d r)|d t k r| ddd t j
|d |d \ |d< }dD ]} | | st# |d || \ }}
t% j |
nG# t( $ r:} | t+ t- | Y d} ~ nd} ~ ww xY w|
|| < |S )z%
Parse CLI arguments
) as_from_rootrC phprX zNo such user (%s)r )r r Nr )rE docrootr z/usr/local/cpanelr rI r z?Import/migrate of Python Selector applications is not supported)r warning)rY rP r )r r1 r6 r r r get_pw_by_nameNoSuchUserExceptionr# r! $safely_resolve_username_and_doc_rootr$ r4 r< isdirr rs r r
check_directory
ValueErrorr r ) r@ r r datapwdwebsite
resolved_userdoc_rootrm app_root_arg directoryrp s r* r z CloudlinuxSelector._parse_args s 6 $-d.@B B B 7 !5!5 6 6 6 E ) )H~
''C&&tH~6666 0 (': &X( GJ
.C.h XZ(8/: /:+M8 % 7)6X %T*-=x P P PGG% D !(D K
122 q/0 q i q-1/-Bf-L-L I-n"p "p
q
q
q 2 V ND , . .X
=
+
+L88L))
&tH~tL7IJJLAy
+I6666
$$T q66& & &
"+D s7 )B *B-;AC> >
D
D G##
H'-0H""H'r c d|v r|d |d< |d= | j r9| dt j i t |d n] t t |d | di z n"# t $ r t d|z Y nw xY wt j | dS )z
Print error and exit
:param dict message: Dictionary with keys "result" as string and optional "context" as dict
r r timestampTr z Error: %sN)
r1 r+ timer printr rs r r r )r@ r
error_codes r* r z"CloudlinuxSelector._error_and_exit s
w ' 1GH ! = - NNK5 6 6 6 Wd + + + +
-c'(+,,w{{9b/I/IIJJJJ
-
-
-kG+,,,,,
- s 9B B-,B-c $ t | dS )z
Print raw data.
Function should be used in case if you want
to print a json string as an output from other utilities
N)rl )rb s r* r z"CloudlinuxSelector._print_raw_data s d r, r c , t |t r| }d|v r#t |d t r|d }| d| |d dk r:d|d< | j d t k r | j rd|d< nd|vrd|v r |d |d< |d= | d t j
i t || j p| d
S ) z
Output data wrapper
:param: `dict` data - data for output to stdout
:param: `bool` force_json - always output json format
rb r rJ r r rC zbMultiPHP system default PHP version is alt-php. PHP Selector does not work and should be disabled!r[ rj N)
r r copy
setdefaultrL r2 r r3 check_multiphp_system_defaultr+ rk r r1 )r@ rb
force_jsonr s r* r z CloudlinuxSelector._print_data s dD ! ! 499;;D~~*T&\4"@"@~F| OOHf - - - H~##%%--!*X:o.#55$:L:j:j:l:l5'[DO %%(d*:*:!%h XX KKdikk2 3 3 3t} :
;;;;;r, c R | j d t k S NrC )r2 rL r r? s r* r z CloudlinuxSelector._is_nodejs z/*0022f< 2 2 2 u %z2" "
* \t/Z/Z/\/\ \ (,Y!Z [ [ [Z''r, c | \ }}| j sr| j j dddd|z d|z | j g}t j |t
j t
j t
j dd | t dS |
| \ }}|r|d k rdS | ||| | ||| dS )
zM
Change all applications all users versions
:return:
rD r z--interpreter=nodejsz--from-version=%sz--new-version=%sT)stdinstdoutstderr close_fdsstart_new_sessionNr )
r r9 r3 r r: r r DEVNULLr r" _get_all_apps_by_version_write_pid_file_move_apps_by_list)r@ r r cmdusers_apps_listr% s r* r z2CloudlinuxSelector._start_change_all_apps_versionsx s
$(#H#H#J#J j* ">)8&#l2"Z/
C
(!)!) "&
[ ) ) ) F -1,I,I,,W,W)) "2a"7"7 F \:7GHHH =MNNNNNr, c
t | D ]|\ }}|D ]t}| j j dddt d|d|d|g }t j | }| |dz }| | t j d u}d S )
a
Move applications from list from one NodeJS version to another
:type dict
:param apps_dict: Application list. List example:
{'cltest1': [u'modjsapp_root'], 'cltest2': [u'app2', u'main_app']}
:param to_version: Move applications to this version
:param total_apps_count: Total applications count for move
:return: None
r r rC rX rY rS r N)
r r3 r r r r r _change_pid_filerk sleep) r@ apps_dictr r% user_name
user_app_listrl r r s r* r z%CloudlinuxSelector._move_apps_by_list s )2)(<(<
$I} )
*FxYhjp )\8_V`c$*3//##%%% A% %%&6777
2
r, c t t }| j j }d}t | D ]\ }} | j j |j |j |j }t | D ]1\ }} | d |k r ||
| |dz
}2x# t t t t f$ r Y w xY w||fS )aB
Retrives list of all NodeJS applications for all users, which uses supplied version of NodeJS
:param from_version: Required NodeJS version
:return: Cortege: (application_list, application_count). Example:
({'cltest1': [u'modjsapp_root'], 'cltest2': [u'app2', u'main_app']}, 3)
r nodejs_versionr )r r r3 r] get_users_dictr read_user_selector_config_jsonpw_dirpw_uidpw_gidappendr TypeErrorr AttributeError)
r@ r users_apps_dict user_infor% r
user_pw_entry
user_app_datarl app_infos
r* r z+CloudlinuxSelector._get_all_apps_by_version s &d++&3BBDD (1)(<(< $I}
$ 2 ? ^ ^!(!(!(! !
+4M*B*B . .&Hh 01\AA' 299(CCC(A-( .
&y(NK
000s
A1B<< C C c t j t | j d }|d | _ dS # Y nxY wdS )z]
Determine is background process already working
:return: True|False
r r TF)jsonloadr+ r> r; )r@ rb s r* r z9CloudlinuxSelector._is_background_process_already_running sH
9U4#6 < <==D%).%9D "4 Dus 48 <c | j d t k rdS | j | }| j | }| }|r
|| j k rdS dS )z
Checks if NodeJS version blocked by background operation
:param nj_version: NodeJS version to check
:return: True - version is locked, False - not locked
rC FT)r2 r r3 resolve_versionr r r; )r@
nj_versionis_bkg_process_presents r* r2 z;CloudlinuxSelector._is_version_locked_by_background_process sx :o && 0 05'77
CC
'DDZPP
!%!L!L!N!N ! jD4J&J&J4ur, c * t j t j t | t | ||t t
j dt | j d t j | j d dS )a
Creates pid file for background process move version from version to version
:param from_version: Move from NJ version
:param to_version: Move to NJ version
:param total_apps_count: Total application count to move
:return: None
)pidr r r% r$ rk w N)
r dumpr4 getpidr floatrk r+ r> chmod)r@ r r r% s r* r z"CloudlinuxSelector._write_pid_file s
9;; - - j// 0$4$)++&&
$c * * , , , $e,,,,,r, c t | j d }t j | }| |S )zc
Reads pid file and returns it's content as dictionary
:return: Dictionary
r )r+ r> r r closer@ fpid_datas r* _read_pid_filez!CloudlinuxSelector._read_pid_file s5
$%s + +9Q<< r, c T | }||d< t t \ }}t j |t |d t
j || j t
j | j d dS # t t t f$ r Y dS w xY w)z
Creates pid file for background process move version from version to version
:param remaining_apps_count: Remaining application count to move
:return: None
r$ )dirr r N)
r r r r r r+ r4 renamer> r OSErrorrf r )r@ r$ r rm temp_file_names r* r z#CloudlinuxSelector._change_pid_file s
**,,H/CH+ , 'J 7 7 7 A~ Ihnc : : ; ; ; Ind&9 : : : HT(% 0 0 0 0 0(+ 66 s BB B'&B'c t | j d }t j | }| |d |d fS # t
t t f$ r Y dS w xY w)z
Retrieves application counts from pid file
:return: Cortege (remaining_apps_count, total_apps_count)
If no background process started, returns None, None
r r$ r% )NN)r+ r> r r r r rf r r s r* r- z0CloudlinuxSelector._get_apps_count_from_pid_file, ss d)3//Ay||H
GGIII 23X>P5QQ Q(+ :: s A A A*)A*c t }| | } t | sdS t j | rdS | t j j s t j || }t j | }| |t j z rQt j
| }t j | st | d|fS n2# t t f$ r }dt | z dfcY d}~S d}~ww xY wdS )a
Validates passenger log file name
:param username: User's name
:param log_filename: passenger log file name to validate
:return: tuple: (message, log_filename).
message: "OK" - filename is valid, any other string - invalid, error text
log_filename: corrected log filename - simlink dereferencing, appends user's homedir for relative paths, etc
)zAERROR: Passenger log filename should contain only english lettersN)zDERROR: Passenger log file should be a filename, not a directory nameNr z%sN)z9ERROR: Passenger log file should be placed in user's homeN)r get_homedirr r4 r< r_
startswithsepr= realpathdirnamer_ r r rf r )rk r rc user_homedir log_realpathr excs r* r z4CloudlinuxSelector._passenger_log_filename_validator: sP ggx00 )"<00
a``w}}\**
dcc **27;77
H !w||L, G G 7++L99L&&|BF':;;
* '//,77w~~g.. %G$$$\))
*
! ) ) )#c((?D( ( ( ( ( ( ( )PPs) D. D. CD. .E ?EE E N)FF)r )Fr ):__name__
__module__ __qualname__rA rV rq rv rx r{ rz staticmethodr r r r r r r r r r r r r r r r r r r r r r r propertyr r recompilerz classmethodr} r
contextlibcontextmanagerr r r r r r r r2 r r r r- r r r, r* r. r. B s V V V @ %*$) 8 8 8 8@ 60 0 0% % % @ S S \S
s s sj@ @ @6, , ,8 8 8 tG G G & & &8! ! !FO O OM M MO O OL L L' ' '' ' 'G G G$
2 2 2 I I IV $ \< < < <: = = X= = = X= #
#BCCW W [W 0( ( (8( ( ($/O /O /Ob , 1 1 1@ - - -& $ Q Q \Q Q Qr, r. )I
__future__r r r ra r r rk rg clcommon.cpapir} r r r4 r r typingr future.utilsr clcommonr clcommon.clexceptionr clcommon.mail_helperr
clcommon.clfuncr cllicenser clselectr
clselect.utilsr r r clselect.baseclselectr r cli_utilsr r clselect.clselectnodejsr "clselect.clselectnodejs.pkgmanagerr clselector.clpassenger_detectlibr collectionsr email.mime.textr tempfiler r0 r cl_selector_arg_parser r r r selectorlibr! r" r# clselect.modelsr$ clselect.clselectexceptr r` r+ objectr. r r, r* r s & % % % % % & & & & & &
" " " " " " 3 3 3 3 3 3 + + + + + + + + + + + + * * * * * * F F F F F F F F F F P P P P P P P P 6 6 6 6 6 6 6 6 . . . . . . 9 9 9 9 9 9 B B B B B B # # # # # # $ $ $ $ $ $ 6 6 6 6 6 6 6 6 6 6 A A A A A A K K K K K K K K K K # # # # # # H H H H H H ! ! !SQ SQ SQ SQ SQ SQ SQ SQ SQ SQr,