| Server IP : 172.24.0.40 / Your IP : 216.73.216.10 Web Server : Apache System : Linux dbweb26.ust.edu.ph 4.18.0-513.5.1.el8_9.x86_64 #1 SMP Fri Sep 29 05:21:10 EDT 2023 x86_64 User : apache ( 48) PHP Version : 8.2.18 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : ON Directory : /lib64/python3.6/site-packages/rhsmlib/services/__pycache__/ |
Upload File : |
3
a�e�X � @ s� d dl mZmZmZ d dlZd dlZd dlZd dlZd dlZd dl m
Z d dl m
Z d dl mZmZ d dlmZ d dlmZ d dlmZmZ d dljZeje�Z G d d
� d
e �Z dS ) � )�print_function�division�absolute_importN)� injection)�ugettext)�
managerlib�utils)�EntCertActionInvoker)� certificate)�
exceptions�productsc @ s� e Zd Zd dd�Zedd� �Zd dd�Zd d
d �Zd!d d
�Zd"dd�Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zd#d d �ZdS )$�EntitlementServiceNc C s< || _ tjtj�| _tjtj�| _tjtj�| _t � | _
d S )N) �cp�inj�require�IDENTITY�identityZPROD_DIRZ product_dirZENT_DIR�entitlement_dirr �
entcertlib)�selfr � r �#/usr/lib64/python3.6/entitlement.py�__init__# s
zEntitlementService.__init__c C sn yt j j|d�}W n4 tk
rF ttd�tjdtj� � d ��Y nX |j� t j j� j� k rjttd���|S )z�
Return new datetime parsed from date
:param on_date: String representing date
:return It returns datetime.datime structure representing date
z%Y-%m-%dzGDate entered is invalid. Date should be in YYYY-MM-DD format (example: z )zPast dates are not allowed) �datetimeZstrptime�
ValueError�_�timeZstrftimeZ localtimeZdate�now)�cls�on_dater r r �
parse_date* s $ z EntitlementService.parse_dateFc C s� t jt j|�}|j|kr ||_|dkrJtjd� t jt j�}d |_|j� |j � | j
j � r�|j � }|j
� }|jj� }|jj� }|j � } ||||| d�}
ntd�di i dd�}
tjdt|
� � |
S )NTz'Deleting cache entitlement status cache)�statusZ status_id�reasons�
reason_ids�validZUnknown�unknownFzentitlement status: %s)r r � CERT_SORTERr �log�debug�ENTITLEMENT_STATUS_CACHE�
server_status� delete_cache�loadr �is_validZget_system_statusZget_system_status_idr" Zget_name_message_mapZget_reason_ids_mapr �str) r r �force�sorter� status_cacheZoverall_statusZoverall_status_idr" r# r$ r! r r r �
get_status< s6
z EntitlementService.get_statusr c
K s, |
rt jtd�|
j� ��t|tj�r,|g}|s:dddg}||||||||| |
d�
}| j|� i }d|kr�tj | j
�j |dd�}dd � |D �|d< d|kr�| j ||dd
�}|r�d d � |D �|d< nd d � |D �|d< d|k�r(| j
||||||| |
t| �t| �dd
� }|�r dd � |D �|d< n||d< |S )NzUnknown arguments: %s� installed�consumed� available)
� pool_subsets�matches� pool_only�match_installed�
no_overlap�
service_level�show_allr �future�
after_dateT)� iso_datesc S s g | ] }|j � �qS r )�_asdict)�.0�xr r r �
<listcomp>� s z0EntitlementService.get_pools.<locals>.<listcomp>)r; r7 r? c S s g | ]}|j � d �qS )�pool_id)r@ )rA rB r r r rC � s c S s g | ] }|j � �qS r )r@ )rA rB r r r rC � s ) r< r r: r9 r7 r; r= r> �page�items_per_pager? c S s g | ] }|d �qS )�idr )rA rB r r r rC � s )r �ValidationErrorr �keys�
isinstance�sixZ string_types�validate_optionsr ZInstalledProductsr �list�get_consumed_product_pools�get_available_pools�int)r r6 r7 r8 r9 r: r; r< r r= r> rE rF �kwargs�options�resultsr3 r4 r5 r r r � get_poolsg sX
z EntitlementService.get_poolsc C s� t jddddddddd d
d d d
dddddg�}t jddddddddd d
d d dd
dddddddg�}tjtj�}|jj� }tjtj�}g } | jj � | jj
� }
t j ||d�} |d k s�|d k r�t
t
| j|
��}
|r�tj} ntj} �x�|
D �]�}
d}d}d}d}d}d}d}d}d}d}d}d}|
j}|�r�|j�p0d}|j�p<d}|
jjdk�r�|
jjdk�r�|j�pdd}|j�ppd}|j�p|d}n d }d }d }|j}|j }|j �p�d}|j �p�d}|j }|j �r�t!d �}nt!d �}|j"�r�t!d �}nt!d�}t!d �}t#|
j$d ��r|
j$j%}d!d"� |
j&D �}g } d} tjtj�j'� �r�|
j(�rnd#|
j(k�rn|
j(d# |k�rd||
j(d# } |j)|�} | �s�|
|j*k�r�| j+t!d$�� n:|
j,j-� t.j.j/t0j1� �k �r�| j+t!d%�� n| j+t!d&�� n| j+t!d'�� |d k�rB|d k�rB|d k�rB| j+|||||||
j2|||
j3� |||| | | |
j,j4� �| |
j,j-� �|�� q�| j+|||||||
j2|||
j3� ||||||| | | |
j,j4� �| |
j,j-� �|�� q�W | S )(N�OldConsumedStatusZsubscription_nameZprovides�sku�contract�account�serialrD �provides_managementZactive�
quantity_used� service_typer; Zstatus_detailsZsubscription_typeZstartsZends� system_type�ConsumedStatus�roles�usage�addons)�
filter_stringr; � ZNo� � ZVirtualZPhysicalZYesz
Not AvailablerG c S s i | ]}|j |j�qS r )�namerG )rA �pr r r �
<dictcomp> s zAEntitlementService.get_consumed_product_pools.<locals>.<dictcomp>ZCNzSubscription is currentzSubscription is expiredzSubscription has not begunz?Subscription management service doesn't support Status Details.)5� collections�
namedtupler r r& r" Z get_subscription_reasons_mapZPOOLTYPE_CACHEr �refreshrM r Z EntitlementCertificateFilter�filter�matchr Zformat_iso8601_dateZ format_date�orderr\ r; �version�major�minorr_ r` ra rf rV rW rX r[ Z virt_onlyr rZ �hasattrZpoolrG r Zare_reasons_supportedZsubject�getZvalid_entitlement_certs�appendZ valid_range�endr r r
ZGMTrY r- Zbegin) r r; r7 r? rU r^ r0 Zcert_reasons_mapZpooltype_cacheZconsumed_statusesZcertsZ cert_filterZdate_formatterZcertrf rV rW rX r[ r\ r_ r` ra r] rZ rn rD Zprovided_productsr" Z pool_typer r r rN � s"
z-EntitlementService.get_consumed_product_poolsc sL |dk r t | d �} d|
}
nd } }
d } }
|||||� ||| |
d�
}tjtj�}tjtj�}|j||�}t|�dkr�tj|||||||| |
| d�
}|j � }|j
||t j � | d�i}||_ |j
� � fdd�}� d k r�tt||��}|
dk�rH| |
|
}| d
|
|
}|dk�r |
}|||� }x |D ]}| |d < |
|d < �q.W |S )
a`
Get list of available pools
:param show_all:
:param on_date:
:param no_overlap:
:param match_installed:
:param matches:
:param service_level:
:param future:
:param after_date:
:param page:
:param items_per_page:
:param iso_dates:
:return:
Tre r )
r< r r: r9 r7 r; r= r> rE rF )
Zget_allZ active_onZ overlappingZ uninstalledrb r= r> rE rF r? )�filter_optionsZpools�timeoutc s$ d}| d r| d }� j � |j � kS )Nrc r; )�lower)Z pool_dataZ
pool_level)r; r r � filter_pool_by_service_level� s zLEntitlementService.get_available_pools.<locals>.filter_pool_by_service_levelN� rE rF )rP r r r ZAVAILABLE_ENTITLEMENT_CACHEZget_not_obsolete_data�lenr Zget_available_entitlementsrw �uuidr Zavailable_entitlementsZ write_cacherM rl )r r< r r: r9 r7 r; r= r> rE rF r? Z_pageZ_items_per_pagerv r �cacheZavailable_poolsrw �datary Zlo_idxZhi_idx�itemr )r; r rO X sd
z&EntitlementService.get_available_poolsc C sL t dddg�j|d �s&tjtd���|d rJd|d krJtjtd���n�|d rnd|d krntjtd ���n�|d
d k r�t ddg�j|d � r�tjtd ���n�|d r�d|d kr�tjtd
���n�|d r�d|d kr�tjtd���n^|d �r t ddg�j|d � �r tjtd���n*| jj� �rHd|d k�rHtjtd���d S )Nr3 r4 r5 r6 z_Error: invalid listing type provided. Only "installed", "consumed", or "available" are allowedr< z0Error: --all is only applicable with --availabler z3Error: --ondate is only applicable with --availabler; zGError: --servicelevel is only applicable with --available or --consumedr9 z<Error: --match-installed is only applicable with --availabler: z7Error: --no-overlap is only applicable with --availabler8 zHError: --pool-only is only applicable with --available and/or --consumedz$Error: this system is not registered)�set�
issupersetr rH r � intersectionr r- )r rR r r r rL � s2
z#EntitlementService.validate_optionsc C s| g }g }xj|D ]b}y|||� |j |� W q tjk
rn } z&|jdkrJ� |j |� tj|� W Y dd}~X qX qW ||fS )a(
Method for unbinding entitlements
:param unbind_method: unbindByPoolId or unbindBySerial
:param consumer_uuid: UUID of consumer
:param ids: List of serials or pool_ids
:return: Tuple of two lists containing unbinded and not-unbinded subscriptions
i� N)rt �
connectionZRestlibException�coder' �error)r Z
unbind_methodZ
consumer_uuidZids�successZfailureZid_�rer r r � _unbind_ids� s
z EntitlementService._unbind_idsc C s | j j| jj�}| jj� |S )zX
Try to remove all entilements
:return: Result of REST API call
)r Z unbindAllr r| r �update)r Zresponser r r �remove_all_entitlements� s
z*EntitlementService.remove_all_entitlementsc C sr g }t j|�}| jj� | jj|�}| j| jj| jj |�\}}|r^x|D ]}|j
|| � qHW | j j � |||fS )z�
Try to remove entitlements by pool IDs
:param pool_ids: List of pool IDs
:return: List of serial numbers of removed subscriptions
)
r �unique_list_itemsr rk Zlist_serials_for_pool_idsr� r ZunbindByPoolIdr r| �extendr r� )r Zpool_ids�removed_serialsZ _pool_idsZpool_id_to_serialsZ
removed_poolsZunremoved_poolsrD r r r � remove_entitlements_by_pool_ids s
z2EntitlementService.remove_entitlements_by_pool_idsc C s6 t j|�}| j| jj| jj|�\}}| jj� ||fS )z�
Try to remove pools by Serial numbers
:param serials: List of serial numbers
:return: List of serial numbers of already removed subscriptions
) r r� r� r ZunbindBySerialr r| r r� )r ZserialsZ_serialsr� Zunremoved_serialsr r r � remove_entitlements_by_serials s
z1EntitlementService.remove_entitlements_by_serialsc C s> t jt jdd�}t jt j�}tjd|j � d|_|j� dS )z�
This callback function is called, when there is detected any change in directory with entitlement
certificates (e.g. certificate is installed or removed)
:return:
N)r z#Clearing in-memory cache of file %s) r r r& r) r' r( Z
CACHE_FILEr* r, )r r0 r1 r r r �reload" s
zEntitlementService.reloadc C sn |dkr@t jt j�}|j� r$|j� t jt j�}|j� r@|j� |dkrd| jj| j j
d�sdt j d� | j
j� S )z�
Try to refresh entitlement certificate(s) from candlepin server
:return: Report of EntCertActionInvoker
TzOWarning: Unable to refresh entitlement certificates; service likely unavailable)r r ZCONTENT_ACCESS_CACHE�exists�removeZCONTENT_ACCESS_MODE_CACHEr+ r Z regenEntitlementCertificatesr r| r' r( r r� )r Z remove_cacher/ Zcontent_accessZcontent_access_moder r r rk . s
zEntitlementService.refresh)N)NF) NNNNNNNNNNr r )NNF) NNNNNNNNr r F)FF)�__name__�
__module__� __qualname__r � classmethodr r2 rT rN rO rL r� r� r� r� r� rk r r r r r
" s$
+
:
6
c#
r
) Z
__future__r r r ri r ZloggingrK r Zsubscription_managerr r Zsubscription_manager.i18nr r r r Z subscription_manager.entcertlibr Zrhsmr
Zrhsmlib.servicesr r Zrhsm.connectionr� Z getLoggerr� r' �objectr
r r r r �<module> s