=OOfB jdZddlmZmZddlmZddlmZddlmZddl Z ddl m Z m Z m Z mZmZmZmZmZmZmZmZmZmZmZmZmZmZmZmZmZmZm Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1d d l2m3Z3m4Z4m5Z5dd l6m7Z7d d l8m9Z9d d l:m;Z;ddlZ>ddl?m@Z@mAZAddlBmCZCmDZDddlEmFZFmGZGddlHmIZImJZJddlKmLZLmMZMddlNmOZOmPZPddlQmRZRmSZSddlTmUZUmVZVddlWmXZXmYZYddlZm[Z[ddl\m]Z]ddl^m_Z_ddl`maZaddlbmcZcddldmeZeddlfmgZgddlhmiZidd ljmkZkdd!llmmZmdd"lnmoZodd#lpmqZqdd$lrmsZsdd%ltmuZudd&lvmwZwd d'lxmyZyd d(lzm{Z{d d)l|m}Z}m~Z~mZmZmZmZmZmZmZmZmZmZmZmZdd*lmZmZmZmZmZdd+lmZmZmZmZmZmZmZdd,lmZdd-lmZe+e,e-e.gZee"e#eeeee(e)eg Zd.Zd/ZGd0d1eZy)2 )deepcopycopy)linesep)RLock)reduceN)' ANONYMOUSSIMPLESASL MODIFY_ADD MODIFY_DELETEMODIFY_REPLACEget_config_parameter DEREF_ALWAYSSUBTREEASYNCSYNC NO_ATTRIBUTESALL_ATTRIBUTESALL_OPERATIONAL_ATTRIBUTESMODIFY_INCREMENTLDIF ASYNC_STREAM RESTARTABLE ROUND_ROBINREUSABLEAUTO_BIND_DEFAULTAUTO_BIND_NONEAUTO_BIND_TLS_BEFORE_BIND SAFE_SYNCSAFE_RESTARTABLEAUTO_BIND_TLS_AFTER_BINDAUTO_BIND_NO_TLS STRING_TYPESSEQUENCE_TYPES MOCK_SYNC MOCK_ASYNCNTLMEXTERNAL DIGEST_MD5GSSAPIPLAINDSASCHEMAALL)RESULT_SUCCESSRESULT_COMPARE_TRUERESULT_COMPARE_FALSE)ExtendedOperationsRoot) ServerPool)Server)abandon_operationabandon_request_to_dict) add_operationadd_request_to_dict)bind_operationbind_request_to_dict)compare_operationcompare_request_to_dict)delete_operationdelete_request_to_dict)extended_operationextended_request_to_dict)modify_operationmodify_request_to_dict)modify_dn_operationmodify_dn_request_to_dict)search_operationsearch_request_to_dict)operation_to_ldifadd_ldif_header)sasl_digest_md5) sasl_external) sasl_plain) SyncStrategy)SafeSyncStrategy)SafeRestartableStrategy)MockAsyncStrategy) AsyncStrategy)ReusableStrategy)RestartableStrategy)LdifProducerStrategy)MockSyncStrategy)AsyncStreamStrategy)unbind_operation)paged_search_control)ConnectionUsage)Tls)LDAPUnknownStrategyError LDAPBindError$LDAPUnknownAuthenticationMethodError"LDAPSASLMechanismNotSupportedErrorLDAPObjectClassErrorLDAPConnectionIsReadOnlyErrorLDAPChangeErrorLDAPExceptionErrorLDAPObjectErrorLDAPSocketReceiveErrorLDAPAttributeErrorLDAPInvalidValueErrorLDAPInvalidPortErrorLDAPStartTLSError) escape_bytesprepare_for_streamcheck_json_dict format_json to_unicode)log log_enabledERRORBASICPROTOCOLEXTENDED#get_library_log_hide_sensitive_data)safe_dn)check_port_and_port_listc|r.t|dk(r t|ddzt|dzS|r1t|dk(r#dt|dzdzt|dzS t|S#t$rYywxYw) Nr r:r1[z]:?)lenstr Exception)endpoints V/var/www/premiumrankchecker/venv/lib/python3.12/site-packages/ldap3/core/connection.py_format_socket_endpointr_sCMQ&8A;#%HQK(888 c(mq(S!%%,s8A;/???8} s% A00 A<;A<c|rB |j} |j}dt|zdzt|zdzSy#t$rd}Y?wxYw#t$rd}Y?wxYw)N)NNNNzz ) getsocknamer getpeernamer)socklocalremotes r_format_socket_endpointsrks  -$$&E .%%'F3E::]JMdekMllorrr  -,E - .-F .s"AA AA A%$A%ceZdZdZddeddedddddddddddddddddddddddfdZd'dZdZd Z d Z d Z e d Z e jd Z e dZdZdZ d(dZ d)dZ d*dZeeddddddddddf dZ d*dZ d+dZ d*dZ d*dZ d,dZ d*dZ d+dZd-dZdZ dZ!d Z" d.d!Z# d/d"Z$ d0d#Z%d*d$Z&e d%Z'd&Z(y)1 Connectiona Main ldap connection class. Controls, if used, must be a list of tuples. Each tuple must have 3 elements, the control OID, a boolean meaning if the control is critical, a value. If the boolean is set to True the server must honor the control or refuse the operation Mixing controls must be defined in controls specification (as per RFC 4511) :param server: the Server object to connect to :type server: Server, str :param user: the user name for simple authentication :type user: str :param password: the password for simple authentication :type password: str :param auto_bind: specify if the bind will be performed automatically when defining the Connection object :type auto_bind: int, can be one of AUTO_BIND_DEFAULT, AUTO_BIND_NONE, AUTO_BIND_NO_TLS, AUTO_BIND_TLS_BEFORE_BIND, AUTO_BIND_TLS_AFTER_BIND as specified in ldap3 :param version: LDAP version, default to 3 :type version: int :param authentication: type of authentication :type authentication: int, can be one of ANONYMOUS, SIMPLE or SASL, as specified in ldap3 :param client_strategy: communication strategy used in the Connection :type client_strategy: can be one of SYNC, ASYNC, LDIF, RESTARTABLE, REUSABLE as specified in ldap3 :param auto_referrals: specify if the connection object must automatically follow referrals :type auto_referrals: bool :param sasl_mechanism: mechanism for SASL authentication, can be one of 'EXTERNAL', 'DIGEST-MD5', 'GSSAPI', 'PLAIN' :type sasl_mechanism: str :param sasl_credentials: credentials for SASL mechanism :type sasl_credentials: tuple :param check_names: if True the library will check names of attributes and object classes against the schema. Also values found in entries will be formatted as indicated by the schema :type check_names: bool :param collect_usage: collect usage metrics in the usage attribute :type collect_usage: bool :param read_only: disable operations that modify data in the LDAP server :type read_only: bool :param lazy: open and bind the connection only when an actual operation is performed :type lazy: bool :param raise_exceptions: raise exceptions when operations are not successful, if False operations return False if not successful but not raise exceptions :type raise_exceptions: bool :param pool_name: pool name for pooled strategies :type pool_name: str :param pool_size: pool size for pooled strategies :type pool_size: int :param pool_lifetime: pool lifetime for pooled strategies :type pool_lifetime: int :param cred_store: credential store for gssapi :type cred_store: dict :param use_referral_cache: keep referral connections open and reuse them :type use_referral_cache: bool :param auto_escape: automatic escaping of filter values :type auto_escape: bool :param auto_encode: automatic encoding of attribute values :type auto_encode: bool :param source_address: the ip address or hostname to use as the source when opening the connection to the server :type source_address: str :param source_port: the source port to use when opening the connection to the server. Cannot be specified with source_port_list :type source_port: int :param source_port_list: a list of source ports to choose from when opening the connection to the server. Cannot be specified with source_port :type source_port_list: list NTFc td}t|_|j5|tvrGd|_t t rtt d|j|t|j||_ ||_ ||_ |s|jr t|_ nu|s t|_ ng|tttt fvr||_ nGd|_t t rtt d|j|t#|j||_|rdnd|_d|_d|_d|_d|_d|_d|_d|_|dur t4|_n|dur t8|_n||_| |_| |_| r t?nd|_ d|_!d|_"d|_#||_$g|_%d|_&d|_'d|_(d|_)d|_*||_+|r|n||_,||_-||_.||_/||_0d|_1| |_2||_3| rdnd|_4tk||_6g|_7||_8||_9||_:||_;||_<||_=d|_>d|_?d|_@t||} | r*t t rtt | t| ||nd|_Cdg|_D| |g|_Dn | |dd|_Dt|tr t|}t|trt|tdd }t|trC||_K|jj||jj||_Nnd|_K||_N|jtk(rt||_Qn|jtk(rt||_Qnq|jtk(rt||_QnL|jtk(rt||_Qn'|jtk(rt||_Qn|jtk(rt||_Qn|jtk(rt||_Qd|_+n|jtk(rt||_Qn|jtk(rt||_Qnk|jtk(rt||_QnGd |_t t rtt d|j|t|j|jj|_d|jj|_e|jj|_f|jj|_g|jj|_h|jjs|jt tr;tr ttd |jnttd |dddy#1swYyxYw) NDEFAULT_THREADED_POOL_NAMEz"unknown client connection strategy %s for <%s>unknown authentication methodTFr)activeexhaustzunknown strategyzinstantiated Connection: <%s>zinstantiated Connection: <%r>)nrrconnection_lockCLIENT_STRATEGIES last_errorrqrrrpr] strategy_typeuserpasswordr authenticationr r r)r_versionauto_referralsrequestresponseresultbound listeningclosedr auto_bindr$sasl_mechanismsasl_credentialsr[_usagesocket tls_startedsasl_in_progress read_only_context_state_deferred_open_deferred_bind_deferred_start_tls_bind_controls_executing_deferredlazy pool_name pool_size cred_store pool_lifetimepool_keepalive starting_tls check_namesraise_exceptions auto_ranger5extend_entries fast_decoderreceive_timeoutempty_attributesuse_referral_cache auto_escape auto_encode_digest_md5_kic_digest_md5_kis_digest_md5_sec_numrxrisource_addresssource_port_list isinstancer%r7r&r6r server_pool initializeget_current_serverserverrrOstrategyr!rPr"rQrrSrrVrrUrrTr'rWr(rRrrXsendopen get_responsepost_send_single_responsepost_send_search no_real_dsa _do_auto_bindrsrv!repr_with_sensitive_data_stripped)!selfrrrrrrclient_strategyrrrrr collect_usagerrrrrrrrrreturn_empty_attributesrrrrr source_portrconf_default_pool_nameport_errs! r__init__zConnection.__init__sG@"66R!S$w  ! !W F&77"Fu%}dootD.t??!0D DI$DM!dii&,##&/#FItT#BB&4#"Au%}dootD:4??KK"DL*8$eD DL DMDKDJ"DNDK"DOE!!2d"!1!*"0D $4D !/@f@f@hi>EoW FW FW Fs XY  Yc|jjrU|j}d|_|j}d|_|t |j |r t |ndt |fS|SN)r thread_saferrrrr)rstatusr temp_response temp_requests r_prepare_return_valuez Connection._prepare_return_valueus] == $ $ MMM DM<Fread_server_infoTz/automatic start_tls befored bind not successful - rrz-automatic start_tls after bind not successfulzautomatic bind not successful)rrrrqrsrprrr$bindr start_tlsrrrunbindrjr#rr^)rerrors rrzConnection._do_auto_bind~s >>dnn^EV4WW5!E?F{{ 5 1~~!11 4 0#<<>>5>9IItI4Mlpl{l{QVY]YhYhQhBDEE"5)E=%>KKM+E22#;; 5 1~~t~<KjnjyjyuW[WfWfOf@BCE"5)E=%>KKM+E22::7VZVeVe54??;Rkmnu%}eT: #E** 1X>rc $|jrt|jnddt|jz|jrdnd|jsdn|j rdnd|j rdn|jrd nd t|j|jsd n|jrd nd |jrdndt|dr |jjj nd|j"rdndg }dj%|S)NNonezuser: rznot lazyunboundz deferred bindrrz deferred openrztls not startedzdeferred start_tlsz tls startedrz not listeningrz No strategyzinternal decoderzpyasn1 decoderr)rrrrrrrrrrrrrhasattrr __class____name__rjoin)rss r__str__zConnection.__str__s $ C  s499~ %iiFZ!ZZIATAToZa HT=P=P/V\ $T[[ 1%)%5%5 SWSkSk;Oq~>>K07j0IDMM # # , ,}"&"3"3 9I zz!}rctd}|jrdj|}ndj|}||jdndj|z }||jdndj|z }||j dndj|z }||j dndj|z }||jdnd j|z }||jdnd j|z }||jdnd j|z }||jdnd j|z }||jdnd j|z }||jdndj|z }||jdnd|jrdndzz }||jdndj|z }||jdndj|z }||j dndj|z }||j"|j"|k(rdndj|z }||j$dndj|z }||j&dndj|z }||j(dndj|z }||j*dndt-|j*zz }||j.dnd|j.rdndzz }||j0dnd|j0rdndzz }||j2dndj|z }||j4dnd|j4rdndzz }||j6dnd|j6rdndzz }||j8dnd|j8rdndzz }||j:dnd |j:rdndzz }|d!z }|S)"Nr#Connection(server={0.server_pool!r}Connection(server={0.server!r}r, user={0.user!r}z, password={0.password!r}, auto_bind={0.auto_bind!r}, version={0.version!r}%, authentication={0.authentication!r}%, client_strategy={0.strategy_type!r}%, auto_referrals={0.auto_referrals!r}%, sasl_mechanism={0.sasl_mechanism!r}), sasl_credentials={0.sasl_credentials!r}, check_names={0.check_names!r}z, collect_usage=TrueFalse, read_only={0.read_only!r}, lazy={0.lazy!r}), raise_exceptions={0.raise_exceptions!r}, pool_name={0.pool_name!r}, pool_size={0.pool_size!r}#, pool_lifetime={0.pool_lifetime!r}%, pool_keepalive={0.pool_keepalive!r} , cred_store=z, fast_decoder= , auto_range=', receive_timeout={0.receive_timeout!r}z, return_empty_attributes=, auto_encode=, auto_escape=, use_referral_cache=))rrformatrrrrrrrrrrusagerrrrrrrrreprrrrrrrrrrrs r__repr__zConnection.__repr__s&!56R!S   5<>)R/L/S/STX/YY 4<<'R-F-M-Md-SS 4&&.R4[4b4bcg4hh 4%%-R3Z3a3abf3gg 4&&.R4[4b4bcg4hh 4&&.R4[4b4bcg4hh 4((0R6a6h6him6nn 4##+R1R1Y1YZ^1__ 4::%R,>DJJ&\c,de 4>>)R/L/S/STX/YY 499$R*=*D*DT*JJ 4((0R6a6h6him6nn DNN*dnn@V.VR]z^B^BCG^H H 4>>)R/L/S/STX/YY 4%%-R3X3_3_`d3ee 4&&.R4[4b4bcg4hh 4??*R4CX1XY 4$$,R3DRVRcRcip3qr 4??*RdooFcj1kl 4''/R5^5e5efj5kk 4((0R7SaeavavW]}D8E F 4##+R2BPTP`P`ffm2no 4##+R2BPTP`P`ffm2no 4**2R9P^b^u^uTZ|C:D E Src td}|jrdj|}ndj|}||jdndj|z }||jdn&djdt |jzz }||j dndj|z }||jdnd j|z }||jdnd j|z }||jdnd j|z }||jdnd j|z }||jdnd j|z }|jtk(rf||jdnSdj|jd|jddt |jdz|jdz }n"||jdndj|z }||jdndj|z }||jdn|jrdndz }||j dndj|z }||j"dndj|z }||j$dndj|z }||j&|j&|k(rdndj|z }||j(dndj|z }||j*dndj|z }||j,dndj|z }||j.dndt1|j.zz }||j2dn|j2rd ndz }||j4dnd!|j4rd"ndzz }||j6dnd#j|z }||j8dn|j8rd$ndz }||j:dnd%|j:rd"ndzz }||j<dnd&|j<rd"ndzz }||j>dnd'|j>rd"ndzz }|d(z }|S))Nrrrrrz, password='{0}'z*rrrrrrz/, sasl_credentials=({0!r}, {1!r}, '{2}', {3!r})rr1*r rrrz, collect_usage=Truerrrr r r r r rz, fast_decoder=Truerrrz, return_empty_attributes=Truerrrr) rrrrrr~rrrrrrr+rrrrrrrrrrrrrrrrrrrrs rrz,Connection.repr_with_sensitive_data_strippeds!56R!S   5<>)R/L/S/STX/YY 4<<'R-F-M-Md-SS 4&&.R4[4b4bcg4hh 4%%-R3Z3a3abf3gg 4&&.R4[4b4bcg4hh 4&&.R4[4b4bcg4hh   * , t,,4:k:r:rswtItIJKtLNRNcNcdeNfhknqrvrGrGHIrJnKhKMQMbMbcdMe;f fA t,,4:e:l:lmq:r rA 4##+R1R1Y1YZ^1__ 4::%R4::,G[bc 4>>)R/L/S/STX/YY 499$R*=*D*DT*JJ 4((0R6a6h6him6nn DNN*dnn@V.VR]z^B^BCG^H H 4>>)R/L/S/STX/YY 4%%-R3X3_3_`d3ee 4&&.R4[4b4bcg4hh 4??*R4CX1XY 4$$,RQUQbQb3Mhop 4??*RdooFcj1kl 4''/R5^5e5efj5kk 4((0R`d`u`u7\|C D 4##+R2BPTP`P`ffm2no 4##+R2BPTP`P`ffm2no 4**2R9P^b^u^uTZ|C:D E Srcf|jjr|jjSdS)zUsed by the LDIFProducer strategy to accumulate the ldif-change operations with a single LDIF header :return: reference to the response stream if defined in the strategy. N)r can_stream get_streamrs rstreamzConnection.streams( .2]]-E-Et}}'')O4Orc|j5|jjr|jj|dddy#1swYyxYwr)rrr set_stream)rvalues rr!zConnection.streams?  ! ! 0}}'' ((/ 0 0 0s 2AAc|jsy|jjr|jj|jjj D]+}|xj|j jz c_-|xj|jjjz c_|jS)zKUsage statistics for the connection. :return: Usage object N) rrpooledresetpoolworkers connectionrterminated_usage)rworkers rrzConnection.usages {{ ==   KK   --,,44 7 v00666  7 KK4==-->> >K{{rc|j5|jj|j|jf|j t k7ra|j tk(r t|_|jr|j|js|js td|cdddS#1swYyxYw)Nzunable to bind) rrappendrrrrrr$rrr^r s r __enter__zConnection.__enter__s  ! !     & & DKK'@ A~~/>>%66%5DN;;IIKzz99;+,<==   s B'B>>Cc|j5|jj\}}|s |js |jr |j |s|jr|j|+ttrttd|| dddy dddy#t $rY`wxYw#1swYyxYw)NrF) rrpoprr!rrdrrrqrrrp)rexc_typeexc_valexc_tb context_boundcontext_closeds r__exit__zConnection.__exit__!s  ! ! ,0,?,?,C,C,E )M>!djjT[[KKM"dkk #u%}h=  $   *   s08B:B+AB:+ B74B:6B77B::Cc ttrttd|d|_|j5|j ru|j si|jjr|jj|d|_ ||_ d|_ ttrttd|nd|_ d|_ |jr|jd|jt k(rtt"rtt"d||jjst%|j&|j|j(d|j* }tt"rtt"d t-|||j/|j1d ||}n)|jj|}n |jt2k(rtt"rtt"d ||jjst%|j&|j|j(|j4|j* }tt"rtt"d t-|||j/|j1d ||}n3|jj|}n|jt6k(r|j8t:vrftt"rtt"d||jjs|j=|}n|jj|}nd|_tt>rtt>d|j|tA|j|jtBk(r|j(r|j4rtE|j(jGddk(rdtt"rtt"d||jjs|jI|}n|jj|}nd|_tt>rtt>d|j|tK|jd|_tt>rtt>d|j|tK|j|jjLsd|jjsN|jt6tBfvr6|jO|\}}tt"rtt"d||n|jjLr.|jP}tt"rtt"d||nx|jjs|jt6tBfvr|}nGd|_tt>rtt>d|j|tK|j|d|_ nV|durd|_ nJ|durd|_ n>|dtRk(rdnd|_ |js|r|dr|js |d|_|r|jr|jUg|_+ttrttd|j|jY|j|jPcdddS#1swYyxYw)a%Bind to ldap Server with the authentication method and the user defined in the connection :param read_server_info: reads info from server :param controls: LDAP controls to send along with the bind operation :type controls: list of tuple :return: bool zstart BIND operation via <%s>NTzdeferring bind for <%s>Frz"performing anonymous BIND for <%s>r)rz)anonymous BIND request <%s> sent via <%s> bindRequestzperforming simple BIND for <%s>z&simple BIND request <%s> sent via <%s>zperforming SASL BIND for <%s>z&requested SASL mechanism not supportedr\r zperforming NTLM BIND for <%s>z)NTLM needs domain\username and a passwordrz-async BIND response id <%s> received via <%s>z$BIND response <%s> received via <%s>r descriptionz done BIND operation, result <%s>)-rqrsrprrrrrr& validate_bindrrrrrrr rtr<rrrr=rrr rr rSASL_AVAILABLE_MECHANISMS do_sasl_bindrrr`r)r~split do_ntlm_bindr_syncrrr2refresh_server_inforr)rrcontrolsrr_rs rrzConnection.bind2s- u  6 =  ! !e Gyy!9!9==''MM//9&*#&.#! u%8$?&+#&*#;;IIuI5&&)3"8,H&JDQ==//"0t?R?RTXT]T]_aosoo#A&x0*UWklsWtvz{#'#A#A$))M[bdlBm#n#'==#>#>x#H((F2"8,H&GN==//"0t?R?RTXT]T]_c_l_lz~{K{K#L&x0*RThipTqswx#'#A#A$))M[bdlBm#n#'==#>#>x#H((D0**.GG&x0*I4P#}}33'+'8'8'BH'+}}'B'B8'LH*R&u-}dootL@QQ((D0yyT]]s499??4;P7QUV7V&x0*I4P#}}33'+'8'8'BH'+}}'B'B8'LH*V&u-}dootLB4??SS&EDO"5)E=$//4H>tOO}}))$--2F2F4K^K^gkmqfrKr $ 1 1( ;IAv"8,H&UW]_cd]]''![[F"8,H&LfVZ[]]))T-@-@T4L-P%F&EDO"5)E=$//4H>tOO>!&DJt^!%DJu_!&DJ)/)9^)KQVDJ::&VM5JSWSbSb*0*?# ,,.DM5!E=tzzJ--djj$++FKe Ge Ge Gs Z0[..[7cXttrttd|d|_|j5|r||_|||_|s |r t|_|ttttfvr||_nI|Gd|_ttrttd|j|t|j|r||_|r||_|j j"s |j%||cdddS|j j*j-|j/d|j0cdddS#t&$rHd|_ttrttd|j|t)|jwxYw#1swYyxYw)Nz!start (RE)BIND operation via <%s>rrz[Unable to rebind as a different user, furthermore the server abruptly closed the connectionT)rqrsrprrrrr rr r r)rrr_rrrr&rrfr^r( rebind_poolrr)rrrrrrrrCs rrebindzConnection.rebindsr u  :D A  ! !" E  # ( !d&,#&)T4!@@&4#+"Au%}dootD:4??KK&4#(8%==''999%5x@5" E" EB ""..011$ DE" E" E6.9'DDO"5)E=$//4H'88 97" E" Es%B3F (E ?F  AFF  F)cttrttd||jr|jj d|_|j5|jrT|jsH|js |jr0|jjd|_ d|_ d|_ nc|jsWt}tt rtt d||j#d|||jjttrttdd|j%dcdddS#1swYyxYw)zUnbind the connected user. Unbind implies closing session as per RFC4511 (4.3) :param controls: LDAP controls to send along with the bind operation zstart UNBIND operation via <%s>NFzUNBIND request sent via <%s> unbindRequestz"done UNBIND operation, result <%s>T)rqrsrprrunbind_referral_cacherrrrrrcloserrrYrtrr)rrCrs rrzConnection.unbinds u  8$ ?  " " MM / / 1  ! ! 4yy!9!9t?R?RVZViVi ##%&+#&+#+0([[*,x("@$G /7H= ##%5!E?F--d3! 4 4 4s C4EE!rctdDcgc]}|j}}ttrt td||j r.|r,t |}ttrt td|||j5|j|stg}n|tk(rtg}t|tr|g}| r&t|tr|jt n| rt|t"r |t fz }t| t$rWtt&rt t&d| t)| || g} n t| } | jt+| | | |j,r|j,j.r|j r|D]}d|vr|j1dd}n|}|j,j.s5|j|vsH||j,j.j2vskd|z|_tt6rt t6d |j4|t9|j4t;||||||||| |j<n||j>|j,r|j,j.nd|j,j@|j }tt&rt t&d tC|||jE|jGd || }g|_$t|t$r$|}tt&rt t&d ||n|jJddk(rtM|dkDrdnd}|s6|jJdtNfvr |j4s|jJd|_tt&r=|D]8}|ddk(rt t&d|||ddk(s't t&d||:ttrt td||jQ|dcdddScc}w#1swYyxYw)a) Perform an ldap search: - If attributes is empty noRFC2696 with the specified size - If paged is 0 and cookie is present the search is abandoned on server attribute is returned - If attributes is ALL_ATTRIBUTES all attributes are returned - If paged_size is an int greater than 0 a simple paged search is tried as described in - Cookie is an opaque string received in the last paged search and must be used on the next paged search response - If lazy == True open and bind will be deferred until another LDAP operation is performed - If mssing_attributes == True then an attribute not returned by the server is set to None - If auto_escape is set it overrides the Connection auto_escape ATTRIBUTES_EXCLUDED_FROM_CHECKzstart SEARCH operation via <%s>z;search base sanitized to <%s> for SEARCH operation via <%s>z>performing paged search for %d items with cookie <%s> for <%s>N;rinvalid attribute type r validatorrz!SEARCH request <%s> sent via <%s> searchRequestz/async SEARCH response id <%s> received via <%s>type searchResDoneTFrr;searchResEntryz,SEARCH response entry <%s> received via <%s> searchResRefz0SEARCH response reference <%s> received via <%s>z"done SEARCH operation, result <%s>r))rlowerrqrsrprrwrur_fire_deferredrrrr%listr.rtupleintrtrkrZrschemar?attribute_typesrrrrgrHrrcustom_validatorrIrrrrr~r2r)r search_base search_filter search_scopedereference_aliases attributes size_limit time_limit types_onlyget_operational_attributesrC paged_sizepaged_criticality paged_cookierv#conf_attributes_excluded_from_checkattribute_nameattribute_name_to_checkrr return_valueentrys rsearchzConnection.searchs>CWWwBx.yQqwwy.y+.y u  8$ ?    !+.K8$H[]hjno  ! !K K    !+_ ~-,- *l3(\ )jT.J!!"<=+ :u0M9<< *c*x("bdnp|~JqKMQR#!H $H~H 45F T` ab{{t{{11d6F6F&0 BNn,2@2F2Fs2KA2N/2@/{{)).E.K.K.MUx.x~U]a]h]h]o]o]]~*CF]*]&u-}dootL0AA B'{'4'3':'1'1'1'1;F;Nt'7'7T_'+'7'7=A[[t{{'9'9d151M1M373C3C EG8$HACYZaCbdhi,,TYYQY-Z[HDM(C(' x("SUacgh'+{{6':o'MRUV^R_bcRctin # H(=nEU(U^b^m^m&*kk-&@DOx(!)k =,<<*XZ_aef"6]n<*\^ceij k 5!E?N--lT-JWK KK K/zK KK Ks,P7 E P<P<."P<GP<'AP<<Qc NtdDcgc]}|j}}ttrt td|d|_|j r,t|}ttrt td|||jr|jjr|j rd|vr|jdd}n|}|jjjr~|j|vrl||jjjvrJd|z|_ttrt td|j |t|j t|t rGd |_ttrt td|j |t#|j |j$5|j't)||||j*|jr|jjnd|jr|jj,nd|j }tt.rt t.d t1|||j3|j5d ||} g|_t| t8r$| } tt.rt t.d | |n|j:ddk(r|j:dt<k(rdnd} | s;|j:dt<t>fvr |j s|j:d|_tt.rt t.d| |ttrt td| |jA| cdddScc}w#1swYyxYw)z- Perform a compare operation rMz start COMPARE operation via <%s>Nz3dn sanitized to <%s> for COMPARE operation via <%s>rNrrOrzvalue cannot be a sequencerPz"COMPARE request <%s> sent via <%s>compareRequestz0async COMPARE response id <%s> received via <%s>rScompareResponserTFr;z'COMPARE response <%s> received via <%s>z#done COMPARE operation, result <%s>)!rrXrqrsrprrrwrurr]r?r^rrrgrr&rhrrYr>rr_rtr?rrrr\rr3r4r) rdn attributer$rCrlrmrorrrps rcomparezConnection.comparems`CWWwBx.yQqwwy.y+.y u  94 @   B8$HSUWY]^ ;;4;;--$2B2Bi*3//#*>q*A'*3'{{!!116M6S6S6U^A7AF]eiepepeweweGeGFG";>U"Uu%}dootD(99 e^ ,:DO5!E=$//4@'8 8  ! ! <    !'Iud>N>NfjfqfqPTP[P[PbPbw{hlhshsHLHSHSHdHdy}KOK[K[\G8$HBD[\cDdfjk55dii@PRY[c6deHDM(C(' x("TVbdhi'+{{6':>O'OTXT_T_`hTinAUAtGL # H(=FY[oEp(py}zIzI&*kk-&@DOx("KXW[\5!E@,O--l;- < <9/z8 < Nz/dn sanitized to <%s> for ADD operation via <%s>r objectclass objectClassc||vr||gzS|Sr)xys rz Connection.add..sQRZ[Q[a1#gabrz"objectClass attribute is mandatoryrzinvalid object class rNrrOrPzADD request <%s> sent via <%s> addRequestz,async ADD response id <%s> received via <%s>z#ADD response <%s> received via <%s>rS addResponserTFr;zdone ADD operation, result <%s>)(rrXrqrsrprrrrwrurrYrr&rZdictrorrrrarr]object_classesrr?r^rgr:rr_rtr;rrrr%r\rr2r)rrv object_classrdrCrlrm conf_classes_excluded_from_check _attributesattr_object_classparm_object_classobject_class_attr_nameattrobject_class_namernrorrrps raddzConnection.addsCWWwBx.yQqwwy.y+.y?STq?r+s!AGGI+s(+s u  5t <z*   B8$HOQSUYZ  ! !F <    ! " #$&!:D\Sa:bD$6iuhv!%' "'Dzz|}415.YcdoqGeHJXZYD=S1T,U`klB`C_D)  #f ))6&N_ `lL!9 `  `289bduyJeJLN3OK. /56"Fu%}dootD*4??;;{{t{{11d6F6F)45K)LD%(..08XX]nvzwBwBwIwIwXwX^X*ACHYDZ*Z&u-}dootL24??CC D'2 BNn,2@2F2Fs2KA2N/2@/.446>aaf}FJFQFQFXFXFhFhgh*CF]*]&u-}dootL0AA B$B T5E5E]a]h]ht{{GYGYnr_c_j_jCJJ[[ptBFBRBRSG8$H>@ST[@\^bc55dii gW_6`aHDM(LC7$:;' x("PR^`dex("GSWX'+{{6':m'KPTP[P[\dPeiwPwt~C # H(=nEU(U^b^m^m&*kk-&@DO5!E!a+F <F Nz2dn sanitized to <%s> for DELETE operation via <%s>connection is read-onlyrz!DELETE request <%s> sent via <%s> delRequestz/async DELETE response id <%s> received via <%s>z&DELETE response <%s> received via <%s>rS delResponserTFr;z"done DELETE operation, result <%s>)rqrsrprrrwrurrYrrrrbr@rtrArrrrr%r\rr2r)rrvrCrrrps rdeletezConnection.deletes u  8$ ?   B8$HRTVX\]  ! ! <    !~~";u%}dootD3DOODD&r*G8$HACYZaCbdhi55dii gW_6`aHDM(LC7$:;' x("SUacghx("JHVZ['+{{6':m'KPTP[P[\dPeiwPwt~C # H(=nEU(U^b^m^m&*kk-&@DO5!E?N--l;9 < < rt t>dtA| ||jC|jEd| |} g|_#t| tHtJfzr$| } tt>rt t>d| |ntt>rt t>d| ||jLddk(r|jLdtNk(rdnd} | s6|jLdtNfvr |j s|jLd|_ttrt td| |jQ| cdddScc}w#1swYyxYw)a7 Modify attributes of entry - changes is a dictionary in the form {'attribute1': change), 'attribute2': [change, change, ...], ...} - change is (operation, [value1, value2, ...]) - operation is 0 (MODIFY_ADD), 1 (MODIFY_DELETE), 2 (MODIFY_REPLACE), 3 (MODIFY_INCREMENT) rMzstart MODIFY operation via <%s>Nz2dn sanitized to <%s> for MODIFY operation via <%s>rrzchanges must be a dictionaryzno changes in modify requestrNrrOr1r rzmalformed changezinvalid change listrPz!MODIFY request <%s> sent via <%s> modifyRequestz/async MODIFY response id <%s> received via <%s>z&MODIFY response <%s> received via <%s>rSmodifyResponserTFr;z"done MODIFY operation, result <%s>))rrXrqrsrprrrwrurrYrrrrbrrrcrr]r?r^rgr&r rrrr~rDrr_rtrErrrr%r\rr2r)rrvchangesrCrlrm changelistrnrochangechange_operationrrrps rmodifyzConnection.modify4sCWWwBx.yQqwwy.y+.y u  8$ ?   B8$HRTVX\]  ! !F <    !~~";u%}dootD3DOODDgt,"@u%}dootD%doo66"@u%}dootD%doo66J") 8;;4;;#5#5$:J:Jn,2@2F2Fs2KA2N/2@/{{))99>U>[>[>]fI?INemqmxmxmmmOmONO*CF]*]&u-}dootL0AA 0fn5&) TacqtDFGIJLMOPHQ;Q6{a'*<&u-}dootL-doo>>28J~.,2C(/0A59I!9LU_anp~AQSTVWYZ\]U^:^.CDO*51 #E=$//4 P"1$//"BB C 28J~.9 8:'r:t7G7G_c_j_jI[I[ptaealalAEALALA]A]rvDHDTDTUG8$HACYZaCbdhi55diiQXZb6cdHDM(LC7$:;' x("SUacghx("JHVZ['+{{6':>N'NSWS^S^_gShlzSztAF # H(=nEU(U^b^m^m&*kk-&@DO5!E?N--l;MF <F </zF <F UG=UU&cttrttd|d|_|jrXt |}tt rtt d||t |}tt rtt d|||j5|j|jrGd|_ttrttd|j|t|jt||||}ttrttdt|||j|j!d||}g|_t%|t&t(fzr$|}ttrttd ||nttrttd |||j*d d k(r|j*d t,k(rdnd}|s6|j*d t,fvr |js|j*d|_ttrttd||j/|cdddS#1swYyxYw)z\ Modify DN of the entry or performs a move of the entry in the DIT. z"start MODIFY DN operation via <%s>Nz5dn sanitized to <%s> for MODIFY DN operation via <%s>z>relative dn sanitized to <%s> for MODIFY DN operation via <%s>rrz$MODIFY DN request <%s> sent via <%s> modDNRequestz2async MODIFY DN response id <%s> received via <%s>z)MODIFY DN response <%s> received via <%s>rS modDNResponserTFr;z%done MODIFY DN operation, result <%s>)rqrsrprrrwrurrYrrrrbrFrtrGrrrrr%r\rr2r) rrv relative_dn delete_old_dn new_superiorrCrrrps r modify_dnzConnection.modify_dns u  ;T B   B8$HUWY[_`!+.K8$H^`kmqr  ! !" <    !~~";u%}dootD3DOODD*"k=,WG8$HDF_`gFhjno55diiPWYa6bcHDM(LC7$:;' x("VXdfjkx("MxY]^'+{{6':o'MRVR]R]^fRgkyRyt@E # H(=nEU(U^b^m^m&*kk-&@DO5!EBLQ--l;E" <" <" NFrrS)abandonRequestr9rIz#ABANDON request: <%s> sent via <%s>rTz\cannot abandon a Bind, an Unbind or an Abandon operation or message ID %s not found via <%s>z#done ABANDON operation, result <%s>)rqrsrprrrYr _outstandingr8rtr9rrrrrrrr)r message_idrCrprs rabandonzConnection.abandons| u  94 @  ! ! <    ! L}}))Z1_MM..:A[A[3[`d`m`m`z`z|FaGHNaOWIaINX\]N]/ ;G"8,H&KMdelMmostII.B"&DK$(DM$&DM#'L"5)E$BDGHRDSUYZ5!E@,O--l;- < < N) no_encodez#EXTENDED request <%s> sent via <%s> extendedReqz1async EXTENDED response id <%s> received via <%s>z(EXTENDED response <%s> received via <%s>rS extendedResprTFr;z$done EXTENDED operation, result <%s>rW)rqrsrprrrYrBrtrCrrrrr\rr2r)r request_name request_valuerCrrrrps rextendedzConnection.extendedsi u  :D A  ! ! K    !(}PYZG8$HCE]^eEfhlm55dii wX`6abHDM(C(' x("UWceijx("LhX\]'+{{6':n'LQUQ\Q\]eQfjxQxtD # H(=nEU(U^b^m^m&*kk-&@DO5!EA<P--lT-J+ K K Ks EFF$cttrttd||j5d}d|_|j j st|j _|jr=|js1d|_ d|_ d}ttrttd|nd|_ |jr|j|j j j|r+|jj r|r|j#d}n|jj sd}ttrttd||j%|cdddS#1swYyxYw)Nz"start START TLS operation via <%s>FTzdeferring START TLS for <%s>z%done START TLS operation, result <%s>)rqrsrprrrtlsr\rrrrrrrrrArBr)rrrps rrzConnection.start_tls s u  ;T B  ! ! < LDK;;??"%% yy!9!9+/(#' # u%=tD+0(;;IIK;;??,,T2t}}7I7I'002#'L++#'L5!EBLQ--l;7 < < |j tk(rddl m }|||}n|j dk(r t||}d|_ttrttd||cdddS#d|_wxYw#1swYyxYw)Nz"start SASL BIND operation via <%s>Tr ) sasl_gssapir-Fz%done SASL BIND operation, result <%s>)rqrsrprrrrr*rMr+rLr,protocol.sasl.kerberosrrN)rrCrrs rr>zConnection.do_sasl_bind.s u  ;T B  ! ! F(((,% 2**h6!.tX!>,, :!0x!@,,6H!,T8!<,,7!+D(!;,1D)5!EBFK+   -2D)!  s$D A>C; (D; DDDcttrttd|d|_|j5|j sd|_ ddlm}|jjdd\}}||||j}t|jd|}ttrttd ||j|jd ||}|j j"s|j%|\}} n|d } d | vr| d j'd jd} d| vrmt|jd|}ttrttd||j|jd ||}|j j"s|j%|\}} n)ttrttd|d ||d } | dt(k(rt|jd|| d }ttrttd||j|jd ||}|j j"s|j%|\}} n,ttrttd|d ||d } nd} d|_ttrttd| | cdddS dddy#d|_wxYw#1swYyxYw)Nz"start NTLM BIND operation via <%s>Tr ) NtlmClientr:r1) user_namedomainrSICILY_PACKAGE_DISCOVERYz3NTLM SICILY PACKAGE DISCOVERY request sent via <%s>r9r server_credsasciirNr)SICILY_NEGOTIATE_NTLMz+NTLM SICILY NEGOTIATE request sent via <%s>z5NTLM SICILY NEGOTIATE response <%s> received via <%s>rSICILY_RESPONSE_NTLMz/NTLM SICILY RESPONSE NTLM request sent via <%s>z)NTLM BIND response <%s> received via <%s>Fz%done SASL NTLM operation, result <%s>)rqrsrprrr utils.ntlmrrr?rr<rrtrrrrArdecoder2) rrCr domain_namer ntlm_clientrrrDrsicily_packagess rr@zConnection.do_ntlm_bindJs u  ;T B  ! !6 (((,%.27-1YY__T1-E*K",y_c_l_l"mK-T\\;UWbcG"8,H&[]ab#==dii W^`h>ijH==--$($5$5h$? 6!)!%/*0*@*G*G*P*V*VWZ*[!_4&4T\\CZ\g&hG*84 #H.[]a b'+'E'EdiiP]_fhpFq'rH#'==#5#5,0,=,=h,G 6#.x#8$'2ikstukv(,%.)1!%h/>A*8G]_j9?9O+Q#.x#8$'2cei$j+/+I+I$))TacjltJu+v'+}}'9'9040A0A(0KIAv'28'<(+H6acklmcnpt(u-5a[F!%,1D)u%FOm6 6 (6 6 b-2D)c6 6 s$K/ IK#'(K/# K,,K//K8c|jjs|j5|jstt t rt t d||j}|j}|j}|jj|||_||_||_ dddyt t rt t d||jjjy#1swYyxYw)Nzrefreshing server info for <%s>z)refreshing server info from pool for <%s>) rr&rrrqrsrprrrrget_info_from_serverr()rprevious_responseprevious_resultprevious_entriess rrBzConnection.refresh_server_infos}}##%% 5{{"5)E#DdK(, %&*kkO'+}}$KK44T:$5DM"1DK$4DM 5 55!EFM MM   3 3 5 5 5s BC22C;c|j5| |j}t|trt d|||}t |}|xst }|j|}|rb|jdk(r/t dgd}|jt||z|z|jt||z|zttrttd|||cdddS dddy#1swYyxYw)NsearchResponse) sort_orderr-z"building LDIF output <%s> for <%s>)rrrr&rJrKrrtellwriterlrqrsrp) r search_result all_base64line_separatorrr! ldif_lines ldif_outputheaders rresponse_to_ldifzConnection.response_to_ldifs  ! ! $ $ -8./?PZgqr ,Z8 !/!:7,11*= {{})!0#!7!: %78OR`8`%abLL!3K.4PSa4a!bcu%C[RVW"!  $%   sCC;1C;;Dc  |j5| |j}t|trt }g|d<|D] ddk(s t } d| d<|r.|st fd dD| d<nt d| d<|r.|st fd dD| d<nt d| d <|dj | t tur t|tj|d ||d td } ttrttd | ||r|j| | cdddS dddy#1swYyxYw)NentriesrSrUrvc3DK|]}d|s |d|fyw)rdNr~.0keyrs r z.Connection.response_to_json..sK;`beDLMYDZ[^D_C,AWX[A\;];`  rdc3DK|]}d|s |d|fyw)zraw:attributesraw_attributesNr~rs rrz.Connection.response_to_json..sL?pjmPXYiPjknPoXN^E_`cEd?e?prrrawT),z: ) ensure_ascii sort_keysindentcheck_circulardefault separatorsz"building JSON output <%s> for <%s>)rrrr&rr.rbytesrmjsondumpsrnrqrsrpr) rrrrsortr!checked_attributes include_empty json_dictrq json_outputrs @rresponse_to_jsonzConnection.response_to_jsons ! !% #$ $ -8 F ') )$ -;H'+;; $&.tnd -#06:;`iqr~i;`7`l 36:8L;Q6Rl 3#0:>?pqy{KrL?p;p&6 7/3H=M4N/Oe !),33E:#;&%<#I."jjQU^duyDO\gh u%C[RVWLL-"K% #% #9 % #% #% #s)rrr) rrrr%rrqrsrp writelinesrrK)rtargetrrrs rresponse_to_filezConnection.response_to_files~  ! ! }}fl3!&$/Fu%BDI!!$"7"7CUY"7"Z[    s AFrz!deferred start_tls not successfulrrr)rrC)rrrrqrsrprrrrrrrrrrjrrrinfoget_infor.r0r]r/rBrd)r read_infores rrYzConnection._fire_deferreds  ! ! 5yy!9!9+/(u%`bfbubuw{xPxPRVReRegkl5** 5 9//#~~u~E$Gfjfufu5SWSbSbKb{}$~E*51 #E=% F KKM"3E"::** 54CVCV W!)4;;3C3C H\H\adfi`jHjtxttuGuGLPLWLWL`L`ekmpdqLqw@002 05D,3 5 5(*"5)E=!T: 05D,3 5 5s=A#H1EG6H G6"G11G66G99 HHHc|jr7|js+|j|j|j|_|jSr)rr _get_entriesrr s rrzConnection.entriess6 ==== $ 1 1$-- N }}rc |j5ddlm}m}g}|D]=}|ddk(s t |dj }||vs-|j |?|jdg}|D]!} |D] } | | k\s |j | #g} |D]u} ||jj} | t| z } | j | | |jjr||| |d |d | n ||| d d | fwg} |D]}|ddk(s t |dj }| D]1} || d ks | dj|}| j |]dt|z|_t!t"rt%t"|j|t'|j ddd| S#1swY SxYw)Nr ) ObjectDefReaderrSrUrdct| Sr)r~)rs rrz)Connection._get_entries..%s #a&r)r)r]basefilter)rdrrzattribute set not found for )rrrrsetkeysr.rrr]rZrrA _create_entryrrrqrrrpre)rsearch_responsesearch_requestrr attr_setsr resp_attr_setunique_attr_setsattr_set unique_set object_defs object_defrrqs rrzConnection._get_entriessN  ! !( ? ,I+ 8F#'77$'(>(C(C(E$FM$I5!((7  8 NN0N 1! % 6"26J!X-6%++H5  6 K, %&dkk.@.@A d8n, ""H$.HLHUHUHZHZF4^F=SUcdlUm{C%D`fgkmwy{}LT`U$V% %G+ ?F#'77$'(>(C(C(E$FM&1 ? (JqM9$.qM$?$?$IE#NN51! ? +I3}K]*]&u-t=-doo>> ?9( ?TU( ?Ts*G G7G?B!G!)G A;GG)F)TN)NNNNNTNr)NNN)TNN)T)NFNNN)FNr{TNTT)Fr{T))r __module__ __qualname____doc__rrrrrrrrpropertyr!setterrr/r7rrGrrrrrrxrrrrrrrr>r@rBrrrrYrrr~rrrrzs>B, $!% $ $"&!$ "'# "!%)-$)!! $ $!"&=yFv+@ "H%NPP  ]]00    $#sGl"" $ $/Ed4F$#/*/!& sKr :<| ]r?operation.deleter@rAoperation.extendedrBrCoperation.modifyrDrEoperation.modifyDnrFrGoperation.searchrHrIprotocol.rfc2849rJrKprotocol.sasl.digestMd5rLprotocol.sasl.externalrMprotocol.sasl.plainrN strategy.syncrOstrategy.safeSyncrPstrategy.safeRestartablerQstrategy.mockAsyncrRstrategy.asynchronousrSstrategy.reusablerTstrategy.restartablerUstrategy.ldifProducerrVstrategy.mockSyncrWstrategy.asyncStreamrXoperation.unbindrYprotocol.rfc2696rZrr[rr\ exceptionsr]r^r_r`rarbrcrdrerfrgrhrirj utils.convrkrlrmrnro utils.logrprqrrrsrtrurvutils.dnrwutils.port_validatorsrxr=rrrobjectrr~rrr5s;0  00000000000 ON+J>AJGMGOGA52,(0>2106806/3"@@@@dcooo<&'#"$ % ! #  KKr