j| R d dl mZ d dl mZ d dl mZ d dlZd dlZd dlZd dlZd dl Z d dl
m Z m Z d dl
m
Z
d dlmZ d dlZd dlmZ d dlmZ d d lmZ d d
lmZmZ d d lmZm Z m Z d d l m Z d d
l m!Z!m"Z"m#Z#m$Z$ ddl%m&Z& d dlm'Z'm(Z( d dlm)Z) d dlm*Z* G d d e*e e+ Z,dS ) )absolute_import)print_function)divisionN)ABCMetaabstractmethod)datetime iteritems)unicode)ClPwd)get_file_lineswrite_file_lines) pretty_jsondelete_using_realpath_keys get_abs_rel)ClSelectExcept)BaseSelectorErrorAbsentFileErrorMissingVirtualenvErrorMissingAppRootError )BaseSelectorManager)file_readlinesfile_writelines)get_using_realpath_keys)with_metaclassc L e Zd ZdZdZdZdZdZdZd Z e
d Z d Z d Z
d Zd'd
Zed(d Zd Zeed
Zd(dZd(dZd Zd Zd Zd Zd Zd Z d Z d Z d Z d Z d Z!d Z"ed Z#d(d Z$d(d Z%d Z&d Z'd! Z(d(d"Z)d)d$Z*d% Z+d& Z,dS )*BaseApplicationsManagerz[
Base class that responsible for gathering and set information about applications.
Nz/var/log/selectorctl.logc : || _ t | _ d S N)_managerr _pwd)selfmanagers Y/opt/cloudlinux/venv/lib64/python3.11/site-packages/clselect/baseclselect/apps_manager.py__init__z BaseApplicationsManager.__init__4 s
GG c t j d }t | j |d|dgd dS # t
t f$ r Y dS w xY w)zi
Writes string to log file
:param log_str: String to write
:return: None
z%Y-%m-%d %H:%M:%S:
aN)r nowstrftimer _LOG_FILE_NAMEIOErrorOSError)clslog_str dt_strings r% write_string_to_logz+BaseApplicationsManager.write_string_to_log8 st //0CDDI S / 7772S1TVY Z Z Z Z Z! DD s AA A A c f | | }|||< | || dS )a
Add data to user's config (update info for an app with app_directory specified)
:param str user: name of unix user
:param str app_directory: Application root directory
:param dict app_data: Application data
:return: None
N)get_user_config_datawrite_full_user_config_data)r# user
app_directoryapp_data current_dicts r% add_app_to_configz)BaseApplicationsManager.add_app_to_configE s= 0066 &. ]# ((|<<<<zEBaseApplicationsManager.add_env_vars_for_htaccess..a s JJJdTJTJJJr' r* r z
zSetEnv {0} {1}z w) get_htaccess_by_appdiropenreadsplitindexappenditemsreplaceformatwritejoin)r# user_namer9 env_varsdoc_rootenv_section_beginenv_section_end
htaccess_filehtaccesslinesstartendenv_varvalues r% add_env_vars_for_htaccessz1BaseApplicationsManager.add_env_vars_for_htaccessR s a\ 33I}hX\]]
F
-->
?
?
? .8JJhmmoo&;&;D&A&AJJJE E))o.F.F $566kk/22%q.)# ./// 3444&.nn&6&6 J JNGU %oodB 7 7 ? ?b I IG !MM$ 3 3 ; ;D" E EELL!1!8!8%!H!HIIII ]+++ _--- . . . . . . . . . . . . . . . -->
?
?
? -8 NN499U++ , , , - - - - - - - - - - - - - - - - - -s$ EFF F 5)G++G/2G/c | | } t ||| | || dS # t $ r Y dS w xY w)z
Removes application from config
:param user: User name
:param app_dir: Application directory
:return: True if app is exists in config,
False - if app is not exists in config
TF)r6 r r7 KeyError)r# r8 app_dir config_datas r% remove_app_from_configz.BaseApplicationsManager.remove_app_from_configr so //55 &tWk B B B , ,T; ? ? ? 4 55 s 'A
A
AFc
| | }|sdS t | D ]\ }}|r t j d|z |d }n t j d|z |d }|Bt d |d dt
| | |d< | || dS )a
Replace domain in config files when it is renamed.
:param username: domain owner
:param domain: previous name
:param new_domain: name after rename
:param include_subdomains: whether we should also rename subdomains
:return:
Nz (\.|^)%s$domainz^%s$z{}{})r6 r
researchr rR lenr7 ) r# usernamerh
new_domaininclude_subdomains full_configappconfigmatchs r% replace_domain_in_configsz1BaseApplicationsManager.replace_domain_in_configs s //99 F %[11
!
!KC!
F ,"79IJJ 'F"2F84DEE #*6==8$]s6{{l]3 , , $! $!x
((;?????r' c F t | | \ }fd|D S )z6
Return list of detected config files
c g | ]A}t j t j | ?|BS rC )ospathexistsrT )rD rq abs_paths r% rF z>BaseApplicationsManager._find_config_files.. s= ```6 XW]@^@^1_1_````r' )r )rU r9 patternsrel_pathry s @r% _find_config_filesz*BaseApplicationsManager._find_config_files s3 )M B B(````X````r' c | || }| j | }| |||| }d t
j d t j || d |d g}|
| | ||| | |
dd }|r| d|z | t
j dz |
t! |d
t j | } t j |d } t% j | j rt% j | j nd
}
n# t, $ r d
}
Y nw xY wt j |t j t j z t j z t j z t j z |
} t j | dd
5 } | | ddd dS # 1 swxY w Y dS )z
Creates .htaccess file for application based on application config data
:param str user_name: User's name
:param str app_root: Application root
:param doc_root: Document root for the domain
:return: None
z{}
zPassengerAppRoot "{}"
zPassengerBaseURI "/{}"
app_uripassenger_log_fileNzPassengerAppLogFile "%s"
r* r? r@ F)follow_symlinksi rI ) get_app_configr" get_homedirrJ rR clpassengerHTACCESS_BEGINrv rw rT extend(get_interpreter_specific_passenger_linesget_binary_pathgetrO HTACCESS_ENDr rm_double_empty_linesstatS_ISREGst_modeS_IMODEFileNotFoundErrorrK O_WRONLYO_CREATO_TRUNC
O_NOFOLLOW O_CLOEXECfdopen
writelines)
r# rU app_rootrW
app_configuser_dirrZ new_linesr src_st keep_modefdfs
r% update_htaccess_filez,BaseApplicationsManager.update_htaccess_file s $ ((H==
9((33 33IxS]^^
MM+4 5 5 % , ,RW\\(H-M-M N N & - -j.C D D
FF Hh ? ? (^^,@$ G G P 9OPPPQQQ 5i@@ W]EBBBF8< V^8T8T_ V^444Z_II III
W][2:-
:}%')|4 Yr3'8
9
9
9 $Q
LL # # # $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $s% >A
G GGI))I-0I-c t )zu
Return list of lines that needs to be added to htaccess and are
specific to the interpreter
)NotImplementedError) binary_pathr s r% r z@BaseApplicationsManager.get_interpreter_specific_passenger_lines s
"!r' c | || }|| j }t j || j ||d| S )a
Return a path to the environment's interpreter binary
Get interpreter path for application
:param user: owner of the application
:param app_root: app path relative to user home (app-root)
:param user_dir: User's home directory
:param binary_name: name of binary in virtual environemnt (python, npm, node)
:return: path to interpreter binary in virtual environment
Nbin) get_interpreter_version_for_app BINARY_NAMErv rw rT VENV_DIR)r# r8 r r binary_nameversions r% r z'BaseApplicationsManager.get_binary_path sG 66tXFF *Kw||HdmXw{[[[r' c p || j S || j | iS )z
Retrives info about user(s).
:param str | None username: Username to retrive information.
:return: Dictionary with user info. Example:
{'user1': pw_struct}
)r"
get_user_dictget_pw_by_name)r# rl s r% get_users_dictz&BaseApplicationsManager.get_users_dict s9 9**,, ,$)228<<==r' c * i }| | }t j | rt j dk rJ| j | }dt _ t j ||j
|j dd }nt | } t j d |pg }nA# t t" f$ r- t% j d | j w xY w|S )z
Get all data from user's config
:param user: name of unix user
:return: json data from user's config as dictionary
r TF
exit_on_error write_logrH zUser config "{}" is broken)_get_path_to_user_configrv rw isfilegeteuidr" r secureio SILENT_FLAGread_file_securepw_uidpw_gidr
jsonloadsrT
ValueError TypeErrorr WrongDatarR _USER_CONFIG)r# r8 _user_config_data user_configuser_pwdatas r% r6 z,BaseApplicationsManager.get_user_config_data s 33D99 7>>+ & & gz||q )22488'+$ 0gngn?DPUW W W &k22
g$(Jrwwtzr/B/B$C$C!! *
g
g
g$./K/R/RSWSd/e/efff
g s ()C >Dc r | | } t ||| S # t $ r Y dS w xY w)z
Retrieves full application config
:param user: User name
:param app_dir: Application directory
:return: Application data as dictionary
If None - No application data found in config
N)r6 r rc )r# r8 rd user_config_datas r% r z&BaseApplicationsManager.get_app_config# sR 44T:: *4:JKK K 44 s (
66c > | || }|d S )z
Retrieves domain for provided user's application
:param username: user name
:param app_directory: application root directory
:return str: application domain
rh r )r# rl r9 r s r% get_app_domainz&BaseApplicationsManager.get_app_domain1 s$ ((=AA
(##r' c > | || }|d S )z
Retrieves uri for provided user's application
:param username: user name
:param app_directory: application root directory
:return str: application uri
r~ r r# rl r9 r: s r% get_app_uriz#BaseApplicationsManager.get_app_uri; s$ &&x ?? ""r' c > | || }|d S )z
Retrieves name of startup file for provided user's application
:param username: user name
:param app_directory: application root directory
:return str: name of startup file of application
startup_filer r s r% get_app_startup_filez,BaseApplicationsManager.get_app_startup_fileE s$ &&x ??''r' c > | || }|d S )z
Retrieves status for provided user's app_directory
:param username: user name
:param app_directory: application root directory
:return str: status of application
app_statusr r s r% get_app_statusz&BaseApplicationsManager.get_app_statusO s$ &&x ?? %%r' c | || }|'t j d | |d| j z S )z
Retrieves interpreter version for provided user and application
:param username: user name
:param app_directory: application root directory
:return str: major interpreter version
Nz)Application config is missed for user: {}
%s_version)r r ConfigMissingErrorrR INTERPRETERr s r% r z7BaseApplicationsManager.get_interpreter_version_for_appY s] &&x ?? 3 5CCI6(CSCSU U
U t'7788r' c | j | }t j || j }|S )z
Get full path to user config ~/${_USER_CONFIG}
:param username: name of unix user
:return: full path to config
)r" r rv rw rT r )r# rl user_homeapplication_configs r% r z0BaseApplicationsManager._get_path_to_user_configf s8 I))(33 W\\)T5F G G!!r' c T | j j | }||k r|S dS )z
Retrieves full version for supplied major version.
:return: str - Full version or None if full version not found
N)r! pkgget_full_version)r#
major_version full_versions r% _get_full_version_for_shortz3BaseApplicationsManager._get_full_version_for_shortq s2
}(99-HH = ( ( tr' c t |j |v r|||j d |< dS |j ||id}|||j < dS )a@
Add single application data to user_data_dest_dict
:param users_data_dest_dict: Destination dictionary with application data
:param user_pw_entry: User's passwd entry
:param app_root_dir: Application root directory
:param app_data: Application data
:return: None
applications)homedirr N)pw_namepw_dir)r# users_data_dest_dict
user_pw_entry app_root_dirr: user_datas r% _add_single_user_appz,BaseApplicationsManager._add_single_user_app{ sd $8 8 8X` !6 7 G U U U )/!-x 8 I ;D !6 7 7 7r' c | |j | }t |d |z }t | |d< dS )z&> Y Y "L( h--
H1L1L'+'G'GQ\H]'^'^ $'/3KSf3f3f 12J KKKIK#$<=gF !5!5!)< 9M * "6 ", ",&H\ " %,-EFwOJ : :8\S` a a a % %j- x X X X X7 Y Yr' c L t | D ]\ }}d|vrd|d< || |< | S )z
Append absent 'passenger_log_file' key with None value to each application
:param user_config_dict: Sourse dictionary to modify
:return: Modified dict with 'passenger_log_file' keys
r Nr )user_config_dictr r: s r% _add_absent_passenger_log_filez6BaseApplicationsManager._add_absent_passenger_log_file sK #,,<"="= 2 2 Hh#83315-.)1 X & & r' c L |t j }t j || j }t j | st
| |dk r&dt _ t j |||dd }nt | }| t j
d | S # t t t t" f$ r'}t% d|t' | dd d}~ww xY w)
a]
Read [python|ruby|node]-selector.json file from user's directory.
:param euid: current effective uid
:param user_homedir: user's home directory
:param uid: uid for drop rights
:param gid: gid for drop rights
:return: Cortege contents_dict. None - there is no [python|ruby|node]-selector.json file in user's directory
:raises BaseSelectorError if error. Exception contents:
{'message': "File %(file)s read/parse error: %(error)s",
'context': {'file': node_json_path, 'error': 'some message'}}
Nr TFr rH z)File %(file)s read/parse error: %(error)s)fileerror)messagecontext)rv r rw rT r rx r r r r r
r r r r/ r0 r r r str)r# user_homediruidgideuidjson_config_path
file_lineses r% read_user_selector_config_jsonz6BaseApplicationsManager.read_user_selector_config_json s+ <:<A
AAc | | } t ||| }||d< n# t $ r Y dS w xY w| || dS )z
Retrieves application status
:param user: User name
:param app_dir: Application directory
:param new_status: New appication status
:type new_status: str
:return: None
r N)r6 r rc r7 )r# r8 rd
new_statusr r s r% set_app_statusz&BaseApplicationsManager.set_app_status s} 44T:: 0w@PQQJ'1J| $ $ FF
((/?@@@@@s .
<<c | | }t j dk st j dk rt j d t
| } t j ||dd dS # t t t f$ r-}t j |d
| d}~ww xY w)z
Write data to user's config
:param user: name of unix user
:param config_data: data in json format
:return: None
r z$root should not write to user configi _tmp)content dest_pathpermsuffixz%Could not write json user config ({})N)r rv r getegidr SelectorExceptionr r write_file_via_tempfiler/ r0 r UnableToSaveDatarR )r# r8 re r
dumped_datar s r% r7 z3BaseApplicationsManager.write_full_user_config_data s 88>>
:<<1
1 1 268 8
8!+.. C
,#*
), C C C 1 7>>qAAC C
C Cs (B C(CCc | }t | D ]\ }} | |j |j |j }|<| D ]'}| d| j z |k r dS (k# t $ r Y wt $ r,}| |j |j
z Y d}~d}~ww xY wdS )z
Returns True if specified NodeJS version is in use by any app of any user.
It will stop search on the first match.
:param version: NodeJS interpreter major version
:return True | False
Nr TF)r r
r
r r r valuesr r r r r4 r r )r# r user_inforU r user_apps_datarp r s r% is_version_in_usez)BaseApplicationsManager.is_version_in_use, s '')) (1)(<(< @ @ $I}
@!%!D!D]EY[h[oEREY"[ "[!- - 4 4 6 6 ( ( 77<$2B#BCCwNN#'444 O"
$
@
@
@((QY)>????????
@us$ A B
B
C C$"C Cc
t j dk r*t j t j j } | | }n,# t j j $ r t j
| w xY w| }|d }t | D ] \ }} |
|j |j |j }| ||| E# t$ $ r Y Qt& $ r\}t j dk r9| |j |j z d| j d| j d|d< n|Y d}~d}~wt2 $ r]}t j dk r:| d| j d |d
| d| j d| j d|d< n Y d}~d}~ww xY w|S ) a
Retrieves info about all installed NodeJS interpreters and user(s) applictions
:param user: User name for read applictions. If None and current euid == 0 - all users will be processed.
If current euid != 0 (called under some user), this argument will be ignored
and only user with uid == euid will be processed
:return: Dictionary with user(s) applications info
:raises ClSelectExcept.NoSuchUser or BaseSelectorError
r available_versionsz Some user's zD can't be read. Some user(s) data absent in output. Please see file z for detailswarningNzFailed to process z
for user r) )rv r _stdpwdgetpwuidr r r clpwdNoSuchUserExceptionr
NoSuchUser_get_interpreter_infor
r
r r r r r r r4 r r r r. Exception) r# r8 r users_apps_infor# rU r r r s r% get_applications_users_infoz3BaseApplicationsManager.get_applications_users_infoG sX , :<<1 #BJLL119D 2 ++D11II~1 2 2 2 +D11 1 2 4466 ,-A B )2)(<(< ( ( $I}'
!%!D!D]EY[h[oEREY"[ "[ ''
7I>ZZZZ"
$
:<<1$$ ,,QY-BCCCC 372C2C2CTEXEXEX2ZOI..
G /....
:<<1$$,,, - - -yyy!!=> > > >
372C2C2CTEXEXEX2ZOI.. /....
$ s8 A )B7=C55
G G
AE!!
G .AGG Tc | j | j }t j || j | }|r.t j | st | t j || }|r.t j | st | ||fS )a
Calculate, check exists and return application folders
This method does not check that application exists in config.
:raises: NoSuchUserException, MissingVirtualenvError, MissingAppRootError
:return: tuple(app_root, app_venv) with absolute paths
)
r" r r rv rw rT r rx r r )r# rl r chk_env chk_app_rootr app_venvs r% get_app_foldersz'BaseApplicationsManager.get_app_folders s I,,X66= 7<< 4=(CC 327>>(33 3(22 27<< 844 0x 8 8 0%h// /!!r' c 8 | j }|S )z)Get initial information about interpreter)r! get_summary)r# r, s r% r* z-BaseApplicationsManager._get_interpreter_info s -3355 r' c @ | j j | S )zi
Just a public proxy to internal method that blocks
any actions with interpreter
)r! r acquire_interpreter_lock)r#
it_versions r% r6 z0BaseApplicationsManager.acquire_interpreter_lock s
} 99*EEEr' )Fr )TT)-__name__
__module__ __qualname____doc__r r. r r r r& classmethodr4 r< ra rf rs staticmethodr| r r r r r r6 r r r r r r r r r r r r r
rJ r r7 r! r- r2 r* r6 rC r' r% r r ( s
L/NKHK
[
= = = - - -@ $@ @ @ @6 a a a \a5$ 5$ 5$n " " ^ \"
\
\
\
\ > > > > ! ! !B $ $ $# # #( ( (& & & 9 9 9 " " " D D D(6 6 6 $Y $Y $YL
\
^ ^ ^ ^D A A A$ C C C@ 6I I I I V" " " "$
F F F F Fr' r )-
__future__r r r r rv pwdr% ri r abcr r r clselect.clpassengerr r future.utilsr
past.builtinsr clcommonr clcommon.utilsr
r clselect.utilsr r r clselectr clselect.baseclselectr r r r selector_managerr r r r r objectr rC r' r% rK s ' & & & & & % % % % % % ' ' ' ' ' ' ' ' * * * * * * " " " " " " ! ! ! ! ! ! ; ; ; ; ; ; ; ; O O O O O O O O O O # # # # # # 2 1 1 1 1 1 : : : : : : : : 2 2 2 2 2 2 ' ' ' ' ' 'F
F F
F F
F F
F F
FnnWf = = F
F F
F F
F F
F F
Fr'