| Server IP : 209.38.156.173 / Your IP : 216.73.216.122 [ Web Server : Apache/2.4.52 (Ubuntu) System : Linux lakekumayuhotel 5.15.0-136-generic #147-Ubuntu SMP Sat Mar 15 15:53:30 UTC 2025 x86_64 User : root ( 0) PHP Version : 8.1.2-1ubuntu2.22 Disable Function : NONE Domains : 2 Domains MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : ON Directory : /lib/python3/dist-packages/uaclient/entitlements/__pycache__/ |
Upload File : |
o
F��c�< � @ s� d dl Z d dlZd dlZd dlZd dlZd dlmZmZmZm Z m
Z
m Z d dl m
Z
mZmZmZmZmZmZ d dlmZ d dlmZ e�� ZG dd� dej�ZdS )� N)�Any�Dict�List�Optional�Tuple�Union)�apt�contract� event_logger�
exceptions�messages�system�util)�base)�ApplicationStatusc sT e Zd ZdZdZdZdZedee e
df fdd��Z ede e
fdd ��Z
defd
d �Zeejde
fd d
���Zd)dedefdd�Zd)dd�Zd)deddfdd�Zdeeeej f fdd�Zdd� Z d)de e
e f de e
e f dedef� fd d �
Z d*d ee e
d ed!eddfd"d#�Z d)deddfd$d%�Z! d+d&edefd'd(�Z"� Z#S ),�RepoEntitlementz*/etc/apt/sources.list.d/ubuntu-{name}.listz$/etc/apt/preferences.d/ubuntu-{name}NF�returnc C � d S �N� ��selfr r �</usr/lib/python3/dist-packages/uaclient/entitlements/repo.py�repo_pin_priority# s z!RepoEntitlement.repo_pin_priorityc C sJ g }| j jj�| ji ��di �}|r#|�di �}t�|�dg ��}|}|S )z debs to install on enablement� entitlement�
directives�additionalPackages)�cfg�machine_token_file� entitlements�get�name�copy)r �packagesr r �additional_packagesr r r r# ' s
��
�zRepoEntitlement.packagesc C s t jt| j�d�}t�|� |S )z%Check if system needs to be rebooted.)�installed_pkgs)r
�
should_reboot�setr# �event� needs_reboot)r �reboot_requiredr r r �_check_for_reboot: s
�
z!RepoEntitlement._check_for_rebootc C r r r r r r r �
repo_key_fileB s z RepoEntitlement.repo_key_file�silentc C s� | j |d� | jr2| jr2t| j�dkrdd�| j� nd}t�d�|�� t�t j
j| j d�� d
S | � � t�t j
j| j d�� | jdd � d
S ) z�Enable specific entitlement.
@return: True on success, False otherwise.
@raises: UserFacingError on failure to install suggested packages
�r- r z: � � z Skipping installing packages{}��title�install)� operationT)�setup_apt_config�supports_access_only� access_only�lenr# �joinr( �info�formatr �ACCESS_ENABLED_TMPLr2 �install_packages� ENABLED_TMPL�_check_for_reboot_msg)r r- � packages_strr r r �_perform_enableG s ��� z RepoEntitlement._perform_enablec C s" t | d�r | �� | j|d� dS )N�remove_packagesr. T)�hasattrrB �_cleanup�r r- r r r �_perform_disable] s
z RepoEntitlement._perform_disablec C s | j |d� dS )z4Clean up the entitlement without checks or messagingr. N)�remove_apt_configrE r r r rD c s zRepoEntitlement._cleanupc C s� | j jj�| ji �}|�di ��di �}|�d�}|s&tjtjj | j
d�fS t j tj
jd�}t�d� |�|�}|rDtjtjj | j
d�fS tjtjj | j
d�fS )Nr r �aptURLr1 )� error_msgz {}/ubuntu)r r r r r! r �DISABLEDr �NO_APT_URL_FOR_SERVICEr; r2 r �get_apt_cache_policy�APT_POLICY_FAILED�msg�re�search�ENABLED�SERVICE_IS_ACTIVE�SERVICE_NOT_CONFIGURED)r �entitlement_cfgr �repo_url�policy�matchr r r �application_statusg s,
� �
����z"RepoEntitlement.application_statusc C sP | j j| jd�}tdd� t�|��� �d�D ��rdS |s dS t|t�|�v �S )z�Check if apt url delta should be applied.
:param apt_url: string containing the apt url to be used.
:return: False if apt url is already found on the source file.
True otherwise.
�r! c s s � | ]}|� d �V qdS )�#N)�
startswith)�.0�liner r r � <genexpr>� s
� �
�z<RepoEntitlement._check_apt_url_is_applied.<locals>.<genexpr>�
FT) �repo_list_file_tmplr; r! �allr
� load_file�strip�split�bool)r �apt_url�apt_filer r r �_check_apt_url_is_applied� s �z)RepoEntitlement._check_apt_url_is_applied� orig_access�deltas� allow_enablec s t � �|||�r
dS |�di �}|�di �}|�d�}|�d�}| j�d�}|r/|r/| �� } n| �� \} }
| tjkr<dS | � |�sot
� d| j � |�di �} | �di ��d�} | rg| j
j| j d �}
t�|
| � | �� | �� |r�t
� d
�d �|��� | j|d � dS )
a1 Process any contract access deltas for this entitlement.
:param orig_access: Dictionary containing the original
resourceEntitlement access details.
:param deltas: Dictionary which contains only the changed access keys
and values.
:param allow_enable: Boolean set True if allowed to perform the enable
operation. When False, a message will be logged to inform the user
about the recommended enabled service.
:return: True when delta operations are processed; False when noop.
Tr r rH r z status-cacheFz5Updating '%s' apt sources list on changed directives.rY z-Installing packages on changed directives: {}�, )� package_list)�super�process_contract_deltasr r �
read_cache�"_check_application_status_on_cacherX r rJ rh �loggingr: r! r` r; r �remove_auth_apt_reporG r5 r9 r= )r ri rj rk �delta_entitlement�delta_directives�
delta_apt_url�delta_packages� status_cacherX �_�orig_entitlement�old_url�
repo_filename�� __class__r r ro � s@
� �� z'RepoEntitlement.process_contract_deltasTrm �cleanup_on_failure�verbosec C s� |s| j }|s dS | j�dg �}t�|�sdS |r#t�dj| jd�� | j r/ddi}g d�}ni }g }zt
j j| jd�}t j
|||j|d� W dS tjyW |rV| �� � w ) a) Install contract recommended packages for the entitlement.
:param package_list: Optional package list to use instead of
self.packages.
:param cleanup_on_failure: Cleanup apt files if apt install fails.
:param verbose: If true, print messages to stdout
N� pre_installzInstalling {title} packagesr1 �DEBIAN_FRONTEND�noninteractive)z--allow-downgradesz$-o Dpkg::Options::="--force-confdef"z$-o Dpkg::Options::="--force-confold")r# � apt_optionsrI �env)r# � messagingr r �handle_message_operationsr( r: r; r2 �apt_noninteractiver �ENABLED_FAILEDr �run_apt_install_commandrN r �UserFacingErrorrD )r rm r r� �msg_opsr� r� rN r r r r= � s6
��z RepoEntitlement.install_packagesc C s� d}d}d}| j js| j jr't�d| j jtj�}t�d| j jtj�}tjj }n | j j
s/| j j rGt�d| j j
tj�}t�d| j j tj�}tjj }tj
|||d� | jj| jd�}| j jj�| j�}|d �di �}|d �di �}|�d �} | s�| j jd
}
|�d �s�t�| j �} | �|
| j�} | r�| �d �} | s�|
} t�d | j� |�d
�}
|
s�t� d�| j���|�d�}|s�t� | j��|�d�}|s�t� d�| j| j j ���| j r�| j s�t� d�| j t!j"j| jd�j#���| j$j| jd�}t�%||| j | j � g }t&j'�(tj)��s |�*d� t&j'�(tj+��s|�*d� |�r>|�s't,�-d�d�.|��� ztj/|d� W n tj �y= | �0� � w t�1||| || j2� |�sQt,�-t!j3� zt�4� W dS tj �yh | j0dd� � w )z�Setup apt config based on the resourceToken and directives.
Also sets up apt proxy if necessary.
:raise UserFacingError: on failure to setup any aspect of this apt
configuration
N�http�https)�
http_proxy� https_proxy� proxy_scoperY r r � obligations�
resourceToken� machineToken�enableByDefaultzWNo resourceToken present in contract for service %s. Using machine token as credentials�aptKeyz6Ubuntu Pro server provided no aptKey directive for {}.rH �suitesz%Empty {} apt suites directive from {}z:Cannot setup apt pin. Empty apt repo origin value '{}'.
{}r1 zapt-transport-httpszca-certificatesz Installing prerequisites: {}rl )r# F)�run_apt_update)5r �global_apt_http_proxy�global_apt_https_proxyr �validate_proxy� PROXY_VALIDATION_APT_HTTP_URL� PROXY_VALIDATION_APT_HTTPS_URLr �
AptProxyScope�GLOBAL�ua_apt_http_proxy�ua_apt_https_proxy�UACLIENT�setup_apt_proxyr` r; r! r r r �
machine_tokenr �UAContractClient� request_resource_machine_accessrr �warningr2 r r� �MissingAptURLDirective� contract_urlr �originr r� rN �repo_pref_file_tmpl�add_ppa_pinning�os�path�exists�APT_METHOD_HTTPS_FILE�append�CA_CERTIFICATES_FILEr( r: r9 r� rG �add_auth_apt_repor, �APT_UPDATING_LISTS�run_apt_update_command)r r- r� r� �scoper| � resource_cfgr r� �tokenr� �client�machine_accessr� rU � repo_suites�repo_pref_file�prerequisite_pkgsr r r r5 s� ��
���
�
�
�
�����
��� � �z RepoEntitlement.setup_apt_configr� c C s� t �� d }| jj| jd�}| jjj| j �di �}|�di �}|�d�}|s-t �
| j��t � ||| j
� t �||� | jrK| jj| jd�}t �|� |r[|sUt�tj� t �� dS dS )z�Remove any repository apt configuration files.
:param run_apt_update: If after removing the apt update
command after removing the apt files.
�seriesrY r r rH N)r
�get_platform_infor` r; r! r r r r r r� r rs r, �remove_apt_list_filesr r� �ensure_file_absentr( r: r r� r� ) r r� r- r� r| r �access_directivesrU r� r r r rG � s& �
�z!RepoEntitlement.remove_apt_config)F)NTT)TF)$�__name__�
__module__� __qualname__r` r� r� r� �propertyr �int�strr r r# re r+ �abc�abstractmethodr, rA rF rD r r r r � NamedMessagerX rh r r ro r= r5 rG �
__classcell__r r r} r r sd
� �
�
���?�
���
�3 ���r ) r� r" rr r� rO �typingr r r r r r �uaclientr r r
r r r
r �uaclient.entitlementsr �(uaclient.entitlements.entitlement_statusr �get_event_loggerr( �
UAEntitlementr r r r r �<module> s $