File: //lib64/python3.6/site-packages/ldap/__pycache__/syncrepl.cpython-36.pyc
3
�`a�H � @ s� d Z ddlmZ ddlmZmZmZmZmZ ddl m
Z
m Z ddl m
Z
mZmZ ddlmZmZmZ dgZG dd � d ej�ZG d
d � d ej�ZG d d
� d
ej�ZG dd� dej�ZG dd� de�Z G dd� dej�Z G dd� dej�Z G dd� de�Z e ee j < G dd� dej�Z!G dd� de�Z"e"ee"j < G d d � d ej�Z#G d d � d ej�Z$G d d!� d!ej%�Z&G d"d#� d#ej�Z'G d$d%� d%ej(�Z)G d&d'� d'�Z*G d(d� d�Z+d)S )*zz
ldap.syncrepl - for implementing syncrepl consumer (see RFC 4533)
See https://www.python-ldap.org/ for project details.
� )�UUID)�tag� namedtype�namedval�univ�
constraint)�encoder�decoder)� __version__�
__author__� __license__)�RequestControl�ResponseControl�KNOWN_RESPONSE_CONTROLS�SyncreplConsumerc @ s e Zd ZdZejdd�ZdS )�SyncUUIDz.
syncUUID ::= OCTET STRING (SIZE(16))
� N)�__name__�
__module__� __qualname__�__doc__r ZValueSizeConstraint� subtypeSpec� r r � /usr/lib64/python3.6/syncrepl.pyr s r c @ s e Zd ZdZdS )�
SyncCookiez%
syncCookie ::= OCTET STRING
N)r r r r r r r r r s r c @ s0 e Zd ZdZejdd�Zejj e
j dd� Z dS ) �SyncRequestModez�
mode ENUMERATED {
-- 0 unused
refreshOnly (1),
-- 2 reserved
refreshAndPersist (3)
},
� refreshOnly� �refreshAndPersist� N)r r )r r ) r r r r r � NamedValues� namedValuesr �
Enumeratedr r �SingleValueConstraintr r r r r # s
r c @ s@ e Zd ZdZejejde� �ejde � �ej
de j d���Z
dS )�SyncRequestValuea:
syncRequestValue ::= SEQUENCE {
mode ENUMERATED {
-- 0 unused
refreshOnly (1),
-- 2 reserved
refreshAndPersist (3)
},
cookie syncCookie OPTIONAL,
reloadHint BOOLEAN DEFAULT FALSE
}
�mode�cookie�
reloadHintFN)r r r r r �
NamedTypes� NamedTyper �OptionalNamedTyper �DefaultedNamedTyper �Boolean�
componentTyper r r r r$ 3 s
r$ c @ s& e Zd ZdZdZd dd�Zd d
� ZdS ) �SyncRequestControlan
The Sync Request Control is an LDAP Control [RFC4511] where the
controlType is the object identifier 1.3.6.1.4.1.4203.1.9.1.1 and the
controlValue, an OCTET STRING, contains a BER-encoded
syncRequestValue. The criticality field is either TRUE or FALSE.
[..]
The Sync Request Control is only applicable to the SearchRequest
Message.
z1.3.6.1.4.1.4203.1.9.1.1r Nr Fc C s || _ || _|| _|| _d S )N)� criticalityr& r% r' )�selfr/ r& r% r' r r r �__init__S s zSyncRequestControl.__init__c C sX t � }|jdt| j�� | jd k r4|jdt| j�� | jrN|jdtj| j�� t j
|�S )Nr% r& r' ) r$ ZsetComponentByNamer r% r& r r' r r, r �encode)r0 Zrcvr r r �encodeControlValueY s
z%SyncRequestControl.encodeControlValue)r Nr F)r r r r � controlTyper1 r3 r r r r r. G s
r. c @ s8 e Zd ZdZejd d d
d�Zejj e
j dddd � Z d
S )� SyncStateOpz�
state ENUMERATED {
present (0),
add (1),
modify (2),
delete (3)
},
�presentr �addr �modify� �deleter N)r6 r )r7 r )r8 r9 )r: r ) r r r r r r r! r r" r r r# r r r r r5 c s r5 c @ s< e Zd ZdZejejde� �ejde� �ej de
� ��Z dS )�SyncStateValuea
syncStateValue ::= SEQUENCE {
state ENUMERATED {
present (0),
add (1),
modify (2),
delete (3)
},
entryUUID syncUUID,
cookie syncCookie OPTIONAL
}
�state� entryUUIDr& N) r r r r r r( r) r5 r r* r r- r r r r r; u s
r; c @ s e Zd ZdZdZd
Zdd� Zd S ) �SyncStateControlam
The Sync State Control is an LDAP Control [RFC4511] where the
controlType is the object identifier 1.3.6.1.4.1.4203.1.9.1.2 and the
controlValue, an OCTET STRING, contains a BER-encoded SyncStateValue.
The criticality is FALSE.
[..]
The Sync State Control is only applicable to SearchResultEntry and
SearchResultReference Messages.
z1.3.6.1.4.1.4203.1.9.1.2r6 r7 r8 r: c C s� t j|t� d�}|d jd�}tt|d jd��d�}|d jd�}|d k r`|j� r`t|�| _nd | _| j j
t |� | _ t|�| _
d S )N)�asn1Specr r< r= )�bytesr& )r �decoder; �getComponentByNamer r@ �hasValue�strr& � __class__�opnames�intr< r= )r0 �encodedControlValue�dr< �uuidr& r r r �decodeControlValue� s z#SyncStateControl.decodeControlValueN)r6 r7 r8 r: )r r r r r4 rF rK r r r r r> � s r> c @ s4 e Zd ZdZejejde� �ejde j
d���Z dS )�
SyncDoneValuez�
syncDoneValue ::= SEQUENCE {
cookie syncCookie OPTIONAL,
refreshDeletes BOOLEAN DEFAULT FALSE
}
r& �refreshDeletesFN) r r r r r r( r* r r+ r r, r- r r r r rL � s rL c @ s e Zd ZdZdZdd� ZdS )�SyncDoneControlaT
The Sync Done Control is an LDAP Control [RFC4511] where the
controlType is the object identifier 1.3.6.1.4.1.4203.1.9.1.3 and the
controlValue contains a BER-encoded syncDoneValue. The criticality
is FALSE (and hence absent).
[..]
The Sync Done Control is only applicable to the SearchResultDone
Message.
z1.3.6.1.4.1.4203.1.9.1.3c C sd t j|t� d�}|d jd�}|j� r2t|�| _nd | _|d jd�}|j� rZt|�| _nd | _d S )N)r? r r& rM ) r rA rL rB rC rD r& �boolrM )r0 rH rI r& Zrefresh_deletesr r r rK � s z"SyncDoneControl.decodeControlValueN)r r r r r4 rK r r r r rN � s rN c @ s4 e Zd ZdZejejde� �ejde j
d���Z dS )�
RefreshDeletez�
refreshDelete [1] SEQUENCE {
cookie syncCookie OPTIONAL,
refreshDone BOOLEAN DEFAULT TRUE
},
r& � refreshDoneTN) r r r r r r( r* r r+ r r, r- r r r r rP � s rP c @ s4 e Zd ZdZejejde� �ejde j
d���Z dS )�RefreshPresentz�
refreshPresent [2] SEQUENCE {
cookie syncCookie OPTIONAL,
refreshDone BOOLEAN DEFAULT TRUE
},
r& rQ TN) r r r r r r( r* r r+ r r, r- r r r r rR � s rR c @ s e Zd ZdZe� ZdS )� SyncUUIDsz(
syncUUIDs SET OF syncUUID
N)r r r r r r- r r r r rS � s rS c @ s@ e Zd ZdZejejde� �ejde j
d��ej de � ��Z
dS )� SyncIdSetz�
syncIdSet [3] SEQUENCE {
cookie syncCookie OPTIONAL,
refreshDeletes BOOLEAN DEFAULT FALSE,
syncUUIDs SET OF syncUUID
}
r& rM F� syncUUIDsN)r r r r r r( r* r r+ r r, r) rS r- r r r r rT � s
rT c @ s� e Zd ZdZejejde� je j
e j e j d�d��ejde
� je j
e j e j d�d��ejde� je j
e j e j d�d��ejd e� je j
e j e j d
�d���Zd S ) �
SyncInfoValuea`
syncInfoValue ::= CHOICE {
newcookie [0] syncCookie,
refreshDelete [1] SEQUENCE {
cookie syncCookie OPTIONAL,
refreshDone BOOLEAN DEFAULT TRUE
},
refreshPresent [2] SEQUENCE {
cookie syncCookie OPTIONAL,
refreshDone BOOLEAN DEFAULT TRUE
},
syncIdSet [3] SEQUENCE {
cookie syncCookie OPTIONAL,
refreshDeletes BOOLEAN DEFAULT FALSE,
syncUUIDs SET OF syncUUID
}
}
� newcookier )Z implicitTag�
refreshDeleter �refreshPresentr9 � syncIdSetr N)r r r r r r( r) r �subtyper ZTagZtagClassContextZtagFormatSimplerP rR rT r- r r r r rV � s$ rV c @ s e Zd ZdZdZdd� ZdS )�SyncInfoMessagea
The Sync Info Message is an LDAP Intermediate Response Message
[RFC4511] where responseName is the object identifier
1.3.6.1.4.1.4203.1.9.1.4 and responseValue contains a BER-encoded
syncInfoValue. The criticality is FALSE (and hence absent).
z1.3.6.1.4.1.4203.1.9.1.4c C s" t j|t� d�}d | _d | _d | _d | _|d j� }|d j� }|d k oN|j � �r |dkrht
|�| _d S i }|j d�}|j � r�t
|�|d< |j d�r�t
|j d��|d< nj|dk�rg }|j d�}x6tt|��D ]&} tt|j| ��d �}
|jt
|
�� q�W ||d< t
|j d
��|d
< t| ||� d S ) N)r? r rW r& ZrefreshrQ rZ rU )r@ rM )r rA rV rW rX rY rZ ZgetNameZ getComponentrC rD rB �
startswithrO �range�lenr r@ ZgetComponentByPosition�append�setattr) r0 ZencodedMessagerI �attr�comp�valr& �uuidsZids�irJ r r r r1 6 s4
zSyncInfoMessage.__init__N)r r r r � responseNamer1 r r r r r\ - s r\ c @ sV e Zd ZdZddd�Zddd �Zd
d � Zd d
� Zddd�Zdd� Z dd� Z
dd� Z dS )r z;
SyncreplConsumer - LDAP syncrepl consumer object.
r Nc K sX |dkr| j � }t||d�}d|kr8|d |g7 < n
|g|d< d| _| j||f|�S )a�
Starts syncrepl search operation.
base, scope, and search_args are passed along to
self.search_ext unmodified (aside from adding a Sync
Request control to any serverctrls provided).
mode provides syncrepl mode. Can be 'refreshOnly'
to finish after synchronization, or
'refreshAndPersist' to persist (continue to
receive updates) after synchronization.
cookie: an opaque value representing the replication
state of the client. Subclasses should override
the syncrepl_set_cookie() and syncrepl_get_cookie()
methods to store the cookie appropriately, rather than
passing it.
Only a single syncrepl search may be active on a SyncreplConsumer
object. Multiple concurrent syncrepl searches require multiple
separate SyncreplConsumer objects and thus multiple connections
(LDAPObject instances).
N)r& r% Z serverctrlsF)�syncrepl_get_cookier. � _SyncreplConsumer__refreshDoneZ
search_ext)r0 �baseZscoper% r& Z search_argsZsyncreqr r r �syncrepl_searcha s
z SyncreplConsumer.syncrepl_searchr r c C s� �x�| j ||dddd�\}}}}}} |dkrrx@|D ]8}
|
jjdkrDq2| jd|
jd� |
jdk r2| j|
j� q2W dS |d k�r,x�|D ]�} | \} }
}x�|D ]�}
|
jjd
kr�q�|
jd kr�| j|
jg� nD|
jd kr�| j |
jg� n*| j
| |
|
j� | j dk�r| j|
jg� |
jdk �r | j|
j� P q�W q�W �nX|d
k�r��xJ|D �]@} | \}}}|t j
k�r^�q>t |�}|jdk �r�| j|j� n�|jdk �r�| jddd� d|jk�r�| j|jd � |jd �r~d| _ | j� n�|jdk �r$| jddd� d|jk�r| j|jd � |jd �r~d| _ | j� nZ|jdk �r>|jd dk�rR| j |jd � n| j|jd � d|jk�r>| j|jd � �q>W |dkrdS qW dS )a�
polls for and processes responses to the syncrepl_search() operation.
Returns False when operation finishes, True if it is in progress, or
raises an exception on error.
If timeout is specified, raises ldap.TIMEOUT in the event of a timeout.
If all is set to a nonzero value, poll() will return only when finished
or when an exception is raised.
r r )�msgid�timeoutZadd_intermediatesZ add_ctrls�all�e rN N)rM F�d r> r6 r: �y r& rQ TrM rU )Zresult4rE r �syncrepl_presentrM r& �syncrepl_set_cookier< r= �syncrepl_delete�syncrepl_entryri r\ rg rW rY �syncrepl_refreshdonerX rZ )r0 rl rm rn �type�msgZmidZctrls�n�v�c�m�dn�attrsZrnameZrespZsimr r r �
syncrepl_poll� sz
z SyncreplConsumer.syncrepl_pollc C s dS )zY
Called by syncrepl_poll() to store a new cookie provided by the server.
Nr )r0 r& r r r rs � s z$SyncreplConsumer.syncrepl_set_cookiec C s dS )zd
Called by syncrepl_search() to retrieve the cookie stored by syncrepl_set_cookie()
Nr )r0 r r r rh � s z$SyncreplConsumer.syncrepl_get_cookieFc C s dS )aF
Called by syncrepl_poll() whenever entry UUIDs are presented to the client.
syncrepl_present() is given a list of entry UUIDs (uuids) and a flag
(refreshDeletes) which indicates whether the server explicitly deleted
non-present entries during the refresh operation.
If called with a list of uuids, the syncrepl_present() implementation
should record those uuids as present in the directory.
If called with uuids set to None and refreshDeletes set to False,
syncrepl_present() should delete all non-present entries from the local
mirror, and reset the list of recorded uuids.
If called with uuids set to None and refreshDeletes set to True,
syncrepl_present() should reset the list of recorded uuids, without
deleting any entries.
Nr )r0 re rM r r r rr � s z!SyncreplConsumer.syncrepl_presentc C s dS )z�
Called by syncrepl_poll() to delete entries. A list
of UUIDs of the entries to be deleted is given in the
uuids parameter.
Nr )r0 re r r r rt s z SyncreplConsumer.syncrepl_deletec C s dS )z�
Called by syncrepl_poll() for any added or modified entries.
The provided uuid is used to identify the provided entry in
any future modification (including dn modification), deletion,
and presentation operations.
Nr )r0 r} r~ rJ r r r ru s z SyncreplConsumer.syncrepl_entryc C s dS )z�
Called by syncrepl_poll() between refresh and persist phase.
It indicates that initial synchronization is done and persist phase
follows.
Nr )r0 r r r rv s z%SyncreplConsumer.syncrepl_refreshdone)r N���)r� Nr )F) r r r r rk r rs rh rr rt ru rv r r r r r \ s
%
Z
N),r rJ r Z pyasn1.typer r r r r Zpyasn1.codec.berr r Z ldap.pkginfor
r r Z
ldap.controlsr
r r �__all__Z OctetStringr r r" r �Sequencer$ r. r5 r; r> r4 rL rN rP rR ZSetOfrS rT ZChoicerV r\ r r r r r �<module> s2
//