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:
6.0.24-6.0 ▾
|
python3-tvault-contego-el9
/
usr
/
lib
/
python3.9
/
site-packages
/
contego
/
__pycache__
/
utils.cpython-39.pyc
|
|---|
a
Jrg$ ã @ s¸ d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlm Z d dl
m Z d dl m
Z
d dlZd dlZd dlZz d dlZW n eyª d dlZY n0 d dlmZ zd dlmZ W n eyæ ddlmZ Y n0 d dlZe e ¡Z ej j Z dZ!d Z"g d
¢Z#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%e0Z1d&d' Z2ej3d(d) Z4d*d+ Z5d,d- Z6dS )0é N)Úsleep)ÚProcess)Ú processutils)Ústrutils)Úlogé z//i )ÚdataÚsecretz -passwordú***c C s t tj t t¡t tksDtj t¡ dg}tD ] }g tj|< g tj|< ttdrg tj|< tj D ]0}t
|d|i t
j t
j
B ¡}tj| |¡ qhtjD ]0}t
|d|i t
j t
j
B ¡}tj| |¡ q tjD ]0}t
|d|i t
j t
j
B ¡}tj| |¡ qØ|D ]2}t
|d|i t
j t
j
B ¡}tj| |¡ qq4t| ts\t| trfd | ¡} t| tr|t | ¡} t| trt | ¡} | 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 ú1/usr/lib/python3.9/site-packages/contego/utils.pyÚsanitize_message) s6
r" c
G sb z4t | |d}| ¡ | ¡ r2td t |d ¡ W n( ty\ } z|W Y d }~n
d }~0 0 d S )N)ÚtargetÚargsé
)r ÚstartÚis_aliver ÚosÚutimeÚ Exception)ÚmethodÚprogress_tracking_file_pathr$ ÚprocessÚexr r r! Ú run_processK s r/ c C s@ t t jt j¡}t t | ¡ dt d| d d
¡¡dd
¡S )Ni Z256sé é é ) ÚsocketZAF_INETZ
SOCK_DGRAMZ inet_ntoaÚfcntlZioctlÚfilenoÚstructÚpack)ZifnameÚsr r r! Úget_ip_addressX s ÿþÿr9 c C s< ddd}t ¡ }| | ¡ ||dd}|d ur4|S t ¡ S )Nc S s" | ||¡r| |||¡S d S d S ©N)Z
has_optionÚget)ÚcfgZSectionZOptionZKeyr r r! Úget_config_valueb s z$get_lan_ip.<locals>.get_config_valueZDEFAULTZmy_ip)N)Ú ConfigParserÚreadr3 Z gethostname)Z config_filer= r< Zipr r r! Ú
get_lan_ipa s
r@ c
C sV zt | ¡ W nB tyP } z*|jtjkr:t j | ¡s< n W Y d}~n
d}~0 0 dS )zeCreate a directory (and any ancestor directories required)
:param path: Directory to create
N)r( ÚmakedirsÚOSErrorÚerrnoZEEXISTÚpathÚisdir)rD Úexcr r r! Ú ensure_treeq s rG c C s: t | d t | d¡ W d n1 s,0 Y 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
rJ c C s° t d| |f ¡ z8t| d}| |¡ W d n1 s>0 Y W n` tyª } zHtd t| d}| |¡ W d n1 s0 Y W Y d }~n
d }~0 0 d S )Nzupdate_progress %s: %srH r% )ÚLOGÚinforI Úwriter* r )r, Z progress_msgÚprogress_tracking_filer. r r r! Úupdate_progress s , rO c C s¨ z8t | d}| ¡ W d W S 1 s,0 Y W nj ty¢ } zRtd t | d$}| ¡ W d W Y d }~S 1 s0 Y W Y d }~n
d }~0 0 d S )NÚrr% )rI Ú readlinesr* r )r, rN r. r r r! Ú get_progress s , rR Fc C s t j| |||dd}|S )NF)ÚstdinÚstdoutÚstderrÚshell)Ú
subprocessÚPopen)ÚcmdrS rT rU rV r- r r r! Úrun_cmd¤ s
ÿrZ é c
C s¼ zd}| ¡ d u rF|dkr$||kr$qFt| |d7 }|d urt| q| j ¡ | j}|rt d| ¡ t d|t | j
¡ d|d ¡ |W S t y¶ } z|W Y d }~n
d }~0 0 d S )Nr r z
Result was %sz7Execution error %(exit_code)d (%(stderr)s). cmd %(cmd)szutf-8)Z exit_coderU rY )
Zpollr rJ rS ÚcloseÚ
returncoderK ÚerrorÚ exceptionr rU r? r* )r- rY Z
sleep_timeZ no_of_countZ
progress_fileÚcountZ _returncoder. r r r! Ú poll_process± s0
ýþÿ ra c
K sê dd }z´| dd ¡}| dd ¡}| dd ¡}| dkr`|t g d¢ ddd d
||d | g}nX| d kr¸| d
d ¡}| dd ¡}|t g d¢ d dd d
|d|d | d | d |g}|W S tyä } z| W Y d } ~ n
d } ~ 0 0 d S )Nc S s. |D ]$}| | d u rt d|| d f qd S )Nz8Required parameter: %s for %s connection can not be NonerY )r* )ÚlocalsÚkeysr r r r! Ú
_key_checkÑ s
ÿÿz!get_cmd_specs.<locals>._key_checkÚauthorized_keyÚuserÚhostZssh)re rf rg z-ozStrictHostKeyChecking=noz-iú@ZscpÚ source_pathÚ dest_path)re rf rg ri rj z-rú:z/*)r; rb r* )
rY Úkwargsrd re rf rg Zcmdspecri rj r. r r r! Ú
get_cmd_specsÐ sB
ú þø
rm c @ s e Zd Zdd ZdS )Úget_dummy_objectc K s | j |¡ d S r: )Ú__dict__Úupdate)Úselfrl r r r! Ú__init__þ s zget_dummy_object.__init__N)Ú__name__Ú
__module__Ú __qualname__rr r r r r! rn ý s rn c C s
| d¡S )Nz%Y-%m-%dT%H:%M:%S.%f)Ústrftime)Zatr r r! Ústrtime s rw c k sÄ | ¡ }d|vrtj|d< tjf i |¤}zN|V W zt |¡ W qÀ tyv } z t t
d|¡ W Y d }~qÀd }~0 0 nFzt |¡ W n4 ty¼ } z t t
d|¡ W Y d }~n
d }~0 0 0 d S )NÚdirzCould not remove tmpdir: %s) ÚcopyÚCONFÚtempdirÚtempfileZmkdtempÚshutilÚrmtreerB rK r^ Z_LE)rl ZargdictZtmpdirÚer r r! r{ s
(ýr{ c
C sd z6| dd¡ d¡d }| |d
}t |¡d d W S ty^ } z| W Y d}~S d}~0 0 dS )zl
Replaces single quote with double quotes.
It Parses the Backing File and returns json.
ú'ú"rk 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 c
C sl z,| r*t ddtjd|| ¡\}}|s*W dS W n: tyf } z"t d | ||¡¡ W Y d}~dS d}~0 0 dS )z2 This utility method changes permission of device.Zsudoz
nova-rootwrapÚchmodTz+cannot change permission of {0} to {1}. {2}NF)r Zexecuterz Zrootwrap_configr* rK rL Úformat)ZdeviceZpermÚoutÚerrr. r r r! Úchange_device_permission s ú
r )r
)r[ r N)7r( r rC r3 r4 r6 rW r Útimer Zmultiprocessingr Zoslo_concurrencyr Ú
contextlibr| r} r> Ú ImportErrorZ configparserZ
oslo_utilsr Zoslo_logr ZloggingZnova.openstack.commonZ contego.confZcontegoZ getLoggerrs rK Zconfrz Z
URL_PREFIXZRWRWRWr r" r/ r9 r@ rG rJ rO rR ÚPIPErZ ra rm Úobjectrn rw Úcontextmanagerr{ r r r r r r! Ú<module> sd
"
û
-