jV : d dl mZ d dl mZ d dl mZ d dlZd dlZd dlZd dlmc m c m
Z d dl Z d dl
Z
d dlmZmZ d dlmZ d dlmZmZmZmZ d dlmZmZ d d lm Z m Z d d
l m Z d d l m!Z! d d
l"m#Z# d dl"m$Z$ d dl"m%Z% d dl&m'Z' d dl(m)Z) d dl*m+Z+ d dl,m-Z- d dl.m/Z/m0Z0 d dl1m2Z2m3Z3 d dl4m5Z5 dZ6e2Z7d1dZ8d2dZ9d Z:d Z;d2d Z< d3d Z=d Z>d2d Z?d2d!Z@d2d"ZAd2d#ZBd$ZCeeDfZEd%ZF G d& d'ejG ZHd( ZI d4d)ZJd* ZKd+ ZLd5d,ZM d6d.ZNd/ ZOd0 ZPdS )7 )print_function)absolute_import)divisionN)urlsplit
urlunsplit)urljoin)ConnectTimeoutRequestExceptionTimeoutTooManyRedirects)DEFAULT_REDIRECT_LIMITREDIRECT_STATI) requote_urito_native_string) iteritems)
basestring ) clpassenger) clselectctl)utils) userdomains) mod_makedirs)ClSelectExcept)ApplicationsManager) environments interpreters)APP_STARTED_CONSTAPP_STOPPED_CONST)clprintzapp.jsFc 2 t | | }|s|}t j || | }| r|rV t j d | }n"# t
$ r t
j | w xY w| || |S )Nversion)key)
destroy_first) _get_prefixr Environmentexistsr KeyErrorr NoSuchAlternativeVersioncreate)user directoryr! env_namer# prefix environment interpreters U/opt/cloudlinux/venv/lib64/python3.11/site-packages/clselect/clselectctlnodejsuser.py_create_environmentr1 * s
y
)
)F *8T6BBK E= E C&3 BBB7KKK C C C 9'BB B C;mDDD s A A=c t | | }|Qt j | } t j | || }n%# t
$ r t
j d|z w xY w|d }t j
t j t j | }t j
|| | }|S )N8No such application (or application not configured) "%s"binary)r$ r summaryr get_using_realpath_keysr' r NoSuchApplicationospathbasenamedirnamer r% )r* r+ app_summaryr- user_summaryr4 r, r. s r0 _get_environmentr> 8 s
y
)
)F"*400 7i VVKK 2JYV
"Fw 0G0G H HIIH *8T6BBK s ? "A!c t j | | \ }}t j t
j | S N)r get_abs_relr8 r9 joinr DEFAULT_PREFIX)r* r+ _rel_dirs r0 r$ r$ L s1 "433JAw
7<< 3W = == c ddl m} | | st j || d dS )z
Check whether particular interpreter version is enabled and raises
exception if not
:param user: user to include in exception
r ) node_managerzversion is not enabledN)clselectnodejsrH NodeManageris_version_enabledr UnableToSetAlternative)r! r* rH s r0 _ensure_version_enabledrM Q s[ -,,,,, # # % % 8 8 A A ] 3D'C[\\\] ]rF c D |t }t j || \ }}| | }| D ]M}t j || \ }}|t
j z |t
j z r|c S NdS )z
Return None if new_app_directory is not nested inside an existing
user application, and the name of conflicting application otherwise
N)r r rA get_user_config_datakeysr8 sep
startswith)new_app_directoryr* apps_manager abs_app_pathrD full_config existing_appexisting_app_abs_paths r0 _get_existing_nesting_app_forrY ] s *,, '.?@@OL! 33D99K#((** #(#4T<#H#H q 26 ! - -.Cbf.L M M 4rF c
: | t } |t j d t || |t }|i }|d}t || | } | t j | t j | }t | || } |
j }
t j
| ||| j |
|||
t j | | |s2t j | }t# j | || }|d }|||t& ||g |d}|
r|
|d< | | || | | ||| dS # t, $ r0}t/ j dd t3 | d
Y d}~dS d}~ww xY w) a
Create application
:param user: unix user name
:param directory: application path in user's home (app-root)
:param alias: alias (app-uri)
:param version: version of interpreter
:param doc_root: doc_root
:param app_mode: application mode for nodejs
:param env_vars: dict with enviroment variables
:param startup_file: main application file
:param domain_name: domain name
:param apps_manager: Application Manager. Class that responsible
for gathering and writing information about applications
:param passenger_log_file: Passenger log filename to write to app's .htaccess
:return: None
Nz Not passed version as argument
production)doc_root startup_filepassenger_log_filedomain)nodejs_versionr_ app_uri
app_statusr] app_mode config_filesenv_varsr^ textERRORstatusmessage)r r WrongDatarM DEFAULT_STARTUP_FILErY BusyApplicationRootr get_aliasr1 r/ r4 r configure INTERPRETERrestartr5 r r6 DEFAULT_APP_STATEadd_app_to_configadd_env_vars_for_htaccess Exceptionr
print_diagstr)r* r+ aliasr! r\ rc re r] domain_namerT r^ conflicting_appr. r4 summary_datar< app_dataerrs r0 r) r) p s < *,, &'GHHHGT***+ 3It\RRO" 0 AAA !% ( (E%dIw??K
$
$
&
&
-F
!- i((( ,"*400 3D)\RR !(+ ! '$ H <);%&""4H===M..tY(SSSSS M M M6g#c((#K#KLLLLLLLLLMs E
F*%FFc d}t j t j | j |d }t j | r= t j | nZ# t $ r t j
dd|iz w xY wt j | rt j | t j |d }t j | st |d t j || dS # t $ r t j d|z w xY w) z
Creates symlink to app's node_modules in app_root
:param username: user name
:param environment_path: Path to app's virtual environment
:param app_root: Application root
:return: None
zCloudlinux NodeJS Selector demands to store node modules for application in separate folder (virtual environment) pointed by symlink called "node_modules". That`s why application should not contain folder/file with such name in application root node_modulesz"Can`t remove symlink %(link_name)s link_namezlib/node_modulesi zError creating symlink. N)r8 r9 rB pwdgetpwnampw_dirislinkremoveOSErrorr RemoveSymlinkErrorr& SymlinkErrorr symlinkCreateSymlinkError)usernameenvironment_pathapp_rootrj r link_tos r0 _create_symlink_to_node_modulesr sV - S\( 3 3 :HnUUI w~~i 3 u Ii u u u 34X\gir[s4stt t u " " 3 )'222gll+-?@@G
7>>' " " %We$$$V
7I&&&&& V V V /0JW0TUUUVs A0 0$BD1 1"Ec t j dk rt d |t }| | | } || | |d| n<# t $ r/}t j ddt | d Y d}~nd}~ww xY w|
d t k rt j
| j }d |d |g } t! j | n# t$ $ r Y nw xY w|+| | || }t) j | | | | t) j | | n# t0 j $ r Y nw xY wdS t5 | | } t7 j | | \ }
} t! j |
n# t$ $ r Y nw xY wt) j | } | | | }
t7 j | || n*# t> $ r |
rY dS t1 j d
|z w xY wt) j! | | t) j | | dS # t0 j $ r Y dS w xY w) aa
Destroy web app with specified directory for specified user
:param user: username
:param app_directory: application directory
:param doc_root: Document root for selected domain
:param apps_manager: Application Manager. Class that responsible
for gathering and writing information about applications
:return: None
r zOperation not permitted.Nrf rg rh rb /nodevenvr3 )"r8 geteuidPermissionErrorr get_app_configrt ru r rv rw getr r r r rB shutilrmtreer get_htaccess_by_appdirr $remove_passenger_lines_from_htaccessremove_app_from_configrq r MissingApprootDirectoryr$ r rA r5 r6 r' rk unconfigure)r*
app_directoryr\ rT
app_configr} user_home
nodevenv_pathhtaccess_filenamer- abs_dirrD r=
app_in_configs r0 destroyr s $
z||q 8999*,, ,,T=AAJM 2 24 h W W W M M M6g#c((#K#KLLLLLLLLM ~~l##'888L&&- )Z !GHH
M- ( ( ( ( D , C CD-Ya b b <=N O O O++D-@@@ m 4 4 4 4 5 D
}
-
-F"400JGQ
g
&t,,L 77mLLMw
%dM<HHHH w w w w44 *+ehu+uvv v w D-000
D-00000 1
sr A) )
B"3%B B"5D
DD E4 4FF4G
GGH I*II2 2JJc T |t }| | | }|t j d|z | d t
k rdS | | || | | |t
t j | | dS )a`
Starts web app with specified directory for specified user
:param user: username
:param app_directory: application directory
:param doc_root: Document root for selected domain
:param apps_manager: Application Manager. Class that responsible
for gathering and writing information about applications
:return: None
Nr3 rb )
r r r rk r r update_htaccess_fileset_app_statusr rq r* r r\ rT r s r0 startr E s *,, ,,T=AAJ &'adq'qrrr~~l##'888%%dM8DDD m5FGGGm,,,,,rF c |t }| | | }|t j d|z | d t
k rt
| || dS t j | | dS )ab
Restarts web app with specified directory for specified user
:param user: username
:param app_directory: application directory
:param doc_root: Document root for selected domain
:param apps_manager: Application Manager. Class that responsible
for gathering and writing information about applications
:return: None
Nr3 rb ) r r r rk r r r r rq r s r0 rq rq a s *,, ,,T=AAJ &'adq'qrrr~~l##'888
dM8,,,,,D-00000rF c ~ |t }| | | }|t j d|z | d t
k rdS | | ||| }t j | | | |t
t j
| | dS )a_
Stops web app with specified directory for specified user
:param user: username
:param app_directory: application directory
:param doc_root: Document root for selected domain
:param apps_manager: Application Manager. Class that responsible
for gathering and writing information about applications
:return: None
Nr3 rb ) r r r rk r r r r r r rq )r* r r\ rT r r s r0 stopr y s *,, ,,T=AAJ &'adq'qrrr~~l##'888$;;D-QY[eff45FGGG m5FGGGm,,,,,rF c e Zd ZdZd ZdS )
_ProbeSessionaw A session that returns a redirect response as it is.
requests reads the body of every redirect it follows, and with
allow_redirects=False still reads the body of the redirect it returns
(to prepare Response.next), whatever `stream` says. Reporting no redirect
target stops both, so the health probe follows redirects itself without
reading any body.
c d S r@ )selfresps r0 get_redirect_targetz!_ProbeSession.get_redirect_target s trF N)__name__
__module__ __qualname____doc__r r rF r0 r r s- rF r c | j d }|"| r| j t vrdS t | d d }t t | j t | }t | |j
d d S )aT The absolute URL a redirect response points to, or None.
A redirect status without a Location, or with an empty one, is the final
response, as requests treats one; so is a blank Location, which requests
would follow. The target's userinfo is dropped:
requests does not send the credentials of a redirect target either.
LocationNlatin1utf8@ )netloc)headersr strip status_coder r encoder r urlr r _replacer
rpartition)responselocationpartss r0
_redirect_urlr s ##J//H 0 0#>99t 9 96BBH WX\;x+@+@AA B BE ennEL,C,CC,H,H,KnLL M MMrF c d} ddt j j t j t
| st j d d | | }
ddit nt dfd
d } d } |f t j
|
}
|
}
n# t $ r}t |t rt |t" s |
d
d }
|
}
n%# t $ r t j | |
z w xY wY d }~nd }~ww xY w | |
|
}|
d
r|
j dk rd|
t- d
d z }pt. } || }n?# t $ r% d }r || }n# t $ r Y nw xY wY nt $ r d }Y nw xY w||j |
k r | || |d< n4 | | rd|v r% | |d st j d t3 | t4 us|dk rt j d fd}|g}d|v r| |d | t9 | D ](}|rt; j | |D ]
} || )|S )a
Check response from user's webapp before and after calling action.
Also compare both responses
:param domain: domain associated with webapp
:param alias: URI associated with webapp
:param action: called action, that make something with webapp: install modules, transit it, etc
:param request_timeout: optional per-request timeout; None preserves the
legacy unbounded health check used by ordinary Selector operations,
except for the optional baseline HTTP probe behind an HTTPS 404,
which is bounded by WEBAPP_REQUEST_TIMEOUT
:param retry_on_timeout: retry the post-action probe once after a timeout
:param strict_status: enforce real HTTP status stability and reject a
healthy application that turns 5xx; an application already
answering 5xx before the action may keep answering the same
status, or recover. Reserved for Shared Store transactions that
need rollback evidence
:param baseline: an earlier return value from this function; Shared Store
migration uses it to compare every post-restart probe with the one
pre-migration response instead of comparing a response with itself.
Its optional 'alternate' entry is the HTTP vhost that is observed
too when HTTPS answers 404 (see docs/design/nodejs-bun-delivery.md,
"Health check endpoint and healthy-response policy")
:param post_action_observations: number of post-action responses checked
against the same baseline
:param post_action_interval: delay between post-action observations
:return: the normalized pre-action response baseline
zTWeb application is inaccessible by its address "%s". The operation wasn't performed.zThe operation was performed, but check availability of application has failed. Web application is inaccessible by its address "%s" after the operation.zThe operation was performed, but check availability of application has failed. Web application responds, but its return code "%s" or content type before operation "%s" doesn't equal to contet type after operation "%s".z+Wrong action for calling in checking webappzhttps://{domain}/{alias})r_ rx z
User-AgentzjMozilla/5.0 (X11; U; Linux i686; en-US; rv:1.9.2.13) Gecko/20101209 CentOS/3.6-2.el5.centos Firefox/3.6.13Nc H ddd}|}|||d< t 5 }t dz D ]E} |j | fi |}| t | } | |c cd d d S F d d d n # 1 swxY w Y t dz )NFT)verifyr streamtimeoutr zExceeded %d redirects.)r ranger closer r ) r r kwargssession_hopr r
max_redirectsrequest_timeouts r0 r z'check_response_from_webapp..get s0 "gFF ?%G 'F9
__ $ ma /00
$
$&7;s55f55 #H--;#OO
$ $ $ $ $ $ $ $
$ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ 7- GHHHs A B9BB B c z | |j d |j |j d dS )N Content-TypeStatus)r content_typer
legacy_status)r r r )r r s r0 snapshotz,check_response_from_webapp..snapshot6 sB $ , 0 0 @ @#/ % - 1 1( ; ;
rF c t | t oPt | d t o(t | d t
u S )Nr r )
isinstancedictr r typeint)values r0 valid_snapshotz2check_response_from_webapp..valid_snapshot> sS 5$'' : uyy / /<<:=1122c9 ;rF zhttps://zhttp://i alternatez Wrong webapp health baseliner z*Wrong number of webapp health observationsc | d }| d }| d }| d } | }n# t $ r}-t |t rt j |z st j |z | }n%# t $ r t j |z w xY wY d}~n(d}~wt $ r t j |z w xY w|j d }|j }|j d } |pd }
|pd } r"d |cxk od
k nc od |cxk od
k nc } n d |cxk od
k nc od |cxk od k nc } r)d |cxk rd
k rn nd |cxk rd
k rn ndS ||k }
n*|| k r|dur|dd
dk p| duo
| dd
dk }
|
| k o-t | o t | ot | }| s|s|
sdS g }|
rJr||}}n|pd| pd}}||k r| d|z n | d|d|d |r | d|pdd|pdd t j |||fz d|dd
| dz )zBCompare one post-action response of an endpoint with its baseline.r r r r Nr r i iW i+ 500zHTTP status is "%s"zHTTP status changed from "z" to ""zcontent type changed from "z Failed check at "z": z; .)r r r r r WebAppError_WEBAPP_REQUEST_ERRORSr r lower_is_healthy_status_is_json_media_typeappendrB )endpoint
webapp_urlbefore_mime_type
before_statusbefore_legacy_statusrequestexcafter_mime_type after_statusafter_legacy_statusbefore_mime_type_normalizedafter_mime_type_normalizedrecovered_from_server_error
status_failed mime_failedreasons
status_before status_after
app_is_brokenapp_is_inaccessible_afterr r retry_on_timeout
strict_statuss r0 check_endpointz2check_response_from_webapp..check_endpoint s e_
#<<77 /
'||O < < 8c*ooGG < < < & c>22 @(41J>@ @ @#
<$0-
:< < <
< #j//)
<
<
<$0-
:< < <
< & 8 8 8 !,)J68 8
8 8 "/--n== * %o 1 1( ; ;'7'=2&D&D&F&F#&5&;%B%B%D%D" L}++++++++NC<4N4N4N4N34N4N4N4N0N
( ' }++++++++J|0J0J0J0Js0J0J0J0J
( ; m****s*****sl/I/I/I/Ic/I/I/I/I/I )\ 9MM &)<< 7)57)"1"-6: (t3 9+BQB/58
(+E E
?'
66 >+L99>,_==?
' { m F
@
K.;\|
).B0C0Ir ,
,, 4| CDDDD"/-- ? @ @ @ N NNN . 4" 4 4o6K6K6K M
N
N
N (
l,
../@/WXXX F V &'TUUU+22 3 J @G .
,
I I I I I I I I.
; ; ;
= 5jAAJc*ooGG% = = = 3((
C 1P1P
'/ $++J BBJ
= #j//)
=
=
=$0.;= = =
= = 8J00 , , I1D1K1K :c*oo.>.>#??H +D.DL
$ "s8\ : :
# # '*s8\'B'B 1 )
$
$
$ #
$ 'L,<
,J,J(0<(H(H% nX&& GX%%$nXk%:;; & &'EFFF
%&&c11'!++ &'STTT_O _O _O _O _O _O _O _O _O _OB
Ih +.///
FHHH 566 % % - J+ , , ,! % %H N8 $ $ $ $ % Osm B> >
EAE DE"D::EE F' 'G#6 GG#
G
G#GG# G#"G#c " d| cxk odk nc S )Nr i r )r s r0 r r s$ + $ $ $ $ $ $ $ $$rF c | pd dd d }|dk p)| d o| d S )zh`application/json` or `application/*+json`, case-insensitive, with
any parameters after ';' ignored.r ;r r zapplication/jsonz application/z+json)splitr r rR endswith)r
media_types r0 r r st +2$$S!,,Q/5577==??J , ,
2%%n55 1 ''003rF c t j d t j d d }t } fd|D }t | dk rt j d |d }||fS )z
Get info (alias and domain) about user's web application
:param app_summary: dict -> summary info about user's web application
:param user: str -> name of unix user
:return: tuple -> (alias, domain)
Nz3Was passed incorrect summary info about applicationz!Was passed incorrect name of userrx c R g | ]#\ }}t j |d !|$S )docroot)r realpaths_are_equal).0r_ r\ r< r* s r0
z*_get_info_about_webapp..
sJ #68u7PQUW_almvaw7x7x rF r z-Can not found suitable domain for application)r rk r r )r< r* rx user_domains
found_domains
app_domains `` r0 _get_info_about_webappr4 s &'\]]] | &'JKKK E t$$L '3 M =Q &'VWWW q!J * rF -c |t }| } t j | }n5# t $ r( t j d w xY w|d t k rd}n|d } |d }
|d } t j \ } t | i fd}
|s t |
| |
dS # t
j $ rs}
d
B
d r- d
n# t $ r Y nw xY wt j d |z d}~ww xY w |
dS )
aI
Install nodejs extension to user's webapp
:param user: name os unix user
:param directory: directory with webapp (app-root)
:param extension: name and version of extension
:param skip_web_check: skip check web application after change it's properties
:param apps_manager: Application Manager. Class that responsible
for gathering and writing information about applications
:param before_install: optionally pass the continuously held app-lock fd to npm
:param after_install: optionally finish that fd handoff after npm
:return: None
Nz%Record about application {} is absentrb Tra r_ r` c d } } | d< d}| | |d< j di |d<
t j d S )Nlock_fd) extensioncwdnpm_ranr )extension_installr rq )
r8 install_kwargs
after_installbefore_installr: r+ r. r9 handedr* s
r0 r zinstall..action5 s %$n&&G 'F9 '0== (/N9 % 9K 9 K KN K Ky $ MOOOD),,,,,rF )r_ rx r r8 r; z3An error occured during installation of modules. %s)r rO r r6 r' r rk r r rA r1 r$ r r report_unhealthy_shared_deliveryru )r* r+ r9 skip_web_checkrT r? r> user_configr| rx r3 r` rD r r} r: r. r@ s ``` `` @@@r0 installrD s# *,, 33D99Kb0y+NN b b b &'N'U'UV_'`'`aaab !222 # h'
./N
tY
/
/FC%dI~FFK
F - - - - - - - - - - - - j &!
) j j jzz)$$0VZZ 5J5J0 @@ y)+ + + + D ,-beh-hii i j sG A 2A8!C5 5E7*E2/E
E2
EE2EE22E7c l i }t t j | D ]\ }}|d t j k r t | || }|d |d |d |d d||< d|v r*t |d dk r|d || d< |S )Nr/ r_ rx name)r_ rx r. r/ domainsr )r r r5 r rp r> as_deepdictr )r* summr+ datar. s r0 r5 r5 [ s
D$[%8%>%>??
9
9 4
"5"A A A &tY==IIKK 8n']&v.&}5
Y T)_!5!5!9!9)-i DOI & KrF c t | t urt | D ]G}t | | t st d|v sd|v sd| | v s
d| | v rt
H| S )N
)r r TypeErrorr r
ValueError)re items r0 validate_env_varsrQ o s H~~T!! (4.*55 O 4<<44<<48D>+A+ATXVZ^E[E[ F\ OrF )NFr@ )NNNNNNNN)NNFFNr r )NN)r5 FNNN)Q
__future__r r r r8 r r $requests.packages.urllib3.exceptionsr r
exceptionsr r r urllib.parser r requests.compatr requests.exceptionsr r
r r requests.modelsr
r requests.utilsr r future.utilsr
past.builtinsr r r r r clcommon.cpapir clcommon.utilsr clselectexceptr clselectnodejs.apps_managerr clselectnodejsuserr r baseclselectr r
clselectprintr rl rr r1 r> r$ rM rY r) r r r rq r r rO r r Sessionr r r$ r r r4 rD r5 rQ r rF r0 rd s & % % % % % & & & & & &
@ @ @ @ @ @ @ @ @ @ @ @
- - - - - - - - # # # # # #A A A A A A A A A A A A B B B B B B B B 8 8 8 8 8 8 8 8 " " " " " " $ $ $ $ $ $ & & & & & & ' ' ' ' ' ' * * * * * * < < < < < < : : : : : : : : > > > > > > > > " " " " " " %
(> > >
] ] ] .
UM UM UM UMp V V VJU
U
U
U
p- - - -81 1 1 10- - - ->
+J7
H$ N N N$ 6:FK=A8945 g g g gT % % %3 3 3 0