>OOfl6dZddlZddlmZmZmZddlmZmZm Z m Z m Z m Z ddl mZmZmZmZddlmZddlmZmZmZmZmZmZdd lmZmZdd lmZeZ Gd d eZ!y)  N)SEQUENCE_TYPESget_config_parameter DIGEST_MD5)LDAPSocketReceiveErrorcommunication_exception_factoryLDAPExceptionErrorLDAPExtensionErrorLDAPOperationResult$LDAPSignatureVerificationFailedError) BaseStrategySESSION_TERMINATED_BY_SERVERRESPONSE_COMPLETETRANSACTION_ERROR) LDAPMessage)log log_enabledERRORNETWORKEXTENDEDformat_ldap_message)decoderdecode_message_fast)md5_hmaccHeZdZdZdZd dZdZdZdZdZ dZ d Z d Z y ) SyncStrategyaZ This strategy is synchronous. You send the request and get the response Requests return a boolean value to indicate the result of the requested Operation Connection.response will contain the whole LDAP response for the messageId requested in a dict form Connection.request will contain the result LDAP message in a dict form ctj||d|_d|_d|_d|_t d|_y)NTF SOCKET_SIZE)r__init__sync no_real_dsapooled can_streamr socket_size)selfldap_connections T/var/www/premiumrankchecker/venv/lib/python3.12/site-packages/ldap3/strategy/sync.pyr zSyncStrategy.__init__0s<dO4   / >c&tj||||r3|jjs |jj yyy#t $r9d|jj _d|jj _YywxYwN) ropen connection_deferred_openrefresh_server_infor server _dsa_info _schema_info)r& reset_usageread_server_infos r(r,zSyncStrategy.open8sw$ -=> DOO$B$B ;335%C ' ;37&&06:&&3 ;sA?BBc|jjs)|jjsd|j_yyy)NT)r- listeningclosedr&s r( _start_listenzSyncStrategy._start_listenAs0((1G1G(,DOO %2H(r)c g}d}d}d}d}d}d}d}d} |r.|r |jjj|j}|jj"t$k(r2|jj&r|jj(s||z}|dk(s|rt*j-|ddd } |dd}d}|t/|z }||z }|| k\r|| d z | d z } || dz | } || d}|d| d z }|jj&} t0j3t5| | |zdd }| |k7rVt7d tt*j-| d zdz|j9zdz| j9zdzd}||z }d}n||z }t/|dkDrt;j<|}|dk(rd}t/||krd}nett>r(tt>dt/|d||j|jA|d|||d}d}t/|dk(rd}nd}|r.tt>r%tt>dt/||j|S#ttj t f$r} dt| z|j_ |jn#tj tf$rYnwxYwttr0ttd|jj|jttt!| t| |jjd} ~ wwxYw)zV Receives data over the socket Checks if the socket is closed Tr)rzerror receiving data: <%s> for <%s>NbigzCSignature verification failed for the recieved LDAP message number z. Expected signature z but got .zreceived %d bytes via <%s>Fz"received %d ldap messages via <%s>)!r-socketrecvr%OSErrorerrorAttributeErrorstr last_errorcloser rrrr rtypesasl_mechanismr_digest_md5_kissasl_in_progressint from_byteslenbytesfromhexrr hexrcompute_ldap_message_sizerappend)r&messages receiving unprocesseddata get_more_datasasl_total_bytes_recievedsasl_received_datasasl_next_packetsasl_buffer_lengthesasl_signature sasl_sec_numkiscalculated_signaturelengths r(rXzSyncStrategy.receivingEs    $%!   ??1166t7G7GHD??11Z?DOODcDclpl{l{mMmM+d2D)S04D-0^^D1Iu-M*#ABx'*$-T:-&$.&04FF *<P>Q+R(-?@XASVXAX-Y*"oo==/4}}Xc 1ICPQF1RDOO. "LL*<="5)E?DOO4N4NPTP_P_`b9:PRYRVWXRYZ]^_Z`Rabcgcrcrc}c}~~ s</I::M,M'6KM'K# M'"K##BM''M,c~|j|\}}||j_|ddk(r~|D]y}|ddk7s d|j_t t r0t t d|jj|jt|jj|j||S)zp Executed after an Operation Request (except Search) Returns the result message or None rKintermediateResponsez multiple messages received errorr<) get_responser-resultrIrrrrrV)r& message_id responsesriresponses r(post_send_single_responsez&SyncStrategy.post_send_single_responses !--j9 6!' &>3 3% MF#'==1SDOO."5)E?DOO4N4NPTP_P_`01K1KLL  M  r)cv|j|\}}||j_t|tr|dd|j_|Sd|j_ttr0ttd|jj |jt|jj )z Executed after a search request Returns the result message and store in connection.response the objects found Nzerror receiving responser<) rhr-ri isinstancerrlrIrrrr)r&rjrkris r(post_send_searchzSyncStrategy.post_send_searchs !--j9 6!' i 0'0|DOO $ %?" u  (B(BDOO T$T__%?%?@@r)c g}d}|s|j}|r|D]}t|dkDs|jjr.|jjj t||jj rt|}|j|}n/tj|t\}} |j|}ttr&ttd|jt!|dt#|d|k(r|j%||ddvsd }t#|ddk(r|d d k(rt&cS|d d k(rt(cSd |j_tt,r0tt,d|jj*|jt/|jj*t#|d|k7rw|ddk(rod|j_tt,r0tt,d|jj*|jt1|jj*d|j_tt,r0tt,d|jj*|jt/|jj*nt&S|s|j%t2|S)zH Performs the capture of LDAP response for SyncStrategy Fr)asn1Specz!ldap message received via <%s>:%sz<< messageIDrK)searchResEntry searchResRefrgT responseNamez1.3.6.1.4.1.1466.20036z2.16.840.1.113719.1.27.103.4z,unknown unsolicited notification from serverr< extendedRespz8multiple extended responses to a single extended requestzinvalid messageId received)rXrQr-usage_usageupdate_received_message fast_decoderrdecode_response_fastrdecodeLDAP_MESSAGE_TEMPLATEdecode_responserrrrrOrVrrrIrrr r) r&rjtimeoutldap_responsesresponse_completerkrl ldap_resp dict_response_s r( _get_responsezSyncStrategy._get_responsest!#(I )$UH8}q(??00 OO22JJ3x=Y??77(;H(EI,0,E,Ei,PM+2>>(Mb+cLIq,0,@,@,KM&x0*Mt`st}@DaEFy56*D*11-@,V4B`!`'8 8=k :#.u#5$'@Z@Z\`\k\k$l&rsL2??yyll*WW5.# S"<S"r)