h UddlZddlZddlZddlZddlZddlZddlZddlmZddl m Z ddl m Z m Z mZddlmZmZmZmZmZmZmZmZddlmZmZmZddlmZmZmZm Z m!Z!m"Z"dd l#m$Z$m%Z%m&Z&m'Z'dd l(m)Z)dd l*m+Z+dd l,m-Z-m.Z.dd l/m0Z0m1Z1ddl2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;ddlm?Z?m@Z@mAZAmBZBmCZCmDZDmEZEmFZFmGZGeArddlHZHndZHe@rddlIZIdZJdZKdZLdZMdZNeOZPeee&e'e%feQd<e@re%ZRne&ZRGddZSGddZTGddZUGddeUZVGdd eVZWGd!d"eUZXGd#d$eWZYGd%d&eVZZd'Z[d(Z\e]e^e^e\e\e_e]e]e\e^d) Z`d*Zaed+d,-ZbGd.d,ZcGd/d0ecZdy)1N)abstractmethod)chain)EmptyFull LifoQueue)AnyCallableDictListOptionalTypeTypeVarUnion)parse_qsunquoteurlparse) CacheEntryCacheEntryStatus CacheFactoryCacheFactoryInterfaceCacheInterfaceCacheKey)Encoder_HiredisParser _RESP2Parser _RESP3Parser)TokenInterface) NoBackoff)CredentialProvider"UsernamePasswordCredentialProvider)AfterConnectionReleasedEventEventDispatcher) AuthenticationError$AuthenticationWrongNumberOfArgsErrorChildDeadlockedErrorConnectionError DataErrorMaxConnectionsError RedisError ResponseError TimeoutError)Retry) CRYPTOGRAPHY_AVAILABLEHIREDIS_AVAILABLE SSL_AVAILABLEcompare_versionsdeprecated_args ensure_stringformat_error_messageget_lib_version str_if_bytes*$s  DefaultParserceZdZdefdZy)HiredisRespSerializerargscg}t|dtr1t|djj |ddz}n)d|dvr"t|dj |ddz} |j t j||S#t$r3tj\}}}t|j|wxYw2Pack a series of arguments into the Redis protocolrrN ) isinstancestrtupleencodesplitappendhiredis pack_command TypeErrorsysexc_infor(with_traceback)selfr>output_value tracebacks r/var/www/fastuser/data/www/generator.snapmosaic.io/flask_app/venv/lib/python3.12/site-packages/redis/connection.pypackzHiredisRespSerializer.packMs d1gs #a)//12T!"X=D T!W_a)DH4D = MM'..t4 5   ="%,,. AuiE"11)< < =s 1$BrPbuffr_arg arg_lengths rTrUzPythonRespSerializer.packcsi d1gs #a)//12T!"X=D T!W_a)DH4D~~xSY)>)>)@(KL++ t{{D) CSJD M) -c:. ~~:s:'='='?J d# c" ~~"J..0   ! 4  d r9returnN)rVrWrXr`rUrYr9rTr[r[^s +r9r[cpeZdZedZedZedZedZedZedZ edZ edZ ed Z edd Z ed Zedd Ze dd dddZedZedZeedeeeefeeefffdZedefdZedZy)ConnectionInterfacecyr]rYrOs rT repr_pieceszConnectionInterface.repr_pieces r9cyr]rYrOcallbacks rTregister_connect_callbackz-ConnectionInterface.register_connect_callbackrtr9cyr]rYrvs rTderegister_connect_callbackz/ConnectionInterface.deregister_connect_callbackrtr9cyr]rYrO parser_classs rT set_parserzConnectionInterface.set_parserrtr9cyr]rYrrs rT get_protocolz ConnectionInterface.get_protocolrtr9cyr]rYrrs rTconnectzConnectionInterface.connectrtr9cyr]rYrrs rT on_connectzConnectionInterface.on_connectrtr9cyr]rYrOr>s rT disconnectzConnectionInterface.disconnectrtr9cyr]rYrrs rT check_healthz ConnectionInterface.check_healthrtr9Tcyr]rYrOcommandrs rTsend_packed_commandz'ConnectionInterface.send_packed_commandrtr9cyr]rYrOr>kwargss rT send_commandz ConnectionInterface.send_commandrtr9cyr]rYrOtimeouts rTcan_readzConnectionInterface.can_readrtr9Fdisconnect_on_error push_requestcyr]rY)rOdisable_decodingrrs rT read_responsez!ConnectionInterface.read_responses r9cyr]rYrs rTrJz ConnectionInterface.pack_commandrtr9cyr]rYrOcommandss rT pack_commandsz!ConnectionInterface.pack_commandsrtr9rncyr]rYrrs rThandshake_metadataz&ConnectionInterface.handshake_metadatas r9tokencyr]rYrOrs rTset_re_auth_tokenz%ConnectionInterface.set_re_auth_tokenrtr9cyr]rYrrs rTre_authzConnectionInterface.re_authrtr9NTrF)rVrWrXrrsrxrzr~rrrrrrrrrrJrpropertyrr bytesrDrrrrrYr9rTrprps                         !        E$ue|*e e-e.e.fe-e e fffd?Z/d@e1fdAZ2dBZ3y)GAbstractConnectionz0Manages communication to and from a Redis serverrNFutf-8strictizredis-pyr:dbpasswordsocket_timeoutsocket_connect_timeoutretry_on_timeoutencodingencoding_errorsdecode_responsessocket_read_sizehealth_check_interval client_namelib_name lib_versionusernameretryredis_connect_funccredential_providerprotocolcommand_packerevent_dispatcherc|s|r | td|t|_n||_tj|_||_| |_||_||_ ||_ ||_ ||_ ||_ ||}||_||_|t urg}|r|j#t$||_|s|rR|t)t+d|_nt/j0||_|j,j3|nt)t+d|_| |_d|_||_t;||| |_d|_d|_ | |_!|jE| g|_#d|_$d|_% tM|}|dks|dkDr tUd ||_+|jY||_-y#tN$r tP}YDtR$r tUdwxYw#dks|dkDr tUd ||_+wxYw) 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'rripzprotocol must be an integerr:zprotocol must be either 2 or 3).r(r#_event_dispatcherosgetpidpidrrrrrrrrrrSENTINELrHr,retry_on_errorr-rrcopydeepcopyupdate_supported_errorsrnext_health_checkrrencoderr_sock_socket_read_sizer~_connect_callbacksr^_re_auth_tokenintrKDEFAULT_RESP_VERSION ValueErrorr'r_construct_command_packer_command_packer)rOrrrrrrrrrr}rrrrrrrrrrrrps rTr`zAbstractConnection.__init__s @ &9&E+   #%4%6D "%5D "99;&  &#6     , ! )%3 "&<# 0 X %N   ! !, /, N}"9;2 "]]51 JJ . .~ >y{A.DJ%:"!""4x:JK "& !1  %"$"8< H A 1uA%&FGGDM#==nM %$A A!"?@ @ A1uA%&FGGDMs$ GG+G.G++G..H c dj|jDcgc] \}}|d|c}}}d|jjd|jjd|dScc}}w)N,=<.(z)>)rcrs __class__rWrV)rOkv repr_argss rT__repr__zAbstractConnection.__repr__EsjHHT5E5E5GHTQ1QCjHI 4>>,,-Qt~~/F/F.Gq SUVVIsA, cyr]rYrrs rTrszAbstractConnection.repr_piecesIrtr9cD |jy#t$rYywxYwr])r Exceptionrrs rT__del__zAbstractConnection.__del__Ms#  OO    s  c~||Str tSt|j|jj Sr])r/r=r[r^rrF)rOpackers rTrz,AbstractConnection._construct_command_packerSs6  M (* *'(;(;T\\=P=PQ Qr9ctj|}||jvr|jj|yy)a^ Register a callback to be called when the connection is established either initially or reconnected. This allows listeners to issue commands that are ephemeral to the connection, for example pub/sub subscription or key tracking. The callback must be a _method_ and will be kept as a weak reference. N)weakref WeakMethodrrH)rOrwwms rTrxz,AbstractConnection.register_connect_callback[s;   ) T,, ,  # # * *2 . -r9c |jjtj|y#t$rYywxYw)z De-register a previously registered callback. It will no-longer receive notifications on connection events. Calling this is not required when the listener goes away, since the callbacks are kept as weak methods. N)rremoverrrrvs rTrzz.AbstractConnection.deregister_connect_callbackgs8    # # * *7+=+=h+G H   s .1 ==c4||j|_y)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 )rN)r_parserr|s rTr~zAbstractConnection.set_parserrs $T5K5KL r9c(|jdy)z5Connects to the Redis server if not already connectedTrN)connect_check_healthrrs rTrzAbstractConnection.connectzs !!t!4r9Trretry_socket_connectcfjry |r#jjfdfd}nj}|_ jj|njjDcgc] }|s |c}_jD]}|}|s |y#tj $r t dt$r}tj|d}~wwxYw#t$rjwxYwcc}w)Nc$jSr])_connectrrsrTz9AbstractConnection.connect_check_health..s DMMOr9c&j|Sr]rerrorrOs rTrz9AbstractConnection.connect_check_health..s4??5;Qr9zTimeout connecting to serverr)rrcall_with_retryrsocketrr,OSErrorr'_error_messageron_connect_check_healthr*rr)rOrrsockerefrws` rTrz'AbstractConnection.connect_check_health~s  ::  :#zz11+-Q}}   &&.,,,,G''-372I2I"S3SU3"S** CuH -~~ ?=> > :!$"5"5a"89 9 :  OO   #Ts/5C 0D D.D.&D .DD D+cyr]rYrrs rTrzAbstractConnection._connectrtr9cyr]rYrrs rT _host_errorzAbstractConnection._host_errorrtr9c6t|j|Sr])r4r )rO exceptions rTrz!AbstractConnection._error_messages#D$4$4$6 BBr9c(|jdy)NTr)rrrs rTrzAbstractConnection.on_connects $$$$7r9c|jj||j}d}|js|js |jr>|jxs t |j|j}|j }|r|jdvrt|jtrK|jt|j|j_ |jj|t|dk(rd|dg}|jd|jdg|dd i|j|_nD|rA|jdg|dd i |j}t%|d k7r t'd |jdvrt|jtrK|jt|j|j_ |jj||jd|j| |j|_|j j)d|jk7r3|j j)d|jk7r t+d|j,rF|jdd|j,| t%|jd k7r t+d |j.r0|jddd|j.| |j |j2r0|jddd|j2| |j|j4rF|jd|j4| t%|jd k7r t+dyy#t"$r+|jd|d d |j}YmwxYw#t0$rYwxYw#t0$rYwxYw)z=Initialize the connection, authenticate and select a databaseN)r:2rdefaultrHELLOAUTHrFrOKzInvalid Username or PasswordsprotoprotozInvalid RESP versionCLIENTSETNAMEzError setting client nameSETINFOzLIB-NAMEzLIB-VERSELECTzInvalid Database)rrrrrr!get_credentialsrrCrr~rEXCEPTION_CLASSESrerrrr%r6r$getr'rrr+rr)rOrparser auth_args cred_provider auth_responses rTrz*AbstractConnection.on_connect_check_healths %  # # ((T5dmmT]]S &557I h6$,, 5 -171I1I . ''-9~"& ! 5  D   1: IN '+&8&8&:D #  D  f Ey Eu E 5 $ 2 2 4 M*d2)*HII]]( *$,, 5 -171I1I . ''-   gt}}<  P&*&8&8&:D #''++H5F++//8DMMI%&<==        )   D..01T9%&ABB }}!!MM!- """$ !!$$!- """$ 77   hl  KD..01T9%&899: C8 5 !!&)B-e!L $ 2 2 4  5`      s6(N2& conn_socks rTrzAbstractConnection.disconnect"s ""$JJ     99;$(( " ""6#3#34  OO  Y'      s$B3BBB B%$B%cx|jddt|jdk7r tdy)z Send PING, expect PONG in returnPINGFrPONGz#Bad response from PING health checkN)rr6rr'rrs rT _send_pingzAbstractConnection._send_ping6s< &u5 **, - 7!"GH H 8r9c$|jy)z Function to call when PING failsNrrOrs rT _ping_failedzAbstractConnection._ping_failed<  r9c|jrStj|jkDr1|jj |j |jyyy)z3Check the health of the connection with a PING/PONGN)rtime monotonicrrrr,r/rrs rTrzAbstractConnection.check_health@sF  % %$..*:T=S=S*S JJ & &t8I8I J+T %r9cR|js|jd|r|j t|tr|g}|D]}|jj |y #t j$r|jtdt$ro}|jt|jdk(rd|jd}}n|jd}|jd}td|d|d d }~wt$r|jwxYw) z2Send an already packed command to the Redis serverFrzTimeout writing to socketrUNKNOWNrzError z while writing to socket. rN)rrrrCrDsendallrrrr,rrer>r' BaseException)rOrritemrerrnoerrmsgs rTrz&AbstractConnection.send_packed_commandEs zz  % %5 % 9      '3'") ) ""4( )~~ < OO :; ; W OO 166{a )166!9vq !F5'1KF8ST"UV V  OO    s5A((6D&A*DD&cx|j|jj||jddy)z+Pack and send a command to the Redis serverrTrN)rrrUrrs rTrzAbstractConnection.send_commandds9   %D % %t ,ND9 ! r9c|j}|s|j|j} |jj |S#t $r0}|j td|d|jd}~wwxYw)z8Poll the socket to see if there's data that can be read.Error while reading from z: N) rrr rrrrr'r>)rOrr host_errorrs rTrzAbstractConnection.can_readksyzz LLN%%'  V<<((1 1 V OO !$=j\AFF8"TU U VsA B+A??Brcd|j} |jdvr|jj||}n|jj|}|jr&tj|jz|_t!|t"r ||S#tj $r!|r|j td|t$r2}|r|j td|d|jd}~wt$r|r|j wxYw#~wxYw)z0Read the response from a previously sent command)3r)rr)rzTimeout reading from r=z : N)r rrrrrrr,rr'r>r7rr2r3rrCr+)rOrrrr>responsers rTrz AbstractConnection.read_responseys%%%'  }}(<<55%5L6 <<55GW5X"  % %%)^^%58R8R%RD " h . 1~~ E"!!6zlCD D W"!!$=j\QVVH"UV V #!   s$AB!D,!;D)-D  D),D/c4|jj|S)rA)rrUrs rTrJzAbstractConnection.pack_commands(t##(($//r9cg}g}d}|j}|D]}|jj|D]}t|}||kDs||kDst |t r*|r$|j tj|d}g}||kDst |t r|j |y|j |||z }|r$|j tj||S)z.Pack multiple commands into the Redis protocolr) r^rrUrerCrhrHrbrc) rOrrPpieces buffer_lengthr_cmdchunkchunklens rTrz AbstractConnection.pack_commandss ++  .C2--22C8 .u:!M1-/!%4 innV&<=$%MFm+z%/LMM%(MM%(!X-M! . .&  MM)..0 1 r9rnc|jSr])rrrs rTrzAbstractConnection.get_protocols }}r9c|jSr]_handshake_metadatarrs rTrz%AbstractConnection.handshake_metadatas'''r9rRc||_yr]rK)rOrRs rTrz%AbstractConnection.handshake_metadatas #( r9rc||_yr])rrs rTrz$AbstractConnection.set_re_auth_tokens #r9c|j\|jd|jjd|jj|j d|_yyNroid)rrtry_get get_valuerrrs rTrzAbstractConnection.re_auths`    *   ##++E2##--/     "&D  +r9)TTrrr)4rVrWrX__doc__rr;r5rr rDfloatboolrrr r r#r`rrrsrrrxrzr~rrrr rrrrr,r/rrrrrrJrrrr rrsetterrrrrYr9rTrrs 6"&*.26!&'!&" %%&%)",%4%6"&"&;?<@"#7;6:/^N ^N3-^N! ^N !) ^N  ^N^N^N^N^N #^Nc]^N3-^N c]!^N"3-#^N$S$Y%^N&%Xb$h%78'^N(&&89)^N*3-+^N,!"d(!34-^N.#?3/^N@W   R / M5 GK% %?C%N    C8m:Dm:^(I K >  V *! *X0<eCHo(E$ue|*FHeYD !}}VXu= 2 2F4F4FJ((OOF$5$5v7J7JAN $ = = C C EB1(:(:AqAB ; ;< ^, 3 34 1! !F ?IABB !# f&6&67"JJL !s=D E55 G >GF#"G# F/,G.F//GG c8|jd|jS)N:)r\r]rrs rTr zConnection._host_error&s))Adii[))r9) localhostiFNr rVrWrXrTr`rsrr  __classcell__rs@rTrYrYs-: !% #  +CZ*r9rYc:eZdZdZdZdZdededejfdZ dZ d Z d Z d Zd Zd ZdZdZd&dZdZd'dZ d(ddddZdZdZedeeeefeeefffdZdZdZ deddfdZ!dZ"d e#eee$e#effd!Z%d"Z&d#e'fd$Z(d%Z)y))CacheProxyConnectionsfooz7.4.0redisconncache pool_lockctj|_||_|jj|_|jj |_|jj |_|j|_||_||_ tj|_ d|_ d|_|j|j yr])rrr_connrr\r]r _pool_lock_cache threadingRLock _cache_lock_current_command_cache_key_current_optionsrx_enable_tracking_callback)rOr}r~rs rTr`zCacheProxyConnection.__init__/s 99; ZZ%% JJOO JJOO #'#;#; # $??,*.' $ &&t'E'EFr9c6|jjSr])rrsrrs rTrsz CacheProxyConnection.repr_piecesBszz%%''r9c:|jj|yr])rrxrvs rTrxz.CacheProxyConnection.register_connect_callbackEs ,,X6r9c:|jj|yr])rrzrvs rTrzz0CacheProxyConnection.deregister_connect_callbackHs ..x8r9c:|jj|yr])rr~r|s rTr~zCacheProxyConnection.set_parserKs l+r9c |jj|jjjdd}|&|jjjdd}|jjjdd}|&|jjjdd}|| t dt |}t |}||j k7st||jdk(r t dy)Nsserverserversversionversionz0Cannot retrieve information about server versionrziTo maximize compatibility with all Redis products, client-side caching is supported by Redis 7.4 or later) rrrrr'r3DEFAULT_SERVER_NAMEr1MIN_ALLOWED_VERSION)rO server_name server_vers rTrzCacheProxyConnection.connectNs jj3377 4H  **77;;HdKKZZ2266z4H  66::9dKJ  !3!"TU U":. #K0  433 3 D,D,DEJ!{ Kr9c8|jjyr])rrrrs rTrzCacheProxyConnection.on_connectes r9c|j5|jjddd|jj|y#1swY#xYwr])rrflushrrrs rTrzCacheProxyConnection.disconnecthsD    KK     t$  s A  Ac8|jjyr])rrrrs rTrz!CacheProxyConnection.check_healthms !r9Tc:|jj|yr])rrrs rTrz(CacheProxyConnection.send_packed_commandps &&w/r9c |j|j5|jjt |dds-d|_|j j|i| dddy ddd|jd tdt |dt|jd|_|j5|jj|j r|jj|j }|j|j k7rf|j5|jjr7|jjd|jjr7ddd dddy|jjt!|j |j"t$j&|j ddd|j j|i|y#1swYxYw#1swYxYw#1swY?xYw) NrrY)r redis_keyskeyszCannot create cache key.Tr) cache_key cache_valuestatusconnection_ref)_process_pending_invalidationsrr is_cachablerrrrrrrErrrrsetrDUMMY_CACHE_VALUEr IN_PROGRESS)rOr>rentrys rTrz!CacheProxyConnection.send_commandus ++-    ;;**8DGPR+ST26/' ''88   U  ::f  %78 8+3Gfjj.@(A+ '   {{t>>? (G(GH''4::5R#22;;=!00>>D>Q$22;;=R   KKOO"== $ 6 6+77#'::  ! 6  00W  0RR  s9AHA0H8AH, H8&AH8H),H5 1H88Ic8|jj|Sr])rrrs rTrzCacheProxyConnection.can_readszz""7++r9Frc|j5|j|jj|j|jj|jjt j k7rTtj|jj|jj}d|_|cdddSddd|jj|||}|j5|j |cdddS|1|jj|jg|cdddS|jj|j}|7t j|_||_ |jj|d|_ddd|S#1swYxYw#1swY|SxYw)N)rrr)rrrrrrrrrrrrdelete_by_cache_keysVALIDr)rOrrrrorA cache_entrys rTrz"CacheProxyConnection.read_responses   //;KKOOD$C$CDPKKOOD$C$CDKK#//0mmKKOOD$C$CDPP37/   ::++- 3%,     3..6 3 3  00$2Q2Q1RS 3 3++//$*I*IJK&%5%;%; "*2 '  ,.2D +% 3(Q  ( 3(s%BS9S3T.U:),~,r9r{cPeZdZdZ dfd ZfdZdZxZS) 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) c ts td||_||_|tj }nWt |trGtj tjtjd}||vrtd|||}||_ ||_ ||_ ||_ |jtj k7r|nd|_||_| |_| |_| |_| |_| |_||_t-|\di|y)aConstructor 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), or an ssl.VerifyMode. 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. ssl_min_version: The lowest supported SSL version. It affects the supported SSL versions of the SSLContext. None leaves the default provided by ssl module. ssl_ciphers: A string listing the ciphers that are allowed to be used. Defaults to None, which means that the default ciphers are used. See https://docs.python.org/3/library/ssl.html#ssl.SSLContext.set_ciphers for more information. Raises: RedisError z$Python wasn't built with SSL supportN)noneoptionalrequiredz+Invalid SSL Certificate Requirements Flag: FrY)r0r*keyfilecertfilessl CERT_NONErCrD CERT_OPTIONAL CERT_REQUIRED cert_reqsca_certsca_dataca_pathcheck_hostnamecertificate_passwordssl_validate_ocspssl_validate_ocsp_stapledssl_ocsp_contextssl_ocsp_expected_certssl_min_version ssl_ciphersrar`)rO ssl_keyfile ssl_certfile ssl_cert_reqs ssl_ca_certs ssl_ca_datassl_check_hostname ssl_ca_path ssl_passwordrrrrrrr CERT_REQSrs rTr`zSSLConnection.__init__s PCD D" $  MMM  s + ----I I- A-Q&m4M&$ " " "&..CMM"A u %1!!2)B& 0&<#.& "6"r9ct|} |j|S#ttf$r|j wxYw)zN Wrap the socket with SSL support, handling potential errors. )rar_wrap_socket_with_sslrr*r')rOrrs rTrzSSLConnection._connectPsHw! --d3 3$  JJL  s "!Ac,tj}|j|_|j|_|j s |j r2|j|j |j |j|j|j |j2|j|j|j|j|j|j|_|jr|j!|j|j"durt$dur t'd|j(r|j"r t'd|j+||j,}|j(r+d dl}d d lm}|j4f|j6j9|j6j:}|j=|j |j?|j n |j4}|jA||jB|j6jE|tGjF}|jI|jK|j,|jLf|jO|jQ|S|j"durRt$rLd d lm)}|||j,|jL|j} | jUr|StWd |S)z Wraps the socket with SSL support. Args: sock: The plain socket to wrap with SSL. Returns: An SSL wrapped socket. )rrrN)cafilecapathcadataTFzcryptography is not installed.zKEither an OCSP staple or pure OCSP connection must be validated - not both.)server_hostnamerr)ocsp_staple_verifier) OCSPVerifierzocsp validation error),rcreate_default_contextrr verify_moderrload_cert_chainrrrrload_verify_locationsrminimum_versionr set_ciphersrr.r*r wrap_socketr\OpenSSLocsprrSSLContext SSLv23_METHODuse_certificate_fileuse_privatekey_fileset_ocsp_client_callbackrrYr request_ocsprr] do_handshaker%ris_validr') rOrcontextsslsockrr staple_ctxconros rTrz#SSLConnection._wrap_socket_with_ssl[su,,.!%!4!4"nn ==DLL  # # 22 $  MM %||'||'  ) )}}T\\$,, *     +&*&:&:G #       0 0 1  ! !T ).D.M=> >  ) )d.D.D  %%dDII%F  ) )  2$$,$[[001J1JK // >..t||<!22  / /$d&A&A  ++((V]]_EC     KKDII. /     LLNN  ! !T ).D *WdiiDMMJAzz|%&=>>r9)NNrNNTNNFFNNNN)rVrWrXrTr`rrrxrys@rTrrsF "'#H#T Mr9rc6eZdZdZdfd ZdZdZdZxZS)UnixDomainSocketConnectionz4Manages UDS communication to and from a Redis serverc @t|di|||_||_yr[)rar`pathr)rOrrrrs rTr`z#UnixDomainSocketConnection.__init__s" "6" ,r9cd|jfd|jfg}|jr|jd|jf|S)Nrrr)rrrrHrcs rTrsz&UnixDomainSocketConnection.repr_piecessB499%dgg7    MM=$*:*:; < r9ctjtjtj}|j|j |j |j |j|j|S#t$rB |jtjn#t$rYnwxYw|jwxYw)z&Create a Unix domain socket connection) rAF_UNIXrfrmrrrrr%r&r'r)rOrs rTrz#UnixDomainSocketConnection._connects}}V^^V-?-?@ 334  LL # ++,    f../   JJL  s0B CB10C1 B=:C<B==Cc|jSr])rrrs rTr z&UnixDomainSocketConnection._host_errors yyr9)Nrwrys@rTrrs:-  "r9r)0FFALSENNOcv||dk(ryt|tr|jtvryt |S)NrF)rCrDupper FALSE_STRINGSrV)rRs rTto_boolrs4 } %%++-="@ ;r9) rrrr^rrmax_connectionsrrrcB|jds-|jds|jds tdt|}i}t|jj D]N\}}|s t |dkDst|d}tj|}|r ||||<J|||<P|jrt|j|d<|jrt|j|d <|jd k(r/|jrt|j|d <t|d <|S|j rt|j |d <|j"rt%|j"|d<|jr6d|vr2 t%t|jj'dd|d<|jdk(r t*|d <|S#ttf$rtd|dwxYw#t(tf$rYMwxYw)Nzredis://z rediss://zunix://zRRedis URL must specify one of the following schemes (redis://, rediss://, unix://)rzInvalid value for 'z' in connection URL.rrunixrconnection_classr\r]r/rrediss) startswithrrrqueryrlrerURL_QUERY_ARGUMENT_PARSERSrrKrrschemerrhostnamer]rreplaceAttributeErrorr)urlrnamerRrs rT parse_urlr s z" >>+ & >>) $ 5  3-C F *002 % e SZ!^E!H%E/33D9FW#)%=F4L %t  % ||$S\\2z ||$S\\2z zzV 88$SXX.F6N%?!"& M! <<$S\\2F6N 88 ]F6N 88F* "7388#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. rrY)r update)r%rr url_optionss rTfrom_urlzConnectionPool.from_url2s?R n  '.45G.HK* + k"}V}r9Nr cache_factoryc |xsd}t|tr|dkr td||_||_||_d|_||_|jds|jdr|jddvr td|jjd}|#t|ts td ||_nc|j |jj|_n7t|jjdj|_|jdd|jdd|jjd d|_|jt|_t!j"|_t!j"|_|j)y) Nlrz,"max_connections" must be a positive integer cache_configr~r)rr@z4Client caching is only supported with RESP version 3z#Cache must implement CacheInterfacer)rCrrrconnection_kwargsrr~_cache_factoryrr*r get_cacherpoprr#rr _fork_lock_lockreset)rOrrr*r-r~s rTr`zConnectionPool.__init__cs*2U/3/?Q3FKL L 0!2. +   04E4I4I'4R $$Z0@ !WXX**..w7E !%8$%JKK" &&2!%!4!4!>!>!@DJ!-..22>B"ikJ gt,nd3!%!7!7!;!;)>)rcr-rlrrWrVr)rOrr conn_kwargss rTrzConnectionPool.__repr__shht7M7M7S7S7UVtq!1#Qqc VW ))*!DNN,C,C+D&&112!D4I4I4R4R3S }D "  WsB$ c:|jjddS)z Returns: The RESP protocol version, or ``None`` if the protocol is not specified, in which case the server default will be used. rN)r-rrrs rTrzConnectionPool.get_protocols %%))*d;;r9cpd|_g|_t|_t j |_y)Nr)_created_connections_available_connectionsr_in_use_connectionsrrrrrs rTr3zConnectionPool.resets+$%!&(##&5 99;r9cf|jtjk7rq|jj d}|st  |jtjk7r|j |jjyy#|jjwxYw)N)r)rrrr1acquirer&r3release)rOacquireds rT _checkpidzConnectionPool._checkpidsF 88ryy{ "..q.9H** *88ryy{*JJL'') #'')s 1BB0*)Use get_connection() without args instead5.3.0 args_to_warnreasonrrYcn|j|j5 |jj}|j j|ddd j |jr|j td|S#t$r|j }YywxYw#1swYcxYw#tttf$r?|j|j|jr tdY|SwxYw#t$r|j!wxYw)zGet a connection from the poolNConnection has dataConnection not ready)r@r2r9r0 IndexErrormake_connectionr:addrrr~r'r,rrr7r>rO command_nameroptions connections rTget_connectionzConnectionPool.get_connections/  ZZ 5 4!88<<>   $ $ ( ( 4  5      B&&(TZZ-?)*?@@3 4!113  4 5 5"$\7; B%%'""$&&()*@AA) B   LL $   sXB6BB6D.'CB30B62B33B66B?ADDDDD4c|j}t|jdd|jdd|jddS)z,Return an encoder based on encoding settingsrrrrrF)rrr)r-rr)rOrs rT get_encoderzConnectionPool.get_encodersF''ZZ G4"JJ'8(C#ZZ(:EB  r9c:|j|jk\r td|xjdz c_|j;t |j di|j |j|jS|j di|j S)zCreate a new connectionzToo many connectionsrrY)r8rr)r~r{rr-r2rrs rTrKzConnectionPool.make_connections  $ $(<(< <%&<= = !!Q&! :: !'%%%?(>(>?TZZ %t$$>t'='=>>r9rPc|j|j5 |jj||j |r@|j j||jjt|n|j dddy dddy#t$r YdddywxYw#1swYyxYw)z(Releases the connection back to the poolN) r@r2r:rKeyErrorowns_connectionr9rHrdispatchr"rrOrPs rTr>zConnectionPool.release(s  ZZ  ((// ; ##J/++22:>&&//0<%%''           s.CB/A"C/ C8CCCCc4|j|jk(Sr])rrYs rTrWzConnectionPool.owns_connection@s~~))r9inuse_connectionsc|j|j5|r!t|j|j}n |j}|D]}|j  dddy#1swYyxYw)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@r2rr9r:r)rOr[ connectionsrPs rTrzConnectionPool.disconnectCsp  ZZ ( #//1I1I #99 ) ( %%' ( ( ( (s AA..A7c$|jy)z-Close the pool, disconnecting all connectionsNrrrs rTr'zConnectionPool.closeWr0r9rc|jjd|i|jD] }||_ |jD] }||_ y)Nr)r-r'r9rr:)rOrr}s rT set_retryzConnectionPool.set_retry[sS %%w&67// DDJ ,, DDJ r9rc>j5jD]GjjfdfdjjfdfdIjD]j  dddy#1swYyxYw)NcdjdjdjSrP)rrRrS)r}rsrTrz1ConnectionPool.re_auth_callback..fs)D-- e 4eoo6Gr9c&j|Sr]_mockrs rTrz1ConnectionPool.re_auth_callback..is$**U"3r9c$jSr])r)r}srTrz1ConnectionPool.re_auth_callback..lsD..0r9c&j|Sr]rdrs rTrz1ConnectionPool.re_auth_callback..ls 5@Qr9)r2r9rrr:r)rOrr}s``@rTre_auth_callbackzConnectionPool.re_auth_callbackbs ZZ .33  **4   **02Q 00 .&&u- . . . .s A9BBrc Kyw)z Dummy functions, needs to be passed as error callback to retry object. :param error: :return: NrYr.s rTrezConnectionPool._mockqs srmr])rnrY)rnrp)rPrYrnNr)"rVrWrXrT classmethodr r!rDr)rYr rrr`rrr3r@r2rQrrSrKr>rWrVrr'r-r`rrhr*rerYr9rTr"r"#s .d3i.c...d$)-9= 7"#7 56 7r # < -*^U:   D W  ?0*,*3*(D(D((u .n .  r9cjeZdZdZddeeffd ZdZdZe dgdd dd Z d Z 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 F||_||_t| d||d|y)N)rrrY) queue_classrrar`)rOrrrrpr-rs rTr`zBlockingConnectionPool.__init__s6'   -+   r9c|j|j|_ |jjd#t$rYnwxYwg|_t j|_yr]) rprpool put_nowaitr _connectionsrrrrrs rTr3zBlockingConnectionPool.resetsf$$T%9%9:   $$T*   99;s? A  A c|j(>?TZZJ/..H1G1GHJ   ,r9rArBrCrDc|jd} |jjd|j}||j } |j |jr t d |S#t$r t dwxYw#t ttf$r?|j|j|jr t dY|SwxYw#t$r|j|wxYw)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)blockrzNo connection available.rHrI)r@rrrrrr'rKrrr,rrr7r>rMs rTrQz%BlockingConnectionPool.get_connections$   >T4<<HJ  --/J      B&&()*?@@)= >""<= = >($\7; B%%'""$&&()*@AA) B   LL $  s6'A=C+B=BAC($C+'C((C++Dc|j|j|s,|j|jj dy |jj |y#t $rYywxYw)z)Releases the connection back to the pool.N)r@rWrrrrsrrYs rTr>zBlockingConnectionPool.releasesj ##J/  ! ! # II  &   II  ,   sA++ A76A7cf|j|jD]}|jy)z(Disconnects all connections in the pool.N)r@rtrrYs rTrz!BlockingConnectionPool.disconnects- ++ $J  ! ! # $r9r])rVrWrXrTrYrr`r3rKr2rQr>rrxrys@rTrlrlzsUF#  0 U: 2  2h*$r9rl)errrrLrr2rabcr itertoolsrqueuerrrtypingrr r r r r rr urllib.parserrr redis.cacherrrrrr_parsersrrrr auth.tokenrbackoffr credentialsr r!eventr"r# exceptionsr$r%r&r'r(r)r*r+r,rr-utilsr.r/r0r1r2r3r4r5r6rrIrdrirfrbrobjectr__annotations__r;r=r[rprrYr{rrrrrrUlistrr r!r"rlrYr9rTrs  ((LLL44JI&O@       C      8E, nDEFF"M M$00fN N b{',{'|G*#G*TS.SlhJhV !3 F/  # ! 6re+,T T n g$^g$r9