B %Q[@sdZddlZyddlmZWn ek r<ddlmZYnXddlmZddlm Z m Z m Z m Z ddl mZdd lmZdd lmZdd lmZmZdd lmZmZmZdd lmZmZddlmZmZm Z ddl!m"Z"ddl#m$Z$ddl%m&Z&ddlm'Z'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2ddl3m4Z4ddl5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;Gddde<Z=Gddde<Z>Gddde>Z?Gddde>Z@dS) N) OrderedDict)linesep) STRING_TYPESSEQUENCE_TYPES MODIFY_ADDMODIFY_REPLACE)WritableAttribute) ObjectDef)AttrDef) LDAPKeyErrorLDAPCursorError)check_json_dict format_jsonprepare_for_stream)operation_to_ldifadd_ldif_header)safe_dnsafe_rdnto_dn)to_stdout_encoding)CaseInsensitiveWithAliasDict)get_config_parameter) STATUS_VIRTUALSTATUS_WRITABLESTATUS_PENDING_CHANGESSTATUS_COMMITTEDSTATUS_DELETED STATUS_INITSTATUS_READY_FOR_DELETIONSTATUS_READY_FOR_MOVINGSTATUS_READY_FOR_RENAMINGSTATUS_MANDATORY_MISSINGSTATUSESINITIAL_STATUSES)RESULT_SUCCESS)log log_enabledERRORBASICPROTOCOLEXTENDEDc@s0eZdZdZddZddZddZdd Zd S) EntryStatezTContains data on the status of the entry. Does not pollute the Entry __dict__. cCsb||_d|_d|_t|_t|_t|_d|_||_ d|_ d|_ t |_ |jrX|j|_nd|_dS)N)dn_initial_status_tor statusr attributesZraw_attributesresponsecursororigin read_timerchanges definition)selfr/r5r;WC:\Users\HIRONO~1\AppData\Local\Temp\pip-install-6i93dh7p\ldap3\ldap3\abstract\entry.py__init__9s zEntryState.__init__cCs|jr |jdk r dt|jd|j|jkr:|jdnd|jd|jrX|jndt}|ddt |j t7}|d|j j rdt |j j nd t7}|d dt |j j t7}|d |jrd nd t7}|d |jr|jjjnd t7}|St|SdS)NzDN: z - STATUS: z, z - READ TIME: zz attributes: z object def: zz attr defs: z response: Zpresentzcursor: )__dict__r/rr0r2r7 isoformatrjoinsortedr3keysr9 _object_class _attributesr4r5 __class____name__object__repr__)r:rr;r;r<rIJsN *" zEntryState.__repr__cCs|S)N)rI)r:r;r;r<__str__VszEntryState.__str__cCsddtdD}|tkrDdt|}ttrZsz)EntryState.set_status..Z*IGNORED_MANDATORY_ATTRIBUTES_IN_OBJECT_DEFzinvalid entry status z %s for <%s>)rr%strr)r*r(rr&r0r2rrrrrr9rE mandatoryrLr3virtualr8r$)r:r2Z/conf_ignored_mandatory_attributes_in_object_def error_messageattrr;r;r< set_statusYs&  zEntryState.set_statusN)rG __module__ __qualname____doc__r=rIrKrUr;r;r;r<r.4s  r.c@seZdZdZddZddZddZdd Zd d Zd d Z ddZ ddZ ddZ ddZ eddZeddZeddZeddZeddZd d!Zed"d#Zed$d%Zed&d'Zed(d)Zed*d+Zd4d0d1Zd5d2d3Zd/S)6 EntryBaseazThe Entry object contains a single LDAP entry. Attributes can be accessed either by sequence, by assignment or as dictionary keys. Keys are not case sensitive. The Entry object is read only - The DN is retrieved by _dn - The cursor reference is in _cursor - Raw attributes values are retrieved with _raw_attributes and the _raw_attribute() methods cCst|||jd<dS)N_state)r.r?)r:r/r5r;r;r<r={szEntryBase.__init__cCs|jr|jdk rdt|jd|jj|jkr:|jjdnd|jd|jrX|jndt}|jj rx\t |jj D]L}|jj |st |jj |drx|jj |j rx|dt |jj |t7}qxW|St|SdS) NzDN: z - STATUS: z, r>z - READ TIME: zr8z )r?entry_dnrrZr0 entry_statusentry_read_timer@rr3rBhasattrr8reprrHrI)r:rJrTr;r;r<rI~sR, zEntryBase.__repr__cCs|S)N)rI)r:r;r;r<rKszEntryBase.__str__ccs$x|jjD]}|jj|Vq WdS)N)rZr3)r: attributer;r;r<__iter__szEntryBase.__iter__cCs(y||dStk r"dSXdS)NTF) __getitem__r)r:itemr;r;r< __contains__s  zEntryBase.__contains__cCst|tr|dkr|jdSd|}d}x&|jjD]}||krB|}PqBW|sx&|jj D]}||krn|}PqnW|sx*|jjD]}|d|kr|}PqW|sx*|jj D]}|d|kr|}PqW|sx*|jjD]}|d|kr|}PqW|sPx.|jj D]}|d|kr.|}Pq.W|s~d|}t t rvt t d||t ||jj|Sd}t t rt t d||t |dS)NrZr>z;binaryz;rangezattribute '%s' not foundz %s for <%s>zattribute name must be a string) isinstancerr?rAsplitrLrZr3rCaliasesr)r*r(r)r:rc attr_foundrTrSr;r;r< __getattr__sX       zEntryBase.__getattr__cCs^||jjkr4d|}ttr*ttd||t|n&d|}ttrRttd||t|dS)Nzattribute '%s' is read onlyz %s for <%s>z#entry is read only, cannot add '%s')rZr3r)r*r(r)r:rcvaluerSr;r;r< __setattr__s  zEntryBase.__setattr__cCs6t|trd|}d}x&|jjD]}||kr0|}Pq0W|svx&|jjD]}||kr\|}Pq\W|sx*|jjD]}|d|kr|}PqW|sx*|jjD]}|d|kr|}PqW|sd|}t t rt t d||t ||jj|Sd}t t r*t t d||t |dS)Nr>z;binaryzkey '%s' not foundz %s for <%s>zkey must be a string) rerrArfrLrZr3rCrgr)r*r(r)r:rcrhrTrSr;r;r<rbs@     zEntryBase.__getitem__cCst|tr|j|jkSdS)NF)rerYr[)r:otherr;r;r<__eq__s  zEntryBase.__eq__cCst|tr|j|jkSdS)NF)rerYr[)r:rlr;r;r<__lt__s  zEntryBase.__lt__cCs|jjS)N)rZr/)r:r;r;r<r[szEntryBase.entry_dncCs|jjS)N)rZr5)r:r;r;r< entry_cursorszEntryBase.entry_cursorcCs|jjS)N)rZr2)r:r;r;r<r\ szEntryBase.entry_statuscCs|jjS)N)rZr9)r:r;r;r<entry_definitionszEntryBase.entry_definitioncCs|jjS)N)rZentry_raw_attributes)r:r;r;r<rqszEntryBase.entry_raw_attributescCs||jjkr|jj|SdS)z :param name: name of the attribute :return: raw (unencoded) value of the attribute, None if attribute is not found N)rZrq)r:namer;r;r<entry_raw_attributeszEntryBase.entry_raw_attributecsfddjjDS)Ncsg|]}jj|jr|qSr;)rprErQ)rMr`)r:r;r<rO sz8EntryBase.entry_mandatory_attributes..)rprE)r:r;)r:r<entry_mandatory_attributessz$EntryBase.entry_mandatory_attributescCst|jjS)N)listrZr3rC)r:r;r;r<entry_attributes"szEntryBase.entry_attributescCstdd|jjDS)Ncss|]\}}||jfVqdS)N)values)rMZ attribute_keyZattribute_valuer;r;r< (sz5EntryBase.entry_attributes_as_dict..)dictrZr3items)r:r;r;r<entry_attributes_as_dict&sz"EntryBase.entry_attributes_as_dictcCs|jjS)N)rZr7)r:r;r;r<r]*szEntryBase.entry_read_timecCs|jjS)N)rZr8)r:r;r;r<_changes.szEntryBase._changesFTNc st}j|d<|r@|s6tfddjD|d<n j|d<|rt|sftfddjD|d<ntj|d<ttkrt|tj|d||dt dd }|r| ||S) Nr/c3s&|]}j|r|j|fVqdS)N)r{)rMkey)r:r;r<rx8sz*EntryBase.entry_to_json..r3c3s&|]}j|r|j|fVqdS)N)rq)rMr~)r:r;r<rx>srawT),z: ) ensure_ascii sort_keysindentcheck_circulardefault separators) ryr[r{rqrPbytesrjsondumpsrwrite) r:rrsortstreamZchecked_attributesZ include_emptyZ json_entryZ json_outputr;)r:r< entry_to_json2s,   zEntryBase.entry_to_jsoncCs~td|jjg||d}t|}|p$t}||}|rz|dkrdtdgd}|t||||t||||S)NZsearchResponse) sort_orderr-) rrZr4rrrAtellrr)r:Z all_base64Zline_separatorrrZ ldif_linesZ ldif_outputheaderr;r;r< entry_to_ldifRs  zEntryBase.entry_to_ldif)Fr}TNTT)FNNN)rGrVrWrXr=rIrKrardrirkrbrmrnpropertyr[ror\rprqrsrtrvr{r]r|rrr;r;r;r<rYos0  . #           rYc@seZdZdZdddZdS)EntryaThe Entry object contains a single LDAP entry. Attributes can be accessed either by sequence, by assignment or as dictionary keys. Keys are not case sensitive. The Entry object is read only - The DN is retrieved by _dn() - The Reader reference is in _cursor() - Raw attributes values are retrieved by the _ra_attributes and _raw_attribute() methods NcCs|jjs*d}ttr"ttd||t||dkrp|jjjr`|jj}|jj t |t rX|ng}nd|krp|j j }|sd}ttrttd||t|t |tst||jj||}|rt |tr|g}t |t rxH|D]:}||jkrd||f}ttr ttd||t|qWng}|s@ddlm}||jj|} n|} |rd| |jt||j} n$| |jj} | j| |j| j_|| j_x| jjjjD]} | jjjj| } | | j kr| | jj!kr| jj| j } t"| j | | j#| j$| j%| j&| j'| j(| j)| j*| j+d }| j}|| 8}||7}t,|| | }| j | jj!kr| jj!| j j+|_+| jj!| j j-|_-| jj!| j j |_ | jj!| j j|_|| jj!| <| jj!| j =qW| j.t/| S) Nz2schema must be available to make an entry writablez %s for <%s> objectclassz8object class must be specified to make an entry writablez%attribute '%s' not in schema for '%s'r )Writer) r~validate pre_query post_queryrdereference_dn descriptionrQ single_valuealias)0roschemar)r*r(rr9rDrp_auxiliary_classrerrrwr rrEr5r connectionZ_refresh_objectr[rurv _create_entryrZr4entriesappendr]r7r6rrr3r rrrrrrrQrZ other_namesr Z raw_valuesrUr)r:Z object_defZ writer_cursorr3Zcustom_validatorZauxiliary_classrSr`rZwritable_cursorZwritable_entryrTZ original_attrZ old_attr_defZ new_attr_defnew_attrr;r;r<entry_writablels               zEntry.entry_writable)NNNNN)rGrVrWrXrr;r;r;r<r_s rc@speZdZddZddZddZeddZdd d Zd dZ ddZ dddZ ddZ ddZ eddZd S) WritableEntrycCs|tk r|||dS)N)Ellipsisrk)r:r~rjr;r;r< __setitem__szWritableEntry.__setitem__cCsddtdD}|dkr2t|tr2||jd<dS|tk r||jjjksT||kr||j j krt |jjj|||jd}||j j t |<|j j | |n&d|}ttrttd||t|dS)NcSsg|] }|qSr;)rL)rMrNr;r;r<rOsz-WritableEntry.__setattr__..Z#ATTRIBUTES_EXCLUDED_FROM_OBJECT_DEFrZ)r5zattribute '%s' not definedz %s for <%s>)rrer.r?rror9rErLrZr3r rPsetr)r*r(r)r:rcrjZ(conf_attributes_excluded_from_object_defZ new_attributerSr;r;r<rks  zWritableEntry.__setattr__cCst|tr|dkr|jdSd|}x,|jjD]}||kr<|jj|Sqzattribute '%s' not definedz %s for <%s>zattribute name must be a string)rerr?rArfrLrZr3rCrgrprEr roaddr)r*r(r)r:rcrTrSr;r;r<ris,        zWritableEntry.__getattr__csfddjDS)Ncsg|]}|jr|qSr;)rR)rMrT)r:r;r<rOsz:WritableEntry.entry_virtual_attributes..)rv)r:r;)r:r<entry_virtual_attributessz&WritableEntry.entry_virtual_attributesTNcCs|r|j|jtkr |jj|j|}|jjjjsR|jjj |dd\}}}n|jjj }|jjj }|jjj }|j ||||dtkr|j}|jjr|jjj|jjjjjkr|jjj}|jjjt|||jjjd<|jjjt|j}|jt|||_|jtdSdS|jtkr8|jjj|jdt|j|jjd}|jjjjsz|jjj |dd\}}}n|jjj }|jjj }|jjj }|j ||||dtkr4tdt|jd|jj|j_|r|r|jjr|jjj|jjjjjkr|j|jjj_|jtd|j_dSdS|jt krNdt|jj} |jj|j| }|jjjjs|jjj |dd\}}}n|jjj }|jjj }|jjj }|j ||||dtkrJ| ddt!|jd d|j_|r2|r2|jjr2|jjj|jjjjjkr2|j|jjj_|jtd|j_dSdS|jt"t#gkrg} xL|j$D]B} | |jj%ks|jj%| j&rj| |j'krj| (d | d qjWd d | |jf} t)t*rt+t*d | |t,| n|jt-kr|j'r|j.j/rx|j'D]} |jj0j1| j2|jj0j1| j3} xp|j4D]}|| kr:Pq:WxR|j.j/D]F}|| krZ|jj5t"kr|j'ddd (|n|j4|7_4qZWqW|jj5t"krt6}x&|j'D]} |j'| dd || <qW|jj7|jd||}n|jj8|j|j'|}|jjjjs<|jjj |dd\}}}n|jjj }|jjj }|jjj }|j ||||dtkr|rv|r~|jjr~|jjj|jjjjjkr~xP|D]H} | j9|j.j:kr| j9|jjj.j:kr|jjjj;<|jj;j:| j9qW|jjj=|jj }|jjj|j|jjjd<x4|D],} | j&s6|jjjj%| j9|jjj| j9<q6W|j>|jjj_?n|@|jtdSdS)NT) get_requestresultrZF+)Z new_superiorrr 'z+mandatory attributes %s missing in entry %sz, z %s for <%s>Z objectClassr)AroZ_reset_historyr\r!rdeleter[ZstrategyZsyncZ get_responser4rrequestZ_store_operation_in_historyr'rZr6serverr?clearr.rUrr"Z modify_dnrArr1rr/ entry_refreshrr#rrr$rtr3rRr|rr)r*r(rrrprrZattribute_typesZ mandatory_inZ optional_inrr0ryrmodifyr~rEr9Z add_attributerr]r7entry_discard_changes)r:ZrefreshcontrolsZ clear_historyrr4rr/r5ZrdnZmissing_attributesrTrSZ attr_classesZ object_classZ aux_classZnew_attributesZ temp_entryr;r;r<entry_commit_changess            &   $ $     $ $  *              $ $$ $ z"WritableEntry.entry_commit_changescCs|j|j|jjdS)N)r|rrZrUr0)r:r;r;r<rts z#WritableEntry.entry_discard_changescCsH|jtttgkr8d|j}ttr0ttd||t||j tdS)Nz%cannot delete entry, invalid status: z %s for <%s>) r\rrr!r)r*r(rrZrU)r:rSr;r;r< entry_deletexs  zWritableEntry.entry_deleter}rcCs |jjr|j|||rdSdS)z; Refreshes the entry from the LDAP Server TF)rorZ refresh_entry)r:triessecondsr;r;r<rszWritableEntry.entry_refreshcCsT|jtttgkr8d|j}ttr0ttd||t|t||j _ |j tdS)Nz#cannot move entry, invalid status: z %s for <%s>) r\rrr"r)r*r(rrrZr1rU)r:Zdestination_dnrSr;r;r< entry_moves  zWritableEntry.entry_movecCsP|jtttgkr8d|j}ttr0ttd||t|||j_ |j tdS)Nz%cannot rename entry, invalid status: z %s for <%s>) r\rrr#r)r*r(rrZr1rU)r:new_namerSr;r;r< entry_renames zWritableEntry.entry_renamecCs|jS)N)r|)r:r;r;r< entry_changesszWritableEntry.entry_changes)TNT)r}r)rGrVrWrrkrirrrrrrrrrr;r;r;r<rs     r)ArXr collectionsr ImportErrorZ utils.ordDictosrr>rrrr r`r Z objectDefr ZattrDefr Zcore.exceptionsrrZ utils.convrrrZprotocol.rfc2849rrZutils.dnrrrZ utils.reprrZ utils.ciDictrZ utils.configrrrrrrr r!r"r#r$r%r&Z core.resultsr'Z utils.logr(r)r*r+r,r-rHr.rYrrr;r;r;r<s2       8  ;qa