File: //usr/libexec/kcare/python/kcarectl/utils.pyo
�
�� ic @ s d d l m Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l
m
Z
d d l m Z e
r� d d l m Z m Z m Z m Z m Z m Z e d d e d e f �Z n e j d
� Z d Z e d � Z e d � Z e d
� Z e
d d d � Z d d � Z d d � Z d d � Z d � Z! d d d d � Z# d e d d � Z$ d � Z% d � Z& d � Z' d � Z( d � Z) d � Z* e! d � � Z+ d � Z, d d! � Z- d d" � Z. d# � Z/ d$ � Z0 d% � Z1 d e2 f d d& � Z3 d S(' i����( t print_functionN( t datetimei ( t constants( t Anyt Callablet Optionalt Tuplet TypeVart Uniont Tt bound.s ^(\d+[.]\d+[-]\d+)i t u t wi� c
C s< t j j | � } | r; t j j | � r; t j | � n y t j | � j } Wn t k
rj | } n Xt j d | d | d t j j
| � d d t � �P } t j | j
� | � | j | � | j � t j | j
� � | j } Wd QXt j | t j � } z t j | � Wd t j | � Xt j | | � d S( Nt modet dirt prefixt .t delete( t ost patht dirnamet existst makedirst statt st_modet Exceptiont tempfilet NamedTemporaryFilet basenamet Falset fchmodt filenot writet flusht fsynct namet opent O_RDONLYt closet rename(
t fnamet contentt
ensure_dirR
t create_modet dnameR t ft tmp_fnamet folder_fd( ( s+ /usr/libexec/kcare/python/kcarectl/utils.pyt atomic_write" s$
7
s utf-8c C sF t | � t k r | St | � t k r5 | j | � S| j | � Sd S( N( t typet ntypet btypet decodet encode( t datat encoding( ( s+ /usr/libexec/kcare/python/kcarectl/utils.pyt nstr> s
t latin1c C s( t | � t k r$ | j | � } n | S( N( R1 t utypeR5 ( R6 R7 ( ( s+ /usr/libexec/kcare/python/kcarectl/utils.pyt bstrH s c C s( t | � t k r$ | j | � } n | S( N( R1 R3 R4 ( R6 R7 ( ( s+ /usr/libexec/kcare/python/kcarectl/utils.pyt ustrO s c sI i � t j � � � � f d � � } � | _ � j | _ � | _ | S( Nc sY | t t | j � � � f } y � | SWn t k
r= n X� | | � } � | <| S( N( t tuplet sortedt itemst KeyError( t argst kwargst cache_keyt result( t cachet fn( s+ /usr/libexec/kcare/python/kcarectl/utils.pyt innerZ s
( t functoolst wrapsRE t cleart orig( RF RG ( ( RE RF s+ /usr/libexec/kcare/python/kcarectl/utils.pyt cachedV s !
c sm � d k r t j � n � d k r0 t j � n � d k rH t j � n i � � � � � � f d � } | S( Nc s" � � � � � � f d � } | S( Nc s� � } x t � � D]q } y � | | � SWn( t k
rT } � | � � sU � qU n Xt j | � t | t j d � � t j � } q Wy � | | � SWn& t k
r� } t | d � � � n Xd S( Ni t attempts(
t rangeR t timet sleept mint randomt uniformR t RETRY_MAX_DELAYt setattr( RA RB t ldelayt _t ext final_ex( t backofft check_retryt countt delayRF t state( s+ /usr/libexec/kcare/python/kcarectl/utils.pyRG v s
&( ( RF RG ( RZ R[ R\ R] R^ ( RF s+ /usr/libexec/kcare/python/kcarectl/utils.pyt decoratoru s ( t NoneR t RETRY_DELAYt RETRY_COUNTt
RETRY_BACKOFF( R[ R\ R] RZ R_ ( ( RZ R[ R\ R] R^ s+ /usr/libexec/kcare/python/kcarectl/utils.pyt retryj s c
C s t j j | � s d Sg } t j | � } | d k rL t j | | � } n xa | D]Y } t j j | | � } | | k r� | j t j | � j
| f � n | j d t � qS WxY | | D]M \ } } t j j
| � s� t j j | � r� t j | � q� t j | � q� Wd S( Nt reverse( R R R t listdirR` t fnmatcht filtert joint appendR t st_mtimet sortt Truet isfilet islinkt removet shutilt rmtree(
t directoryt exclude_patht keep_nt patternR6 R? t itemt full_pathRW t entry( ( s+ /usr/libexec/kcare/python/kcarectl/utils.pyt clean_directory� s
"$c C sp t t j j t j d � d d �t t j j t j d � d d �t j j t j � rl t j t j � n d S( Nt modulesRu i t patches( Rz R R Ri R t PATCH_CACHER t CACHE_KEY_DUMP_PATHt unlink( ( ( s+ /usr/libexec/kcare/python/kcarectl/utils.pyt clear_all_cache� s ""c C s} t j j | � } t j j | � s4 t j | � n t | d � �4 } t j | | � | j � t j | j
� � Wd QXd S( Nt wb( R R R R R R$ Rq t copyfileobjR! R" R ( t responset dstt
parent_dirR- ( ( s+ /usr/libexec/kcare/python/kcarectl/utils.pyt save_to_file� s
c C s( t j | � } | r$ | j d � p' | S( Ni ( t
VERSION_REt matcht group( t versionR� ( ( s+ /usr/libexec/kcare/python/kcarectl/utils.pyt strip_version_timestamp� s c C sI | j d � \ } } } | s9 | j d � \ } } } n t j | d � S( NR t s %Y-%m-%d( t partitionR t strptime( t str_rawt str_datet sepRW ( ( s+ /usr/libexec/kcare/python/kcarectl/utils.pyt parse_response_date� s c G s= d d l m } d j d � t d | j � f | � D� � S( Ni ( t ipv6_supportt /c s s | ] } | j d � Vq d S( R� N( t strip( t .0t it( ( s+ /usr/libexec/kcare/python/kcarectl/utils.pys <genexpr>� s ( R R� Ri Rh R` t get_patch_server( t partsR� ( ( s+ /usr/libexec/kcare/python/kcarectl/utils.pyt get_patch_server_url� s c C s? t j j | � s d St | � � } | j � j � SWd QXd S( N( R R R R` R$ t readR� ( t filenameR- ( ( s+ /usr/libexec/kcare/python/kcarectl/utils.pyt try_to_read� s c C s
t t j � S( N( R� R R~ ( ( ( s+ /usr/libexec/kcare/python/kcarectl/utils.pyt
get_cache_key� s c C s< t j j | � s | St | | � � } | j � SWd QXd S( N( R R R R$ R� ( R( R
t defaultR- ( ( s+ /usr/libexec/kcare/python/kcarectl/utils.pyt
_read_file� s c C s t | d | � } | S( Nt r( R� ( R( R� RD ( ( s+ /usr/libexec/kcare/python/kcarectl/utils.pyt read_file� s c C s t | d | � } | S( Nt rb( R� ( R( R� RD ( ( s+ /usr/libexec/kcare/python/kcarectl/utils.pyt
read_file_bin� s c C sa i } | j � } xH | D]@ } | r | j d � \ } } } | rY | j � | | <qY q q W| S( Nt :( t
splitlinesR� R� ( R6 RD t
data_linest linet keyt delimitert value( ( s+ /usr/libexec/kcare/python/kcarectl/utils.pyt data_as_dict� s
c C s t t t j � � � S( N( t strt intRO ( ( ( s+ /usr/libexec/kcare/python/kcarectl/utils.pyt
timestamp_str� s c G s t | � d S( s a workaround to fix T201N( t print( t values( ( s+ /usr/libexec/kcare/python/kcarectl/utils.pyt
print_wrapper s c s � � � f d � } | S( Nc s+ t j � � � � � � f d � � } | S( Nc s� y � | | � SWn� � k
r� } � r� g | D] } t | � ^ q0 g | j � D] \ } } d j | | � ^ qR } � d j � j d j | � | � � n � SXd S( Ns {0}={1}s {0}({1}) failed: {2}s , ( R� R? t formatt __name__Ri ( RA RB t et at kt vt arg_list( t default_returnt errorsRF t logger( s+ /usr/libexec/kcare/python/kcarectl/utils.pyRG s N(( RH RI ( RF RG ( R� R� R� ( RF s+ /usr/libexec/kcare/python/kcarectl/utils.pyR_ s ' ( ( R� R� R� R_ ( ( R� R� R� s+ /usr/libexec/kcare/python/kcarectl/utils.pyt catch_errors s (4 t
__future__R Rg RH R RR t reRq R RO R R R R t typingR R R R R R R t compileR� t
CACHE_ENTRIESR1 R2 R3 R: R0 R8 R; R< RL R` Rd Rz R� R� R� R� R� R� R� R� R� R� R� R� R� R R� ( ( ( s+ /usr/libexec/kcare/python/kcarectl/utils.pyt <module> sN .
$