a
jL; @ s d dl Z d dlZd dlZd dlZd dlZd dlmZ d dlm Z d dl
m Z ddl m
Z
mZmZ G dd deZG d d
d
eZG d d d eZG d
d deZdS ) N)ucd)misc)
DatabaseError )GroupPersistorEnvironmentPersistorRPMTransactionc @ sj e Zd Zdd Zdd Zdd Zdd Zd d
Zd d Zd
d Z dd Z
dd Z dd Z dd Z
edd Zedd Zedd Zed d Zed d Zed!d" Zed#d$ Zed%d& Zejd'd& Zed(d) Zejd*d) Zed+d, Zed-d. Zed/d0 Zejd1d0 Zed2d3 Z d4d5 Z ed6d7 Z d8d9 Z ed:d; Z edd? Z"d@S )ARPMTransactionItemWrapperc C s |d us J || _ || _d S N)_swdb_item)selfswdbitem r 2/usr/lib/python3.9/site-packages/dnf/db/history.py__init__# s z"RPMTransactionItemWrapper.__init__c C s | j S r
)r ZgetItemZtoStrr
r r r __str__( s z!RPMTransactionItemWrapper.__str__c C s | j |j k S r
r r
otherr r r __lt__+ s z RPMTransactionItemWrapper.__lt__c C s | j |j kS r
r r r r r __eq__. s z RPMTransactionItemWrapper.__eq__c C s
| j S r
)r __hash__r r r r r 1 s z"RPMTransactionItemWrapper.__hash__c C s dS )NTr )r
patternr r r match4 s z RPMTransactionItemWrapper.matchc C s | j d uS r
)r
getRPMItemr r r r
is_package7 s z$RPMTransactionItemWrapper.is_packagec C s | j d uS r
r ZgetCompsGroupItemr r r r is_group: s z"RPMTransactionItemWrapper.is_groupc C s | j d uS r
r ZgetCompsEnvironmentItemr r r r is_environment= s z(RPMTransactionItemWrapper.is_environmentc C s
| j S r
r r r r r get_group@ s z#RPMTransactionItemWrapper.get_groupc C s
| j S r
r! r r r r get_environmentC s z)RPMTransactionItemWrapper.get_environmentc C s | j S r
)r r getNamer r r r nameF s z RPMTransactionItemWrapper.namec C s | j S r
)r r ZgetEpochr r r r epochJ s z RPMTransactionItemWrapper.epochc C s | j S r
)r r Z
getVersionr r r r versionN s z!RPMTransactionItemWrapper.versionc C s | j S r
)r r Z
getReleaser r r r releaseR s z!RPMTransactionItemWrapper.releasec C s | j S r
)r r ZgetArchr r r r archV s z RPMTransactionItemWrapper.archc C s* | j rd| j | j| jS d| j| jS )Nz{}:{}-{}z{}-{})r' formatr( r) r r r r evrZ s z RPMTransactionItemWrapper.evrc C s | j S r
)r r ZgetNEVRAr r r r nevra` s z RPMTransactionItemWrapper.nevrac C s
| j S r
)r Z getActionr r r r actiond s z RPMTransactionItemWrapper.actionc C s | j | d S r
)r Z setActionr
valuer r r r. h s c C s
| j S r
)r Z getReasonr r r r reasonl s z RPMTransactionItemWrapper.reasonc C s | j |S r
)r Z setReasonr/ r r r r1 p s c C s& z | j W S ty Y dS 0 d S N )r Z
getActionNameAttributeErrorr r r r action_namet s z%RPMTransactionItemWrapper.action_namec C s& z | j W S ty Y dS 0 d S r2 )r ZgetActionShortr4 r r r r action_short{ s z&RPMTransactionItemWrapper.action_shortc C s
| j S r
)r getStater r r r state s z RPMTransactionItemWrapper.statec C s | j | d S r
)r setStater/ r r r r8 s c C s
| j S r
r Z getRepoidr r r r from_repo s z#RPMTransactionItemWrapper.from_repoc C s | j sdS d| j S )Nr3 @r: r r r r ui_from_repo s
z&RPMTransactionItemWrapper.ui_from_repoc C s d S r
r r r r r
obsoleting s z$RPMTransactionItemWrapper.obsoletingc C s | j j| S r
)r rpm
get_reasonr r r r r@ s z$RPMTransactionItemWrapper.get_reasonc C s | j jj| j S r
)r r? Z _swdb_ti_pkgr r r r r pkg s z RPMTransactionItemWrapper.pkgc C s | j jS r
)rA filesr r r r rB s z RPMTransactionItemWrapper.filesc C s | j S r
)rA r r r r _active s z!RPMTransactionItemWrapper._activeN)#__name__
__module__ __qualname__r r r r r r r r r" r# r$ propertyr& r' r( r) r* r, r- r. setterr1 r5 r6 r8 r; r= r> r@ rA rB rC r r r r r " sj
r c @ s e Zd ZdZdZdd Zedd Zedd Zedd Z ed
d Z
ed d
Z edd Z edd Z
edd Zedd Zedd Zedd Zedd Zed d Zd d Zd d! Zd"d# Zd$d% Zd&d' Zd(d) Zd*S )+TransactionWrapperFc C s
|| _ d S r
)_transr
transr r r r s zTransactionWrapper.__init__c C s
| j S r
rJ ZgetIdr r r r tid s zTransactionWrapper.tidc C s
| j S r
)rJ Z
getCmdliner r r r cmdline s zTransactionWrapper.cmdlinec C s
| j S r
)rJ Z
getReleaseverr r r r
releasever s z TransactionWrapper.releaseverc C s
| j S r
)rJ Z
getDtBeginr r r r
beg_timestamp s z TransactionWrapper.beg_timestampc C s
| j S r
)rJ ZgetDtEndr r r r
end_timestamp s z TransactionWrapper.end_timestampc C s
| j S r
)rJ getRpmdbVersionBeginr r r r beg_rpmdb_version s z$TransactionWrapper.beg_rpmdb_versionc C s
| j S r
)rJ getRpmdbVersionEndr r r r end_rpmdb_version s z$TransactionWrapper.end_rpmdb_versionc C s t | j tjjkS r
)intrJ r7 libdnf transactionTransactionItemState_DONEr r r r return_code s z TransactionWrapper.return_codec C s
| j S r
)rJ Z getUserIdr r r r loginuid s zTransactionWrapper.loginuidc C s | j S r
)packagesr r r r data s zTransactionWrapper.datac C s | j }t|S r
)rJ getConsoleOutputbool)r
outputr r r is_output s
z TransactionWrapper.is_outputc C s
| j S r
)rJ Z
getCommentr r r r comment s zTransactionWrapper.commentc C s
| j S r
)rJ ZgetPersistencer r r r persistence s z TransactionWrapper.persistencec C s | j gS r
rM r r r r tids s zTransactionWrapper.tidsc C s g S r
r r r r r performed_with s z!TransactionWrapper.performed_withc s j } fdd|D S )Nc s g | ]}t |qS r )r .0ir r r
z/TransactionWrapper.packages..)rJ ZgetItems)r
resultr r r r] s
zTransactionWrapper.packagesc C s dd | j D S )Nc S s g | ] }|d qS r r rg r r r rj rk z-TransactionWrapper.output..rJ r_ r r r r ra s zTransactionWrapper.outputc C s g S r
r r r r r error s zTransactionWrapper.errorc C s | j |k| _d S r
)rJ rU altered_gt_rpmdb)r
Zrpmdbvr r r compare_rpmdbv s z!TransactionWrapper.compare_rpmdbvN)rD rE rF altered_lt_rpmdbrp r rG rN rO rP rQ rR rT rV r[ r\ r^ rb rc rd re rf r] ra ro rq r r r r rI sF
rI c @ st e Zd Zdd Zdd Zedd Zdd Zed d
Zed d Z ed
d Z
edd Z edd Z dd Z
dS )MergedTransactionWrapperc C s t j|j| _d S r
)rX rY ZMergedTransactionrJ rK r r r r s z!MergedTransactionWrapper.__init__c C s | j |j d S r
)rJ mergerK r r r rt s z MergedTransactionWrapper.mergec C s
| j S r
)rJ Z listUserIdsr r r r r\ s z!MergedTransactionWrapper.loginuidc C s
| j S r
)rJ ZlistIdsr r r r re s z MergedTransactionWrapper.tidsc C s dd | j D S )Nc S s g | ]}t |tjjkqS r )rW rX rY rZ rg r r r rj
rk z8MergedTransactionWrapper.return_code..)rJ Z
listStatesr r r r r[ s z$MergedTransactionWrapper.return_codec C s
| j S r
)rJ Z listCmdlinesr r r r rO s z MergedTransactionWrapper.cmdlinec C s
| j S r
)rJ ZlistPersistencesr r r r rd s z$MergedTransactionWrapper.persistencec C s
| j S r
)rJ ZlistReleaseversr r r r rP s z#MergedTransactionWrapper.releaseverc C s
| j S r
)rJ Z listCommentsr r r r rc s z MergedTransactionWrapper.commentc C s dd | j D S )Nc S s g | ] }|d qS rm r rg r r r rj rk z3MergedTransactionWrapper.output..rn r r r r ra s z MergedTransactionWrapper.outputN)rD rE rF r rt rG r\ re r[ rO rd rP rc ra r r r r rs s
rs c @ s e Zd Zd6ddZdd Zedd Zedd Zed
d Zed d
Z edd Z
dd Z dd Z edd Z
dd Zd7ddZd8d d Zd d! Zd"d# Zd$d% Zd&d' Zddejjfd(d)Zd*d+ Zd,d- Zd9d.d/Zd:d0d1Z d2d3 Z d4d5 Z dS );
SwdbInterfacer3 c C s8 t || _d | _d | _d | _d | _d | _|| _g | _d S r
) strrP _rpm_group_envZ _addon_datar _db_dir_output)r
Zdb_dirrP r r r r ! s
zSwdbInterface.__init__c C s | d S r
)closer r r r __del__- s zSwdbInterface.__del__c C s | j d u rt| | _ | j S r
)rw r r r r r r? 0 s
zSwdbInterface.rpmc C s | j d u rt| | _ | j S r
)rx r r r r r group6 s
zSwdbInterface.groupc C s | j d u rt| | _ | j S r
)ry r r r r r env< s
zSwdbInterface.envc C s t j| jtjjjS r
)ospathjoinrz rX rY SwdbZdefaultDatabaseNamer r r r dbpathB s zSwdbInterface.dbpathc
C s\ | j sVztj| j| _ W n0 tyJ } ztt|W Y d}~n
d}~0 0 | j | j S )z Lazy initialize Swdb object N) r rX rY r r RuntimeErrorr rv initTransaction)r
exr r r r F s "
zSwdbInterface.swdbc C s t j|| j}| d S r
)rX rY Z Transformerr transform)r
Z input_dirZ transformerr r r r S s zSwdbInterface.transformc C sX z| ` W n ty Y n0 d | _d | _d | _| jrH| j | j d | _g | _d S r
) _tidr4 rw rx ry r ZcloseTransactionZ
closeDatabaser{ r r r r r| W s
zSwdbInterface.closec C s
| j S r
)r ZgetPathr r r r r e s zSwdbInterface.pathc C s
| j S r
)r Z
resetDatabaser r r r reset_dbi s zSwdbInterface.reset_dbTc C s | j }|sd S t|S r
)r ZgetLastTransactionrI )r
complete_transactions_onlytr r r lastm s
zSwdbInterface.lastNr Fc s pg dd D | j }dd |D } rD fdd|D }t|D ]>\}}|dkr^qL||d }|j |j krLd|_d|_qL|d d d S ) Nc S s g | ] }t |qS r )rW rg r r r rj w rk z%SwdbInterface.old..c S s g | ] }t |qS r )rI rg r r r rj y rk c s g | ]}|j v r|qS r )rN rg re r r rj | rk r r T)r ZlistTransactions enumeraterJ rS rU rr rp )r
re limitr rl ri rL Z
prev_transr r r oldu s
zSwdbInterface.oldc C s t | j S r
)rI r Z
getCurrentr r r r get_current s zSwdbInterface.get_currentc C sB | j |}| |}tjj}| j||||}|tjj |S )zSet reason for package)
r? Z_pkg_to_swdb_rpm_itemreporX rY Z#TransactionItemAction_REASON_CHANGEr ZaddItemr9 rZ )r
rA r1 rpm_itemZrepoidr. Ztir r r
set_reason s
zSwdbInterface.set_reasonc C s | j t|S )zGet repository of package)r Z
getRPMReporv )r
rA r r r r s zSwdbInterface.repoc C s* | j t|}|du r |S t| |}|S )z Get package data for packageN)r ZgetRPMTransactionItemrv r )r
rA rl r r r package_data s
zSwdbInterface.package_datac C sr z| j W n Y n0 | j ttt t||p>dtt
|}| j | j | j
| || _|S r2 )r r ZbeginTransactionrW calendarZtimegmtimegmtimerv r Z getloginuidZ
setReleaseverrP ZsetPersistencer )r
Z
rpmdb_versionZ
using_pkgsZtsisrO rc rd rN r r r beg s
zSwdbInterface.begc C sN | j }||j ||jp"d ||j ||j |
|j |S )Nr ) r Z
createRPMItemsetNamer& ZsetEpochr' Z
setVersionr( Z
setReleaser) ZsetArchr* )r
Zpor r r r pkg_to_swdb_rpm_item s
z"SwdbInterface.pkg_to_swdb_rpm_itemc C s@ t | dsd S |sd S | D ] }t|}| jd|f q d S )Nr r )hasattr
splitlinesr r{ append)r
msgliner r r log_scriptlet_output s
z"SwdbInterface.log_scriptlet_outputc C s t | dsd S |d u rDtjj}| jD ] }|jtjjkr$tjj} qDq$| jD ]\}}| j
|| qJg | _| j t t
t|| d S )Nr )r rX rY ZTransactionState_DONEr? r8 ZTransactionItemState_ERRORZTransactionState_ERRORr{ r ZaddConsoleOutputLineZendTransactionrW r rv )r
rV r[ errorsZtsiZfile_descriptorr r r r end s
zSwdbInterface.endc C s | j |S )z{ Search for history transactions which contain specified
packages al. la. "yum list". Returns transaction ids. )r ZsearchTransactionsByRPM)r
patternsZ ignore_caser r r search s zSwdbInterface.searchc C s8 | j |j|jd}|tjjkr$dS |tjjkr4dS dS )z)Returns True if package is user installedr TF)r resolveRPMTransactionItemReasonr& r* rX rY TransactionItemReason_USER TransactionItemReason_UNKNOWN)r
rA r1 r r r user_installed s z SwdbInterface.user_installedc C sF |r| j |j|j|}n| j |j|jd}|tjjkrBtjj}|S )a2 Get reason of package before transaction being undone. If package
is already installed in the system, keep his reason.
:param pkg: package being installed
:param first_trans: id of first transaction being undone
:param rollback: True if transaction is performing a rollbackr )r r r& r* rX rY r r )r
rA Z first_transZrollbackrl r r r get_erased_reason s z SwdbInterface.get_erased_reason)r3 )T)Nr F)r3 NN)T) rD rE rF r r} rG r? r~ r r r r r| r r r r r r r r rX rY Z TransactionPersistence_UNKNOWNr r r r r r r r r r r ru s@
ru )r r r Zlibdnf.transactionrX Z libdnf.utilsZdnf.i18nr Zdnf.yumr Zdnf.exceptionsr r~ r r r objectr rI rs ru r r r r s Q&