| Server IP : 3.96.16.70 / Your IP : 216.73.216.15 Web Server : Apache System : Linux ip-172-31-26-103.ca-central-1.compute.internal 6.1.163-186.299.amzn2023.x86_64 #1 SMP PREEMPT_DYNAMIC Tue Feb 24 16:35:42 UTC 2026 x86_64 User : ec2-user ( 1000) PHP Version : 8.4.18 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : OFF Directory : /lib/python3.9/site-packages/dnf/__pycache__/ |
Upload File : |
a
�!cLQ � @ sF d dl mZ d dl mZ d dlmZmZ d dlZd dlZd dl Zd dl
Zd dl Zd dl Zd dl
Zd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl Z d dl Z d dl Z dZ dZ!e j"e j# d Z$de�%e$�e j&f Z'd e'e!f d
e'e f d d �Z(e�)d
�Z*dd� Z+dd� Z,d-dd�Z-dd� Z.G dd� de/�Z0G dd� de1�Z2G dd � d ej3j4�Z5G d d � d e/�Z6G d d � d ej7j8�Z9G d!d"� d"ej3j:�Z;G d#d$� d$e;�Z<G d%d&� d&e;�Z=G d'd(� d(ej3j:�Z>ej7j?j@ZAej7j?jBZCej7j?jDZEG d)d*� d*ej7jF�ZGG d+d,� d,ejHjI�Z?dS ).� )�absolute_import)�unicode_literals)�ucd�_N�packagesZ
mirrorlistz-_.:z(?P<repoid>[%s]+)\-[%s]{16}z>^%s\/.*((xml|yaml)(\.gz|\.xz|\.bz2|.zck)?|asc|cachecookie|%s)$z^%s\/%s\/.+rpm$z^.+(solv|solvx)$)�metadatar Zdbcache�dnfc C s t jj�| �}|dk rdS |S )zAReturn index of an invalid character in the repo ID (if present).r N)�libdnf�repo�RepoZverifyId)Zrepo_idZ
first_invalid� r �,/usr/lib/python3.9/site-packages/dnf/repo.py�repo_id_invalidH s r c G s8 |D ] }|| |�}|d ur| S qt td�| ��d S )Nz"no matching payload factory for %s)�
ValueErrorr )�pkg�progressZ factories�fn�ploadr r r
� _pkg2payloadO s
r Tc
C s� dd� }|j �� dd� t| |d�D �}t� }z tjj�tj�|�|� W n. t yx } zt
|�|_ W Y d }~n
d }~0 0 |� � |j �
� |_|D ]b}|�� }|d u s�|�d�r�q�|�� } | j}
|
j} |dkr�|j�| � q�| jj�� |g|j| < q�|S )Nc S s t | d� S )NZdelta)�hasattr)�payloadr r r
�_download_sort_keyY s z._download_payloads.<locals>._download_sort_keyc S s g | ] }|� � �qS r )�_librepo_target)�.0r r r r
�
<listcomp>] s �z&_download_payloads.<locals>.<listcomp>)�key� Not finishedzAlready downloaded)�err�clear�sorted�_DownloadErrorsr r
�
PackageTargetZdownloadPackagesZVectorPPackageTarget� RuntimeError�str�_fatal�wait�copy� _recoverableZgetErr�
startswithZ getCallbacks�
package_ploadr �_skipped�add�_repoZexpire�_pkg_irrecoverable) �payloadsZdrpmZ fail_fastr �targets�errs�eZtgtr � callbacksr r r r r
�_download_payloadsW s2
� r3 c C sH | \}}|D ]2}|j }||v r*||j7 }q ||j7 }||j7 }q ||fS �N)r �
download_size�
_full_size)Zsavingr. r0 �realZfullr r r r r
�_update_savingx s
r8 c @ s> e Zd Zdd� Zdd� Zedd� �Zejdd� �Zdd � Zd
S ) r c C s i | _ i | _d | _t� | _d S r4 )r- �_val_recoverabler$ �setr* ��selfr r r
�__init__� s z_DownloadErrors.__init__c C s" | j r | j S | jr d| jgiS i S �N� )r- r$ r; r r r
�_irrecoverable� s
z _DownloadErrors._irrecoverablec C s | j S r4 �r9 r; r r r
r' � s z _DownloadErrors._recoverablec C s
|| _ d S r4 rA )r< Znew_dctr r r
r' � s c C s |j | jv rdS |jS �Nr )r r* r5 )r< r r r r
�_bandwidth_used� s z _DownloadErrors._bandwidth_usedN) �__name__�
__module__� __qualname__r= r@ �propertyr' �setterrC r r r r
r � s
r c @ s e Zd Zdd� ZdS )�_DetailedLibrepoErrorc C s, t �| � |jd | _|jd | _|| _d S )Nr � )� Exceptionr= �argsZ librepo_codeZ librepo_msg�
source_url)r< Z librepo_errrM r r r
r= � s
z _DetailedLibrepoError.__init__N)rD rE rF r= r r r r
rI � s rI c @ s e Zd Zdd� ZdS )�_NullKeyImportc C s dS )NTr �r< �idZuseridZ fingerprint�urlZ timestampr r r
�_confirm� s z_NullKeyImport._confirmN)rD rE rF rR r r r r
rN � s rN c @ s e Zd Zdd� Zedd� �ZdS )�Metadatac C s
|| _ d S r4 )r, �r< r
r r r
r= � s zMetadata.__init__c C s
| j �� S r4 )r, �freshr; r r r
rU � s zMetadata.freshN)rD rE rF r= rG rU r r r r
rS � s rS c s4 e Zd Z� fdd�Zdd� Zdd� Zdd� Z� ZS ) �PackageTargetCallbacksc s t t| ��� || _d S r4 )�superrV r= r) )r< r) �� __class__r r
r= � s z PackageTargetCallbacks.__init__c C s | j �d ||� dS rB )r) �_end_cb)r< �status�msgr r r
�end� s zPackageTargetCallbacks.endc C s | j �d ||� dS rB )r) � _progress_cb�r< ZtotalToDownloadZ
downloadedr r r
r � s z PackageTargetCallbacks.progressc C s | j �d ||� dS rB )r) �_mirrorfail_cb)r< r\ rQ r r r
�
mirrorFailure� s z$PackageTargetCallbacks.mirrorFailure)rD rE rF r= r] r ra �
__classcell__r r rX r
rV � s rV c sH e Zd Z� fdd�Zdd� Zdd� Zdd� Zed d
� �Zd d � Z � Z
S )
�PackagePayloadc s$ t t| ��|� t| �| _|| _d S r4 )rW rc r= rV r2 r )r< r r rX r r
r= � s
zPackagePayload.__init__c C sR t jj}|du rt jj}n$|�d�r(dS |tjjjkr>t jj }| j
� | ||� dS )z"End callback to librepo operation.Nr ) r �callbackZ
STATUS_FAILEDZ STATUS_OKr( r r
�PackageTargetCBZ TransferStatus_ALREADYEXISTSZSTATUS_ALREADY_EXISTSr r] )r< �cbdataZ lr_statusr\ r[ r r r
rZ � s
zPackagePayload._end_cbc C s | j �| tjj|� d S r4 )r r] r rd Z
STATUS_MIRROR)r< rf r rQ r r r
r` � s z PackagePayload._mirrorfail_cbc C sV z| j � | |� W n> tyP t�� \}}}t�|||�}t�d�|�� Y n0 d S r> ) r rK �sys�exc_info� traceback�format_exception�logger�critical�join�r< rf �total�done�exc_type� exc_value�
exc_tracebackZ except_listr r r
r^ � s zPackagePayload._progress_cbc C s | j S r4 )r5 r; r r r
r6 � s zPackagePayload._full_sizec
C s� | j }|j}tj�|� |d| | j| j| jd�}|�| � � � t
j � |j j
|d |d |d |d |d |d |d d
d
| j� S ) NT)�dest�resumerf Z
progresscbZendcbZmirrorfailurecb� relative_urlrt �
checksum_type�checksum� expectedsize�base_urlru r )r �pkgdirr �util�
ensure_dirr^ rZ r` �update�_target_paramsr r
r! r, r2 )r< r r{ Z
target_dctr r r
r � s$ ��z PackagePayload._librepo_target) rD rE rF r= rZ r` r^ rG r6 r rb r r rX r
rc � s
rc c @ s( e Zd Zdd� Zdd� Zedd� �ZdS )�
RPMPayloadc C s t j�| jj�S r4 )�os�path�basenamer �locationr; r r r
�__str__ s zRPMPayload.__str__c C sT | j }|�� \}}tjj�|�}|tjjjkr>t�t d�|� |j
|||j |j d�S )Nz unsupported checksum type: %s)rv rw rx ry rz )
r Z returnIdSumr r
r! Z checksumTypeZChecksumType_UNKNOWNrk �warningr r� � downloadsize�baseurl)r< r ZctypeZcsumZ
ctype_coder r r
r s �zRPMPayload._target_paramsc C s | j jS �zTotal size of the download.)r r� r; r r r
r5 s zRPMPayload.download_sizeN)rD rE rF r� r rG r5 r r r r
r� s r� c s@ e Zd Z� fdd�Zdd� Zdd� Zdd� Zed d
� �Z� Z S ) �RemoteRPMPayloadc s� t t| ��d|� || _d| _|| _| jjp.d| jj�d� }t �
|� d��� � d d� }d| }t
j�| jj|d�| _tj�| j� t
j�| j| �� �d ��| _d S )
NZ
unused_objectr r? Zbasearch�utf8� z commandline-r �/)rW r� r= �remote_location� remote_size�confZ
releasever�
substitutions�get�hashlibZsha256�encodeZ hexdigestr� r� rm Zcachedirr{ r r| r} r� �lstripZ
local_path)r< r� r� r �sZdigestZrepodirrX r r
r= s zRemoteRPMPayload.__init__c C s t j�| j�S r4 )r� r� r� r� r; r r r
r� ) s zRemoteRPMPayload.__str__c C s\ || _ z| j�| |� W n> tyV t�� \}}}t�|||�}t�d� |�� Y n0 d S r> )
r� r rK rg rh ri rj rk rl rm rn r r r
r^ , s z RemoteRPMPayload._progress_cbc
C s< t j�| jjtj�| j�| j dd dtj�
| j�ddd| j � S )Nr T) r r
r! r� �_configr� r� r� r� r{ �dirnamer2 r; r r r
r 5 s
�z RemoteRPMPayload._librepo_targetc C s | j S r� )r� r; r r r
r5 ; s z RemoteRPMPayload.download_size)
rD rE rF r= r� r^ r rG r5 rb r r rX r
r� s r� c sz e Zd Z� fdd�Zdd� Zdd� Zdd� Zd d
� Zd d � Ze d
d� �Z
e dd� �Z e j dd� �Z dd� Z
dd� Z� ZS )� MDPayloadc s. t t| ��|� d| _d| _d| _t� | _d S )Nr? r F)rW r� r= �_text�_download_size�fastest_mirror_runningr: �mirror_failures�r< r rX r r
r= C s
zMDPayload.__init__c C s t jjr| jS | j�d�S d S )Nzutf-8)r �pycompZPY3r� r� r; r r r
r� J s zMDPayload.__str__c C s | j S r4 )r� r; r r r
� __unicode__P s zMDPayload.__unicode__c C s || _ | j�| |� d S r4 )r� r )r< rf ro rp r r r
r^ S s zMDPayload._progress_cbc C s\ |t jjjkr"td�| }d| _n*|t jjjkrH| jrH|rBd| nd}nd S | j�|� d S )Nz,determining the fastest mirror (%s hosts).. Tz
error: %s
zdone.
) r r
�RepoCBZ FastestMirrorStage_DETECTIONr r� ZFastestMirrorStage_STATUSr �message)r< rf �stage�datar\ r r r
�_fastestmirror_cbW s zMDPayload._fastestmirror_cbc C s& | j �|� d||f }t�|� d S )Nzerror: %s (%s).)r� r+ rk �debug)r< rf r\ rQ r r r r
�_mirror_failure_cbc s z MDPayload._mirror_failure_cbc C s | j S r4 )r� r; r r r
r5 h s zMDPayload.download_sizec C s | j S r4 )� _progressr; r r r
r l s zMDPayload.progressc C s |d u rt j�� }|| _d S r4 )r rd �NullDownloadProgressr� r� r r r
r p s
c C s || _ | j�dd� d S )NrJ r )r� r �start)r< �textr r r
r� v s zMDPayload.startc C s d| _ | j�| d d � d S rB )r� r r] r; r r r
r] z s z
MDPayload.end)rD rE rF r= r� r� r^ r� r� rG r5 r rH r� r] rb r r rX r
r� A s
r� c sL e Zd Z� fdd�Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z � Z
S )�
RepoCallbacksc s t t| ��� || _|j| _d S r4 )rW r� r= r, � _md_ploadrT rX r r
r= � s zRepoCallbacks.__init__c C s | j �|� d S r4 )r� r� )r< Zwhatr r r
r� � s zRepoCallbacks.startc C s | j �� d S r4 )r� r] r; r r r
r] � s zRepoCallbacks.endc C s | j �d ||� dS rB )r� r^ r_ r r r
r � s zRepoCallbacks.progressc C s | j �d ||� d S r4 )r� r� )r< r� Zptrr r r
�
fastestMirror� s zRepoCallbacks.fastestMirrorc C s | j �d |||� dS rB )r� r� )r< r\ rQ r r r r
�handleMirrorFailure� s z!RepoCallbacks.handleMirrorFailurec C s | j j�|||||�S r4 )r, � _key_importrR rO r r r
�
repokeyImport� s zRepoCallbacks.repokeyImport) rD rE rF r= r� r] r r� r� r� rb r r rX r
r� � s r� c s e Zd ZeZd4� fdd� Zedd� �Zedd� �Zej dd� �Zed d
� �Z
d d � Z e
j d
d
� �Z
edd� �Z edd� �Z
e
j dd� �Z
dd� Zdd� Z� fdd�Zdd� Zdd � Zd d � Zd d � Zd!d"� Zd#d$� Zd%d&� Zd'd(� Zd)d*� Zd+d,� Zd-d.� Zd/d0� Z d5d2d3�Z � Z S )6r Nc s� t t| �j||d� | jj�� tj�|r.|nd| j�| _t t
j � � �| _
t| �| _| jj�� | j�| j� d | _t� | _d | _| j�|r�|jr�tn| j� |r�| j�|j� t
jj� � | _ |d ur�|j nd| _ d S )N)Zsection�parentr? T) rW r r= r� �thisZdisownr r
r, r� r rd r� r� r� Z
_callbacksZ setCallbacks�_pkgdirrN r� r ZsetSyncStrategyZ cacheonly�SYNC_ONLY_CACHE� DEFAULT_SYNCZsetSubstitutionsr� r� Z
SubstitutionsZ_substitutionsZcheck_config_file_ageZ_check_config_file_age)r< �nameZ parent_confrX r r
r= � s$
��z
Repo.__init__c C s
| j �� S r4 )r, ZgetIdr; r r r
rP � s zRepo.idc C s
| j �� S r4 )r, ZgetRepoFilePathr; r r r
�repofile� s z
Repo.repofilec C s | j �|� d S r4 )r, ZsetRepoFilePath)r< �valuer r r
r� � s c C s | j �� r| j �� S | �� S r4 )r, ZisLocalZgetLocalBaseurl� cache_pkgdirr; r r r
r{ � s
z Repo.pkgdirc C s$ | j d ur| j S tj�| j�� t�S r4 )r� r� r� rm r, � getCachedir�_PACKAGES_RELATIVE_DIRr; r r r
r� � s
zRepo.cache_pkgdirc C s
|| _ d S r4 )r� �r< �valr r r
r{ � s c C s t j�| j�� d�S )NZpubring)r� r� rm r, r� r; r r r
� _pubring_dir� s zRepo._pubring_dirc C s
| j �� S r4 )r, ZgetLoadMetadataOtherr; r r r
�load_metadata_other� s zRepo.load_metadata_otherc C s | j �|� d S r4 )r, ZsetLoadMetadataOtherr� r r r
r� � s c C s | j |j k S r4 )rP )r< �otherr r r
�__lt__� s z Repo.__lt__c C s d| j j| jf S )Nz<%s %s>)rY rD rP r; r r r
�__repr__� s z
Repo.__repr__c s t t| ��||� d S r4 )rW r � __setattr__)r< r� r� rX r r
r� � s zRepo.__setattr__c C s | j �� d S r4 )r, �disabler; r r r
r� � s z Repo.disablec C s | j �� d S r4 )r, �enabler; r r r
r� � s z Repo.enablec C s | j �|� dS )a/ Ask for additional repository metadata type to download.
Given metadata_type is appended to the default metadata set when
repository is downloaded.
Parameters
----------
metadata_type: string
Example: add_metadata_type_to_download("productid")
N)r, ZaddMetadataTypeToDownload�r< Z
metadata_typer r r
� add_metadata_type_to_download� s
z"Repo.add_metadata_type_to_downloadc C s | j �|� dS )aI Stop asking for this additional repository metadata type
in download.
Given metadata_type is no longer downloaded by default
when this repository is downloaded.
Parameters
----------
metadata_type: string
Example: remove_metadata_type_from_download("productid")
N)r, Z removeMetadataTypeFromDownloadr� r r r
�"remove_metadata_type_from_download s z'Repo.remove_metadata_type_from_downloadc C s | j �|�S )z�Return path to the file with downloaded repository metadata of given type.
Parameters
----------
metadata_type: string
)r, ZgetMetadataPathr� r r r
�get_metadata_path s zRepo.get_metadata_pathc C s | j �|�S )z�Return content of the file with downloaded repository metadata of given type.
Content of compressed metadata file is returned uncompressed.
Parameters
----------
metadata_type: string
)r, ZgetMetadataContentr� r r r
�get_metadata_content! s
zRepo.get_metadata_contentc
C s� d}z�z| j �� }W nr tjjtfy� } zR| jjrbd| j }| jjD ]}|d| 7 }qFt �
|� t j �
t|���W Y d}~n
d}~0 0 W t� | j_n t� | j_0 t| j �| _|S )a� Load the metadata for this repo.
Depending on the configuration and the age and consistence of data
available on the disk cache, either loads the metadata from the cache or
downloads them from the mirror, baseurl or metalink.
This method will by default not try to refresh already loaded data if
called repeatedly.
Returns True if this call to load() caused a fresh metadata download.
Fz7Errors during downloading metadata for repository '%s':z
- %sN)r, �loadr �error�Errorr" r� r� rP rk r� r �
exceptionsZ RepoErrorr# r: rS r )r< �retr1 r\ Zfailurer r r
r� - s
( z Repo.loadc C sP | j s| j�d� | j rL| jdkr&dS | j�� }| j�� rDtd|�}d|fS dS )a) Get the number of seconds after which the cached metadata will expire.
Returns a tuple, boolean whether there even is cached metadata and the
number of seconds it will expire in. Negative number means the metadata
has expired already, None that it never expires.
F���)TNr T)Fr )r r, Z loadCacheZmetadata_expireZ getExpiresInZ isExpired�min)r< Z
expirationr r r
�_metadata_expire_inJ s
zRepo._metadata_expire_inc C s
|| _ d S r4 )r� )r< Z
key_importr r r
�_set_key_import] s zRepo._set_key_importc C s || j _d S r4 )r� r r� r r r
�set_progress_bar` s zRepo.set_progress_barc C s
| j �� S )zoReturns user defined http headers.
Returns
-------
headers : tuple of strings
)r, ZgetHttpHeadersr; r r r
�get_http_headersd s zRepo.get_http_headersc C s | j �|� dS )a Sets http headers.
Sets new http headers and rewrites existing ones.
Parameters
----------
headers : tuple or list of strings
Example: set_http_headers(["User-Agent: Agent007", "MyFieldName: MyFieldValue"])
N)r, ZsetHttpHeaders)r< Zheadersr r r
�set_http_headersn s zRepo.set_http_headers��http�ftp�file�httpsc s@ � �fdd�}� sdS | j �� }|r,||�S | jr<|| j�S dS )z�
:param location: relative location inside the repo
:param schemes: list of allowed protocols. Default is ('http', 'ftp', 'file', 'https')
:return: absolute url (string) or None
c s^ | D ]T}�r@t jj�|�d }|�v rXtj�|� �d�� S qtj�|� �d�� S qd S )Nr r� )r r� �urlparser� r� rm r� )Zurl_listrQ r� �r� �schemesr r
�schemes_filter� s z,Repo.remote_location.<locals>.schemes_filterN)r, Z
getMirrorsr� )r< r� r� r� Zmirrorsr r� r
r� { s
zRepo.remote_location)NN)r� ) rD rE rF �SYNC_TRY_CACHEr� r= rG rP r� rH r{ r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� rb r r rX r
r � sF
r )T)JZ
__future__r r Zdnf.i18nr r Z dnf.callbackr Zdnf.confZdnf.conf.substitutionsZ dnf.constZ
dnf.cryptoZdnf.exceptionsZ dnf.loggingZ
dnf.pycompZdnf.utilZ dnf.yum.miscZ libdnf.errorr Z libdnf.repo� functoolsr� ZhawkeyZlogging�operatorr� �reZshutil�stringrg �timeri r� Z_MIRRORLIST_FILENAME�
ascii_letters�digitsZ
_REPOID_CHARS�escapeZ hexdigitsZ _CACHEDIR_REZ CACHE_FILESZ getLoggerrk r r r3 r8 �objectr rK rI rd Z KeyImportrN rS r
re rV ZPayloadrc r� r� r� r ZSyncStrategy_LAZYZ SYNC_LAZYZSyncStrategy_ONLY_CACHEr� ZSyncStrategy_TRY_CACHEr� r� r� r� ZRepoConfr r r r
�<module> sr
��
�
!
8&?