File: //lib/python2.7/site-packages/leapp/cli/commands/upgrade/util.pyc
�
��ic @ s� 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 d d l
m Z d d l m
Z
d d l m Z d d l m Z d d l m Z m Z m Z d d l m Z d d
l m Z m Z d � Z d � Z d
� Z d d � Z d � Z d d � Z! d � Z" d � Z# d � Z$ d � Z% e& d � Z' d � Z( d � Z) d � Z* d d � Z+ d S( i����N( t datetime( t
command_utils( t
get_config( t CommandError( t find_and_scan_repositories( t audit( t get_checkpointst get_connectiont get_messages( t report_unsupported( t fetch_upgrade_report_messagest generate_report_filec C s7 d � } t j j d d � s3 | t j � t _ n d S( Nc s" t j � � � f d � � } | S( Nc sa t j j d d � } z d t j d <� | | � SWd t j j d � | r\ | t j d <n Xd S( Nt LEAPP_DEVEL_DATABASE_SYNC_OFFt 1( t ost environt gett Nonet pop( t argst kwargst saved( t f( sC /usr/lib/python2.7/site-packages/leapp/cli/commands/upgrade/util.pyt wrapper s
( t functoolst wraps( R R ( ( R sC /usr/lib/python2.7/site-packages/leapp/cli/commands/upgrade/util.pyt disable_db_sync_decorator s
t LEAPP_DATABASE_FORCE_SYNC_ON( R R R R R t create_connection( R ( ( sC /usr/lib/python2.7/site-packages/leapp/cli/commands/upgrade/util.pyt disable_database_sync s
c C sy t d
| � } t j | p! i g d j d i � j d d � � j d i � } x# | D] } | d t j | d <qV Wd S( sL
Restores leapp environment variables from the `IPUConfig` message.
t IPUConfigi t messaget datas {}t leapp_env_varst valuet nameN( R ( R t jsont loadsR R R ( t contextt messagesR! t entry( ( sC /usr/lib/python2.7/site-packages/leapp/cli/commands/upgrade/util.pyt restore_leapp_env_vars& s @
c
C s9 t � } t j j | j d d � � sC t j | j d d � � n g | j d d � j d � D]T } t j j t j j | j d d � | � � r_ t j j | j d d � | � ^ q_ } t j j | j d d � � s� t j | j d d � � n | r5t j j | j d d � � r3| j | j d d � � n t
j � j d � } t j j | j d d � d j
| � � } t j | d � �� } xh | D]` } | j | � t j j | � r�t j | d
t �n y t j | � Wq�t k
r�q�Xq�Wt j j | j d d � � r,| j | j d d � � n Wd
QXn d
S( s0 Archive log files from a previous run of Leapp t files_to_archivet dirt filest ,t archivet debugs %Y%m%d%H%M%Ss leapp-{}-logs.tar.gzs w:gzt
ignore_errorst databaset pathN( R R R2 t isdirR t makedirst splitt isfilet joint appendR t nowt strftimet formatt tarfilet opent addt shutilt rmtreet Truet removet OSError( t cfgR R* R9 t archive_filet tart file_to_add( ( sC /usr/lib/python2.7/site-packages/leapp/cli/commands/upgrade/util.pyt archive_logfiles0 s0 T *
c C s= t � j d | � r- t � j d | � } n t | d | �S( Nt repositoriest manager( R t
has_optionR R ( R# t repo_pathRJ ( ( sC /usr/lib/python2.7/site-packages/leapp/cli/commands/upgrade/util.pyt load_repositories_fromS s c C s# t d d d d �} | j � | S( NRL s /etc/leapp/repo.d/RJ ( RM R t load( RJ ( ( sC /usr/lib/python2.7/site-packages/leapp/cli/commands/upgrade/util.pyt load_repositoriesY s
c C sy t d � �a } | r- | j d | f � } n | j d � } | j � } | ri | d t j | d � f SWd QXd i f S( s0
:return: Context of the last execution
sE SELECT context, stamp, configuration FROM execution WHERE context = ?sc SELECT context, stamp, configuration FROM execution WHERE kind = 'upgrade' ORDER BY id DESC LIMIT 1i i N( R R t executet fetchoneR$ R% ( t use_contextt dbt cursort row( ( sC /usr/lib/python2.7/site-packages/leapp/cli/commands/upgrade/util.pyt fetch_last_upgrade_context_ s !c C s> t d � �, } | j d � } | j � } | r4 | SWd QXd S( s1
:return: All upgrade execution contexts
s[ SELECT context, stamp, configuration FROM execution WHERE kind = 'upgrade' ORDER BY id DESCN( R R RP t fetchall( RS RT RU ( ( sC /usr/lib/python2.7/site-packages/leapp/cli/commands/upgrade/util.pyt fetch_all_upgrade_contextsp s
c C s% t d | � } | r! | d d Sd S( NR& i����t phase( R R ( R& t checkpoints( ( sC /usr/lib/python2.7/site-packages/leapp/cli/commands/upgrade/util.pyt get_last_phase} s c C s. t j | d � d k p- | j | d � d k S( sg
Checks whether the given environment variable or the given configuration value are set to '1'
t 0R
( R t getenvR ( t env_vart conf_vart
configuration( ( sC /usr/lib/python2.7/site-packages/leapp/cli/commands/upgrade/util.pyt check_env_and_conf� s c C s� t � } g d d g D]0 } t j j | j d d � d j | � � ^ q \ } } t | � } t | | | | � t | | | | � d S( sQ
Generates all report files for specific leapp run (txt and json format)
t txtR$ t reportR+ s leapp-report.{}N( R R R2 R7 R R; R
R ( R& t
report_schemaRD R t
report_txtt report_jsonR' ( ( sC /usr/lib/python2.7/site-packages/leapp/cli/commands/upgrade/util.pyt generate_report_files� s F c C s� g } xs | j | d � j d � D]V } t j j | j | d � | � } | sh | r" t j j | � r" | j | � q" q" W| S( s6
Provide files from particular config section
R, R- R+ ( R R5 R R2 R7 R6 R8 ( t sectionRD t
must_existR, t file_t file_path( ( sC /usr/lib/python2.7/site-packages/leapp/cli/commands/upgrade/util.pyt
get_cfg_files� s "! c sO t j � � j d d � d k rK � f d � � D� } t | | d � n d S( Nt LEAPP_UNSUPPORTEDR\ R
c s, i | ]" } | j d � r � | | � q S( t LEAPP_DEVEL_( t
startswith( t .0t k( t env( sC /usr/lib/python2.7/site-packages/leapp/cli/commands/upgrade/util.pys
<dictcomp>� s t whitelist_experimental( R R R R ( R` t
devel_vars( ( Rr sC /usr/lib/python2.7/site-packages/leapp/cli/commands/upgrade/util.pyt warn_if_unsupported� s c C sq | j r d n t j d d � t j d <t j d d k sD | j rT d t j d <n t j d d � t j d <d S( sE
Set environment variables following command line arguments.
R
t LEAPP_DEBUGR\ t
LEAPP_VERBOSEN( R/ R R] R t verbose( R ( ( sC /usr/lib/python2.7/site-packages/leapp/cli/commands/upgrade/util.pyt handle_output_level� s ( c C s� | j rP t t j g | j D] } | j d � ^ q � � | _ d t j d <n
d t j d <t j d d � d k r{ d n d t j d <| j r� d t j d <nS t j j
d � s� d t j d <n1 t j d � d k r� t j d d � t j d <n | j r
d t j d <n | j r2d j
| j � t j d
<n t j j d d � d k sV| j rfd t j d <n | j r�| j t j d <n d t j k r�d
t j d <n | j r�| j t j d <n t j j d � } | r�t j j | � t j d <n | j r
d t j d <n t j | � \ } } | t j d <| t j d <t j d � } d j d t j | � d t j | � � t j d <i t j d d � d 6t j d d � d 6| j p�d d 6d � t j D� d 6t j d 6} | S( sQ Returns a configuration dict object while setting a few env vars as a side-effectR- R
t LEAPP_EXPERIMENTALR\ Rm t
LEAPP_NO_RHSMs /usr/sbin/subscription-managert LEAPP_DEVEL_SKIP_RHSMt LEAPP_NO_INSIGHTS_REGISTERt LEAPP_ENABLE_REPOSt LEAPP_NO_RHSM_FACTSt LEAPP_TARGET_PRODUCT_CHANNELt gat LEAPP_TARGET_ISOt LEAPP_NOGPGCHECKt! LEAPP_UPGRADE_PATH_TARGET_RELEASEt LEAPP_UPGRADE_PATH_FLAVOURs /etc/os-releases {source}to{target}t sourcet targett LEAPP_IPU_IN_PROGRESSRv R/ Rw Rx Rs c S s1 i | ]' } | j d � r t j | � | � q S( t LEAPP_( Ro R R] ( Rp Rr ( ( sC /usr/lib/python2.7/site-packages/leapp/cli/commands/upgrade/util.pys
<dictcomp>� s t environmentt cmd( ( Rs t listt itertoolst chainR5 R R R] t no_rhsmR2 t existst no_insights_registert
enablerepoR7 R t
no_rhsm_factst channelt isot abspatht
nogpgcheckR t vet_upgrade_patht get_os_release_version_idR; t get_major_versiont syst argv( R t it target_iso_patht target_versiont flavort current_versionR` ( ( sC /usr/lib/python2.7/site-packages/leapp/cli/commands/upgrade/util.pyt prepare_configuration� sT 7
+ $
c C sw xp | j d d � D]\ } | j | � } | r> | j | � q d j | � } | rc | j | � n t | � � q Wd S( NRs s No such Actor: {}( ( R t lookup_actort whitelist_experimental_actorR; t errorR ( RI t workflowR` t loggert
actor_namet actort msg( ( sC /usr/lib/python2.7/site-packages/leapp/cli/commands/upgrade/util.pyt process_whitelist_experimental� s (, R R� R$ R R? R� R< R t leapp.cli.commandsR t leapp.cli.commands.configR t leapp.exceptionsR t leapp.repository.scanR t leapp.utilsR t leapp.utils.auditR R R t leapp.utils.outputR t leapp.utils.reportR
R R R) RH R RM RO RV RX R[ Ra Rg RA Rl Ru Ry R� R� ( ( ( sC /usr/lib/python2.7/site-packages/leapp/cli/commands/upgrade/util.pyt <module> s<
#
<