�
��ic@s�dd
lZdd
l
Z
dd
lZdd
lZddlmZ
ddlmZ
ddlm	Z	
ddl
mZ
ddlm
Z

yddlmZ
Wnek
r�


eZn
Xd�Zd	�Zd
ef
d��YZd�Zd
S(
i����N(
twraps(
tchain(
tFULL_VERSION(
t_call(
tget_messages(
tJSONDecodeErrorcCstj
jd
�
S(s�
    Check if the current process is running inside a container

    :return: True if the process is running inside a container, False otherwise
    s/run/host/container-manager(tostpathtexists(((sJ/usr/lib/python2.7/site-packages/leapp/cli/commands/upgrade/breadcrumbs.pytruns_in_containersc
sT�f
d
��g|j�D](\}
}�|
|�D]}|^q5q}t
|�
S(s3 Flatten nested dicts and lists into a single dict cs�t|
t
�rFgt|
�
j�D] \}}|d
||f^q"St|
t�r�tgt|
�
D])\}}�|d
t|�
|�^qe�S||
fg
S(Nt
.(t
isinstancetdictt
_flattenedtitemstlistR
t	enumeratetstr(tkeytvaluet
kt
vt
i(
texpand(sJ/usr/lib/python2.7/site-packages/leapp/cli/commands/upgrade/breadcrumbs.pyRs


7

@
(RR(t
dRRtitemR((
RsJ/usr/lib/python2.7/site-packages/leapp/cli/commands/upgrade/breadcrumbs.pyR
s;
t_BreadCrumbsc
BsGeZ
d�Zd
�Zd�Zd�Zd�Zd�Zd�ZRS(cCs�i|
d
6|j�d6gd6dj
gtjD]'}d|krF|ndj|�
^q.�
d6td6tjj�j�dd	6tjj�j�dd
6dd6dd
6t	�d6dd6t
d6|_dS(Ntactivitytpackagestleapp_file_changest
 s"{}"texecutedtsuccesst
Ztactivity_startedtactivity_endedtt	source_ost	target_ostenvtrun_idtversion(t
_get_packagestjointsystargvtformattTruetdatetimetutcnowt	isoformatRRt_crumbs(tselfRR((sJ/usr/lib/python2.7/site-packages/leapp/cli/commands/upgrade/breadcrumbs.pyt__init__(s





A








c

Cst|j
d
<dS(NR (tFalseR3(
R4((sJ/usr/lib/python2.7/site-packages/leapp/cli/commands/upgrade/breadcrumbs.pytfail8s
cCs�tj
jd
�
sdtj
jd�
s(dSytjd
�

Wqdtk
r`
}
|jdkraqaqdXnyttdd��U}tj	t
i
g|
D]$}|jdd�d
kr�|^q�d
6�
|dd�

WdQX|j�
Wntk
r�


n
XdS(Ns/etc/rhsm/factss	/etc/rhsmis/etc/rhsm/facts/leapp.factst
wRR$t
preupgradetupgradetleapptindenti(R9R:(
RRtisdirRtmkdirtOSErrorterrnotopentjsontdumpR
tgett_commit_rhsm_facts(R4t
activitiest
et
fR((sJ/usr/lib/python2.7/site-packages/leapp/cli/commands/upgrade/breadcrumbs.pyt_save_rhsm_facts;s"











(



c
CsWt�r
dSd
ddg}
yt
|
d�d��
Wntttfk
rR


n
XdS(Ns/usr/sbin/subscription-managertfactss--updatec
SsdS(
N(
tNone(t
xt
y((sJ/usr/lib/python2.7/site-packages/leapp/cli/commands/upgrade/breadcrumbs.pyt<lambda>Xs(R	RR?t
ValueErrort	TypeError(R4tcmd((sJ/usr/lib/python2.7/site-packages/leapp/cli/commands/upgrade/breadcrumbs.pyRESs
	




c
CsDtj
jd
d�|jd<|jdj|j��

td |jd�}
tj|
p^ig
djdi�jdd	��
jd
idd6dd6�}d
j	|�|jd<dj	|�|jd<t
j
j�j�d|jd<d�tj
j
�D�
|jd<y
tdd��

}|jd�

i
gd6}yItj|�
}t|t�r}
t|jdd�t�r}
|}q}
nWntk
r�



n
X|dj|j�

|jd�

|j�
tj||dddt�
|jd�

tj
jdd�dkr|j|d�

nWdQXWn!tk
r?


tjjd�

n
XdS(!NtLEAPP_EXECUTION_IDsN/AR(Rt	IPUConfigitmessagetdatas{}R)ttargettsources!Red Hat Enterprise Linux {target}R&s!Red Hat Enterprise Linux {source}R%R!R#c
Ss.i|]$\}
}|
jd�
r||
�qS(
tLEAPP_(
t
startswith(t.0RR((sJ/usr/lib/python2.7/site-packages/leapp/cli/commands/upgrade/breadcrumbs.pys
<dictcomp>fs	R's/etc/migration-resultssa+RFR<it	sort_keyss

tLEAPP_NO_RHSM_FACTSt
0t
1s3WARNING: Could not write to /etc/migration-results
(
RS(RtenvironRDR3textendt_verify_leapp_pkgsRRBtloadsR.R0R1R2RRAtseektloadRRRKRRtappendttruncateRCR/twriteRIR?R,tstderr(R4tmessagestversionstcrumbstdoctcontent((sJ/usr/lib/python2.7/site-packages/leapp/cli/commands/upgrade/breadcrumbs.pytsave]s:



%
)


 
 

























c
Cs�d
ddg}
t|
d�d��}|j
dd�dkr�|j
dd�r�gg|djd�
D]*}|j�rh|j�jd	d
�^qhD]"}i|dd6|d
d6^q�SngS(
Ns	/bin/bashs-csMrpm -qa --queryformat="%{nevra} %{SIGPGP:pgpsig}
" | grep -Ee "leapp|snactor"c
SsdS(
N(
RK(RLRM((sJ/usr/lib/python2.7/site-packages/leapp/cli/commands/upgrade/breadcrumbs.pyRNst	exit_codeitstdouts

Ri
tnevrat	signature(RRDRKtsplittstrip(R4RQtrestlinet
t((sJ/usr/lib/python2.7/site-packages/leapp/cli/commands/upgrade/breadcrumbs.pyR*}s





k
c
Cs
tj
jd
�
sgStj
jd
�
jd�
}
dddj|
d|
d�g}t|d�d��}|jd	d�dkr
|jd
d�r
gg|d
jd�
D]*}|j�r�|j�jdd�^q�D]"}i|dd
6|dd6^q�SngS(NtLEAPP_IPU_IN_PROGRESSttos	/bin/bashs-cs%rpm -V leapp leapp-upgrade-el{}toel{}ii
c
SsdS(
N(
RK(RLRM((sJ/usr/lib/python2.7/site-packages/leapp/cli/commands/upgrade/breadcrumbs.pyRN�sRoRps

Rtresultt	file_name(RR_RDRsR.RRKRt(R4tupg_pathRQRuRvRw((sJ/usr/lib/python2.7/site-packages/leapp/cli/commands/upgrade/breadcrumbs.pyRa�s



#




k
(	t__name__t
__module__R5R7RIRERnR*Ra(((sJ/usr/lib/python2.7/site-packages/leapp/cli/commands/upgrade/breadcrumbs.pyR's
				
	 		c
st��
�f
d
��
}
|
S(s�
    Ensures that `/etc/migration-results` gets produced on every invocation of `leapp upgrade` & `leapp preupgrade`

    Every execution of the upgrade will have their own entry in the /etc/migration-results file.
    For a user flow like: leapp preupgrade && leapp upgrade && reboot there should be 5 new entries in the file:

    1. leapp preupgrade
    2. leapp upgrade (Source OS)
    3. leapp upgrade (Initram Phase - Until including RPM transaction)
    4. leapp upgrade (Initram Phase - Post RPM Transaction)
    5. leapp upgrade (Target OS - First Boot)

    Depending on future design changes of the IPU Worklow, the output may vary.
    cs�td
�j
�
}zmy�d|||
�
SWnOtk
r`
}
|jdkrZ|j�
n�ntk
r}


|j�
�n
XWd|j�
XdS(NRtbreadcrumbsi(RR}t
SystemExittcodeR7t
BaseExceptionRn(targstkwargsRRG(
RH(sJ/usr/lib/python2.7/site-packages/leapp/cli/commands/upgrade/breadcrumbs.pytwrapper�s











(
R(RHR�((
RHsJ/usr/lib/python2.7/site-packages/leapp/cli/commands/upgrade/breadcrumbs.pytproduces_breadcrumbs�s(R0RBRR,t	functoolsRt	itertoolsR
R;Rtleapp.libraries.stdlib.callRtleapp.utils.auditRtjson.decoderRtImportErrorROR	R
tobjectRR�(((sJ/usr/lib/python2.7/site-packages/leapp/cli/commands/upgrade/breadcrumbs.pyt<module>
s 











			l