1iz ddlZddlmZdZdZdZdZideded ed ed ed ed ededededededededededeeeeeeedZdZ dZ dZ dZ dZ dZdZd Zdd!Zd"Zd#Zd$Zd%Zd&Zd'Zd(Zd)Zd*Zd+Zd,Zd-Zd.Zd/Zd0Z d1Z!d2Z"d3Z#d4Z$d5Z%d6Z&d7Z'd8Z(d9Z)d:Z*d;Z+d<Z,d=Z-d>Z.d?Z/d@Z0dAZ1dBZ2dCZ3dDZ4dEZ5dFZ6dGZ7dHZ8dIZ9dJZ:ie:dKe;e:dLe<e:dMe#e:dNee:dOe1e:dPeidQe6dRe#dSe7dTe#dUe#dVe8dWe5dXe%dYe#dZe#d[e#d\e;d]e#d^e#d_e#d`e#dae#idbe#dce-dde#dee0dfe0dge#dhe#die#dje#dke#dle0dme2dne#doe#dpe#dqe#dre#idse"dte(duedvedwe#dxe;dye;dzd{d|e4d}e4d~e#de9de'ddde#de#deide#de#de#dede#de#de#de#de+de#dede'dddedede#de;e#ee e)dZ=ie:dde:dee:dee:de"e:dde:dde:ddidddedddddddededdddddde&dedddddddeddee e eee,eee$e*d Z>ie:dde:ddÄe:dee:dee:dNedńe3dƄdDŽe e eedȄdɄdʄd˜ Z?y)N str_if_bytesc||sy t|}tjj|S#t$rYywxYw)z5Converts a unix timestamp to a Python datetime objectN)int ValueErrordatetime fromtimestampresponses `/mnt/e/genesis-system/.venvs/voice-bridge/lib/python3.12/site-packages/redis/_parsers/helpers.pytimestamp_to_datetimer sC x=    * *8 44 s / ;;ct|}d|z}td|jD}d}|D]}||vst||||<|S)zDParse the results of Redis's DEBUG OBJECT command into a Python dictztype:c3>K|]}|jdyw:Nsplit).0kvs r z%parse_debug_object..s=bBHHSM=s)refcountserializedlengthlrulru_seconds_idle)rdictrr)r int_fieldsfields r parse_debug_objectrsgH%H!H=HNN,<==HMJ3 H !(5/2HUO3 Oci}t|}fd|jD]}|s|jdr|jddk7rh|j dd\}}|dk(r|j dd\}}|dk(r(|j dgj||||<|j d gj||S) z;Parse the result of Redis's INFO command into a Python dictc\d|vrd|vr d|vr t|St|Sd|vr(|jdDcgc] }|s|c}Si}|jdD]/}|sd|vr!|j dd\}}|||<+d||<1|S#t$r|cYSwxYwcc}w)N,=.T)floatrrrrsplit)valuevsub_dictitemk get_values r r-zparse_info..get_value(s e 5 0 %< <'u:% */++c*:@QaIaL@ @H C( *$;;;sA.DAq"+A,HQK%)HTN *O   As!B BB) B) B&%B&#rr% cmdstat_hostmodulemodules__raw__)r splitlines startswithfindrr' setdefaultappend)r infolinekeyr(r-s @r parse_infor<#s DH%H.##%< ,yy~#"ZZQ/ U.(!%S!!4JC(?OOIr299)E:JK )% 0DI 2.55d;%<( Krc t|dd}|jD]9\}}|jdst|ts)t|dd||<;|S)z!Parse the results of MEMORY STATST) decode_keysdecode_string_valueszdb.) pairs_to_dictitemsr5 isinstancelist)r kwargsstatsr;r(s r parse_memory_statsrFVsZ (4 PEkkm U >>% Zt%<&4dE#J Lrzcan-failover-its-masterz config-epochzdown-after-millisecondszfailover-timeoutz info-refreshzlast-hello-messagezlast-ok-ping-replyzlast-ping-replyzlast-ping-sentzmaster-link-down-timez master-portznum-other-sentinelsz num-slavesz o-down-timezpending-commandszparallel-syncsport)quorumzrole-reported-timez s-down-timezslave-priorityzslave-repl-offsetzvoted-leader-epochct|t}t|djd}dD] \}}||v||<|S)Nflagsr")) is_mastermaster)is_slaveslave)is_sdowns_down)is_odowno_down) is_sentinelsentinel)is_disconnected disconnected)is_master_down master_down)pairs_to_dict_typedSENTINEL_STATE_TYPESsetr)r+resultrJnameflags r parse_sentinel_stater_|sS '; |Dcgc] }t|c}Scc}wrari)r rerLs r parse_sentinel_masters_resp3ros=E F6 &v . FF Fc Z|Dcgc]}ttt|c}Scc}wrarbr rer+s r #parse_sentinel_slaves_and_sentinelsrss#FN Od \4!8 9 OO Os (c @|Dcgc]}t|fi|c}Scc}wrarnrrs r )parse_sentinel_slaves_and_sentinels_resp3rus!DL MD &t 7w 7 MM Msc 8|xr|dt|dfxsdSNrr%rrds r parse_sentinel_get_masterrys$  7!c(1+&67 ?4?rc|iS|s|rI|ddd}|rtt|}|ddd}|rtt|}tt||St |}tt||S)z-Create a dict given a list of key/value pairsNr%)rcrrzipiter)r r>r?keysvaluesits r r@r@s{ *!} |T*D!$Q$ v.FCf%&& (^CBK  rct|}i}t||D]\}}||vr |||}|||<|S#t$rYwxYwra)r}r|rh)r type_inforr\r;r(s r rYrYsn hB F"bk U )  & #u- s  M   s 9 AAc |r|jds|S|jdt}t|}tt |t ||S)zr If ``withscores`` is specified in the options, return the response as a list of (value, score) pairs withscoresscore_cast_func)getr&r}rCr|rc)r rerrs r zset_score_pairsrsJ 7;;|4kk"3U;O hB BOR01 22rc x|r|jds|S|jdt}|d||dgSzi If ``withscores`` is specified in the options, return the response as a [value, score] pair withscorerrr%rr&r rers r zset_score_for_rankr@ 7;;{3kk"3U;O QK!5 66rc |r|jds|S|jdt}|Dcgc]\}}|||gc}}Scc}}w)zr If ``withscores`` is specified in the options, return the response as a list of [value, score] pairs rrr)r rerr]vals r zset_score_pairs_resp3rsJ 7;;|4kk"3U;O:B CYT3T?3' ( CC CsA c x|r|jds|S|jdt}|d||dgSrrrs r zset_score_for_rank_resp3rrrc |r|jds|S|d}ttt|Dcgc] }||d| c}Scc}w)z If ``groups`` is specified, return the response as a list of n-element tuples with n being the value found in options['groups'] groupsN)rrCr|range)r renis r sort_return_tuplesrsM 7;;x0A eAh7hqt!tn78 997sA c |yg}|D]e}|Pd|vr)|j|dt|dg|dd2|j|dt|dfU|jdg|S)Nclaim_min_idle_timerr%r{)NN)r8r@)r redatars r parse_stream_listrs D & =$/ QqT=1#6?12?@ QqT=1#678 KK %& Krct|dS)NTr>r@r s r pairs_to_dict_with_str_keysrs t 44rc4ttt|Sra)rCrcrr s r parse_list_of_dictsr"s /: ;;rc @|jddr|St|S)N parse_justidFrrrds r parse_xclaimr&s {{>5) X &&rc V|jddr|dSt|d|d<|S)NrFr%rrds r parse_xautoclaimr,s1{{>5){#HQK0HQK Orc t|trt|d}n,|jDcic]\}}t ||}}}|j ddsR|j d}||d|dt|df|d<|d}||d|dt|df|d<|S|d Dcic]\}}|t|c}}|d <t |d dkDrst|d dtr]|d D cgc]} t| dc} |d <|d D]2} | d s | d d| d D cgc]} t| dc} | d <4|S|d D cgc]/} | jDcic]\}}t ||c}}1c}}} |d <|Scc}}wcc}}wcc} wcc} wcc}}wcc}}} w) NTrfullFz first-entryrr%z last-entryentriesr consumers)rBrCr@rArrlen) r rerr,r)firstlast_identrygroupgcs r parse_xinfo_streamr3s(D!X48/7~~/?@tq! Q"@@ ;;vu %'  q!5#(8]58-D"ED L!  Q 3"&q'=a+A!BD " KHLIWe3 e 44WY tH~  "z$x.2CT'JDHN;@ e6DN(^ [>a nQ&7&CDEkN&?@ aT:&AkN  K"(^16 >1a!#>DN K1AX & ?s/F7F%F+:F0!F;9F5F;5F;c X|gS|Dcgc]}|dt|dfi|gc}Scc}wrw)r)r rers r parse_xreadrRs9 @H I1QqT$QqT5W5 6 II Is'c t|iS|jDcic]\}}|t|fi|gc}}Scc}}wra)rAr)r rer;r(s r parse_xread_resp3rXsH EM^^EU 7AsE11 22  s4c |jddr t|S|dxsgDcgc]\}}|t|d}}}|d|d|d|dScc}}w) N parse_detailF)r]pendingrr%r{)rminmaxr)rparse_xpending_ranger)r rerprs r parse_xpendingr`sl{{>5)#H--rc |\}}|jdd}|r|xsg}n|xr t|xsi}t||fS)N no_valuesF)rr@r)r rerrrpayloads r parse_hscanrsJIFA K/I'r( a(.B v; rc |jdt}|\}}t|}t|t t |t ||fS)Nr)rr&r}rrCr|rc)r rerrrrs r parse_zscanrsGkk"3U;OIFA aB v;SS"%=>? ??rc F|Dcgc]}| t|ndc}Scc}wrar)r rescores r parse_zmscorers$EM NEE-E%L4 7 NN Nsc p|jddrdndfd}|Dcgc] }|| c}Scc}w)Ndecode_responsesFr cX|dt|dt|dd}t|dtr7j|d|d<t |dk\r|d|d <|d |d <|S|d|d <j|d|d<t |d k\r|d |d <|d|d <|S)Nrr%r{)id start_timedurationrcommandclient_address client_name complexity)rrBrCjoinr)r+r\spaces r parse_itemz%parse_slowlog_get..parse_itemsQs47|TRSWV d1gt $ % 47 3F9 4yA~+/7'((,Q}% $(7F< % 47 3F9 4yA~+/7'((,Q}% r)r)r rerr+rs @r parse_slowlog_getrs8;;159CtE.*2 2Jt  22 2s3c |jddr t|S|jddr|jddr=|dDcgc].}t|dgttt|ddz0}}n)|dDcgc]}ttt|}}t |d|t |d t|d iSt |Scc}wcc}w) a Parse the response from `STRALGO` command. Without modifiers the returned value is string. When LEN is given the command returns the length of the result (i.e integer). When IDX is given the command returns a dictionary with the LCS length and all the ranges in both the strings, start and end offset for each string, where there are matches. When WITHMATCHLEN is given, each array representing a match will also have the length of the match at the beginning of the array. rFidx withmatchlenr%r/Nrr{r)rrrCrctupler)r rematchmatchess r parse_stralgors{{5% 8}{{5% ;;~u -&a[eBi."T#eU3BZ*@%AAG =EQKH5tCu-.HGH ! %w ! %s8A;'7    !! Is 3C C"c Xt|}td|jDS)Nc3DK|]}|s|jdywrr)rr:s r rz%parse_cluster_info..sJDT 3Js  )rrr4rds r parse_cluster_infors&H%H JH,?,?,AJ JJrc j|jd}|jddd\}}}}}}}} |jdd} d|vr*d|vr&|jddjddnd} || |||||gg| dk(rd nd d } t|d k\rt|dd\} }| |c| d <| d<| | fS)Nr@rr"r% connectedTF) node_idhostnamerJ master_idlast_ping_sentlast_pong_rcvdepochslots migrationsr  rr)rr _parse_slots)r: line_itemsr addrrJrpingpongrr ipr  node_dictrrs r _parse_node_linersCJDHJJsOTVUVDWAGT5)T4 C B36$;3$;tzz#q!'',Q/TVH&+5T5 I :!(AB8z6;Z3 'Il3 y=rcPgg}}|D]}d|vr.|ddjdd\}}|j||dd5d|vr.|ddjdd\}}|j||ddg|jdDcgc]}|}}|j|||fScc}w) Nz->-r%r/ migrating)slotr rkz-<- importing-)rr8) slot_rangesrrs_rangeslot_id dst_node_id src_node_idsls r rrsB:E " G #*1R=#6#6ua#@ G[    [;O g #*1R=#6#6ua#@ G[    [;O %,MM#$67br7G7 LL ! " * 8s B#c rt|ttfr|j}t d|DS)z @see: https://redis.io/commands/cluster-nodes # string / bytes @see: https://redis.io/commands/cluster-replicas # list of string / bytes c3DK|]}tt|ywra)rr)rnodes r rz&parse_cluster_nodes..*sJ d!34Js )rBstrbytesr4rrds r parse_cluster_nodesr-#s1 (S%L)&&( JJ JJrc \ |ds|dr|S t|ts|g}n|}|ds |ds|ds|Stdtd}dg}|d Dcgc] }||s ||c}z }|Dcgc]"}tt d t ||$c}S#t$r|cYSwxYwcc}wcc}w) z Parse the response of 'GEOSEARCH', GEORADIUS' and 'GEORADIUSBYMEMBER' commands according to 'withdist', 'withhash' and 'withcoord' labels. store store_distwithdist withcoordwithhashc:t|dt|dfSrwrlls r z)parse_geosearch_generic..Fsr!uuRU| <r)r1r2r3c|Sraxs r r7z)parse_geosearch_generic..Ls1r)r1r3r2c|d|dSrwr9)fvs r r7z)parse_geosearch_generic..Ns1be r)KeyErrorrBrCr&rrcr|)r re response_listcastfors r parse_geosearch_genericrC-s  7 w|4O 5 h %!  : w{';GJDW< D  A@ OaGAJ$q' OOACP QaD,c!Qi8 9 QQ- * P Qs# B B$B$)'B) B! B!c 2i}|D]}i}t|d}||d<t|d|d<|dDcgc] }t|c}|d<|d|d<|d |d <|d |d <t|d kDr|d |d<|d|d<|d|d<|||<|Scc}w)Nrr]r%arityr{rJr first_key_posr last_key_posr step_countrtipsrkey_specificationsr subcommands)rrrr recommandsrcmd_dictcmd_namer^s r parse_commandrPQsH & +# O>;KLZS% S!5(LL\4=9:DMStK/@ABD#D$45D$v,$ 4<(GLf6<Sx01!D + " $!%[ 1!!?Gnn>NOdaa,q/1O!D  rjH #))#.S&)Wn '"(//':RS D#Dd7m+DO KEM"! P!s#I I <I+I%3I+%I+c |yt|trZg}|D]Q}t|dd}|jdd}t ||d<t |d|d<|j |S|St|}|S)NTz client-infor z age-seconds)rBrCr@rparse_client_infor&r8r)r rerloglog_data client_infos r parse_acl_logrfs(D! "C$S$5H",,}b9K&7 &DH] #',H],C&DH] # KK ! " Kx  Krci}t|jjD]}|jd\}}|||<dD]}||vst||||<|S)zg Parsing client-info in ACL Log in following format. "key1=value1 key2=value2 key3=value3" r#>tot-memargv-mem qbuf-freedbrageoblollsubidleomempsubqbufmulti)rstriprr)r(rer9r;int_keys r rbrbs KU#))+113!ZZ_ U C! = k !#&{7';#q3ITrzBZPOPMAX BZPOPMINc@|xr|d|dt|dfxsdS)Nrr%r{rrs r r7r7`s'q'FadAaD%!+-F'N$rzACL CATc4ttt|SrarCrcrrs r r7r7bc,23rz ACL GENPASSzACL HELPc4ttt|Srarrs r r7r7d$s<34rzACL LISTc4ttt|Srarrs r r7r7errz ACL USERSc4ttt|Srarrs r r7r7fs4L! 45rz ACL WHOAMIzCLIENT GETNAMEzCLIENT TRACKINGINFOc4ttt|Srarrs r r7r7isT#lA*>%?rzCLUSTER GETKEYSINSLOTc4ttt|Srarrs r r7r7jstC a,@'ArzCOMMAND GETKEYSc4ttt|Srarrs r r7r7ksc,&:!;r CONFIG GETz DEBUG OBJECTGEOHASHc4ttt|Srarrs r r7r7nrrGEOPOSc.ttd|S)NcB|t|dt|dfSdSrwrr5s r r7z..ps#r~be eBqEl34r)rCrcrs r r7r7os OQRSrHGETALLc(|xr t|xsiSrarrs r r7r7rs/}Q/52r MEMORY STATSz MODULE LISTc>|Dcgc] }t|c}Scc}wrar)rms r r7r7ts:1mA.::rp) RESETSENTINEL MASTERSENTINEL MASTERSSENTINEL SENTINELSSENTINEL SLAVESSTRALGOXINFO CONSUMERS XINFO GROUPSZADDZMSCOREc8|xr t|xs tSrarrs r r7r7rrz0ZRANGE ZINTER ZPOPMAX ZPOPMIN HGETALL XREADGROUPc |Srar9)rrDs r r7r7sArz6ZRANGE ZRANGEBYSCORE ZREVRANGE ZREVRANGEBYSCORE ZUNIONc t|trH|Dcgc]8}|jDcic]\}}t|t|c}}:c}}}St |Scc}}wcc}}}wra)rBrCrArrrr;r;r(s r r7r7sl a   GHggi P U\#  U 3 3 P  QZ  P sA*A$A*$A*c|jDcic]"\}}| t|nd| t|nd$c}}Scc}}wrarArrr;r(s r r7r7sL'')  C!_ S$#(#4L $ ?s'?ch|jDcic]\}}t||c}}Scc}}wrarrs r r7r7s(!'')TJC|C0%7TTs.c t|tr6|jDcic]\}}t|t|c}}St|Scc}}wra)rBrrAr)rrer;r(s r r7r7sM a CD'')LJCc L/ /L!_LsAc |Dcgc]/}|jDcic]\}}t||c}}1c}}}Scc}}wcc}}}wrarrs r r7r7sCHI""CDAGGI>jc5c E !>">"AAAAc |Dcgc]/}|jDcic]\}}t||c}}1c}}}Scc}}wcc}}}wrar)rdr;r(s r r7r7sCHICDAGGI>jc5c E !>>r) r~rrrrrrrrrr)FF)@r redis.utilsrr rr<rFrrZr_rfrirlrorsruryr@rYrrrrrrrrrrrrrrrrrrrrrrrrrrrrrr-rCrPrSrUrWr`rfrbrxr}rr&_RedisCallbacks_RedisCallbacksRESP2_RedisCallbacksRESP3r9rr rs$5$0fsCs  C  # #scS33#3 c!" C#$/6  = GPN@!&  37D7: 5<' >J  /  *,6   @O 3:":K .(K!RH&*5* (V$@ 77Z 7 Z 4e< Z CZ,k:Z/Z",.?@#Z$$%Z&'Z(})Z*7+Z,-Z.$/Z0$1Z2$3Z4G5Z6g7Z8g9Z:d;Z<=Z>W?Z@AZBWCZDEZFgGZH&IZJGKZL(MZN+OZPQZRWSZT'UZVWZXwYZZ)[Z\}]Z^_Z`'aZbwcZdgeZfgZh}iZj [kZl JmZn%oZpGqZr4sZtTuZv /wZx(yZz-{Z| G}Z~ Z@ JAZB1CZDGEZF7GZH3?0@ A0F5G0H&I0J:K0L,.=:*' _0f0&(G0: 0@0!0 ,.?@!0"# U14C@ [0r