File: //etc/leapp/repos.d/system_upgrade/common/libraries/utils.pyo
�
��ic @ s" 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 d d l m Z m
Z
m Z m Z m
Z
d d l m Z d e d � Z d e d � Z e d d
d d � d d
� � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d d � Z d d � Z d S( i����N( t StopActorExecutionError( t mounting( t apit CalledProcessErrort configt runt STDOUT( t
deprecatedc C s� t j r$ t j j j d | � } n t j j j � } | rw t j rw t | t j � rg | j | � q� | j | � nN | r� d d l m
} t | t j � r� | j | | � � q� | j | � n | S( s
Applies a workaround to parse a config file using py3 AND py2
ConfigParser has a new def to read strings/files in Py3, making
the old ones (Py2) obsoletes, these function was created to use the
ConfigParser on Py2 and Py3
:type cfg: str
:type strict: bool
t stricti����( t StringIO( t sixt PY3t movest configparsert ConfigParsert
isinstancet string_typest read_stringt read_filet cStringIOR t readfp( t cfgR t parserR ( ( sQ /usr/share/leapp-repository/repositories/system_upgrade/common/libraries/utils.pyt parse_config
s i� c C s t j d | d | d | � d S( Nt patht modet exists_ok( R t _makedirs( R R R ( ( sQ /usr/share/leapp-repository/repositories/system_upgrade/common/libraries/utils.pyt makedirs. s t sinces
2022-02-03t messages� The "apply_yum_workaround" function has been deprecated, use "DNFWorkaround" message as used in the successive "RegisterYumAdjustment" actor.c C s� t j d � } | s0 t d d d t � � � n d d | g } y) | pW t j d d � } | j | � Wna t k
r� } t d d j t | � � � � n1 t
k
r� } t d d
j t | � � � � n Xd S( sY
Applies a workaround on the system to allow the upgrade to succeed for yum/dnf.
t handleyumconfigR s( Failed to find mandatory script to applyt detailss /bin/bashs -ct base_dirt /s= Failed to execute script to apply yum adjustment. Message: {}s+ Failed to apply yum adjustment. Message: {}N( R t
get_tool_pathR t reinstall_leapp_repository_hintR t NotIsolatedActionst callt OSErrort formatt strR ( t contextt yum_script_patht cmdt e( ( sQ /usr/share/leapp-repository/repositories/system_upgrade/common/libraries/utils.pyt apply_yum_workaround2 s c C s� | \ } } | t k r) t j � r) d S| t k r> t j n t j } t j d k rr t j | j � | g � n
| j
| � d S( s[
Custom log handler to always show stdout to console and stderr only in DEBUG mode
Ni i ( i i ( R R t is_debugt syst stdoutt stderrt version_infot ost writevt filenot write( t fd_infot buft _unusedt fd_typet target( ( sQ /usr/share/leapp-repository/repositories/system_upgrade/common/libraries/utils.pyt logging_handlerP s c C s i d d 6S( s�
Convenience function for creating a detail for StopActorExecutionError with a hint to reinstall the
leapp-repository package
s0 Try to reinstall the `leapp-repository` package.t hint( ( ( ( sQ /usr/share/leapp-repository/repositories/system_upgrade/common/libraries/utils.pyR$ ^ s c C st t j d k r? t j � j d | j | | d j | d � n1 t j � j d | j | t | � j t | � � d S( sQ
Helper function for shutil.rmtree to only report errors but don't fail.
i i sT While trying to remove directories: %s failed at %s with an exception %s message: %si i N( i i ( R0 R3 R t current_loggert warningt __name__t typeR) ( t funcR t exc_info( ( sQ /usr/share/leapp-repository/repositories/system_upgrade/common/libraries/utils.pyt% report_and_ignore_shutil_rmtree_errorh s ! c C s� y t | � Wnu t k
r� } | rX t d t | � d i d j | d � d 6� � n t d d j d j | � t | � � � � n Xd S( sH
Perform run with already handled OSError for some convenience.
R R s2 Please ensure that {} is installed and executable.i R> s% Failed to execute command {} with: {}t N( R R' R R) R( t join( R, R- ( ( sQ /usr/share/leapp-repository/repositories/system_upgrade/common/libraries/utils.pyt call_with_oserror_handledy s c C s_ y t | � WnJ t k
rZ } t d d j d j | � t | � � d i | | 6� � n Xd S( s�
Perform `run` which handles OSError through call_with_oserror_handled and transforms CalledProcessError to a
StopActorExecutionError with a hint given by the caller.
R s) Failed to execute command `{}`. Error: {}t R N( RH R R R( RG R) ( R, R> R- ( ( sQ /usr/share/leapp-repository/repositories/system_upgrade/common/libraries/utils.pyt call_with_failure_hint� s !c s � f d � } | S( s�
Decorator to handle any exception going through and running cleanup tasks through the given cleanup_function
parameter.
c s% t j � � � � f d � � } | S( Nc s} y � | | � SWne t k
rx t j � j d � y � | | � Wn* t k
rq t j � j d d t �n X� n Xd S( Ns; Clean guard caught an exception - Calling cleanup function.s1 Caught and swallowed an exception during cleanup.RD ( t ExceptionR R? t debugR@ t True( t argst kwargs( t cleanup_functiont f( sQ /usr/share/leapp-repository/repositories/system_upgrade/common/libraries/utils.pyt wrapper� s
( t functoolst wraps( RQ RR ( RP ( RQ sQ /usr/share/leapp-repository/repositories/system_upgrade/common/libraries/utils.pyt
clean_wrapper� s !( ( RP RU ( ( RP sQ /usr/share/leapp-repository/repositories/system_upgrade/common/libraries/utils.pyt clean_guard� s c C s& t | d � � } | j � SWd QXd S( sQ
Reads the file specified by path in text mode and returns the contents.
t rN( t opent read( R RQ ( ( sQ /usr/share/leapp-repository/repositories/system_upgrade/common/libraries/utils.pyR � s c C s� d � } | s | } n t j | � } t | d � } | sd d } | j d | j � } | | � n t | d � } | r� d } | j d | j � } | | � n | S( sa
Consume and return exactly one message of the given type, error if there are none or more than one available.
Calls ``error_callback`` if there are none or more than one messages available of the requested type
with a string describing the error condition.
Note: this function is private, experimental and will likely be subject to change.
:param model_class: Message type to consume
:param Callable[[str], None] error_callback: Callback to call when error condition arises, e.g., raising the
StopActorExecutionError (default).
c S s t | � � d S( N( R ( t msg( ( sQ /usr/share/leapp-repository/repositories/system_upgrade/common/libraries/utils.pyt default_callback� s sO Exactly one {cls_name} message of type is required, however, none was received.t cls_namesZ Exactly one {cls_name} message is required, however, more than one messages were received.N( R t consumet nextt NoneR( RA ( t model_classt error_callbackR[ t model_instancest model_instanceRZ t
next_instance( ( sQ /usr/share/leapp-repository/repositories/system_upgrade/common/libraries/utils.pyt$ _require_exactly_one_message_of_type� s
c C sh d � } | s | } n t j | � } t | d � } | sd d } | j d | j � } | | � n | S( s<
Consume and return one message of the given type, error if there are no messages available.
Calls ``error_callback`` if there are no messages available of the requested type
with a string describing the error condition.
Note: this function is private, experimental and will likely be subject to change.
:param model_class: Message type to consume
:param Callable[[str], None] error_callback: Callback to call when error condition arises, e.g., raising the
StopActorExecutionError (default).
c S s t | � � d S( N( R ( RZ ( ( sQ /usr/share/leapp-repository/repositories/system_upgrade/common/libraries/utils.pyR[ � s sO Exactly one {cls_name} message of type is required, however, none was received.R\ N( R R] R^ R_ R( RA ( R` Ra R[ Rb Rc RZ ( ( sQ /usr/share/leapp-repository/repositories/system_upgrade/common/libraries/utils.pyt _require_some_message_of_type� s
( RS R4 R0 R
t leapp.exceptionsR t leapp.libraries.commonR t leapp.libraries.stdlibR R R R R t leapp.utils.deprecationR R_ RM R R R. R= R$ RE RH RJ RV R Re Rf ( ( ( sQ /usr/share/leapp-repository/repositories/system_upgrade/common/libraries/utils.pyt <module> s* (!
#