a
ja @ s d dl mZ d dl mZ d dl mZ ddlmZmZ d dlmZm Z d dl
Z
d dl Z d dl Z d dl
Z d dlZ d dlZ d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl Z d dl Z e dZ!e
" j#d kre
" j#ndZ$e$% Z&d
d Z'dbd d
Z(dcddZ)dd Z*dd Z+dd Z,dd Z-dd Z.dd Z/d d Z0d d Z1d!d" Z2d#d$ Z3d%d& Z4d'd( Z5d)d* Z6d+d, Z7d-d. Z8d/d0 Z9d1d2 Z:d3d4 Z;d5d6 Zd;d< Z?d=d> Z@d?d@ ZAdAdB ZBdCdD ZCdddFdGZDdHdIejEfdJdKZFdLdM ZGdNdO ZHdPdQ ZIdRdS ZJG dTdU dUeKZLG dVdW dWeMZNG dXdY dYeOZPdZd[ ZQd\d] ZRd^d_ ZSG d`da daZTdS )e )print_function)absolute_import)unicode_literals )PY3
basestring)_ucdNdnfZyumc C s t | dg t | dg t | dg t }|D ]}||v r|W Y d }~n
d }~0 0 d S )Ni )r8 )rB makedirsOSErrorerrnoZEEXISTrF isdir)Zdnamer/ r r r
ensure_dir s
rO c C sD g }| }t j|\}}|s2|s$|s@|d| q@|d| q|S )z`
Split path by path separators.
Use os.path.join() to join the path back to string.
r )rB rF splitinsert)rF resultheadtailr r r
split_path s rU c C s4 z t | }W n ty* t t| }Y n0 |dkS rA )r= TypeErrorlist)iterablelr r r empty s
rZ c C s, t | }z
t|W S ty& Y dS 0 dS )zFReturns the first item from an iterable or None if it has no elements.Niternext
StopIterationrX itr r r first s
ra c C s6 t | }ztdd |D W S ty0 Y d S 0 d S )Nc s s | ]}|d ur|V qd S r< r ).0itemr r r z!first_not_none..r[ r_ r r r first_not_none s
rf c C s t t| S r< )timefile_timestampfnr r r file_age s rk c C s t | jS r< )rB statst_mtimeri r r r rh s rh c C s8 zt t d W S ty2 dt Y S 0 d S )Nr zUID: %s)pwdgetpwuidrB rC KeyErrorr r r r get_effective_login s rq c C s( |D ] }| |} | du r| S q| S )z!Like dict.get() for nested dicts.N)get)ZdctkeysZ not_foundkr r r get_in s
ru c s fdd}t ||g g fS )Nc s | t | | | S r< )boolr )Zaccrc ri r r splitter s z!group_by_filter..splitter) functoolsreduce)rj rX rw r ri r group_by_filter s rz c c s" |D ]}||r| V |V qdS )z/Insert an item into an iterable by a condition.Nr )rc rX conditionZ
original_itemr r r insert_if s r| c C s* z t | W n ty Y dS 0 dS dS )z&Test whether an iterator is exhausted.TFN)r] r^ )iteratorr r r is_exhausted s
r~ c C s* t | r| g} t| to(tdd | D S )Nc s s | ]}t |t d @ V qdS )z*[?N)r )rb pr r r rd re z"is_glob_pattern..)is_string_type
isinstancerW any)patternr r r is_glob_pattern s r c C s t rt| tS t| tS d S r< )r r r) r )objr r r r s
r c s fdd}|S )zDecorator to get lazy attribute initialization.
Composes with @property. Force reinitialization by deleting the .
c s fdd}|S )Nc s< z t | W S ty6 | }t| | | Y S 0 d S r< )getattrAttributeErrorr )r val)attrnamerj r r
cached_getter s z6lazyattr..get_decorated..cached_getterr )rj r r ri r
get_decorated s z lazyattr..get_decoratedr )r r r r r lazyattr s r c G s t t| g|R S )zLike functools.map(), but return a list instead of an iterator.
This means all side effects of fn take place even without iterating the
result.
rW map)rj seqr r r mapall s r c C s8 t dt | }tjjs4t d }|r4||}|S )z6Convert time into locale aware datetime string object.z%cr ) rg strftime localtimer
r r locale getlocaledecode)Z timestamptZcurrent_locale_settingr r r normalize_time s
r c C s zxd} dd t | D }t|dkrt|d }td| |&}| }t|dkW d W S 1 sj0 Y W dS ttfy Y dS 0 dS )zDecide whether we are on line power.
Returns True if we are on line power, False if not, None if it can not be
decided.
z/sys/class/power_supplyc S s g | ]}| d r|qS )ZAC)r )rb Znoder r r
& re z on_ac_power..r z {}/{}/onliner N) rB rE r= openformatreadintr(
ValueError)Z ps_folderZac_nodesZac_nodeZ ac_statusdatar r r on_ac_power s ,r c C s z ddl } W n ty Y dS 0 z0| }|dd}| |d}|dd}W n | jyh Y dS 0 |dkrvdS |dv rdS |d v rd
S td |dS ) zDecide whether we are on metered connection.
Returns:
True: if on metered connection
False: if not
None: if it can not be decided
r Nz org.freedesktop.NetworkManagerz /org/freedesktop/NetworkManagerz org.freedesktop.DBus.PropertiesZMetered)r T) Fz&Unknown value for metered property: %r)dbus ImportErrorZ SystemBusZ
get_objectZ InterfaceZGetZ
DBusExceptionr )r ZbusproxyZifaceZmeteredr r r on_metered_connection1 s( r c C s& t |\}}tj| |t| |fS )zUse a predicate to partition entries into false entries and true entries.
Credit: Python library itertools' documentation.
) itertoolsteer
r filterfalsefilter)ZpredrX t1t2r r r partitionN s r c C s& zt | W n ty Y n0 d S r< )shutilrmtreerL rF r r r rH W s rH c # sB t fdd}t | |}||V ||}|s6q>|V q(dS )zSplit an iterable into tuples by a condition.
Inserts a separator before each item which meets the condition and then
cuts the iterable by these separators.
c s t t fdd| S )Nc s | kS r< r )r/ separatorr r g re z4split_by..next_subsequence..)tupler takewhile)r` r r r next_subsequencef s z"split_by..next_subsequenceN)objectr| )rX r{ r ZmarkedZ subsequencer r r split_by] s
r c C s | |r| t|d S d S r< )r r= )r> prefixr r r strip_prefixu s
r Fc C sL |st | t jr t | dS t| d W d n1 s>0 Y dS )z{Create an empty file if it doesn't exist or bump it's timestamps.
If no_create is True only bumps the timestamps.
Na)rB accessF_OKutimer )rF Z no_creater r r touch{ s r write c
C s zh| dkr| | nP| dkr(| n>| dkrD| | | n"| dkrZt||d n td| W n@ ty } z(tdt|j t
| W Y d }~n
d }~0 0 d S )Nr flushZ write_flushprint)r zUnsupported type: z{}: {}) r r r r r( r* criticalr type__name__r )tpmsgoutr/ r r r _terminal_messenger s
r c C sj d}t | dk}t| ddD ]H\}}|rB|dtd d| 7 }n|dtd d 7 }|d|7 }q |S ) z
Format string about problems in resolve
:param resolve_problems: list with list of strings (output of goal.problem_rules())
:return: string
r r )r$ z
ZProblemz %d: z: z
- )r= enumerater rG )Zresolve_problemsr Zcount_problemsiZrsr r r _format_resolve_problems s r c C sX | d }| d ur4| dkr4|| d 7 }|| d | d | S )N-0:.)NEVRA)teZnevrar r r _te_nevra s r c
C s t d | D ]@}| }d }|d ur,|j}dt|||| }t | q|D ]2}dt||j|j|j |j
| }t | qTd S )Nz Logging transaction elementsz@RPM element: '{}', Key(): '{}', Key state: '{}', Failed() '{}': z^SWDB element: '{}', State: '{}', Action: '{}', From repo: '{}', Reason: '{}', Get reason: '{}') r* debugKeystater r Failedr) actionZ from_reporeasonZ
get_reason)rpm_transactionswdb_transactionrpm_eltsiZ tsi_stater r r r _log_rpm_trans_with_swdb s
r c
C sH t jjt jjt jjt jjt jjh}dd |D }d}d}| D ]}t|}| }|d u sbt |ds|D ]4} | j
t jj krzqf| j |vrqft
| |krf| } qqf|d u st |dsttd| d}q<| rt jj|_
d}q.Fpkgz%TransactionItem not found for key: {}Tz)TransactionSWDBItem not found for key: {}z#Errors occurred during transaction.)r% transactionZ TransactionItemAction_DOWNGRADEDZ TransactionItemAction_OBSOLETED TransactionItemAction_REMOVEZ TransactionItemAction_UPGRADEDZ!TransactionItemAction_REINSTALLEDr r hasattrr Z TransactionItemState_UNKNOWNr r) r* r r r r TransactionItemState_ERRORZTransactionItemState_DONEr r )
r r Zrevert_actionsZ
cached_tsiZ el_not_foundr+ r Zte_nevrar Z
tsi_candidater r r _sync_rpm_trans_with_swdb sJ
r c @ s$ e Zd Zdd Zdd Zdd ZdS )tmpdirc C s dt jj }tj|d| _d S )Nz%s-)r )r
constZPREFIXr5 ZmkdtemprF )selfr r r r __init__ s ztmpdir.__init__c C s | j S r< r r r r r __enter__ s ztmpdir.__enter__c C s t | j d S r< )rH rF )r exc_type exc_value tracebackr r r __exit__ s ztmpdir.__exit__N)r
__module__ __qualname__r r r r r r r r s r c s( e Zd ZdZ fddZdd Z ZS )BunchzDictionary with attribute accessing syntax.
In DNF, prefer using this over dnf.yum.misc.GenericHolder.
Credit: Alex Martelli, Doug Hudgeon
c s t t| j|i | | | _d S r< )superr r __dict__)r argskwds __class__r r r s zBunch.__init__c C s t | S r< )idr r r r __hash__ s zBunch.__hash__)r r r __doc__r r
__classcell__r r r r r s r c s, e Zd Z fddZdd Zdd Z ZS )
MultiCallListc s t t| | | d S r< )r r r extend)r rX r r r r s zMultiCallList.__init__c s fdd}|S )Nc s fdd}t t|S )Nc s t | }| i S r< )r )vmethod)r r9 whatr r call_what
s
z8MultiCallList.__getattr__..fn..call_whatr )r r9 r r r )r r9 r rj s z%MultiCallList.__getattr__..fnr )r r rj r r r __getattr__ s zMultiCallList.__getattr__c s fdd}t t|| S )Nc s t | d S r< )r )rc r r r r setter s z)MultiCallList.__setattr__..setterr )r r r r r r
r __setattr__ s zMultiCallList.__setattr__)r r r r r r r r r r r r s r c
C sh t g g g g g g g g g g g d }| D ]<}|jtjjkrF|j| q$|jtjjkrb|j | q$|jtjj
kr|j tjj kr|j
| nD|j tjjkr|j| n(|j tjjkr|j| n |j| q$|jtjjkr|j| q$|jtjjkrH|j tjjkr |j| n*|j tjjkr:|j| n |j| q$|jtjjkr$|j| q$|S )N)
downgradederased erased_clean
erased_dep installedinstalled_group
installed_depinstalled_weak reinstalledupgradedfailed) r r r% r r r r r Z TransactionItemAction_DOWNGRADEr
Z TransactionItemAction_INSTALLr ZTransactionItemReason_GROUPr Z TransactionItemReason_DEPENDENCYr Z%TransactionItemReason_WEAK_DEPENDENCYr r Z TransactionItemAction_REINSTALLr r ZTransactionItemReason_CLEANr r r Z TransactionItemAction_UPGRADEr )r r2 r r r r _make_lists sJ
r c
s fdd}t j|} jd|d\}}||}g }td|jftd|jftd|j|j |j
|j ftd|j ftd |ftd
|j
|j |j ftd |jffD ]&\} }
||| t|
t|d q|S )
al Returns a human-readable summary of the results of the
transaction.
:param action_callback: function generating output for specific action. It
takes two parameters - action as a string and list of affected packages for
this action
:return: a list of lines containing a human-readable summary of the
results of the transaction
c s | j |j k| j |j k }|dkr$|S tj| j | j| j| j| jd}tj|j |j|j|j|jd}|| j}|dkrz|S | j|jk| j|jk S )zCompares two transaction items or packages by nevra.
Used as a fallback when tsi does not contain package object.
r )nameepochversionreleasearch) r hawkeyZNEVRAr r r r Zevr_cmpZsack)Zitem1Zitem2retZnevra1Znevra2baser r _tsi_or_pkg_nevra_cmpP s z7_post_transaction_output.._tsi_or_pkg_nevra_cmpF)Zreport_problemsr ZUpgradedZ
DowngradedZ InstalledZ ReinstalledZSkippedZRemovedr )key)r
utilr Z_skipped_packagesunionr r r
r r r r r r r r r r sortedrx
cmp_to_key) r! r Zaction_callbackr" Z
list_bunchZskipped_conflictsZskipped_brokenZskippedr r Ztsisr r r _post_transaction_outputF s:
r( c C s | r| S t dS )Nz )r )Z
input_namer r r _name_unset_wrappery s r) c @ sd e Zd ZdZdZdd Zedd Zedd Z d d
Z
d d Z ed
d Z edd Z
dd ZdS ) _BootcSystemz/usri c C s^ | sttddd l}|| _|dd ddlm} || _| jj
| _ | j | _
d S )Nz Not running on a bootc system.r OSTreez1.0)r+ )is_bootc_systemr& r giZ_giZrequire_versionZ
gi.repositoryr+ _OSTreeZSysrootZ new_defaultZ_sysrootZrequire_booted_deployment_booted_deployment)r r- r+ r r r r s z_BootcSystem.__init__c C s d} t j| S )zYReturns true is the system is managed as an immutable container, false
otherwise.z/run/ostree-booted)rB rF isfile)Z
ostree_bootedr r r r, s z _BootcSystem.is_bootc_systemc C s t | jt jS )z-Returns true if and only if /usr is writable.)rB r usrW_OK)clsr r r is_writable s z_BootcSystem.is_writablec C s
| j S r< )r/ Z get_unlockedr r r r _get_unlocked_state s z _BootcSystem._get_unlocked_statec C s | | jjjkS )zReturns true if and only if the bootc system is unlocked in a
transient state, i.e. a overlayfs is mounted as read-only on /usr.
Changes can be made to the overlayfs by remounting /usr as
read/write in a private mount namespace.)r5 r. DeploymentUnlockedState TRANSIENTr r r r is_unlocked_transient s z"_BootcSystem.is_unlocked_transientc C s t d }|| jdkr"tddddd| jg}ztj|dd}| W nT t yv t
j t
d |d Y n, tjy t
j t
d
| j|jY n0 d S ) Nr z!Failed to unshare mount namespaceZmountz--options-source=disablez-oz
remount,rwTtextz%s: command not found.z$Failed to mount %s as read/write: %s)ctypesZCDLLZunshare CLONE_NEWNSrL r1
subprocessruncheck_returncodeFileNotFoundErrorr
exceptionsErrorr CalledProcessErrorstderr)r3 ZlibcZ
mount_commandcompleted_processr r r _set_up_mountns s
z _BootcSystem._set_up_mountnsc C sx g d} zt j| dd}| W nP tyL tjtd| d Y n( t jyr tjtd|j Y n0 d S )N)ZostreeZadminZunlockz --transientTr9 z.%s: command not found. Is this a bootc system?r zFailed to unlock system: %s)
r= r> r? r@ r
rA rB r rC rD )Zunlock_commandrE r r r _unlock s z_BootcSystem._unlockc C s | }| jjj| jjj| jjj| jjjf}||vrFttd|j | jjj| jjjf}||v rdn6|| jjjkr|
| n|| jjjkr| dS )z+Set up a writable overlay on bootc systems.z"Unhandled bootc unlocked state: %sN) r5 r. r6 ZNONEZ DEVELOPMENTr7 ZHOTFIXr r Z
value_nickrG rF )r Zbootc_unlocked_stateZvalid_bootc_unlocked_statesZwritable_unlocked_statesr r r
make_writable s&
z_BootcSystem.make_writableN)r r r r1 r< r staticmethodr, classmethodr4 r5 r8 rF rG rH r r r r r* ~ s
r* )N)NNr1 )F)UZ
__future__r r r r r r Zdnf.i18nr r argparser; r
Z dnf.callbackZ dnf.constZ
dnf.pycomprM rx r r r ZloggingrB rn r r= sysr5 rg Z libdnf.repor% Zlibdnf.transactionZ getLoggerr* ArgumentParserprogZ MAIN_PROGupperZMAIN_PROG_UPPERr r0 r; r@ rD rJ rO rU rZ ra rf rk rh rq ru rz r| r~ r r r r r r r r rH r r r stdoutr r r r r r r dictr rW r r r( r) r* r r r r s
( -3