File: //lib/python3.9/site-packages/dnf-plugins/__pycache__/spacewalk.cpython-39.pyc
a
�߾g�7 � @ sf d dl mZ d dl mZ d dlmZmZ d dlZd dlZd dlZd dl Z d dl
Z
d dl Z d dl m Z d dl
mZ d dlZd dlZd dlZd dlZd dlmZ d dlmZ d Zed
�Zed �Zed �Zed
�Zed�Z ed�Z ed�Z ed�Z ed�Z ed�Z!ed�Z"ed�Z#ed�Z$G dd� dej%�Z&G dd� dej'j(�Z)dd � Z*G d d � d e+�Z,d d � Z-d!d"� Z.dS )#� )�absolute_import)�unicode_literals)�_�loggerN)�copy)�PRIO_PLUGINCONFIG)�ustr)�
up2dateErrorsz_spacewalk.jsonz7CloudLinux Network based repositories will be disabled.z4CloudLinux Network channel support will be disabled.z@There was an error communicating with CloudLinux Network server.z=This system is not registered with CloudLinux Network server.z.This system is not subscribed to any channels.z SystemId could not be acquired.z%You can use rhn_register to register.z@This system is receiving updates from CloudLinux Network server.z�For security reasons packages from CloudLinux Network based repositories can be verified only with locally installed gpg keys. GPG key '%s' has been rejected.z.Package profile information could not be sent.z=Missing required login information for CloudLinux Network: %sz'Leapp upgrade is running - using cache.z>Spacewalk plugin has to be run under with the root privileges.c sZ e Zd ZdZ� fdd�Zdd� Zdd� Zdd d
�Zd d � Zd
d� Z dd� Z
dd� Z � Z S )� SpacewalkZ spacewalkc s� t t| ��||� || _|| _tj�| jjj t
�| _ d| _ i | _
t| jj�| _| �| j�| _d| j�� v r�| j�d�}|D ]\}}| j�||t� qztj�� s�t�t� d| j_| jjs�d S t� d� | � � d S )NF�mainz initialized Spacewalk plugin) �superr
�__init__�base�cli�os�path�join�confZ
persistdir�STORED_CHANNELS_NAME�stored_channels_path�connected_to_spacewalk� up2date_cfgr Z read_config�parser�sections�items�
_set_valuer �dnf�utilZ am_i_rootr �warning� MUST_BE_ROOT�enabled�debug�activate_channels)�selfr r �options�key�value�� __class__� �9/usr/lib/python3.9/site-packages/dnf-plugins/spacewalk.pyr
; s* �
zSpacewalk.__init__c C s$ | j js d S | jsd S d| jj_d S )NT)r r r ZdemandsZ root_user�r# r) r) r* �configR s
zSpacewalk.configc C s t �d� d S )Nz$/usr/sbin/clnreg_ks --strict-edition)r �systemr+ r) r) r* �clnreg^ s zSpacewalk.clnregTc
C s� i }d }d}d }d }| � � }|s(|}�n�tj�d�rFt�t� |}�n�tj� � | _
t | j
�}| j
d f}d}|s�ztj j
| jjd�}d}W ql tjy� } z>|dkr�| �� d}W Y d } ~ qlt�dtt| � W Y d } ~ d S d } ~ 0 0 ql|�st�dtt� | �i � d S ztjj| jjd�}
W n� tj�yX } z t�dtt| � W Y d } ~ d S d } ~ 0 tj�y� t�dt t � | �i � Y d S tj �y� t�d t t t t� Y d S 0 d| _!t�"t#� |
D ]$} | d
�r�t$| �%� �|| d < �q�| �|� | j&j'} |�%� D ]�\}
}|�(|
�}d }|�r*|�(d
�}t)| j�}|
| j*�+� v �rn| j*�%|
�}|D ]\}}|�,||t-� �qTt.|| j&j||j|||||j/|j0d � �}| �1|� �qt�2|� d S )
Nr z/etc/cln_leapp_in_progressZuseNoSSLForPackagesF��timeoutT�%s
%s
%sz%s
%sz %s %s
%s
%s�version�label) r �proxyr0 � sslcacert�
force_http�cached_version�
login_info�gpgcheckr )3�_read_channels_filer r �isfiler r �LEAPP_IN_PROGRESS�up2date_clientr, ZinitUp2dateConfigr �get_ssl_ca_certZ up2dateAuthZ getLoginInfor r0 r �RhnServerExceptionr. �error�COMMUNICATION_ERROR� RHN_DISABLED�NOT_REGISTERED_ERROR�_write_channels_fileZ
rhnChannelZgetChannelDetailsZCommunicationErrorZNoChannelsError�NOT_SUBSCRIBED_ERROR�CHANNELS_DISABLEDZNoSystemIdError�NO_SYSTEM_ID_ERROR�USE_RHNREGISTERr �info�UPDATES_FROM_SPACEWALK�dictr r �repos�getr r r r r �
SpacewalkRepor9 r �addr! )r# Z
networkingZenabled_channelsr5 r6 Z proxy_urlr8 Zcached_channelsZ clnreg_tried�eZ svrChannels�channelrL Z
channel_idZ channel_dictZcached_channelr7 r r$ r% r& �repor) r) r* r" a s�
�
�
� zSpacewalk.activate_channelsc
C s� | j js dS | jsdS | jd dkr8| �� }tj�|� ztjj| j j d� W n6 t
j y� } z t �
dtt|� W Y d}~n
d}~0 0 dS )z, Update system's profile after transaction. NZwriteChangesToLog� r/ r1 )r r r r �_make_package_deltar= ZrhnPackageInfoZlogDeltaPackagesZupdatePackageProfiler0 r r? r r@ rA �PROFILE_NOT_SENT)r# �deltarP r) r) r* � transaction� s �
zSpacewalk.transactionc
C s� zHt | jd��(}|�� }t�|�}|W d � W S 1 s<0 Y W n\ ttfy~ } z|jtjkrj� W Y d }~n0d }~0 tj j
y� } z W Y d }~n
d }~0 0 i S )N�r) �openr �read�json�loads�FileNotFoundError�IOError�errno�ENOENT�decoderZJSONDecodeError)r# �
channels_fileZcontentZchannelsrP r) r) r* r: � s
( z Spacewalk._read_channels_filec
C s| z@t | jd�� }tj||dd� W d � n1 s40 Y W n6 ttfyv } z|jtjkrb� W Y d }~n
d }~0 0 d S )N�w� )�indent)rY r r[ �dumpr] r^ r_ r` )r# �varrb rP r) r) r* rD � s 2 z Spacewalk._write_channels_filec C s. dd� | j jjD �dd� | j jjD �d�}|S )Nc S s$ g | ] }|j |j|j|j|jf�qS r) ��namer2 �releaseZepochZarch��.0�pr) r) r* �
<listcomp>� s �z1Spacewalk._make_package_delta.<locals>.<listcomp>c S s$ g | ] }|j |j|j|j|jf�qS r) rh rk r) r) r* rn � s �)ZaddedZremoved)r rW Z install_setZ
remove_set)r# rV r) r) r* rT � s ���z Spacewalk._make_package_delta)T)
�__name__�
__module__� __qualname__ri r
r, r. r" rW r: rD rT �
__classcell__r) r) r' r* r
7 s
Yr
c s> e Zd ZdZg d�Z� fdd�Zdd� Zd
� fdd � Z� ZS ) rN zB
Repository object for Spacewalk. Uses up2date libraries.
)zX-RHN-Server-IdzX-RHN-Auth-User-Idz
X-RHN-AuthzX-RHN-Auth-Server-TimezX-RHN-Auth-Expire-Offsetc
sV t t� ��t|d �|�d�� t|d �� _� fdd�|d D �� _|�d�� _|�d�� _zt |d �� _
W n> t y� } z&t �
ttj�|�� g � _
W Y d }~n
d }~0 0 |d
|�d �kr�d � _|�d
�� _d� _d� _d � _d� _|�d�� _|�d�� _|�d�� _|�d��r&� �� n� � � t � d��rR� � � }|�rR� � |� d S )Nr3 r ri c s g | ]}|d � j �qS )z /GET-REQ/)�id)rl �urlr+ r) r* rn � � z*SpacewalkRepo.__init__.<locals>.<listcomp>rt r5 r4 Z gpg_key_urlr2 r7 rS r8 r r0 r9 r6 r �set_http_headers) r rN r
r rM ri Zbaseurlr5 r4 �get_gpg_key_urlsZgpgkey�InvalidGpgKeyLocationr r �GPG_KEY_REJECTEDr Zi18nZucdZmetadata_expirer8 Z keepaliveZ bandwidthZretriesZthrottler0 r9 r6 �enable�disable�hasattr�create_http_headersrv )r# rQ ZoptsrP � http_headersr' r+ r* r
� s: �
zSpacewalkRepo.__init__c C s� g }| j s|S | jD ]X}|| j vr6t| }tj�|��| j | dv rT|�d| � q|�d|| j | f � q| js~|�d� |S )N)N� z*%s:
X-libcurl-Empty-Header-Workaround: *z%s: %sz.X-RHN-Transport-Capability: follow-redirects=3)r8 �needed_headers�MISSING_HEADERr �ErrorZ RepoError�appendr6 )r# r~ �headerr@ r) r) r* r} s
z!SpacewalkRepo.create_http_headersTc s0 t t| ��||�}| �� }|r,|�tj|� |S )N)r rN �_handle_new_remoter} Zsetopt�librepoZLRO_HTTPHEADER)r# ZdestdirZ mirror_setupZhandler~ r' r) r* r� - s
z SpacewalkRepo._handle_new_remote)T) ro rp rq �__doc__r� r
r} r� rr r) r) r' r* rN � s
%rN c C s& | � � }|D ]}t|�s t|��q |S )a
Parse the key urls and validate them.
key_url_string is a space seperated list of gpg key urls that must be
located in /etc/pkg/rpm-gpg/.
Return a list of strings containing the key urls.
Raises InvalidGpgKeyLocation if any of the key urls are invalid.
)�split�is_valid_gpg_key_urlrx )Zkey_url_stringZkey_urls�key_urlr) r) r* rw 9 s
rw c @ s e Zd ZdS )rx N)ro rp rq r) r) r) r* rx H s rx c C sP | � d�}t|�dkrdS |\}}|�� dkr2dS tj�|�}|�d�sLdS dS )Nz://� F�filez/etc/pki/rpm-gpg/T)r� �len�lowerr r �normpath�
startswith)r� Z proto_split�protor r) r) r* r� K s
r� c C s4 d| v r| d st �| d }t|�tkr0|d S |S )NZ sslCACertr )ZBadSslCaCertConfig�type�list)r Zca_certsr) r) r* r> Y s r> )/Z
__future__r r Zdnfpluginscorer r r Zdnf.exceptionsr_ r[ r� r r Zdnf.conf.configr Zup2date_client.up2dateAuthr= Zup2date_client.configZup2date_client.rhnChannelZ up2date_client.rhnPackageInfoZrhn.i18nr r r rB rF rA rC rE rG rH rJ ry rU r� r< r ZPluginr
rR ZReporN rw � Exceptionrx r� r> r) r) r) r* �<module> sJ 4O