File: //usr/lib64/python3.9/site-packages/rhsmlib/dbus/objects/__pycache__/syspurpose.cpython-39.pyc
a
X�Zh� � @ s� d Z ddlmZ ddlZddlZddlZddlmZmZm Z m
Z
ddl m Z ddl
mZ ddlmZ ddlmZ dd lmZ er�dd
lmZ e� e�e�ZG d d � d ej�ZG d
d� dej�Z G dd� dej �Z dS )z�
This module contains implementation of D-Bus object representing system purpose.
It uses interface: com.redhat.RHSM1.Syspurpose and path:
/com/redhat/RHSM1/Syspurpose
� )�
TYPE_CHECKINGN)� constants� base_object�util�
dbus_utils)�
syspurpose)�SyspurposeStore)�init_dep_injection)� ungettext)�Locale)�
UEPConnectionc @ s2 e Zd ZdZdej ZdZdZdd� Z dd� Z
d S )
�ThreeWayMergeConflictz@
Raise this exception, when client application tries to
z%s.ErrorF�warnc C s
|| _ dS )z�
Initialize this exception
:param conflict_fields: dictionary with conflicted attributes.
The key is attribute and value is current value set on server.
N��conflict_fields)�selfr � r �E/usr/lib64/python3.9/site-packages/rhsmlib/dbus/objects/syspurpose.py�__init__2 s z ThreeWayMergeConflict.__init__c C sN g }| j �� D ] \}}|�dj||d�� qd�|�}tddt|��j|d�S )zW
Text representation of exception
:return: string of exception
z%{conflict_attr} of "{existing_value}")Z
conflict_attrZexisting_valuez, zuWarning: The following field was recently set for this system by the entitlement server administrator: {conflict_msg}zwWarning: The following fields were recently set for this system by the entitlement server administrator: {conflict_msg})� conflict_msg)r �items�append�format�joinr
�len)r � conflicts�key�valuer r r r �__str__: s ��
��z ThreeWayMergeConflict.__str__N) �__name__�
__module__� __qualname__�__doc__r �SYSPURPOSE_INTERFACEZ_dbus_error_nameZinclude_tracebackZseverityr r r r r r r
) s
r
c @ sF e Zd Zed�dd�Zed�dd�Zed�dd�Zeed�d d
�Zd S ) � SyspurposeDBusImplementation)�returnc
C sP d}t �|�}z
|j}W n2 tyJ } zt�t|���W Y d }~n
d }~0 0 |S )Nz$/etc/rhsm/syspurpose/syspurpose.json)r �read�contents� Exception�dbus�
DBusException�str)r Zsystem_purpose_path�storer' �excr r r �get_system_purposeT s
$z/SyspurposeDBusImplementation.get_system_purposec C s. | � i �}t�|�}|�� d }|�|�}|S )N�status)� build_uepr �
SyspurposeZget_syspurpose_statusZget_overall_status)r �uep�system_purposeZ
raw_statusr/ r r r �get_system_purpose_status_ s
z6SyspurposeDBusImplementation.get_system_purpose_statusc C sF | � i �}t�|�}|�� }|d u rB| �� r8t�d��n
t�d��|S )Nz*Unable to get valid system purpose fields.zHUnable to get valid system purpose fields. The system is not registered.)r0 r r1 Z!get_owner_syspurpose_valid_fieldsZ
is_registeredr) r* )r r2 r3 � valid_fieldsr r r �get_valid_fieldsh s
�z-SyspurposeDBusImplementation.get_valid_fields)�valuesr% c C sb | � i �}t�|�}|�|�}i }|�� D ]$\}}||v r*|| |kr*|||< q*|r^t|d��|S )Nr )r0 r r1 Zset_syspurpose_valuesr r
)r r7 r2 r3 �
new_valuesr r r r r r �set_system_purposex s
z/SyspurposeDBusImplementation.set_system_purposeN) r r r! �dictr. r+ r4 r6 r9 r r r r r$ S s r$ c s� e Zd ZdZejZejZd� fdd� Z e
j ejddd�e
j e
j
ddd����Ze
j ejddd�e
j
dd d
���Ze
j ejddd�e
j
dd d ���Ze
j ejd
dd�e
j e
j
dd� ���Ze
jejdd�e
j
dd� ��Z� ZS )�SyspurposeDBusObjectzs
A D-Bus object interacting with subscription-manager to get
information about current system purpose.
Nc s" t t| �j|||d� t� | _d S )N)�conn� object_path�bus_name)�superr; r r$ �impl)r r< r= r> �� __class__r r r � s z SyspurposeDBusObject.__init__�s)Z in_signatureZ
out_signaturec C s, t j|td�}t�|� | j�� }t�|�S )z�
D-Bus method for getting current system purpose
:param locale: string with locale
:param sender:
:return: json representation of system purpose contents
�Z
expected_type) r �dbus_to_pythonr+ r �setr@ r. �json�dumps)r �locale�senderr3 r r r �
GetSyspurpose� s
z"SyspurposeDBusObject.GetSyspurposec C s& t j|td�}t�|� | j�� }|S )z�
D-Bus method for getting system purpose status
:param locale: string representing locale
:param sender: object representing application which called this method
:return:
rD )r rE r+ r rF r@ r4 )r rI rJ r/ r r r �GetSyspurposeStatus� s
z(SyspurposeDBusObject.GetSyspurposeStatusc C s, t j|td�}t�|� | j�� }t�|�S )a
Method for getting valid syspurpose attributes and values
:param locale: string with locale
:param sender: object representing application which called this method
:return: string representing dictionary with valid fields
rD ) r rE r+ r rF r@ r6 rG rH )r rI rJ r5 r r r �GetValidFields� s
z#SyspurposeDBusObject.GetValidFieldsza{sv}sc C s< t j|td�}t j|td�}t�|� | j�|�}t� |�S )a/
Set syspurpose values
:param syspurpose_values: Dictionary with all syspurpose values
:param locale: String with locale
:param sender: Object representing client application that called this method
:return: String with successfully set syspurpose values
rD )
r rE r: r+ r rF r@ r9 rG rH )r Zsyspurpose_valuesrI rJ r8 r r r �
SetSyspurpose� s
z"SyspurposeDBusObject.SetSyspurpose� )Z signaturec C s t �dtj � dS )z{
Signal fired, when system purpose is created/deleted/changed
:param sender:
:return: None
zD-Bus signal %s emittedN)�log�debugr r# )r r r r �SyspurposeChanged� s z&SyspurposeDBusObject.SyspurposeChanged)NNN)N)N)N)r r r! r" r ZSYSPURPOSE_DBUS_PATHZdefault_dbus_pathr# Zinterface_namer r Zdbus_service_methodZdbus_handle_senderZdbus_handle_exceptionsrK rL rM rN Zdbus_service_signalrR �
__classcell__r r rA r r; � sP �
�
�
��r; ) r" �typingr r) rG ZloggingZ rhsmlib.dbusr r r r Zrhsmlib.servicesr Zsyspurpose.filesr Z"subscription_manager.injectioninitr Zsubscription_manager.i18nr
r Zrhsm.connectionr Z getLoggerr rP r* r
ZBaseImplementationr$ Z
BaseObjectr; r r r r �<module> s"
*5