File: //usr/lib/python3.9/site-packages/ipaplatform/base/__pycache__/services.cpython-39.pyc
a
�N(iiJ � @ s� d Z ddlmZ ddlZddlZddlZddlZddlZddlZddl m
Z
ddl m Z ddl
mZ ddlmZ e�e�Zg d�Zd gd
d gd
d gd
d gd �Zd
ZG dd� de�ZG dd� d�ZG dd� de�Zddd�ZeZei �Z g d�Z dS )zj
This base module contains default implementations of IPA interface for
interacting with system services.
� )�absolute_importN)�ipautil)�paths)�tasks)�Mapping) Z
certmonger�dirsrvZhttpdZipaZkrb5kdcZdbusZnslcdZnscd�ntpdZportmapZrpcbindZkadminZsshdZautofsZrpcgssdZ rpcidmapdZ pki_tomcatd�chronydZ
domainnameZnamedZ
ods_enforcerdZ ods_signerdZgssproxyz nfs-utilsZsssdZNetworkManagerz ipa-custodiazipa-dnskeysyncdzipa-otpdzipa-ods-exporterzsystemd-resolvedZunboundi� i� i� )r z pki-tomcatd@pki-tomcat.servicez
pki-tomcatz pki-tomcatdg�������?c @ s@ e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd d
� Z dS )�
KnownServicesz�
KnownServices is an abstract class factory that should give out instances
of well-known platform services. Actual implementation must create these
instances as its own attributes on first access (or instance creation)
and cache them.
c C s
|| _ d S �N��_KnownServices__d)�self�d� r �=/usr/lib/python3.9/site-packages/ipaplatform/base/services.py�__init__N s zKnownServices.__init__c C s
| j | S r r )r �keyr r r � __getitem__Q s zKnownServices.__getitem__c C s
t | j�S r )�iterr
�r r r r �__iter__T s zKnownServices.__iter__c C s
t | j�S r )�lenr
r r r r �__len__W s zKnownServices.__len__c C s t �| j�S r )�sixZ
itervaluesr
r r r r �__call__Z s zKnownServices.__call__c C s, z | j | W S ty& t|��Y n0 d S r )r
�KeyError�AttributeError)r �namer r r � __getattr__] s zKnownServices.__getattr__N)
�__name__�
__module__� __qualname__�__doc__r r r r r r r r r r r
G s r
c @ s� e Zd ZdZd%dd�Zd&dd�Zd'd d
�Zd(d d �Zd)d
d�Zd*dd�Z d+dd�Z
dd� Z d,dd�Z d-dd�Z
d.dd�Zd/dd �Zd0d d �Zd1d d �Zd2d!d"�Zd3d#d$�ZdS )4�PlatformServicez�
PlatformService abstracts out external process running on the system
which is possible to administer (start, stop, check status, etc).
Nc C sB dd l }|| _|d ur || _n |j| _tjdj| d�tdd� d S )Nr zC{s.__class__.__name__}('{s.service_name}', api=None) is deprecated.)�s� )�
stacklevel)�ipalib� service_name�api�warnings�warn�format�RuntimeWarning)r r) r* r( r r r r k s ��zPlatformService.__init__� Tc C s� |sdS g }z:t tjd��}t�|�}W d � n1 s:0 Y W n tyX Y n0 | j|vrp|�| j� t tjd�� }t�||� W d � n1 s�0 Y dS )z�
When a service is started record the fact in a special file.
This allows ipactl stop to always stop all services that have
been started via ipa tools
N�r�w) �openr �
SVC_LIST_FILE�json�load� Exceptionr) �append�dump)r �
instance_name�capture_output�wait�update_service_list�svc_list�fr r r �starty s ,
zPlatformService.startc C s� |sdS g }z:t tjd��}t�|�}W d � n1 s:0 Y W n tyX Y n0 | j|v rr|�| j� qZt tjd�� }t�||� W d � n1 s�0 Y dS )zQ
When a service is stopped remove it from the service list file.
Nr0 r1 ) r2 r r3 r4 r5 r6 r) �remover8 )r r9 r: r< r= r> r r r �stop� s ,
zPlatformService.stopc C s d S r r �r r9 r: r; r r r �reload_or_restart� s z!PlatformService.reload_or_restartc C s d S r r rB r r r �restart� s zPlatformService.restartc C s d S r r rB r r r � try_restart� s zPlatformService.try_restartc C s dS �NFr )r r9 r; r r r �
is_running� s zPlatformService.is_runningc C s dS rF r r r r r � is_installed� s z PlatformService.is_installedc C s dS rF r �r r9 r r r �
is_enabled� s zPlatformService.is_enabledc C s dS rF r rI r r r � is_masked� s zPlatformService.is_maskedc C s d S r r rI r r r �enable� s zPlatformService.enablec C s d S r r rI r r r �disable� s zPlatformService.disablec C s d S r r rI r r r �mask� s zPlatformService.maskc C s d S r r rI r r r �unmask� s zPlatformService.unmaskc C s d S r r rI r r r �install� s zPlatformService.installc C s d S r r rI r r r r@ � s zPlatformService.remove)N)r/ TTT)r/ TT)r/ TT)r/ TT)r/ TT)r/ T)r/ )r/ )r/ )r/ )r/ )r/ )r/ )r/ )r r! r" r# r r? rA rC rD rE rG rH rJ rK rL rM rN rO rP r@ r r r r r$ d s.
�
�
�
r$ c s� e Zd ZdZd0� fdd� Zd1dd�Zd2dd�Zd3d
d �Zd4� fd
d� Zd5� fdd� Z d6dd�Z
d7dd�Z d8dd�Z d9dd�Z
d:dd�Zd d � Zd;d d �Zd<d d!�Zd=d"d#�Zd>d$d%�Zd?d&d'�Zd@d(d)�ZdAd*d+�Zd,d-� Zd.d/� Z� ZS )B�SystemdServicez%s.target.wantsNc s8 t t| �j||d� || _tj�tj| j�| _ d | _
d S )N)r* ) �superrQ r � systemd_name�os�path�joinr �LIB_SYSTEMD_SYSTEMD_DIR�lib_path�lib_path_exists)r r) rS r* �� __class__r r r � s
�zSystemdService.__init__c C s� | j d u rtj�| j�| _ | j�d�}|d dkrP|sPdt| jj j
� dd�� S | j r�|r�t |�dkrl| jS t |�dkr�|d d dkr�| jS t |�dkr�|r�d|d |f S d |d }tj�
tj|�}tj�|�r�|S | jS )
N�@r r zdirsrv@%s.service�.�-� z
%s@%s.servicez %s.target)rY rT rU �existsrX rS �split�strr* �envZrealm�replacer rV r rW )r r9 � operation�elementsZtgt_nameZsrv_libr r r �service_instance� s(
�
z SystemdService.service_instancec s( ddd��t � �fdd�|�d�D ��S )a
Parses 'systemctl show' output and returns a dict[variable]=value
Arguments: text -- 'systemctl show' output as string
separator -- optional (defaults to None), what separates
the key/value pairs in the text
Nc S s* t | �dkr&| �|�}|d |d fS dS )Nr_ r ���)NN)r ra )�x� separator�yr r r �splitter s
z0SystemdService.parse_variables.<locals>.splitterc 3 s | ]}�|� d �V qdS ))rj Nr )�.0ri �rj rl r r � <genexpr>
� z1SystemdService.parse_variables.<locals>.<genexpr>�
)N)�dictra )r �textrj r rn r �parse_variables� s
z SystemdService.parse_variablesr/ c C sV d}|t v rt | }n$| j�d�}|d t v r:t |d }|rRt�d|| jjj� dS )zA
If this is a service we need to wait for do so.
Nr\ r Z localhost)�wellknownportsrS ra r �wait_for_open_portsr* rc Zstartup_timeout)r r9 Zportsrf r r r rv s
�z"SystemdService.wait_for_open_portsTc s� | � |�}tjd|g}|dkr(|�d� |dkr:|�d� tj|| d� t| jjdd �dv }t t
| �j ||d � t �
d
|� d S ) NrA zipa-otpd.socketz--ignore-dependencieszipa-ods-exporter.servicezipa-ods-exporter.socket�Z skip_output�context�ZipactlZ installer�r< zStop of %s complete)rg r � SYSTEMCTLr7 r �run�getattrr* rc rR rQ rA �logger�debug)r r9 r: �instance�argsr< rZ r r rA s"
��
�zSystemdService.stopc sz t jtjd| �|�g| d� t| jjdd �dv }|rP| �|�rP| � | �|�� t
t | �j ||d� t
�d| �|�� d S )Nr? rw rx ry rz zStart of %s complete)r r| r r{ rg r} r* rc rG rv rR rQ r? r~ r )r r9 r: r; r< rZ r r r? 3 s&
��
��
��zSystemdService.startFc C sR t jtj|| �|�g| d� |r<| �|�r<| �| �|�� t�d| �|�� d S )Nrw zRestart of %s complete) r r| r r{ rg rG rv r~ r )r r9 re r: r; r r r �
_restart_baseC s
���z SystemdService._restart_basec C s | � |d||� d S )Nzreload-or-restart�r� rB r r r rC O s �z SystemdService.reload_or_restartc C s | � |d||� d S )NrD r� rB r r r rD T s �zSystemdService.restartc C s | � |d||� d S )Nz try-restartr� rB r r r rE X s �zSystemdService.try_restartc
C s� | � |d�}ztjtjd|gdd�}W nV tjy| } z<|jdkrfdt|j�v rft �
t � W Y d }~q W Y d }~dS d }~0 0 |jdkr�d|jv r�t �
t � q |jdkr�dS dS q d S )Nz is-activeT�r: � Z
activatingFr ) rg r r| r r{ �CalledProcessError�
returncoderb �output�time�sleep�SERVICE_POLL_INTERVAL)r r9 r; r� �result�er r r rG \ s"
�
zSystemdService.is_runningc C sf zJt jtjddgdd�}|jdkr(W dS | �|j�}| �d�|vrHW dS W n t jy` Y dS 0 dS )Nzlist-unit-filesz--fullTr� r Fr/ ) r r| r r{ r� rt r� rg r� )r r� Zsvarr r r rH u s
�
zSystemdService.is_installedc C sL d}z*t �tjd| �|�g�}|jdkr,d}W n t jyF d}Y n0 |S )NT�
is-enabledr F)r r| r r{ rg r� r� )r r9 Zenabledr� r r r rJ � s ��
zSystemdService.is_enabledc C sV d}z8t jtjd| �|�gdd�}|jdkr:|jdkr:d}W n t jyP Y n0 |S )NFr� Tr� r_ �masked)r r| r r{ rg r� r� r� )r r9 r� r� r r r rK � s ��zSystemdService.is_maskedc C sh | j d u rtj�| j�| _ | j�d�}t|�}| j rZ|dkrZ|d d dkrZ| �|� d S | j rt|dkrt| �� d S t|�dk�rZ|dk�rZtj� t
j | j |d �}tj� || �
|��}z�tj�|�s�t�|� t�|d� tj�|�r�t�|� tj�|��s8tj�|��s t�| j|� nt�|� t�| j|� t�� W n t�yV Y n0 n
| �|� d S )Nr\ r_ r r] i� )rY rT rU r` rX rS ra r �_SystemdService__enablerV r �ETC_SYSTEMD_SYSTEM_DIR�SYSTEMD_SRV_TARGETrg �isdir�mkdir�chmod�unlink�islink�symlinkr �systemd_daemon_reloadr6 )r r9 rf �l�srv_tgt�srv_lnkr r r rL � s@
��
zSystemdService.enablec C s� | j �d�}|dkr�t|�dkr�tj�tj| j|d �}tj�|| � |��}z.tj�
|�rrtj� |�rrt� |� t
�� W q� ty� Y q�0 n2z t�tjd| � |�g� W n tjy� Y n0 d S )Nr\ r/ r_ r rM )rS ra r rT rU rV r r� r� rg r� r� r� r r� r6 r r| r{ r� )r r9 rf r� r� r r r rM � s*
��
�
zSystemdService.disablec C sb t j�tj| �|��}t j�|�r,t �|� z t� tj
d| �|�g� W n tj y\ Y n0 d S )NrN ) rT rU rV r r� rg r` r� r r| r{ r� )r r9 r� r r r rN � s
�
zSystemdService.maskc C s6 z t �tjd| �|�g� W n t jy0 Y n0 d S )NrO �r r| r r{ rg r� rI r r r rO � s
�
zSystemdService.unmaskc C s6 z t �tjd| �|�g� W n t jy0 Y n0 d S )NrL r� rI r r r Z__enable s
�
zSystemdService.__enablec C s | � � d S r )rL r r r r rP s zSystemdService.installc C s | � � d S r )rM r r r r r@ s zSystemdService.remove)N)N)N)r/ )r/ T)r/ TT)TF)r/ TT)r/ TT)r/ TT)r/ T)r/ )r/ )r/ )r/ )r/ )r/ )r/ )r r! r" r� r rg rt rv rA r? r� rC rD rE rG rH rJ rK rL rM rN rO r� rP r@ �
__classcell__r r rZ r rQ � s4
$
�
�
5
rQ c C s t �d S r )�NotImplementedError)r r* r r r �base_service_class_factory s r� )r r zsystemd-timesyncd)N) r# Z
__future__r rT r4 r� Zloggingr+ r Z ipapythonr Zipaplatform.pathsr Zipaplatform.tasksr �collections.abcr Z getLoggerr r~ Zwellknownservicesru r� r
r$ rQ r� ZserviceZ
knownservicesZtimedate_servicesr r r r �<module> s8
� j H