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.1.2-5.1 ▾
|
python3-tvault-contego-el9
/
usr
/
lib
/
python3.9
/
site-packages
/
contego
/
__pycache__
/
utils.cpython-39.pyc
|
|---|
a
«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 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 dgZ d d
gZ!d d gZ"i Z#i Z$e"D ]Z%g e#e%< e!D ]0Z&e 'e&d
e%i ej(ej)B ¡Z*e#e% +e*¡ q,g e$e%< e D ]0Z&e 'e&d
e%i ej(ej)B ¡Z*e$e% +e*¡ qjq d/ddZ,dd Z-dd Z.dd Z/dd Z0dd Z1dd Z2d d Z3ej4ej4ej4d fd d!Z5d0d#d$Z6d%d& Z7G d'd( d(e8Z9d)d* Z:e j;d+d, Z<d-d. Z=dS )1é N)Úsleep)ÚProcess)Ústrutils)Úlogé z//z$(%(key)s[0-9]*\s*[=]\s*)[^\s^\'^\"]+z.(%(key)s[0-9]*\s*[=]\s*[\"\'])[^\"\']*([\"\'])z-([-]{2}%(key)s[0-9]*\s+)[^\'^\"^=^\s]+([\s]*)ÚdataÚsecretÚkeyú***c C s d| }d| d }t | tr(d | ¡} t | trtD ]H}|| ¡ v r6t| D ]}t ||| ¡} qNt | D ]}t ||| ¡} qjq6nt | t
rt | ¡ | S )Nz\g<1>z\g<2>ú )
Ú
isinstanceÚlistÚjoinÚstrÚ_SANITIZE_KEYSÚlowerÚ_SANITIZE_PATTERNS_2ÚreÚsubÚ_SANITIZE_PATTERNS_1Údictr Zmask_dict_password)Úmessager Z substitute1Z substitute2r Úpattern© r ú1/usr/lib/python3.9/site-packages/contego/utils.pyÚsanitize_message9 s
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_processJ 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_addressW s ÿþÿr2 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_valuea s z$get_lan_ip.<locals>.get_config_valueZDEFAULTZmy_ip)N)Ú ConfigParserÚreadr, Z gethostname)Z config_filer6 r5 Zipr r r Ú
get_lan_ip` s
r9 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)r= Úexcr r r Ú ensure_treep s r@ 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
rC 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: %srA r )ÚLOGÚinforB Úwriter# r )r% Z progress_msgÚprogress_tracking_filer' r r r Úupdate_progress s , rH 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 )rB Ú readlinesr# r )r% rG r' r r r Ú get_progress s , rK Fc C s t j| |||dd}|S )NF)ÚstdinÚstdoutÚstderrÚshell)Ú
subprocessÚPopen)ÚcmdrL rM rN rO r& r r r Úrun_cmd£ s
ÿrS é 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_coderN rR )
Zpollr rC rL ÚcloseÚ
returncoderD ÚerrorÚ exceptionr rN r8 r# )r& rR Z
sleep_timeZ no_of_countZ
progress_fileÚcountZ _returncoder' r r r Ú poll_process° s0
ýþÿ rZ 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 NonerR )r# )ÚlocalsÚkeysr r r r Ú
_key_checkÐ s
ÿÿz!get_cmd_specs.<locals>._key_checkÚauthorized_keyÚuserÚhostZssh)r^ r_ r` z-ozStrictHostKeyChecking=noz-iú@ZscpÚ source_pathÚ dest_path)r^ r_ r` rb rc z-rú:z/*)r4 r[ r# )
rR Úkwargsr] r^ r_ r` Zcmdspecrb rc r' r r r Ú
get_cmd_specsÏ sB
ú þø
rf c @ s e Zd Zdd ZdS )Úget_dummy_objectc K s | j |¡ d S r3 )Ú__dict__Úupdate)Úselfre r r r Ú__init__ý s zget_dummy_object.__init__N)Ú__name__Ú
__module__Ú __qualname__rk r r r r rg ü s rg c C s
| d¡S )Nz%Y-%m-%dT%H:%M:%S.%f)Ústrftime)Zatr r r Ústrtime s rp 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Úrmtreer; rD rW Z_LE)re ZargdictZtmpdirÚer r r rt s
(ýrt 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.
ú'ú"rd 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
)rT r N)>r! r r< r, r- r/ rP r Útimer Zmultiprocessingr Ú
contextlibru rv r7 Ú ImportErrorZ configparserZ
oslo_utilsr Zoslo_logr ZloggingZnova.openstack.commonZ contego.confZcontegoZ getLoggerrl rD Zconfrs Z
URL_PREFIXZ_FORMAT_PATTERNS_1Z_FORMAT_PATTERNS_2r r r r r ÚcompileÚDOTALLÚ
IGNORECASEZreg_exÚappendr r( r2 r9 r@ rC rH rK ÚPIPErS rZ rf Úobjectrg rp Úcontextmanagerrt r r r r r Ú<module> s|
ÿ
û
-