/
lib
/
python3.9
/
site-packages
/
dnf-plugins
/
__pycache__
/
Upload File
HOME
a ���f�, � @ s@ d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlmZ d dl Zd dl m Z m Z d dl Z ej�d d� d dlmZ d dlmZ d dlmZ d dlmZmZmZ d Ze d �Ze d �Ze d �Z e d �Z e d�Z e d�Z e d�Z e d�Z!G dd� dej"�Z#G dd� dej$j%�Z&dd� Z'G dd� de(�Z)dd� Z*d d � Z+dS ) � N)�PRIO_PLUGINCONFIG)�_�loggerz*/usr/share/oracle-cloud-agent/plugins/osms)�actions)�config)�ustr)� get_cacert� get_proxy� OsmsServerz _osms.jsonz)OSMS based repositories will be disabled.z2There was an error communicating with OSMS server.z/This system is not registered with OSMS server.z2This system is receiving updates from OSMS server.z�For security reasons packages from OSMS 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 OSMS: %sz9OSMS plugin has to be run under with the root privileges.c sJ e Zd ZdZ� fdd�Zdd� Zddd�Zd d � Zd d � Zd d� Z � Z S )� OsmsPluginZ osmspluginc s t t| ��||� || _|| _tj�| jjj t �| _ d| _ i | _ t�| jj�| _| �| j�| _d| j�� v r�| j�d�}|D ]\}}| j�||t� q|tj�� s�t�t� d| j_| jjs�d S | jj dkr�d}n"| jj dkr�d}n| jj dk r�d}t |� t� d� | � � d S )NF�main� �INFO�DEBUG�WARNINGzinitialized OSMS plugin) �superr �__init__�base�cli�os�path�join�conf� persistdir�STORED_CHANNELS_NAME�stored_channels_path�connected_to_osms� up2date_cfg�copy� read_config�parser�sections�items� _set_valuer �dnf�util� am_i_rootr �warning� MUST_BE_ROOT�enabled� debuglevel�init_root_logger�debug�activate_channels)�selfr r �options�key�value� log_level�� __class__� �:/usr/lib/python3.9/site-packages/dnf-plugins/osmsplugin.pyr , s4 zOsmsPlugin.__init__c C s | j js d S | jr d| jj_d S )NT)r r) r �demands� root_user�r. r5 r5 r6 r H s zOsmsPlugin.configTc C s< i }d }d}d }d }d }d }| � � } |s0| }�nDt�� | _t| jdd�\}}}t| j�}| jd }zt| jjd�� � }W n6 t y� } z t � dt t| � W Y d } ~ d S d } ~ 0 0 t�� } |r�| s�t � dtt� | �i � d S zt| jjd�j�| �} W n8 t �y. } z t � dt t| � W Y d } ~ d S d } ~ 0 0 d| _t �t� | D ]$} | d �rDt| �� �|| d < �qD| �|� | jj}|�� D ]�\}}| �|�}d }|�r�|�d�}t � | j�}|| j � � v �r�| j �|�}|D ]\}}|� ||t � �q�| jj||||j|||||j!|j"d � }t#||�}|�$|� �q�t �%|� d S ) Nr T)ZexternalZuseNoSSLForPackages��timeout�%s %s %sz%s %s� last_modified�label) r �proxy�proxy_username�proxy_passwordr; � sslcacert� force_http�cached_version� login_info�gpgcheckr) )&�_read_channels_filer �initUp2dateConfigr r r r r r; �login� Exceptionr �error�COMMUNICATION_ERROR� RHN_DISABLEDZ getSystemId�NOT_REGISTERED_ERROR�_write_channels_fileZup2dateZ listChannelsr �info�UPDATES_FROM_OSMS�dictr" r �repos�getr r r! r# r rF r) �OsmsRepo�addr, )r. Z networkingZenabled_channelsrB rC Z proxy_urlr@ rA rE Zcached_channels�eZ system_id�channels�channelrS Z channel_idZ channel_dictZcached_channelrD r r/ r0 r1 �opts�repor5 r5 r6 r- N sz � z OsmsPlugin.activate_channelsc C sd | j js dS | jsdS ztj| j jd� W n4 ty^ } z t�dt t |� W Y d}~n d}~0 0 dS )z, Update system's profile after transaction. Nr: r< ) r r) r r Zpackage_refresh_listr; rJ r rK rL �PROFILE_NOT_SENT)r. rW r5 r5 r6 � transaction� s zOsmsPlugin.transactionc C s� zHt | jd��(}|�� }t�|�}|W d � W S 1 s<0 Y W nJ ttfy~ } z|jtjkrj� W Y d }~n d }~0 tj j y� Y n0 i S )N�r) �openr �read�json�loads�FileNotFoundError�IOError�errno�ENOENT�decoder�JSONDecodeError)r. � channels_file�contentrX rW r5 r5 r6 rG � s ( z OsmsPlugin._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)r_ r ra �dumprc rd re rf )r. �varri rW r5 r5 r6 rO � s 2 z OsmsPlugin._write_channels_file)T) �__name__� __module__� __qualname__�namer r r- r] rG rO � __classcell__r5 r5 r3 r6 r ( s J r c s: e Zd Zg d�Z� fdd�Zdd� Zd � fdd� Z� ZS ) rU )zX-RHN-Server-IdzX-RHN-Auth-User-Idz X-RHN-AuthzX-RHN-Auth-Server-TimezX-RHN-Auth-Expire-Offsetc s� t t� ��t|d �|�d�� t|d �� _� fdd�t�� D �� _|�d�� _ |�d�� _ |�d�� _ |�d �� _ zt |d �� _W n> ty� } z&t�ttj�|�� g � _W Y d }~n d }~0 0 |d |�d �kr�d � _|�d�� _d� _d� _d � _d� _|�d�� _ |�d�� _ |�d�� _ � j � d��rJt�!d� j � d� _"|�d��r`� �#� n� �$� t%� d��r�� �&� }|�r�� �'|� d S )Nr> r rs c s g | ]}|d � j �qS )z /GET-REQ/)�id)�.0�urlr9 r5 r6 � <listcomp>� � z%OsmsRepo.__init__.<locals>.<listcomp>rB r? r@ rA Z gpg_key_urlr= rD � rE r r; rF rC Zocidz3Set module_hotfixes = True for custom repository %sTr) �set_http_headers)(r rU r r rT rs r Z getServerlURL�baseurlrB r? r@ rA �get_gpg_key_urls�gpgkey�InvalidGpgKeyLocationr r' �GPG_KEY_REJECTEDr$ �i18n�ucd�metadata_expirerE Z keepalive� bandwidth�retries�throttler; rF rC ru � startswithr, �module_hotfixes�enable�disable�hasattr�create_http_headersr{ )r. rY rZ rW � http_headersr3 r9 r6 r � s@ zOsmsRepo.__init__c C s� g }| j D ]X}|| jvr,t| }tj�|��| j| dv rJ|�d| � q |�d|| j| f � q t�� }|d r�|�d|d � | j s�|�d� |�d� |S )N)N� z*%s: X-libcurl-Empty-Header-Workaround: *z%s: %sZtenantIdzX-Tenant-Id: %sz.X-RHN-Transport-Capability: follow-redirects=3zContent-Length: 0) �needed_headersrE �MISSING_HEADERr$ �Error� RepoError�appendr rH rC )r. r� �headerrK r r5 r5 r6 r� � s z OsmsRepo.create_http_headersTc s0 t t| ��||�}| �� }|r,|�tj|� |S )N)r rU �_handle_new_remoter� Zsetopt�librepoZLRO_HTTPHEADER)r. �destdirZ mirror_setup�handler� r3 r5 r6 r� s zOsmsRepo._handle_new_remote)T)rp rq rr r� r r� r� rt r5 r5 r3 r6 rU � s (rU 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_urlr )Zkey_url_stringZkey_urls�key_urlr5 r5 r6 r} s r} c @ s e Zd ZdS )r N)rp rq rr r5 r5 r5 r6 r ! s r c C sP | � d�}t|�dkrdS |\}}|�� dkr2dS tj�|�}|�d�sLdS dS )Nz://r F�filez/etc/pki/rpm-gpg/T)r� �len�lowerr r �normpathr� )r� Z proto_split�protor r5 r5 r6 r� % s r� c C s6 t �� }|�� rd S d|_|�t �� � |�| � d S )Nr )�logging� getLogger� hasHandlers� propagate� addHandler� NullHandler�setLevel)r2 Z root_loggerr5 r5 r6 r+ 4 s r+ ),r re ra r� r �sysr$ �dnf.conf.configr �dnf.exceptions�dnfpluginscorer r r� r �insertZosmsr r Z osms.i18nr Z osms.serverr r r r rM rL rN rQ r� r\ r� r( �Pluginr r[ �ReporU r} rJ r r� r+ r5 r5 r5 r6 �<module> sB � V