h UddlZddlZddlZddlZddlZddlZddlZddlZddlm Z ddlm Z ddl m Z ddl mZmZmZddlmZddlmZmZddlmZmZmZdd lmZdd lmZmZdd lmZm 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-dd l.m/Z/dd l0m1Z1m2Z2m3Z3m4Z4 ddl5Z5dZ6n #e7$rdZ6YnwxYwe8ej9iZ:e6r+e;e5drde:e5j<<de:e5j=<n de:e5j><e?e:@ZAe2rddlBZBdZCdZDdZEdZFdZGeHZIdZJdZKdZLdZMeedZNGddZOGddZPGd d!ZQGd"d#ePZRGd$d%ePZSePeTd&<e2reSZUneRZUGd'd(ZVGd)d*ZWGd+d,ZXGd-d.eXZYGd/d0eYZZGd1d2eXZ[d3Z\d4Z]e^e_e_e]e]e`e^e^e]d5 Zad6ZbGd7d8ZcGd9d:ecZddS);N)abstractmethod)SEEK_END)chain)EmptyFull LifoQueue)time)OptionalUnion)parse_qsunquoteurlparse) NoBackoff)CredentialProvider"UsernamePasswordCredentialProvider)AuthenticationError$AuthenticationWrongNumberOfArgsErrorBusyLoadingErrorChildDeadlockedErrorConnectionError DataErrorExecAbortErrorInvalidResponse ModuleErrorNoPermissionError NoScriptError ReadOnlyError RedisError ResponseError TimeoutError)Retry)CRYPTOGRAPHY_AVAILABLEHIREDIS_AVAILABLEHIREDIS_PACK_AVAILABLE str_if_bytesTFSSLWantReadError*$s zConnection closed by server.z:Error loading the extension. Please check the server logs.z5Error unloading module: no such module with that namez/Error unloading module: operation not possible.z[Error unloading module: the module exports one or more module-side data types, can't unload)zxAUTH called without any password configured for the default user. Are you sure your configuration is correct?z(Client sent AUTH, but no password is setc&eZdZdZdZdZddZdS)Encoderz=Encode strings to bytes-like and decode bytes-like to stringsc0||_||_||_dSNencodingencoding_errorsdecode_responses)selfr0r1r2s L/var/www/html/Sam_Eipo/venv/lib/python3.11/site-packages/redis/connection.py__init__zEncoder.__init___s  . 0r*ct|ttfr|St|trt dt|t t fr"t|}nzEncoder.encodeds eeZ0 1 1 L t $ $ 5 U| , , KK&&((EEE3'' E{{+HC8CCC  eS ! ! FLL0DEEE r*Fc|js|r^t|tr|}t|tr ||j|j}|S)z:Return a unicode string from the bytes-like representation)r2r7r9tobytesr8decoder0r1)r3rBforces r4rFzEncoder.decode{se   JE J%,, ( %'' J T]D4HII r*NF)rA __module__ __qualname____doc__r5r>rFr*r4r,r,\sLCC111 .r*r,cNeZdZdedededeeeeee ee eie ee e eeeedZdZdS) BaseParserzmax number of clients reachedzinvalid passwordz,wrong number of arguments for 'auth' commandz,wrong number of arguments for 'AUTH' command)ERR WRONGPASS EXECABORTLOADINGNOSCRIPTREADONLYNOAUTHNOPERMc,|dd}||jvrb|t|dzd}|j|}t|tr||t }||St |S)zParse an error response rN)splitEXCEPTION_CLASSESlenr7dictgetr)r3response error_codeexception_classs r4 parse_errorzBaseParser.parse_errors^^C((+ / / /J! 3 5 56H"4Z@O/400 O"1"5"5h "N"N"?8,, ,X&&&r*N)rArIrJrrrMODULE_LOAD_ERRORrMODULE_EXPORTS_DATA_TYPES_ERRORNO_SUCH_MODULE_ERROR MODULE_UNLOAD_NOT_POSSIBLE_ERRORNO_AUTH_SET_ERRORrrrrrr[rbrLr*r4rNrNs ,_  3 !"F !"F { +[ + ,k   ")##!!%#16 ' ' ' ' 'r*rNc eZdZdejdedefdZdefdZdedfd e ed e ee fd e e de fd Z d ede fd Zd edefdZdefdZdefdZdeddfdZddZddZdS) SocketBuffersocketsocket_read_sizesocket_timeoutc`||_||_||_tj|_dSr.)_sockrkrlioBytesIO_buffer)r3rjrkrls r4r5zSocketBuffer.__init__s, 0,z|| r*returnc|j}|jdt}|j|||z S)z3 Remaining unread length of buffer r)rqtellseekr)r3posends r4 unread_byteszSocketBuffer.unread_bytessNl!!l8,, #Syr*NTlengthtimeoutraise_on_timeoutc|j}|j}d}|tu}|j}|} |dt |r|| |j|} t| tr't| dkrtt|| t| } || z }|||kr || |r||jdSdS#t j$rH|rt%dY|| |r||jdSdSt&$r} t(| jd} |sD| j| kr9Yd} ~ || |r||jdSdStd| jd} ~ wwxYw#|| |r||jwwxYwNrTzTimeout reading from socketFz!Error while reading from socket: )rnrkSENTINELrqrtrur settimeoutrecvr7r8r\rSERVER_CLOSED_CONNECTION_ERRORwriterlrjrzr NONBLOCKING_EXCEPTIONS#NONBLOCKING_EXCEPTION_ERROR_NUMBERSr^ __class__errnoargs)r3ryrzr{sockrkmarkercustom_timeoutbuf current_posdata data_lengthexalloweds r4_read_from_socketzSocketBuffer._read_from_sockets z0 0lhhjj  H  % OOG $ $ $ 5 z'788dE**Js4yyA~~)*HIII $!$ii +%%&6// HH[ ! ! ! 5 344444 5 5~    B"#@AAA HH[ ! ! ! 5 344444 5 5& Q Q Q :==blBOOG# G(;(;uuu HH[ ! ! ! 5 344444 5 5""Obg"O"OPP P Q HH[ ! ! ! 5 34444 5s=(B D'' HH = H-H3H ,HHH 4H?crt|p||dS)NFrzr{)r:rxrr3rzs r4can_readzSocketBuffer.can_reads@D%%''(( D,B,Be-C- -  r*c|dz}|j|}|t|z }|r2||||j|z }|ddS)Nr')rqreadr\r)r3ryrmissings r4rzSocketBuffer.readst!|  ((3t99$  /  " "7 + + + DL%%g.. .DCRCyr*c |j}|}|tsE|||z }|tE|ddS)Nr)rqreadlineendswithSYM_CRLFr)r3rrs r4rzSocketBuffer.readlinestl||~~--)) #  " " $ $ $ CLLNN "D--)) # CRCyr*c4|jS)z+ Get current read position )rqrtr3s r4get_poszSocketBuffer.get_poss|  """r*rvc:|j|dS)zO Rewind the buffer to a specific position, to re-start reading N)rqru)r3rvs r4rewindzSocketBuffer.rewinds  #r*c|}|dkrdS|dkr)|j}|| d|d|<|j||jddS)zH After a successful read, purge the read part of buffer rN)rxrq getbuffertruncateru)r3unreadviews r4purgezSocketBuffer.purges""$$ A:: F A::<))++D &ND&M f%%% !r*cx |jn#t$rYnwxYwd|_d|_dSr.)rqclose Exceptionrnrs r4rzSocketBuffer.close'sT  L       D    s  ))rrN)rArIrJrjr;r<r5rxrr r objectr:rrr8rrrrrrrLr*r4riris}$m$7:$LQ$$$$c!%(0+/ -5-5 -5uf}%-5#4. -5  -5-5-5-5^  $    3 5    %##### #$ &      r*ric@eZdZdZdZdZdZdZdZd dZ d d Z d S) PythonParserzPlain Python parsing classc>||_d|_d|_d|_dSr.)rkencoderrnrqr3rks r4r5zPythonParser.__init__8s# 0   r*cR |dS#t$rYdSwxYwr. on_disconnectrrs r4__del__zPythonParser.__del__>A         DD   &&c|j|_t|j|j|j|_|j|_dS)zCalled when the socket connectsN)rnrirkrlrqrr3 connections r4 on_connectzPythonParser.on_connectDs<% # J-z/H   ") r*cpd|_|j |jd|_d|_dS)z"Called when the socket disconnectsN)rnrqrrrs r4rzPythonParser.on_disconnectLs7 < # L   DL r*cD|jo|j|Sr.)rqrrs r4rzPythonParser.can_readTs|> 5 5g > >>r*Fc |jr|jnd} ||}|j|S#t$r#|jr|j|wxYw)Ndisable_decoding)rqr_read_responser BaseExceptionr)r3rrvresults r4 read_responsezPythonParser.read_responseWs(, >dl""$$$$ ((:J(KKF L   M    | ) ##C(((  s A-Bcj}|stt|dd|dd}}|dkrE|dd}|}t |tr||S|dkrn|dkrt|S|dkr|d krdS|dkr(jt|}nP|d kr|d krdS|d kr*fd tt|D}ntd |d urj |}|S)NrY-utf-8replace)errors+:r)s-1r(c<g|]}S)r)r).0irr3s r4 z/PythonParser._read_response..s;##5E#FFr*zProtocol Error: F) rqrrrrFrbr7r;rrangerr)r3rrawbyter_errors`` r4rzPythonParser._read_responsecsl##%% B!"@AA ARaR#abb'h 4<<wyAAH$$X..E%11  L T\\  T\\x== T\\h%//4 T\\|((X77HH T\\h%//4 T\\s8}}--HH ""|j|_|jdur||dSdS)NFrT)rrrrgetsread_from_socketrs r4rzHiredisParser.can_readsl| B!"@AA A  % ' '"&,"3"3"5"5D "e++,,Wu,UUUtr*Tc|j}|tu} |r|||j|j}|dkrt t |j|jd| |r||j dSdS#tj $r3|rtdY|r||j dSdSt$rm}t|jd}|s/|j|kr$Yd}~|r||j dSdSt d|jd}~wwxYw#|r||j wwxYwr})rnrr recv_intorqrrrfeedrrjrzr rrr^rrr)r3rzr{rrbufflenrrs r4rzHiredisParser.read_from_socketsz 0 6 )(((j**4<88G!||%&DEEE L  dlAw 7 7 7 6 455555 6 6~    B"#@AAA 6 455555 6 6& Q Q Q :==blBOOG# G(;(;uuu 6 455555 6 6""Obg"O"OPP P Q 6 45555 6s<A1B$$ EE% E.-EE?EEEE=Fc |jstt|jdur|j}d|_|S|r|jd}n|j}|durN||r|jd}n|j}|duNt |tr|t |tr%|r#t |dtr|d|S)NFr)rrrrrrr7list)r3rr_s r4rzHiredisParser.read_responses+| B!"@AA A  e + +*H"'D O  +|((//HH|((**H%  ! ! # # # /<,,U33<,,.. % h 0 0 N x & &  8A;88  1+ r*NrH) rArIrJrKr5rrrrrrrrLr*r4rrs00333  $ $ $$$$ (0$6666<      r*r DefaultParserceZdZdZdS)HiredisRespSerializerc"g}t|dtrEt|d|ddz}nrZappendr pack_command TypeErrorsysexc_inforwith_traceback)r3routput_rB tracebacks r4packzHiredisRespSerializer.packs d1gs # # 5a))//1122T!""X=DD T!W__a))DH4D = MM'.t44 5 5 5 5 = = ="%,.. AuiE""11)<< < = s 'CAD N)rArIrJrrLr*r4rrs#r*rceZdZddZdZdS)PythonRespSerializerrrNc"||_||_dSr.)_buffer_cutoffr>)r3 buffer_cutoffr>s r4r5zPythonRespSerializer.__init__s+ r*c \g}t|dtrEt|d|ddz}nrZ SYM_EMPTYjoinSYM_STARr\rrmapr9 SYM_DOLLARr)r3rrbuffrarg arg_lengths r4rzPythonRespSerializer.packs d1gs # # 5a))//1122T!""X=DD T!W__a))DH4D~~xSYY)>)>)@)@(KLL+ t{D))  CSJD M)) --c:...!~~:s:'='='?'?J d### c""" ~~"J..00      d r*r)rArIrJr5rrLr*r4rrs7+++++r*rceZdZdZdddedddeddddddddfdeefd Zd Z e d Z d Z d Z dZdZdZdZe dZe dZe dZdZdZdZdZdZd!dZdZd"dZd#dZdZd ZdS)$AbstractConnectionz0Manages communication to and from a Redis serverrNFrstricticredential_providerc| s|r|tdtj|_||_| |_||_||_| |_||_ |turg}|r| t||_ | s|rX| "ttd|_nt#j| |_|j|n!ttd|_| |_d|_||_t/||||_d|_| |_||g|_d|_|||_dS)a2 Initialize a new Connection. To specify a retry policy for specific errors, first set `retry_on_error` to a list of the error/s to retry on, then set `retry` to a valid `Retry` object. To retry on TimeoutError, `retry_on_timeout` can also be set to `True`. Nz'username' and 'password' cannot be passed along with 'credential_provider'. Please provide only one of the following arguments: 1. 'password' and (optional) 'username' 2. 'credential_provider'rYrip) rosgetpidpiddb client_namerpasswordusernameretry_on_timeoutrrr retry_on_errorr!rretrycopydeepcopyupdate_supported_errorshealth_check_intervalnext_health_checkredis_connect_funcr,rrn_socket_read_size set_parser_connect_callbacksr_construct_command_packer_command_packer)r3rrrrr0r1r2 parser_classrkr rrrr"rcommand_packers r4r5zAbstractConnection.__init__Ns4   &9&E+  9;;&#6     0 X % %N  0  ! !, / / /,  /N /}"9;;22 "]511 J . .~ > > > >y{{A..DJ%:"!""4x:JKK  !1  %%%"$"#==nMMr*cdd|D}|jjd|dS)N,c"g|] \}}|d| S)=rL)rkvs r4rz/AbstractConnection.__repr__..s&HHHTQjjQjjHHHr*<>)r repr_piecesrrA)r3 repr_argss r4__repr__zAbstractConnection.__repr__sJHHHHT5E5E5G5GHHHII .)88I8888r*cdSr.rLrs r4r2zAbstractConnection.repr_pieces r*cR |dS#t$rYdSwxYwr.) disconnectrrs r4rzAbstractConnection.__del__s?  OO         DD rcr||StrtSt|j|jjSr.)r$rrrrr>)r3packers r4r&z,AbstractConnection._construct_command_packers:  M # R(** *'(;T\=PQQ Qr*c^|jtj|dSr.)r%rweakref WeakMethod)r3callbacks r4register_connect_callbackz,AbstractConnection.register_connect_callbacks* &&w'9('C'CDDDDDr*cg|_dSr.)r%rs r4clear_connect_callbacksz*AbstractConnection.clear_connect_callbackss"$r*c2||j|_dS)z Creates a new instance of parser_class with socket size: _socket_read_size and assigns it to the parser for the connection :param parser_class: The required parser class )rkN)r#_parser)r3r(s r4r$zAbstractConnection.set_parsers $|T5KLLL r*cjrdS jfdfd}nQ#tj$rt dt $r'}t|d}~wwxYw|_ j  n n##t$r wxYwj D]}|}|r |dS)z5Connects to the Redis server if not already connectedNc,Sr.)_connectrsr4z,AbstractConnection.connect..s r*c.|Sr.r8)rr3s r4rGz,AbstractConnection.connect..stu7M7Mr*zTimeout connecting to server)rnrcall_with_retryrjrzr OSErrorr_error_messager"rrr8r%)r3rerefr>s` r4connectzAbstractConnection.connectsV :  F ::--'''')M)M)M)MDD~ ? ? ?=>> > : : :!$"5"5a"8"899 9 :  &.!!!!''---    OO     *  CsuuH   s!!.'A<"A77A<1B99 CcdSr.rLrs r4rFzAbstractConnection._connectr6r*cdSr.rLrs r4 _host_errorzAbstractConnection._host_errorr6r*cdSr.rL)r3 exceptions r4rLz!AbstractConnection._error_messager6r*cB|j||js|js|jr|jpt |j|j}|}|jdg|Rddi |}nB#t$r5|d|dd|}YnwxYwt|dkrtd|j rP|dd |j t|dkrtd |jrO|d |jt|dkrtd d Sd S)z=Initialize the connection, authenticate and select a databaseAUTH check_healthFr~rWOKzInvalid Username or PasswordCLIENTSETNAMEzError setting client nameSELECTzInvalid DatabaseN)rCrrrrrget_credentials send_commandrrr%rrrr)r3 cred_provider auth_args auth_responses r4rzAbstractConnection.on_connects %%%  # J  J J(T5dmT]SS &5577I D f Ey E E Eu E E E 5 $ 2 2 4 4 7 5 5 5 !!&)B-e!LLL $ 2 2 4 4  5M**d22)*HIII   C   h 43C D D DD..0011T99%&ABBB 7 :   h 0 0 0D..0011T99%&8999 : :99s7B t|jkr)|j|j|jdSdSdS)z3Check the health of the connection with a PING/PONGN)r r r!rrJrirkrs r4rWzAbstractConnection.check_health&sT  % K$&&43I*I*I J & &t8I J J J J J K K*I*Ir*Tcr|js||r| t|tr|g}|D]}|j|dS#t j$r$|tdt$rq}|t|j dkrd|j d}}n|j d}|j d}td|d|dd}~wt$r|wxYw) z2Send an already packed command to the Redis serverzTimeout writing to socketrYUNKNOWNrError z while writing to socket. .N)rnrOrWr7r?sendallrjrzr8r rKr\rrr)r3commandrWitemrMrerrmsgs r4send_packed_commandz&AbstractConnection.send_packed_command+siz  LLNNN        '3'' $") ) ) ""4(((( ) )~ < < < OO   :;; ; W W W OO   16{{a )16!9vq !"U5"U"UF"U"U"UVV V    OO     s7A,,;D6'A,D#D6cv||jj||dddS)z+Pack and send a command to the Redis serverrWTrXN)rur'rr^)r3rrs r4r^zAbstractConnection.send_commandFsJ   %D %t ,ND99 !     r*c|j}|s||} |j|S#t $r3}|td|d|jd}~wwxYw)z8Poll the socket to see if there's data that can be read.Error while reading from z: N) rnrOrRrCrrKr8rr)r3rzr host_errorrMs r4rzAbstractConnection.can_readMsz  LLNNN%%''  V<((11 1 V V V OO   !"Tj"T"TAF"T"TUU U VsA B .BB c|} |j|}n#tj$r'|t d|t$r3}|td|d|j d}~wt$r|wxYw|j rt|j z|_ t|tr||S)z0Read the response from a previously sent commandrzTimeout reading from rxz : N)rRrCrrjrzr8r rKrrrr r r!r7r)r3rryr_rMs r4rz AbstractConnection.read_response[s.%%''  |11CS1TTHH~ E E E OO   CzCCDD D    OO   !GJGGqvGG     OO       % I%)VVd.H%HD " h . . Ns2>C0.B#Cc |jj|S)r)r'rres r4rzAbstractConnection.pack_commandus(t#($//r*cg}g}d}|j}|D]}|jj|D]}t|}||ks||kst |t r3|r-|t|d}g}||kst |t r||||||z }|r-|t||S)z.Pack multiple commands into the Redis protocolr) rr'rr\r7r9rrr) r3commandsrpieces buffer_lengthrcmdchunkchunklens r4 pack_commandsz AbstractConnection.pack_commandsys( +  . .C2-2C8 . .u::!M11-//!%440> innV&<&<===$%MFm++z%/L/L+MM%((((MM%(((!X-MM! .$  2 MM)..00 1 1 1 r*T)rrH) rArIrJrKrrr rr5r4rr2rr&r?rAr$rOrFrRrLrr8rirkrWrur^rrrrrLr*r4rrKs 66  "<@#ANAN &&89!ANANANANF999  ^  RRREEE%%%MMMB  ^   ^   ^ &:&:&:P$III KKK 6    V V V V4000r*rcJeZdZdZ d fd ZdZd Zd Zd ZxZ S) Connectionz4Manages TCP communication to and from a Redis server localhostNFrc ||_t||_||_|p||_||_|pi|_||_tj di|dSNrL) hostr;portrlsocket_connect_timeoutsocket_keepalivesocket_keepalive_options socket_typesuperr5) r3rrrlrrrrrrs r4r5zConnection.__init__sn II ,&<&N# 0(@(FB%&""6"""""r*cd|jfd|jfd|jfg}|jr|d|jf|S)Nrrrr)rrrrrr3r~s r4r2zConnection.repr_piecessL49% ':T47OL   = MM=$*:; < < < r*cd}tj|j|j|jtjD]<}|\}}}}}d} tj|||}|tjtjd|j rk|tj tj d|j D]&\} } |tj| | '||j||||j|cS#t$$r#} | }||Yd} ~ 6d} ~ wwxYw||t%d)zCreate a TCP socket connectionNrYz)socket.getaddrinfo returned an empty list)rj getaddrinforrr SOCK_STREAM setsockopt IPPROTO_TCP TCP_NODELAYr SOL_SOCKET SO_KEEPALIVEritemsrrrOrlrKr) r3errresfamilysocktypeproto canonnamesocket_addressrr.r/rs r4rFzConnection._connects % Ity$"2F4F   ! !CBE >FHeYD !}VXu== 2F4FJJJ(BOOF$5v7JANNN $ = C C E EBB1(:AqAAAA ;<<< ^,,, 3444  ! ! !#JJLLL ! ?IABBBsC=E E. E))E.c$|jd|jS)N:)rrrs r4rRzConnection._host_errors)))di)))r*cJ|}t|jdkr5 d|d|jddS#t$rd|jdcYSwxYw d|jdd|d |jddS#t$rd|jdcYSwxYw) NrYzError connecting to z. rrpzConnection Error: roz connecting to . )rRr\rAttributeErrorr3rTrys r4rLzConnection._error_messages%%'' y~  ! # # @.j.."*....! @ @ @?IN1,=????? @ @:Y^A.::!::%.^A%6:::" @ @ @?IN1,=????? @s#AAA#!BB"!B")rrNNFNr rArIrJrKr5r2rFrRrL __classcell__rs@r4rrs:: #!%######( 'C'C'CR***@@@@@@@r*rcFeZdZdZ dfd ZfdZxZS) SSLConnectionzManages SSL connections to and from the Redis server(s). This class extends the Connection class, adding SSL functionality, and making use of ssl.SSLContext (https://docs.python.org/3/library/ssl.html#ssl.SSLContext) NrequiredFc  tstd||_||_| tj}nWt |trBtjtjtj d}||vrtd|||}||_ ||_ ||_ ||_ ||_||_| |_| |_| |_| |_t)jdi| dS)aeConstructor Args: ssl_keyfile: Path to an ssl private key. Defaults to None. ssl_certfile: Path to an ssl certificate. Defaults to None. ssl_cert_reqs: The string value for the SSLContext.verify_mode (none, optional, required). Defaults to "required". ssl_ca_certs: The path to a file of concatenated CA certificates in PEM format. Defaults to None. ssl_ca_data: Either an ASCII string of one or more PEM-encoded certificates or a bytes-like object of DER-encoded certificates. ssl_check_hostname: If set, match the hostname during the SSL handshake. Defaults to False. ssl_ca_path: The path to a directory containing several CA certificates in PEM format. Defaults to None. ssl_password: Password for unlocking an encrypted private key. Defaults to None. ssl_validate_ocsp: If set, perform a full ocsp validation (i.e not a stapled verification) ssl_validate_ocsp_stapled: If set, perform a validation on a stapled ocsp response ssl_ocsp_context: A fully initialized OpenSSL.SSL.Context object to be used in verifying the ssl_ocsp_expected_cert ssl_ocsp_expected_cert: A PEM armoured string containing the expected certificate to be returned from the ocsp verification service. Raises: RedisError z$Python wasn't built with SSL supportN)noneoptionalrz+Invalid SSL Certificate Requirements Flag: rL) ssl_availablerkeyfilecertfilessl CERT_NONEr7r? CERT_OPTIONAL CERT_REQUIRED cert_reqsca_certsca_dataca_pathcheck_hostnamecertificate_passwordssl_validate_ocspssl_validate_ocsp_stapledssl_ocsp_contextssl_ocsp_expected_certrr5)r3 ssl_keyfile ssl_certfile ssl_cert_reqs ssl_ca_certs ssl_ca_datassl_check_hostname ssl_ca_path ssl_passwordrrrrr CERT_REQSrs r4r5zSSLConnection.__init__sH ECDD D" $  MMM  s + + 5 --I I-- Q-QQ&m4M&$ " " 0$0!!2)B& 0&<#""6"""""r*c"t}tj}|j|_|j|_|js|jr'| |j|j|j |j |j |j '||j |j |j |||j}|jdurt$durt'd|jr|jrt'd|jrd dl}d d lm}|jY|j|jj}||j||jn|j}|||j|j |tCj!}|"|#|j|j$f|%|&|S|jdurOt$rHd d lm'}|||j|j$|j } | (r|StSd |S)z Wrap the socket with SSL support)rrrN)cafilecapathcadata)server_hostnameTFzcryptography is not installed.zKEither an OCSP staple or pure OCSP connection must be validated - not both.rrY)ocsp_staple_verifier) OCSPVerifierzocsp validation error)*rrFrcreate_default_contextrr verify_moderrload_cert_chainrrrrload_verify_locations wrap_socketrrr"rrOpenSSLocsprrSSLContext SSLv23_METHODuse_certificate_fileuse_privatekey_fileset_ocsp_client_callbackrrrj request_ocsprOr do_handshakercris_validr) r3rcontextsslsockrr staple_ctxconrors r4rFzSSLConnection._connect?sww!!,..!%!4"n = DL   # # 2 $    M %|'|'  ) )}T\$, *   %%dDI%FF  !T ) ).D.M.M=>> >  ) d.D    )  NNN 2 2 2 2 2 2$,$[001JKK // >>>..t|<<<<!2  / /$d&A    +((V]__EEC       KKDI. / / /       LLNNNN  !T ) ).D ) * * * * * * WdiDMJJAzz|| ?%&=>>>r*) NNrNNFNNFFNN)rArIrJrKr5rFrrs@r4rrs  "'#@#@#@#@#@#@#DAAAAAAAAAr*rc<eZdZdZd fd ZdZdZdZdZxZ S) UnixDomainSocketConnectionz4Manages UDS communication to and from a Redis serverNc V||_||_tjdi|dSr)pathrlrr5)r3rrlrrs r4r5z#UnixDomainSocketConnection.__init__s5 ,""6"""""r*cpd|jfd|jfg}|jr|d|jf|S)Nrrr)rrrrrs r4r2z&UnixDomainSocketConnection.repr_piecessC49%dg7   = MM=$*:; < < < r*ctjtjtj}||j||j|S)z&Create a Unix domain socket connection)rjAF_UNIXrrrlrOr)r3rs r4rFz#UnixDomainSocketConnection._connectsF}V^V-?@@ +,,, TY r*c|jSr.)rrs r4rRz&UnixDomainSocketConnection._host_errors yr*c|}t|jdkrd|d|jddSd|jdd|d|jddS)NrYz!Error connecting to unix socket: rrrproz connecting to unix socket: )rRr\rrs r4rLz)UnixDomainSocketConnection._error_messages%%'' y~  ! # #VJVV).QRBSVVV  6*6666!*!2666 r*)rNrrs@r4rrs::######         r*r)0FFALSENNOc||dkrdSt|tr|tvrdSt |S)NrF)r7r?upper FALSE_STRINGSr:)rBs r4to_boolrsI } t%%++--="@"@u ;;r*) rrlrrrrmax_connectionsr rc\|ds9|ds$|dstdt|}i}t|jD]\}}|rt |dkrnt|d}t |}|r8 ||||<[#ttf$rtd|dwxYw|||<|j rt|j |d<|j rt|j |d <|j d kr)|jrt|j|d <t|d <n|jrt|j|d <|jrt%|j|d<|jrUd|vrQ t%t|jdd|d<n#t(tf$rYnwxYw|j dkr t*|d <|S)Nzredis://z rediss://zunix://zRRedis URL must specify one of the following schemes (redis://, rediss://, unix://)rzInvalid value for `z` in connection URL.rrunixrconnection_classrrr/rrediss) startswith ValueErrorrr queryrr\r URL_QUERY_ARGUMENT_PARSERSr^rrrschemerrhostnamerr;rrr)urlrnamerBparsers r4 parse_urlr su z"" >>+ & &  >>) $ $  5   3--C F **0022 % % e  %SZZ!^^E!H%%E/33D99F %W#)6%==F4LL!:.WWW$%U4%U%U%UVVVW %t  |3$S\22z |3$S\22z zV 8 /$SX..F6N%?!"" < 3$S\22F6N 8 + ]]F6N 8 F** "738#4#4#<# - `rediss://` creates a SSL wrapped TCP socket connection. See more at: - ``unix://``: creates a Unix Domain Socket connection. The username, password, hostname, path and all querystring values are passed through urllib.parse.unquote in order to replace any percent-encoded values with their corresponding characters. There are several ways to specify a database number. The first value found will be used: 1. A ``db`` querystring option, e.g. redis://localhost?db=0 2. If using the redis:// or rediss:// schemes, the path argument of the url, e.g. redis://localhost/0 3. A ``db`` keyword argument to this function. If none of these options are specified, the default db=0 is used. All querystring options are cast to their appropriate Python types. Boolean arguments can be specified with string values "True"/"False" or "Yes"/"No". Values that cannot be properly cast cause a ``ValueError`` to be raised. Once parsed, the querystring arguments and keyword arguments are passed to the ``ConnectionPool``'s class initializer. In the case of conflicting arguments, querystring arguments always win. rrL)r update)clsrr url_optionss r4from_urlzConnectionPool.from_url sPR nn  ' '.45G.HK* + k"""s}}V}}r*Nc |pd}t|tr|dkrtd||_||_||_t j|_| dS)Nlrz,"max_connections" must be a positive integer) r7r;rrconnection_kwargsr threadingLock _fork_lockreset)r3rrrs r4r5zConnectionPool.__init__:st*2U/3// M?Q3F3FKLL L 0!2.$.** r*c pt|jdt|jdi|jdS)Nr0r1rL)r@rAr=rrrs r4r4zConnectionPool.__repr__PsSDzz" I I*T*DDT-CDDEE I I I r*ctj|_d|_g|_t |_tj|_ dS)Nr) rr_lock_created_connections_available_connectionsset_in_use_connectionsrrrrs r4rzConnectionPool.resetVs@^%% $%!&(##&55 9;;r*cZ|jtjkr|jd}|st  |jtjkr||jdS#|jwxYwdS)N)rz)rrrracquirerrrelease)r3acquireds r4 _checkpidzConnectionPool._checkpidgsF 8ry{{ " "..q.99H +** *8ry{{**JJLLL'')))))'')))) # "s 0B B(c||j5 |j}n$#t$r|}YnwxYw|j|dddn #1swxYwY | | rtdnb#ttf$rN| || rtdYnwxYwn$#t$r||wxYw|S)zGet a connection from the poolNConnection has dataConnection not ready)r%rrpop IndexErrormake_connectionraddrOrrrKr8rr#r3 command_namekeysoptionsrs r4get_connectionzConnectionPool.get_connections  Z 5 5 4!8<<>>  4 4 4!1133  4  $ ( ( 4 4 4  5 5 5 5 5 5 5 5 5 5 5 5 5 5 5      B&&((A)*?@@@A#W- B B B%%'''""$$$&&((B)*@AAABB B     LL $ $ $    sbB8BABABB BD*##CD*AD&#D*%D&&D**!E c|j}t|dd|dd|ddS)z,Return an encoder based on encoding settingsr0rr1rr2Fr/)rr,r^)r3rs r4 get_encoderzConnectionPool.get_encodersV'ZZ G44"JJ'8(CC#ZZ(:EBB    r*c|j|jkrtd|xjdz c_|jdi|jS)zCreate a new connectionzToo many connectionsrYrL)rrrrrrs r4r+zConnectionPool.make_connectionsR  $(< < <!"899 9 !!Q&!!$t$>>t'=>>>r*c||j5 |j|n#t$rYnwxYw||r|j|n2|xjdzc_|  ddddS ddddS#1swxYwYdS)z(Releases the connection back to the poolrYN) r%rrremoveKeyErrorowns_connectionrrrr8rs r4r#zConnectionPool.releasesI  Z   (// ;;;;     ##J// +22:>>>> ))Q.))%%'''!        ?                  s2B99B9 AB9AAB99B=B=c"|j|jkSr.)rrs r4r8zConnectionPool.owns_connections~))r*Tc||j5|rt|j|j}n|j}|D]}| ddddS#1swxYwYdS)z Disconnects connections in the pool If ``inuse_connections`` is True, disconnect connections that are current in use, potentially by other threads. Otherwise only disconnect connections that are idle in the pool. N)r%rrrrr8)r3inuse_connections connectionsrs r4r8zConnectionPool.disconnects  Z ( (  :#/1I #9 ) ( ( %%'''' ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( (s>A((A,/A,rr!rrc|jd|i|jD] }||_ |jD] }||_ dS)Nr)rrrrr)r3rconns r4 set_retryzConnectionPool.set_retrys^ %%w&6777/  DDJJ,  DDJJ  r*r)rr!rrN)rArIrJrK classmethodrrr5r4rr%r1r3r+r#r8r8r?rLr*r4r r s  ..[.b *4,   "-*-*-*^B   ???****(((((r*r cJeZdZdZddeeffd ZdZdZdZ dZ d Z xZ S) BlockingConnectionPoola Thread-safe blocking connection pool:: >>> from redis.client import Redis >>> client = Redis(connection_pool=BlockingConnectionPool()) It performs the same function as the default :py:class:`~redis.ConnectionPool` implementation, in that, it maintains a pool of reusable connections that can be shared by multiple redis clients (safely across threads if required). The difference is that, in the event that a client tries to get a connection from the pool when all of connections are in use, rather than raising a :py:class:`~redis.ConnectionError` (as the default :py:class:`~redis.ConnectionPool` implementation does), it makes the client wait ("blocks") for a specified number of seconds until a connection becomes available. Use ``max_connections`` to increase / decrease the pool size:: >>> pool = BlockingConnectionPool(max_connections=10) Use ``timeout`` to tell it either how many seconds to wait for a connection to become available, or to block forever: >>> # Block forever. >>> pool = BlockingConnectionPool(timeout=None) >>> # Raise a ``ConnectionError`` after five seconds if a connection is >>> # not available. >>> pool = BlockingConnectionPool(timeout=5) 2c \||_||_tjd||d|dS)N)rrrL) queue_classrzrr5)r3rrzrrFrrs r4r5zBlockingConnectionPool.__init__sS'  -+        r*c||j|_ |jdn#t$rYnwxYw-g|_t j|_dSr.) rFrpool put_nowaitr _connectionsrrrrs r4rzBlockingConnectionPool.reset.s$$T%9::    $$T****     9;;s= A  A c^|jdi|j}|j||S)zMake a fresh connection.rL)rrrJrrs r4r+z&BlockingConnectionPool.make_connectionFs:*T*DDT-CDD    ,,,r*c`|d} |jd|j}n#t$rt dwxYw||} | |rt dnb#t tf$rN| ||rt dYnwxYwn$#t$r| |wxYw|S)a7 Get a connection, blocking for ``self.timeout`` until a connection is available from the pool. If the connection returned is ``None`` then creates a new connection. Because we use a last-in first-out queue, the existing connections (having been returned to the pool after the initial ``None`` values were added) will be returned before ``None`` values. This means we only create new connections when we need to, i.e.: the actual number of connections will only increase in response to demand. NT)blockrzzNo connection available.r'r() r%rHr^rzrrr+rOrrKr8rr#r-s r4r1z%BlockingConnectionPool.get_connectionLsz   >T4<HHJJ > > >""<== = >  --//J      B&&((A)*?@@@A#W- B B B%%'''""$$$&&((B)*@AAABB B     LL $ $ $   s:!:A.D #B'&D 'ADD DD !D+c|||s0||jddS |j|dS#t $rYdSwxYw)z)Releases the connection back to the pool.N)r%r8r8rHrIrrs r4r#zBlockingConnectionPool.releases ##J//   ! ! # # # I  & & & F  I  , , , , ,    DD sA77 BBcj||jD]}|dS)z(Disconnects all connections in the pool.N)r%rJr8rs r4r8z!BlockingConnectionPool.disconnectsC + $ $J  ! ! # # # # $ $r*) rArIrJrKrrr5rr+r1r#r8rrs@r4rBrBsF#       "0 222h*$$$$$$$r*rB)errrorrjrrr<abcrr itertoolsrqueuerrrr typingr r urllib.parser r r redis.backoffrredis.credentialsrrredis.exceptionsrrrrrrrrrrrrrrr redis.retryr! redis.utilsr"r#r$r%rr ImportErrorBlockingIOError EWOULDBLOCKrhasattrr&SSLWantWriteErrorSSLErrorrr/rrrr rrrrrrcrerfrdrgr,rNrirr__annotations__rrrrrrrrrr;r<rrr r rBrLr*r4ras ((((((((((""""""""4444444444######TTTTTTTT"JJJMMMMM(78I&J#>ws&''>DE+C,@AEF+C,ABB<=+CL9BGGIIJJNNN     !? 688PN#T  ':0C &&&&&&&&R%'%'%'%'%'%'%'%'PEEEEEEEEPZZZZZ:ZZZzjjjjjJjjjZ!!MM M$00000000fJJJJJJJJZ \@\@\@\@\@#\@\@\@~IIIIIJIIIX$$$$$!3$$$N/  # !  666r}}}}}}}}@^$^$^$^$^$^^$^$^$^$^$sB B*)B*