File: //usr/lib/python3.9/site-packages/ipalib/__pycache__/backend.cpython-39.opt-1.pyc
a
}�fl � @ s� d Z ddlZddlZddlZddlmZ ddlmZmZm Z ddl
m Z m Z m
Z
e�e�ZG dd� dej�ZG dd � d e�ZG d
d � d e�ZdS ) z*
Base classes for all backed-end plugins.
� N)�plugable)� PublicError�
InternalError� CommandError)�context�
Connection�destroy_contextc @ s e Zd ZdZdS )�Backendz-
Base class for all backend plugins.
N)�__name__�
__module__� __qualname__�__doc__� r r �2/usr/lib/python3.9/site-packages/ipalib/backend.pyr # s r c @ sR e Zd ZdZddd�Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
e e
�Z dS )� Connectiblea$
Base class for backend plugins that create connections.
In addition to the nicety of providing a standard connection API, all
backend plugins that create connections should use this base class so that
`request.destroy_context()` can properly close all open connections.
Fc C s6 t �| |� |r| j| _nd| jtt| ��f | _d S )Nz%s_%s)r �__init__�name�id�str)�selfZapiZshared_instancer r r r 2 s
zConnectible.__init__c O s` t t| j�r(td�| j| jt�� j���| j|i |��}t t| jt
|| j �� t �
d| j� dS )z1
Create thread-local connection.
z%{0} is already connected ({1} in {2})z Created connection context.%sN)�hasattrr r � Exception�formatr � threading�current_thread�create_connection�setattrr �
disconnect�logger�debug)r �args�kw�connr r r �connect9 s ��zConnectible.connectc O s t d| j ��d S )Nz%s.create_connection()��NotImplementedErrorr )r r r! r r r r J s z Connectible.create_connectionc C sN t t| j�s(td�| j| jt�� j���| �� t t| j� t
� d| j� d S )N�!{0} is not connected ({1} in {2})z Destroyed connection context.%s) r r r r r r r r �destroy_connection�delattrr r �r r r r r M s �� zConnectible.disconnectc C s t d| j ��d S )Nz%s.destroy_connection()r$ r) r r r r' Z s z Connectible.destroy_connectionc C s t t| j�S )zY
Return ``True`` if thread-local connection on `request.context` exists.
)r r r r) r r r � isconnected] s zConnectible.isconnectedc C s6 t t| j�s(td�| j| jt�� j���tt| j�j S )z1
Return thread-local connection.
r& )
r r r �AttributeErrorr r r r �getattrr" r) r r r Z
__get_connc s ��zConnectible.__get_connN)F)
r
r r r
r r# r r r' r* Z_Connectible__get_conn�propertyr" r r r r r ) s
r c @ s& e Zd Zddd�Zdd� Zdd� ZdS ) � ExecutionerNc C sT |dur|t jd< | jjr0| jjj|ddd� n | jj�� |durPtt d|� dS )zA
client_ip: The IP address of the remote client.
NZ
KRB5CCNAME)�ccacheZ
size_limitZ
time_limit� client_ip)
�os�environ�envZ in_serverr Zldap2r# Z rpcclientr r )r r/ r0 r r r �create_contextu s
� zExecutioner.create_contextc C s
t � d S )N)r r) r r r r � s zExecutioner.destroy_contextc
O s� z�z2|| j vrt|d��| j | |i |��W W t� S tyH � Y n@ ty� } z(t�d|jjt |�� t
� �W Y d }~n
d }~0 0 W t� nt� 0 d S )N)r znon-public: %s: %s) ZCommandr r r r r � exception� __class__r
r r )r �_namer �options�er r r �execute� s
� � zExecutioner.execute)NN)r
r r r4 r r: r r r r r. s s
r. )r
Zloggingr r1 Zipalibr Z
ipalib.errorsr r r Zipalib.requestr r r Z getLoggerr
r ZPluginr r r. r r r r �<module> s
J