File: //lib/python3.6/site-packages/dnf/__pycache__/transaction_sr.cpython-36.pyc
3
gaf @ s d dl mZ d dl mZ d dl mZ d dlZd dlZd dlmZ d dlZ d dl
Z
d Z d Z de e f Z
G dd de jjZG d d
d
e jjZG d d d eZd
d Zdd ZG dd deZdS ) )absolute_import)print_function)unicode_literalsN)_z%s.%sc s e Zd Z fddZ ZS )TransactionErrorc s t t| j| d S )N)superr __init__)selfmsg) __class__ $/usr/lib/python3.6/transaction_sr.pyr / s zTransactionError.__init__)__name__
__module__ __qualname__r
__classcell__r r )r r
r . s r c s e Zd Z fddZ ZS )TransactionReplayErrorc sv || _ t|ttfr || _n|g| _|r:tdj|d}ntd}x | jD ]}|dt| 7 }qJW tt | j
| dS )z
:param filename: The name of the transaction file being replayed
:param errors: a list of error classes or a string with an error description
zWThe following problems occurred while replaying the transaction from file "{filename}":)filenamez<The following problems occurred while running a transaction:z
N) r
isinstancelisttupleerrorsr formatstrr r r )r r r r
error)r r r
r 4 s z TransactionReplayError.__init__)r r r r r r r )r r
r 3 s r c s e Zd Z fddZ ZS )#IncompatibleTransactionVersionErrorc s t t| j|| d S )N)r r r )r r r
)r r r
r M s z,IncompatibleTransactionVersionError.__init__)r r r r r r r )r r
r L s r c " C s | j d\}}y t|}W n8 tk
rR } z t|tdj|dW Y d d }~X nX y t| W n8 tk
r } z t|tdj|dW Y d d }~X nX |tkrt|tdj|tdd S )N.z1Invalid major version "{major}", number expected.)majorz1Invalid minor version "{minor}", number expected.)minorzPIncompatible major version "{major}", supported major version is "{major_supp}".)r Z
major_supp)splitint
ValueErrorr r r
VERSION_MAJORr )versionr r r er r r
_check_versionQ s$ $ $r% c C s dt i}g }g }g }| dkr |S x0| j D ]"}|j r`|j|j|jtjj|j |j
d q,|j r|j }|j|j
g tjj|j d}x:|j D ].}|d j|j |j tjj|j d qW |j| q,|j r,|j } |j| j g tjj| j d}
x<| j D ]0} |
d j| j
| j tjj| j d qW |j|
q,W |rb||d
< |rp||d< |r~||d < |S ) z
Serializes a transaction to a data structure that is equivalent to the stored JSON format.
:param transaction: the transaction to serialize (an instance of dnf.db.history.TransactionWrapper)
r# N)actionnevrareasonrepo_id)r& idpackages
package_typesr+ )name installed package_type)r& r* groupsr, r0 )r* r.
group_typerpms environments)VERSIONr+
is_packageappendZ action_namer' libdnf transactionZ TransactionItemReasonToStringr( Z from_repoZis_groupZ get_groupZ
getGroupIdZcompsPackageTypeToStringZgetPackageTypesZ getPackagesZgetNameZ getInstalledZgetPackageTypeZis_environmentZget_environmentZgetEnvironmentIdZ getGroupsZ getGroupType) r8 datar2 r0 r3 tsigroup
group_datapkgenvenv_datagrpr r r
serialize_transactionl sX rA c @ s e Zd ZdZd/ddZdd Zd d
Zd d Zd
d Zdd Z dd Z
dd Z dd Z dd Z
dd Zdd Zd d Zd d Zd!d" Zd#d$ Zd%d& Zd'd( Zd)d* Zd+d, Zd-d. ZdS )0TransactionReplaya
A class that encapsulates replaying a transaction. The transaction data are
loaded and stored when the class is initialized. The transaction is run by
calling the `run()` method, after the transaction is created (but before it is
performed), the `post_transaction()` method needs to be called to verify no
extra packages were pulled in and also to fix the reasons.
NFc C sv || _ || _|| _|| _|| _| j jjs.d| _t | _i | _ g | _
|rX|rXt t dn|rh| j
| n
| j| dS )a
:param base: the dnf base
:param filename: the filename to load the transaction from (conflicts with the 'data' argument)
:param data: the dictionary to load the transaction from (conflicts with the 'filename' argument)
:param ignore_extras: whether to ignore extra package pulled into the transaction
:param ignore_installed: whether to ignore installed versions of packages
:param skip_unavailable: whether to skip transaction packages that aren't available
TzKConflicting TransactionReplay arguments have been specified: filename, dataN)_base _filename_ignore_installed_ignore_extras_skip_unavailableconfstrictset _nevra_cache_nevra_reason_cache _warningsr! r _load_from_file_load_from_data)r baser r9 Z
ignore_extrasZignore_installedZskip_unavailabler r r
r s
zTransactionReplay.__init__c % C s || _ t|dN}ytj|}W n8 tjjk
rX } zt|t|d W Y d d }~X nX W d Q R X y| j| W n, t k
r } zt||W Y d d }~X nX d S )Nrr )
rE openjsonloaddecoderZJSONDecodeErrorr r rP r )r fnf replay_datar$ r r r
rO s .z!TransactionReplay._load_from_filec C s| || _ | j| j | j jdg | _| j| jtdd | j jdg | _| j| jtdd | j jdg | _| j| jtdd d S )Nr2 Zarrayr0 r3 ) _replay_data_verify_toplevel_jsonget_rpms _assert_typer _groups
_environments)r r9 r r r
rP s z!TransactionReplay._load_from_datac C s |r| j j| nt|d S )N)rN r6 r )r Z warn_onlyr
r r r
_raise_or_warn s z TransactionReplay._raise_or_warnc C s$ t ||s ttdj||dd S )Nz*Unexpected type of "{id}", {exp} expected.)r* Zexp)r r r r )r valuetr* Zexpectedr r r
r^ s
z TransactionReplay._assert_typec C sJ | j }d|kr$t|tdjdd| j|d tdd t|d | d S )Nr# zMissing key "{key}".)keystring)rE r r r r^ r r% )r rY rW r r r
r[ s
z'TransactionReplay._verify_toplevel_jsonc C sD y,|d }|d }|d }t jj|d }W nv tk
rh } z ttdj|jd dW Y d d }~X n< tk
r } z ttdj|d |d W Y d d }~X nX t j
|}|j t j gd
}t
|d krttd j|d
|d } d| j| jf }
| jjj j| j| jd} | jd k r"| jnd} | j| | j| jd}
|r`|
j|d}|r`|j|
j }
|
s| j| jtdj|d
d S |dkr| jj | |d(kr|| j |< |d)kr.|dkr| j r| jj | r| j| j tdj|
|d t j!j"| jjj#|
d}| jj$j%|| jj&j' d n|dkr|
j( }
|
sf| j| jtd j||d d S t j!j"| jjj#|
d}| jj$j%|| jj&j' d n|d*kr
|
j }
|
s| j| j td#j||d d S | j s|dkr@xX|
D ]}| jj$j)|d$d% qW n6|dkr*| jj*j+|
d | nttd&j||d'd S )+Nr& r' r) r( z%Missing object key "{key}" in an rpm.r )rd zFUnexpected value of package reason "{reason}" for rpm nevra "{nevra}".)r( r' )Zforms z)Cannot parse NEVRA for package "{nevra}".)r' z%s.%s)r- arch)epochr# release)Zreponamez Cannot find rpm nevra "{nevra}".z
Reason ChangeInstallUpgrade Downgrade ReinstallRemovedz:Package "{na}" is already installed for action "{action}".)nar& )r= )ZselectZoptionalzLPackage nevra "{nevra}" not available in repositories for action "{action}".)r' r& Upgraded
Downgraded Reinstalled Obsoletedz<Package nevra "{nevra}" not installed for action "{action}".F)Z
clean_depszFUnexpected value of package action "{action}" for rpm nevra "{nevra}".)r& r' )rj rk rl rm rn )rj rk rl )rp rq rr rn rs ),r7 r8 Z StringToTransactionItemReasonKeyErrorr r r args
IndexErrorhawkeyZSubjectZget_nevra_possibilitiesZ
FORM_NEVRAlenr- rg rD Zsackqueryfilterrh r# ri unionr. ra rH rL addrM Z_get_installonly_queryrF dnfZselectorZSelectorrK ZgoalinstallrI rJ Z availableZerasehistoryZ
set_reason)r pkg_datar& r' r) r( r$ ZsubjZ
parsed_nevrasZ parsed_nevraro Zquery_narh ry Z
query_repoZsltrr= r r r
_replay_pkg_action sz ("
$
z$TransactionReplay._replay_pkg_actionc C s2 | j jj|}|s,| j| jtd| d S | j jjj||j |j
|}yx|D ]}|d }| j |t dd |d }| j |t
dd |d } | j | t d d y|j||tjj| W qN tjjk
r }
ztt |
W Y d d }
~
X qNX qNW W n> tk
r, }
z ttd
j|
jd d W Y d d }
~
X nX |S )
Nz Group id '%s' is not available.r- zgroups.packages.namere r. zgroups.packages.installedbooleanr/ z groups.packages.package_typez.Missing object key "{key}" in groups.packages.r )rd )rD compsZ _group_by_idra rH r r r; newr- ui_namer^ r boolZ
addPackager7 r8 stringToCompsPackageTyper Errorr rt r ru ) r group_id pkg_typespkgsZ comps_group
swdb_groupr= r- r. r/ r$ r r r
_create_swdb_groupv s*
&*z$TransactionReplay._create_swdb_groupc C s* | j |||}|d k r&| jjjj| d S )N)r rD r r; r~ )r r r r r r r r
_swdb_group_install s z%TransactionReplay._swdb_group_installc C sT | j jjj|s*| j| jtd| d S | j|||}|d k rP| j jjj| d S )Nz Group id '%s' is not installed.) rD r r; r\ ra rF r r upgrade)r r r r r r r r
_swdb_group_upgrade s z%TransactionReplay._swdb_group_upgradec C sT | j jjj|s*| j| jtd| d S | j|||}|d k rP| j jjj| d S )Nz Group id '%s' is not installed.) rD r r; r\ ra rF r r downgrade)r r r r r r r r
_swdb_group_downgrade s z'TransactionReplay._swdb_group_downgradec C sT | j jjj|s*| j| jtd| d S | j|||}|d k rP| j jjj| d S )Nz Group id '%s' is not installed.) rD r r; r\ ra rF r r remove)r r r r r r r r
_swdb_group_remove s z$TransactionReplay._swdb_group_removec C sd | j jj|}|s,| j| jtd| d S | j jjj||j |j
|}yx|D ]}|d }| j |t dd |d }| j |t
dd |d } | j | t d d ytjj| } W n2 tjjk
r }
ztt |
W Y d d }
~
X nX | tjjtjjfkr ttd
j|d d |j||| qNW W n> tk
r^ }
z ttd j|
jd
dW Y d d }
~
X nX |S )Nz%Environment id '%s' is not available.r* zenvironments.groups.idre r. z environments.groups.installedr r1 z environments.groups.group_typezlInvalid value "{group_type}" of environments.groups.group_type, only "mandatory" or "optional" is supported.)r1 z2Missing object key "{key}" in environments.groups.r )rd )rD r Z_environment_by_idra rH r r r> r r- r r^ r r r7 r8 r r r r ZCompsPackageType_MANDATORYZCompsPackageType_OPTIONALr ZaddGrouprt ru ) r env_idr r0 Z comps_envswdb_envr@ r* r. r1 r$ r r r
_create_swdb_environment s8
*z*TransactionReplay._create_swdb_environmentc C s* | j |||}|d k r&| jjjj| d S )N)r rD r r> r~ )r r r r0 r r r r
_swdb_environment_install s z+TransactionReplay._swdb_environment_installc C sT | j jjj|s*| j| jtd| d S | j|||}|d k rP| j jjj| d S )Nz%Environment id '%s' is not installed.) rD r r> r\ ra rF r r r )r r r r0 r r r r
_swdb_environment_upgrade s z+TransactionReplay._swdb_environment_upgradec C sT | j jjj|s*| j| jtd| d S | j|||}|d k rP| j jjj| d S )Nz%Environment id '%s' is not installed.) rD r r> r\ ra rF r r r )r r r r0 r r r r
_swdb_environment_downgrade s z-TransactionReplay._swdb_environment_downgradec C sT | j jjj|s*| j| jtd| d S | j|||}|d k rP| j jjj| d S )Nz%Environment id '%s' is not installed.) rD r r> r\ ra rF r r r )r r r r0 r r r r
_swdb_environment_remove s z*TransactionReplay._swdb_environment_removec C s | j S )z>
:returns: the loaded data of the transaction
)rZ )r r r r
get_data s zTransactionReplay.get_datac C s | j S )zW
:returns: an array of warnings gathered during the transaction replay
)rN )r r r r
get_warnings
s z TransactionReplay.get_warningsc C s | j }g }xJ| jD ]@}y| j| W q tk
rP } z|j| W Y dd}~X qX qW x| jD ]}y
|d }|d }ytjj|d }W n: tj j
k
r } z|jtt | w`W Y dd}~X nX |dkr| j |||d n|dkr| j
|||d nl|dks|d kr,| j|||d nD|d
ks@|d krT| j|||d n |jttd j||d
W q` tk
r } z&|jttdj|jd d W Y dd}~X q` tk
r } z|j| W Y dd}~X q`X q`W x| jD ]} y| d }| d }
ytjj| d }W n> tj j
k
r^ } z |jtt | wW Y dd}~X nX |dkr~| j|
|| d n|dkr| j|
|| d nl|dks|d kr| j|
|| d nD|d
ks|d kr| j|
|| d n |jttdj||
d W np tk
rN } z&|jttdj|jd d W Y dd}~X n. tk
rz } z|j| W Y dd}~X nX qW |rt||dS )z*
Replays the transaction.
Nr& r* r, rj r+ rn rk rp rl rq z@Unexpected value of group action "{action}" for group "{group}".)r& r; z&Missing object key "{key}" in a group.r )rd r0 zJUnexpected value of environment action "{action}" for environment "{env}".)r& r> z-Missing object key "{key}" in an environment.)rE r] r r r6 r_ r7 r8 r r r r r r r r r r rt ru r` r r r r r ) r rW r r r$ r< r& r r r? r r r r
run sv
*
*"zTransactionReplay.runc C s8 | j js dS g }x| j jD ] }y
|j}W n$ tk
rP } zw W Y dd}~X nX t|}|| jkr| j s|jtjj tjj
tjj fkrt dj
|d}| js|jt| n | jj| y>| j| }|jtjjtjjfkstjj||jdkr||_W q tk
r } zW Y dd}~X q X q W |r4t| j|dS )z
Sets reasons in the transaction history to values from the stored transaction.
Also serves to check whether additional packages were pulled in by the
transaction, which results in an error (unless ignore_extras is True).
NzgPackage nevra "{nevra}", which is not present in the transaction file, was pulled into the transaction.)r' r )rD r8 r= rt r rL rF r& r7 Z TransactionItemAction_UPGRADEDZ TransactionItemAction_DOWNGRADEDZ!TransactionItemAction_REINSTALLEDr r rG r6 r rN rM Z TransactionItemAction_INSTALLZ TransactionItemAction_REMOVEZ TransactionItemReasonComparer( r rE )r r r: r= r$ r' r
Z
replay_reasonr r r
post_transactiond s<
z"TransactionReplay.post_transaction)rC NFFF)r r r __doc__r rO rP ra r^ r[ r r r r r r r r r r r r r r r r r r r
rB s4
a
(
SrB )Z
__future__r r r r7 rw Zdnf.i18nr Zdnf.exceptionsr} rT r" Z
VERSION_MINORr4
exceptionsr r r r r% rA objectrB r r r r
<module> s K