�
i�B^c@`
s3dd
lm
Z

ddlmZ
ddlmZ
ddlZddlZddlZddlZddlZddl	Z	ddl
Z
ddlZddlmZ
ddl
mZmZmZmZ
ddlmZ
ddlmZ
dd	lmZmZmZ
d
dlmZ
d
dlmZ
d
Zdd�
Z dddd�Z!d�Z"d�Z#d�Z$d�Z%d�Z&d�Z'd�Z(d�Z)d�Z*d�Z+dd�
Z,dd�
Z-d�Z.d�Z/d�Z0d �Z1d!�Z2d"�Z3d#�Z4ddd$e5d%�Z6d&�Z7d'�Z8d(�Z9dd)�
Z:dS(*i(
tprint_function(
tabsolute_import(
tdivisionN(
ttime(tAnyStrtListtDicttOptional(
tresolve_username_and_doc_root(
tCP_NAME(tNoDomaintNotSupportedt
IncorrectDatai
(
tclprint(
tClSelectExcepts/sbin/cagefs_enter_usercC`
s�yOtj
|d
td�
dtjdtjdtd|
�
}|j�\}}Wn5ttfk
r�
}
t	j
|dt|�
��
n
X|jdkr�t	j
|p�dd	j|�
|f�
�
n|S(
s�
    Runs external process and returns output
    :param cmd: command and arguments as a list
    :param env_data
    :return string
    tstdins	/dev/nulltstdouttstderrt	close_fdstenvisoutput of the command: %s
%st
 (t
subprocesstPopentopentPIPEtSTDOUTtTruetcommunicatetOSErrortIOErrorRtFileProcessErrortstrt
returncodetExternalProgramFailedtjoin(tcmdtenv_datatoutputtstd_outtstd_errt
e((s?/opt/alt/python27/lib/python2.7/site-packages/clselect/utils.pytrun_command"s



	
	

	


 



cC`
s�y[tj
|d
td�
dtjdtjd|dtd|d|
�
}|j�\}}Wn5ttfk
r�
}
tj	|d	t
|�
��
n
X|j||fS(
s�

    Runs external process and returns output.
    Differs from subprocess.check_output, run_command above, and check_output below in that it does not
     throw an exception if process's return code != 0
    :param cmd: command and arguments as a list
    :param env_data
    :param preexec_fn: Pre-exec function. None if don't need
    :param cwd: Directory name to set as current
    :return Cortege: (ret_code, stdout, stderr)
    Rs	/dev/nullRRt
preexec_fnRtcwdRi(RRRRRRRRRRRR (R#R$R*R+tprocessR&R'R(((s?/opt/alt/python27/lib/python2.7/site-packages/clselect/utils.pytrun_command_full:s



	
	



	


 
c
C`
sJd
}
y&t|�
}|j
�}
|j�
Wnttfk
rE


n
X|
S(s8
    Reads file contents and returns it as a string
    t(RtreadtcloseRR(tfilenametdefaults_contentst
f((s?/opt/alt/python27/lib/python2.7/site-packages/clselect/utils.pytread_file_as_stringUs






cO`
st||
�
dS(
N(
tcheck_output(targstkwargs((s?/opt/alt/python27/lib/python2.7/site-packages/clselect/utils.pyt
check_callcs
c
O`
s8
|
jd
d�}|
jd�
}|
jdd�}|
jdd�}|r_||7}|
d=ny+tjd|dtjdtj|
�}Wn5ttfk
r�
}
tj	|dt
|�
��
n
X|j�\}}	|r�|j|�

|j
�
n|dk	r

|j�
n|jr4
tj|p+
|	p+
|�
�
n|S(	sv

    check_output(val1, val2, val3, arg4=val4)
    equivalent
    check_output(args=(val1, val2, val3), arg4=val4)
    or equivalent
    check_output(val1, args=(val2, val3), arg4=val4)
    DON'T USE check_output((val1, val2, val3), arg4=val4)
    :param tuple *args: arguments for command line
    :param dict **kwargs: parameters for subprocess.Popen
    :return str:
    terrorR6R%twaitRRiN(tpoptNonetgetRRRRRRRRRtwriteR0R:R R!(
R6R7R9targs_from_kwargsR%R:t
pR(RR((s?/opt/alt/python27/lib/python2.7/site-packages/clselect/utils.pyR5gs*












 









	

c
C`
sAgtj
|�
D]-}
tjjtjj||
��
r|
^qS(
N(tostlistdirtpathtisdirR"(RCt
d((s?/opt/alt/python27/lib/python2.7/site-packages/clselect/utils.pyt	list_dirs�s

cc`
sa|V
xU|
D]M\}}|t|�
V
x/|D]'}|d
j
tt||f��
V
q.WqWdS(Nt
.(RR"tmap(RCtversionstmajortminorstminor((s?/opt/alt/python27/lib/python2.7/site-packages/clselect/utils.pyt
versioning�s






c
C`
sUytj
|�

Wn=tk
rP
}

|
jtjkrJtjj|�
rJqQ�n
XdS(
N(RAtmakedirsRterrnotEEXISTRCRD(RCtexc((s?/opt/alt/python27/lib/python2.7/site-packages/clselect/utils.pytmkdir_p�s



$
cC`
s�tj
jtj|�
j�
}tj
jtj
j||
��
}t||�d
jtj	�
}t
||f�
s�tjd|
|f�
�
n||fS(s�
    Returns absolute and relative to user's home directories paths,
    after eliminating all symlinks
    :param user: Unix user whose home contains the directory
    :param directory: The directory to obtain absolute and relative paths for
    is&Directory '%s' not in user home ('%s')(
RARCtrealpathtpwdtgetpwnamtpw_dirR"ts_partitiontlstriptseptallRt	WrongData(tusert	directorytuser_dirtabs_dirtrel_dir((s?/opt/alt/python27/lib/python2.7/site-packages/clselect/utils.pytget_abs_rel�s
!




cC`
stj
jd
�
S(Ns/var/.cagefs(RARCRD(((s?/opt/alt/python27/lib/python2.7/site-packages/clselect/utils.pyt	in_cagefs�s
c
C`
s4d
}
t
|�
}z|j�}
Wd
|j�
X|
S(sE
    read litle file and close
    :param path:
    :return str:
    N(R<RR/R0(RCtdatatstream((s?/opt/alt/python27/lib/python2.7/site-packages/clselect/utils.pyt	file_read�s



c
C`
s4g}
t|�
}z|j
�}
Wd
|j�
X|
S(sE
    read litle file and close
    :param path:
    :return str:
    N(Rt	readlinesR0(RCRcRd((s?/opt/alt/python27/lib/python2.7/site-packages/clselect/utils.pytfile_readlines�s



t
wcC`
s2t||�}z|j
|
�

Wd
|j�
Xd
S(sN
    write litle data to file and close
    :param path:
    :return str:
    N(RR>R0(RCtlinetmodeRd((s?/opt/alt/python27/lib/python2.7/site-packages/clselect/utils.pyt
file_write�s

cC`
s2t||�}z|j
|
�

Wd
|j�
Xd
S(sN
    write litle data to file and close
    :param path:
    :return str:
    N(Rt
writelinesR0(RCtlinesRjRd((s?/opt/alt/python27/lib/python2.7/site-packages/clselect/utils.pytfile_writelines�s

cC`
s�tj
d
dkr3tj
ddkr3|j|
�
S|j|
d�}t|�
dkrq|d
|
|df}n|d
ddf}|S(s�
    str.partition for all python versions
    :param s:		string to parse
    :param sep:		separator to split by
    :return:		cortege - see str.partition function for python 2.5+
    iii
iR.(tsystversion_infot	partitiontsplittlen(t
sRYts_partstret_cortege((s?/opt/alt/python27/lib/python2.7/site-packages/clselect/utils.pyRW�s&




cC`
sxyt|
d
�}Wnt
k
r'


dSXd}tj|�
}x*|D]"}|j|�
rD|d7}qDqDW|j�
|S(s"
    find regex count in file
    t
rii
N(RRR<tretcompiletsearchR0(tpatternRCR3tcountertregexRi((s?/opt/alt/python27/lib/python2.7/site-packages/clselect/utils.pytgrep
s










c
C`
sd
dlm
}

|
|�
S(s�
    Determines is user should be skipped in selectorctl work
    :param username: user name to check
    :return: True - user should be skipped, False - not
    i(
tis_admin(tclcommon.cpapiR(tusernameR((s?/opt/alt/python27/lib/python2.7/site-packages/clselect/utils.pytuser_should_be_skipped
sc
C`
s�tj
j|�
s�y0tjd
�
}
tj|d�
tj|
�

Wq�ttfk
r�
}
td|dt|�
�
t	j
d�

q�XndS(Nii�
sError: failed to createt
:i
(RARCRDtumaskRNRRtprintRRotexit(tdest_dirtumask_savedR(((s?/opt/alt/python27/lib/python2.7/site-packages/clselect/utils.pytmake_dir 
s







c

C`
sNytj
|�

Wntk
r$


n
Xtjj|�
rJtj|t�
ndS(
N(RAtunlinkRRCRDtshutiltrmtreeR(
RC((s?/opt/alt/python27/lib/python2.7/site-packages/clselect/utils.pytremove_file_or_dir+
s






cC`
s�yhtj
j|
�
rMtj|
�
|krgtj|
�

tj||
�
qgnt|
�

tj||
�
Wn?tk
r�
}
td
|
d|dt	|�
�
t
jd�

n
XdS(NsError: failed to create symlinks->R�i
(RARCtislinktreadlinkR�tsymlinkR�RR�RRoR�(tsrctdstR(((s?/opt/alt/python27/lib/python2.7/site-packages/clselect/utils.pytmake_symlink4
s










c

C`
stj
|d
ddddt�
S(Ntindentit
separatorst
,s: t	sort_keys(R�s: (tjsontdumpsR(
Rc((s?/opt/alt/python27/lib/python2.7/site-packages/clselect/utils.pytpretty_jsonB
s
ttextcC`
s

|}d
}yt
d
|d|
�\}}Wn�tk
ru


tj|idd6dj||
�d6�
tjd�

n�tk
r�


|r�q
tj|idd6dt	d6�
tjd�

nFt
k
r



tj|idd6d	|
|fd6�
tjd�

n
X||fS(s�

    Safely resolve username and doc_root by domain,
    or resolve document root by username,
    or resolve document root and username by effective uid
    :param pass_not_supported_panel: pass not supported panel for php selector
    :param msg_format: error messages' format (json or text)
    :param user: str -> name of unix user
    :param domain: str -> domain of panel user
    :return: tuple -> user, doc_root
    R\tdomaintERRORtstatuss(No domain found for user: {}, domain: {}tmessagei
s6NodeJs/Ruby/Python selector not supported for %s panels%Domain %s is not owned by the user %sN(R<RR
R
t
print_diagtformatRoR�RR	R(R\R�t
msg_formattpass_not_supported_paneltresult_usertresult_doc_root((s?/opt/alt/python27/lib/python2.7/site-packages/clselect/utils.pyt$safely_resolve_username_and_doc_rootG
s<

























cC`
sdt||
�d
}x5|D]-}t||�d
}||kr||SqWt
dj|
�
�
�
dS(s

    Transform all directories to realpath, compare and return config value
    :param user: str -> unix user - owner of the config
    :param directory: str -> wanted directory key
    :param config: dict -> config to get value from,
        should have directories as keys
    is%Config does not contain directory: {}N(RatKeyErrorR�(R\R]tconfigt
abs_directorytconf_dirtabs_conf_dir((s?/opt/alt/python27/lib/python2.7/site-packages/clselect/utils.pytget_using_realpath_keys|
s





cC`
s�t||
�d
}t
}xC|j�D]5}t||�d
}||kr&||=t}q&q&W|s}tdj|
�
�
�
ndS(s

    Transform all directories to realpath, compare and remove directory key
    :param user: str -> unix user - owner of the config
    :param directory: str -> wanted directory key
    :param config: dict -> config to remove key from,
        should have directories as keys
    is%Config does not contain directory: {}N(RatFalsetkeysRR�R�(R\R]R�R�tremoved_at_least_oneR�R�((s?/opt/alt/python27/lib/python2.7/site-packages/clselect/utils.pytdelete_using_realpath_keys�
s









cC`
s$t||
�d
t||�d
kS(s#

    Checks that two paths in user home directory are the same after
    stripping symlinks
    :param user: Unix user whose home directory contains both paths
    :type path1: str
    :type path2: str
    :return: True if paths are canonically the same otherwise False
    :rtype: bool
    i(
Ra(R\tpath1tpath2((s?/opt/alt/python27/lib/python2.7/site-packages/clselect/utils.pytrealpaths_are_equal�
s
c
C`
s�i}|si}nt||
g|}t
j|d
|dt
jdt
j�
}|j�\}}|j}	|r�|	dkr�idj|
�
d6dd6t�d	6}n|j�}||d
<|	|d<|	r�t	nt
|d<|S(
s=
    Run any process using the utility cagefs_enter_user
    RRRi�s�User's process "{}" failed and didn't return anything. It could mean that user has too small limit of PMEM for running of cloudlinux-selector. Please, increase the limit to user and try run process againtdetailsR9tresultt	timestampR%R tfailed(tCAGEFS_ENTER_USER_BINRRRRR R�RtstripRR�(
R\tpath_to_utilitytargs_for_utilitytenv_varsR�R#R,Rt
_tretcode((s?/opt/alt/python27/lib/python2.7/site-packages/clselect/utils.pytrun_process_in_cagefs�
s$
	

'

	










(;t
__future__RR
RRORARTRxRRoR�R�RttypingRRRRtclcommon.clpwdRR�R	tclcommon.cpapi.cpapiexceptionsR
RRt
clselectprintR
tclselectexceptRR�R<R)R-R4R8R5RFRMRRRaRbReRgRkRnRWR~R�R�R�R�R�R�R�R�R�R�R�(((s?/opt/alt/python27/lib/python2.7/site-packages/clselect/utils.pyt<module>sX










"


			#			
				

								5