a
}�f�& � @ s� d Z ddlmZ ddlZddlZddlZddlZddlmZ ddl
m Z m Z ddl
mZ e�e�Zedd� e jD ��Zd ed
< d ed < d
ed< ded< ded< ed ed< ded< ded< ded< ded< ed ed < ed ed < d ed < ed ed < d!ed"< ed" ed#< d$ed%< G d&d'� d'e j�ZG d(d)� d)e�ZG d*d+� d+e�ZG d,d-� d-e�Zd2d.d/�ZG d0d1� d1e j�Z e j Z eZ e � Z dS )3zD
Contains Red Hat OS family-specific service class implementations.
� )�absolute_importN)�services)�ipautil�dogtag)�pathsc c s | ]}|d | fV qdS )�
%s.serviceN� )�.0�xr r �?/usr/lib/python3.9/site-packages/ipaplatform/redhat/services.py� <genexpr>- s �r zrpc-gssd.serviceZrpcgssdznfs-idmapd.serviceZ rpcidmapdznis-domainname.serviceZ
domainnamezdirsrv@.service�dirsrvz pki-tomcatd@pki-tomcat.service� pki-tomcatd� pki_tomcatdzipa-otpd.socketzipa-otpdzipa-dnskeysyncd.servicezipa-dnskeysyncdz
named.servicez
named-regularznamed-pkcs11.servicez named-pkcs11Znamedznamed-conflictzods-enforcerd.servicez
ods-enforcerdZ
ods_enforcerdzods-signerd.servicez ods-signerdZ ods_signerdzgssproxy.serviceZgssproxyc s" e Zd ZeZd� fdd� Z� ZS )�
RedHatServiceNc sB |}|| j v r| j | }nd|vr*d| }tt| ��|||� d S )N�.r )� system_units�superr �__init__)�selfZ service_name�api� systemd_name�� __class__r r r T s
zRedHatService.__init__)N)�__name__�
__module__� __qualname__�redhat_system_unitsr r �
__classcell__r r r r r Q s r c sB e Zd Zdd� Zd � fdd� Zd
� fdd � Zejd
d � �Z� Z S )�RedHatDirectoryServicec C s d� tjd|�}tj�|�S )Nz{}/{}-{}Zslapd)�formatr Z
ETC_DIRSRV�os�path�exists)r �
instance_nameZ file_pathr r r � is_installedc s z#RedHatDirectoryService.is_installed� TFc s� |r�| j �d�}tj�tj| j �}tj�tj| j|d �}tj�|| �|��}tj� |�sh| �
|� n$tj� ||�s�t� |� t�
||� | �|||��&}tt| �j|||d� W d � n1 s�0 Y d S )N�@r ��capture_output�wait)r �splitr! r" �joinr ZETC_SYSTEMD_SYSTEM_DIRZSYSTEMD_SRV_TARGET�service_instancer# �enable�samefile�unlink�symlink� _RedHatDirectoryService__waitr r �restart) r r$ r) r* �ldapi�elementsZsrv_etcZsrv_tgtZsrv_lnkr r r r3 g s(
�
��
�z RedHatDirectoryService.restartc sH | � |||��&}tt| �j|||d� W d � n1 s:0 Y d S )Nr( )r2 r r �start)r r$ r) r* r4 r r r r6 � s
�z RedHatDirectoryService.startc c st |rB| � |�}|�d�r$|d d� }|�d�r:|dd � }|sBd}|rjdV tj| }t�|| jjj � n|V d S )Nz.servicei����r
� F)
r- �endswith�
startswithr Z SLAPD_INSTANCE_SOCKET_TEMPLATEr Zwait_for_open_socketr �env�startup_timeout)r r$ r* r4 Z socket_namer r r Z__wait� s
�z RedHatDirectoryService.__wait)r& TTF)r& TTF)
r r r r% r3 r6 �
contextlib�contextmanagerr2 r r r r r r a s � �r c s e Zd Zd� fdd� Z� ZS )�RedHatIPAServicer& c s t t| ��|� | �|� d S �N)r r> r. r3 )r r$ r r r r. � s zRedHatIPAService.enable)r& )r r r r. r r r r r r> � s r> c s& e Zd Zdd� Zd� fdd� Z� ZS )�RedHatCAServicec
C s� t �d� t| jjj�}t�� | }t�� |k r�zt�| jjj �}W n, t
yp } zd| }W Y d }~n
d }~0 0 t �d|� |dkr�q�t �d� t� d� q$t d| ��d S )Nz Waiting until the CA is runningz"check interrupted due to error: %szThe CA status is: %s�runningzWaiting for CA to start...� zCA did not start in %ss)
�logger�debug�floatr r: r; �timer � ca_status�host� Exception�sleep� RuntimeError)r �timeoutZ
op_timeout�status�er r r �wait_until_running� s
z"RedHatCAService.wait_until_runningr& Tc
s~ |rt t| ��|�S z4t�� }|dkr,W dS |dkrF|rF| �� W dS W n0 tyx } zt�d|� W Y d }~n
d }~0 0 dS )NrA TZstartingz Failed to check CA status: %sF) r r@ �
is_runningr rG rO rI rC rD )r r$ r* rM rN r r r rP � s
�zRedHatCAService.is_running)r& T)r r r rO rP r r r r r r@ � s r@ c C s@ | dkrt | |�S | dkr$t| |�S | dv r6t| |�S t| |�S )Nr
Zipa)r r )r r> r@ r )�namer r r r � redhat_service_class_factory� s
rR c s& e Zd Z� fdd�Zddd�Z� ZS )�RedHatServicesc s@ dd l }t� }tjD ]}| �||j�||< qtt| ��|� d S )Nr ) �ipalib�dict�
base_services�wellknownservices�service_class_factoryr r rS r )r rT r �sr r r r � s
zRedHatServices.__init__Nc C s
t ||�S r? )rR )r rQ r r r r rX � s z$RedHatServices.service_class_factory)N)r r r r rX r r r r r rS � s
rS )N) �__doc__Z
__future__r Zloggingr! rF r< Zipaplatform.baser rV Z ipapythonr r Zipaplatform.pathsr Z getLoggerr rC rU rW r ZSystemdServicer r r> r@ rR Z
KnownServicesrS Ztimedate_servicesZserviceZ
knownservicesr r r r �<module> sL
� @
(