Why Gemfury?
Push, build, and install
RubyGems
npm packages
Python packages
Maven artifacts
PHP packages
Go Modules
Debian packages
RPM packages
NuGet packages
Repository URL to install this package:
|
Version:
5.2.8-5.2 ▾
|
python3-tvault-contego
/
usr
/
lib
/
python3.6
/
site-packages
/
contego
/
__pycache__
/
utils.cpython-36.opt-1.pyc
|
|---|
3
ïq`e" ã @ s¦ d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlm Z d dl
m Z d dl Z d dl
Z
d dlZy d dlZW n ek
r d dlZY nX d dlmZ yd dlmZ W n ek
rÞ ddlmZ Y nX d dlZejeZ ej j Z dZ dd d
gZ d,d d
Z!dd Z"dd Z#dd Z$dd Z%dd Z&dd Z'dd Z(ej)ej)ej)d fd d Z*d-d d!Z+d"d# Z,G d$d% d%e-Z.d&d' Z/e j0d(d) Z1d*d+ Z2dS ).é N)Úsleep)ÚProcess)Ústrutils)Úlogé z//ÚdataÚsecretz -passwordú***c C s¬ t tjjt tt tksZtjjt dg}x&tD ] }g tj|< g tj|< ttdr¢g tj|< x:tj D ]0}t
j |d|i t
j t
j
B }tj| j| qnW x:tjD ]0}t
j |d|i t
j t
j
B }tj| j| qªW x:tjD ]0}t
j |d|i t
j t
j
B }tj| j| qæW x:|D ]2}t
j |d|i t
j t
j
B }tj| j| q W q8W t| tsrt| tr|dj| } t| trtj| } t| tr¨tj| } | S )Nz$(%(key)s[0-9]*\s*[ ]\s*)[^\s^\'^\"]+Ú_SANITIZE_PATTERNS_WILDCARDÚkeyú )Úsetr Ú_SANITIZE_KEYSÚ intersectionÚextendZ_SANITIZE_PATTERNS_1Z_SANITIZE_PATTERNS_2Úhasattrr
Z_FORMAT_PATTERNS_WILDCARDÚreÚcompileÚDOTALLÚ
IGNORECASEÚappendZ_FORMAT_PATTERNS_2Z_FORMAT_PATTERNS_1Ú
isinstanceÚlistÚtupleÚjoinÚstrZ
mask_passwordÚdictZmask_dict_password)Úmessager Z_FORMAT_PATTERNS_3r ÚpatternZreg_ex© r ú/usr/lib/python3.6/utils.pyÚsanitize_message' s6
r! c G s` y4t | |d}|j |j r2td tj|d W n& tk
rZ } z
|W Y d d }~X nX d S )N)ÚtargetÚargsé
)r ÚstartZis_aliver ÚosÚutimeÚ Exception)ÚmethodÚprogress_tracking_file_pathr# ÚprocessÚexr r r Ú run_processI s r- c C s@ t j t jt j}t jtj|j dtjd| d d
dd
S )Ni Z256sé é é ) ÚsocketZAF_INETZ
SOCK_DGRAMZ inet_ntoaÚfcntlZioctlÚfilenoÚstructÚpack)ZifnameÚsr r r Úget_ip_addressV s
r7 c C s< ddd}t j }|j| ||dd}|d k r4|S tj S )Nc S s" | j ||r| j|||S d S d S )N)Z
has_optionÚget)ÚcfgZSectionZOptionZKeyr r r Úget_config_value` s z$get_lan_ip.<locals>.get_config_valueZDEFAULTZmy_ip)N)Ú ConfigParserÚreadr1 Z gethostname)Z config_filer: r9 Zipr r r Ú
get_lan_ip_ s
r= c C sT yt j| W n@ tk
rN } z$|jtjkr<t jj| s> n W Y dd}~X nX dS )zeCreate a directory (and any ancestor directories required)
:param path: Directory to create
N)r& ÚmakedirsÚOSErrorÚerrnoZEEXISTÚpathÚisdir)rA Úexcr r r Ú ensure_treeo s rD c
C s& t | d tj| d W dQ R X dS )zy Utility to simulate the filesystem "touch" command.
Args:
file_path (str): Path to file to be touched.
ÚaN)Úopenr& r' )Z file_pathr r r Ú
touch_file~ s
rG c C s t jd| |f y$t| d}|j| W d Q R X W nJ tk
r } z.td t| d}|j| W d Q R X W Y d d }~X nX d S )Nzupdate_progress %s: %srE r$ )ÚLOGÚinforF Úwriter( r )r* Z progress_msgÚprogress_tracking_filer, r r r Úupdate_progress s rL c C sh y t | d
}|j S Q R X W nD tk
rb } z(td t | d
}|j S Q R X W Y d d }~X nX d S )NÚrr$ )rF Ú readlinesr( r )r* rK r, r r r Ú get_progress s rO Fc C s t j| |||dd}|S )NF)ÚstdinÚstdoutÚstderrÚshell)Ú
subprocessÚPopen)ÚcmdrP rQ rR rS r+ r r r Úrun_cmd¢ s rW é c C s¼ yd}xB| j d krH|dkr&||kr&P t| |d7 }|d k rt| qW | jj | j}|rtjd| tjd|t | j
j d|d |S t k
r¶ } z
|W Y d d }~X nX d S )Nr r z
Result was %sz7Execution error %(exit_code)d (%(stderr)s). cmd %(cmd)szutf-8)Z exit_coderR rV )
Zpollr rG rP ÚcloseÚ
returncoderH ÚerrorZ exceptionr rR r< r( )r+ rV Z
sleep_timeZ no_of_countZ
progress_fileÚcountZ _returncoder, r r r Ú poll_process¯ s*
r] c
K sî dd }yº|j dd }|j dd }|j dd }| dkrb|t dddg dddd ||d
| g}n^| d krÀ|j d d }|j d
d }|t dddd d
g d ddd |d|d
| d | d |g}|S tk
rè } z
| W Y d d } ~ X nX d S )Nc S s2 x,|D ]$}| | d krt d|| d f qW d S )Nz8Required parameter: %s for %s connection can not be NonerV )r( )ÚlocalsÚkeysr r r r Ú
_key_checkÏ s
z!get_cmd_specs.<locals>._key_checkÚauthorized_keyÚuserÚhostZsshz-ozStrictHostKeyChecking=noz-iú@ZscpÚ source_pathÚ dest_pathz-rú:z/*)r8 r^ r( )
rV Úkwargsr` ra rb rc Zcmdspecre rf r, r r r Ú
get_cmd_specsÎ s< ri c @ s e Zd Zdd ZdS )Úget_dummy_objectc K s | j j| d S )N)Ú__dict__Úupdate)Úselfrh r r r Ú__init__ü s zget_dummy_object.__init__N)Ú__name__Ú
__module__Ú __qualname__rn r r r r rj û s rj c C s
| j dS )Nz%Y-%m-%dT%H:%M:%S.%f)Zstrftime)Zatr r r Ústrtimeÿ s rr c k sz | j }d|krtj|d< tjf |}z
|V W d ytj| W n2 tk
rr } ztj t
d| W Y d d }~X nX X d S )NÚdirzCould not remove tmpdir: %s) ÚcopyÚCONFÚtempdirÚtempfileZmkdtempÚshutilZrmtreer? rH r[ Z_LE)rh ZargdictZtmpdirÚer r r rv s
rv c C sZ y4| j ddjdd }| |d
}tj|d d S tk
rT } z| S d}~X nX dS )zl
Replaces single quote with double quotes.
It Parses the Backing File and returns json.
ú'ú"rg r NÚfileÚfilename)ÚreplaceÚfindÚjsonÚloadsr( )Z backing_fileZjson_key_positionZbacking_file_contextr, r r r Ú"parse_encrypted_image_backing_file s r )r )rX r N)3r& r r@ r1 r2 r4 rT r Ztimer Zmultiprocessingr Ú
contextlibrw rx r; Ú ImportErrorZ configparserZ
oslo_utilsr Zoslo_logr ZloggingZnova.openstack.commonZ contego.confZcontegoZ getLoggerro rH Zconfru Z
URL_PREFIXr r! r- r7 r= rD rG rL rO ÚPIPErW r] ri Úobjectrj rr Úcontextmanagerrv r r r r r Ú<module> sZ
"
-