z*FakeConnection._decode..Ns%<<<4DLL&&<<z*FakeConnection._decode..Ps3RRRADLLOOT\\!__RRRr ) isinstancelistdictitemsbytesencoderdecode)r&rbs` rrfzFakeConnection._decodeLs h % % <<<<8<<< < $ ' ' RRRRAQAQRRR R % ( ( <&&x00 0Or c |jstjtj|jjs{ |jj}ny#tj $rI| ddr| tjtjwxYw|jj }t|tr|| ddr|S||S)Ndisconnect_on_errorTdisable_decodingF)r$rUrVrWrXrSrT responses get_nowaitqueueEmptyget disconnectrnrrf)r&rrbs r read_responsezFakeConnection.read_responseVsz C'(ABB B|% 2 G:/::<<; G G G::3T::&OO%%%+D,EFFF G z+//11H h 0 0 N ::(% 0 0 *O<<)) )s AAB*cpd|jfd|jfg}|jr|d|jf|S)Nserverr5 client_name)rSr5rappend)r&piecess r repr_pieceszFakeConnection.repr_piecesisCT\*T47O<   = MM=$*:; < < < r commandcdSrrR)r&rs r_get_from_local_cachez$FakeConnection._get_from_local_cacheotr keyscdSrrR)r&rrbrs r_add_to_local_cachez"FakeConnection._add_to_local_cacherrr c|jSr) server_key)r&s r__str__zFakeConnection.__str__us r )rN)r)__name__ __module__ __qualname__rrr#r r]rfloatboolrarfr~rrstrrrrrr __classcell__r's@rrrs::s:t::::JJJJJJ & *& & & & P U U U U U U U*c*c****&T%S/2 Xc]t8C=CtTWy]ar rceZdZddddejddedeedee e e fde d ee e d ed dffd Zeded ed efd ZxZS)FakeRedisMixinN)rU)rversion server_typerPrOrrrrrPrrc* t|g|Ri| | d< ddslj dd} dd} |&tjt d| d<| &tjt d| d <hd } t ||||d } |  fd | Dtjj di|  d< dd d d dd dd ddd vrd vrd d<t d<tj di dS)a :param server: The FakeServer instance to use for this connection. :param version: The Redis version to use, as a tuple (major, minor). :param server_type: The type of server, e.g., "redis", "valkey". :param lua_modules: A set of Lua modules to load. :param client_class: The Redis client class to use, e.g., redis.Redis or valkey.Valkey. rconnection_poolNcharseterrorsz/"charset" is deprecated. Use "encoding" insteadencodingz5"errors" is deprecated. Use "encoding_errors" insteadencoding_errors>r5hostportrrpasswordr)usernamerTrsocket_timeoutrmax_connectionsdecode_responsesretry_on_timeouthealth_check_interval)connection_classrrrPrOc*i|]}|v||SrRrR)rgargkwdss rrmz+FakeRedisMixin.__init__..s+%^%^%^RUY]R]R]c49R]R]R]r rTrrrPlib_namer fakeredisrR)r r|warningswarnDeprecationWarningrupdaterU connectionConnectionPoolpoprr"r)r&rrrrPrOrrrrconn_pool_argsconnection_kwargsrr's @rrzFakeRedisMixin.__init__zs"1OOOOOOXxx)400$ [hhy$//GXXh--F" 01bccddd#*Z ! 01hiijjj*0&'N&%3"** , !!   $ $%^%^%^%^%^%^%^ _ _ _&+&6&E&Z&ZHY&Z&ZD" # 4    d### D!!! %%% %%%   -4"7"7*D "-D   4     r c|dd|ddtjj|i|}t|_||d|i|S)Nrz7.4rrUr) setdefaultrUrfrom_urlrr)clsrrpools rrzFakeRedisMixin.from_urlsh)U+++-111#,d=f== .s$949&999r )rrrrURedisrrrr rrintrrr classmethodrrrrs@rrrys(,04")*.[@!@!@!@!$@!{C,- @!  @! c#h' @!@! @!@!@!@!@!@!D:S:C:D:::[:::::r rceZdZdS)FakeStrictRedisNrrrrRr rrrDr rceZdZdS) FakeRedisNrrRr rrrrr r)%rzrtypingrrrrrrr rUfakeredis._fakesocketr fakeredis._helpersr r r1rrWrSrrrr_typingrrrmodelr Connectionrr StrictRedisrrrrRr rrs CCCCCCCCCCCCCCCCCC ,,,,,,NNNNNNNNQQQQQQQQQQQQ7777777777ggggg,e.>gggTJ:J:J:J:J:J:J:J:Z     ne&7              r