mBNj+FddlZddlmZdZdZdZdZdZdZd Z id e d e d e d e de de de de de de de de de de de de de e e e e e e dZ dZ dZ dZdZd Zd!Zd"Zd#Zd$Zd%Zd&Zd'Zd(Zd)Zd*Zd+Zd,Zd-Zd.Zd/Zdd0Z d1Z!d2Z"d3Z#d4Z$d5Z%d6Z&d7Z'd8Z(d9Z)d:Z*d;Z+d<Z,d=Z-d>Z.d?Z/d@Z0dAZ1dBZ2dCZ3dDZ4dEZ5dFZ6dGZ7dHZ8dIZ9dJZ:dKZ;dLZdOZ?dPZ@dQZAdRZBdSZCdTZDdUZEdVZFdWZGdXZHdYZIdZZJd[ZKd\ZLd]ZMd^ZNd_ZOd`ZPdaZQdbZRdcZSddZTdeZUdfZVdgZWdhZXdiZYdjZZdkZ[dlZ\dmZ]dnZ^doZ_dpZ`dqZadrZbdsZcdtZdduZedvZfdwZgdxZhdyZidzZjd{Zkd|Zld}Zmd~ZndZodZpdZqddlrmsZsmtZtmuZumvZvmwZwmxZxmyZyy)N str_if_bytesc||sy t|}tjj|S#t$rYywxYw)z5Converts a unix timestamp to a Python datetime objectN)int ValueErrordatetime fromtimestampresponses g/Users/ahmed/devFolder/Ultron/claude-voice/.venv/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=,.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_valuesdb. pairs_to_dictitemsr5 isinstancelistr kwargsstatsr;r(s r parse_memory_statsrIVsU (4 PEkkm U >>% Zt%<&4dE#J$ Lrc t|d}|jD]8\}}|jdst|ts)t|d||<:|S)zParse MEMORY STATS for unified RESP2 output. Unified responses decode structural keys while preserving string-like values as delivered, matching the approved RESP2/RESP3 unification shape. Tr>r@rArFs r parse_memory_stats_unifiedrLasP ( 5Ekkm U >>% Zt%<&u$?E#J$ Lrc L|jDcic]\}}t||}}}|jD]X\}}|jdst|ts)|jDcic]\}}t||c}}||<Z|Scc}}wcc}}w)a8Parse the results of MEMORY STATS on RESP3 wire. Each entry arrives as a top-level ``dict`` instead of a flat list of pairs; decode the keys to ``str`` and recurse into the per-database ``db.*`` sub-dicts so the Python shape matches what :func:`parse_memory_stats` produces from RESP2 wire. r@)rCrr5rDr)r rGr;r(rHr,r)s r parse_memory_stats_resp3rNns9A8H I8H*#u\#  %8HE Ikkm U >>% Zt%<9>GA,q/1,GE#J$ L JHs B9B c |Dcgc]/}|jDcic]\}}t||c}}1c}}}Scc}}wcc}}}w)zParse list-of-maps responses on RESP3 wire (e.g. ``XINFO`` family). Each list entry arrives as a ``dict`` with bytes keys; decode the keys to ``str`` so the Python shape matches what :func:`parse_list_of_dicts` produces from RESP2 wire. rCr)r rGxr;r(s r parse_list_of_dicts_resp3rR}sDMU UHq B *#u\#  % BH UU B UsAAAAzcan-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-epoch)) is_mastermaster)is_slaveslave)is_sdowns_down)is_odowno_down) is_sentinelsentinel)is_disconnected disconnected)is_master_down master_downc.tD] \}}||v||<y)zSet ``is_master`` / ``is_slave`` / ``is_sdown`` / ``is_odown`` / ``is_sentinel`` / ``is_disconnected`` / ``is_master_down`` on ``result`` based on membership in the ``flags`` set. N)_SENTINEL_DERIVED_BOOLEANS)resultflagsnameflags r _add_derived_sentinel_booleansris 1 du}t 1rcxt|t}t|djd}t |||SNrfr")pairs_to_dict_typedSENTINEL_STATE_TYPESsetrri)r+rerfs r parse_sentinel_stateros7 '; i}|D]}t|}|||d<|Sr|rzr rurerVr~s r parse_sentinel_masters_resp3rs0 F*62 %uV} Mrc Z|Dcgc]}ttt|c}Scc}wrqrrr rur+s r #parse_sentinel_slaves_and_sentinelsrs'FN Ohd \4!8 9h OO Os (c @|Dcgc]}t|fi|c}Scc}wrqrrs r )parse_sentinel_slaves_and_sentinels_resp3rs%DL MHD &t 7w 7H MM Msc#LK|jD] \}}||yw)zxYield key/value pairs from a RESP3 sentinel-state map as a flat iterable suitable for ``parse_sentinel_state``. N)rC)r~r;r(s r _flatten_resp3_state_pairsrs&kkm U  $s"$c Ftttt|Srqrorsrrrts r +parse_sentinel_master_resp3_to_resp2_legacyrs L2LX2V W XXrc li}|D],}tttt|}|||d<.|Sr|rrs r ,parse_sentinel_masters_resp3_to_resp2_legacyrsB F$  8@ A !&uV}  Mrc l|Dcgc]$}tttt|&c}Scc}wrqrrs r 9parse_sentinel_slaves_and_sentinels_resp3_to_resp2_legacyrs; D S/I$/OPQ  s)1c xttt|}t|dj d|d<|Srkrorsrrnrr rur~s r parse_sentinel_master_unifiedrs5 \8!< =Ew--c23E'N Lrc i}|D]C}ttt|}t|dj d|d<|||d<E|S)Nrfr"rgrr}s r parse_sentinel_masters_unifiedr sT F$St%<=U7^11#67g %uV} Mrc g}|D]L}ttt|}t|dj d|d<|j |N|Srk)rorsrrnrr8r ruoutr+r~s r +parse_sentinel_slaves_and_sentinels_unifiedrsR C$St%<=U7^11#67g 5 Jrc <t|fi|}t||d|SNrfrzrirs r #parse_sentinel_master_unified_resp3rs$ &x ;7 ;E"5%.9 Lrc \i}|D]$}t|}t||d|||d<&|S)Nrfrgrrs r $parse_sentinel_masters_unified_resp3r$s> F*62&ueGn= %uV} Mrc pg}|D].}t|fi|}t||d|j|0|Sr)rzrir8rs r 1parse_sentinel_slaves_and_sentinels_unified_resp3r-sA C*4;7;&ueGn= 5 Jrc 8|xr|dt|dfxsdSNrr%rrts r parse_sentinel_get_masterr6s$  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%)rsrrzipiter)r r>r?keysvaluesits r rBrB:s{ *!} |T*D!$Q$ v.FCf%&& (^CBK  rct|}i}t||D]\}}||vr |||}|||<|S#t$rYwxYwrq)rrrx)r type_inforrer;r(s r rlrlMsi hB F"bk U )  & #u- s " M   s 9 AAc&turSfd}|S)aWrap score_cast_func to handle scientific notation in RESP2 byte strings. Redis returns scores as byte strings in RESP2, and large numbers may use scientific notation (e.g., b'1.7732526297292595e+18'). Python's int() cannot parse scientific notation directly. Rather than unconditionally routing through float() (which would change the input type for every custom callable), we try the original function first and only fall back to converting through float() on ValueError. cb |S#ttf$rt|cYSwxYwrq)r TypeErrorr&)rQscore_cast_funcs r _safe_castz)_wrap_score_cast_func.._safe_castis6 -"1% %I& -"58, , -s  ..r&)rrs` r _wrap_score_cast_funcr\s %- rc |r|jds|St|jdt}t|}t t |t ||S)zr If ``withscores`` is specified in the options, return the response as a list of (value, score) pairs withscoresr)getrr&rrErrsr rurrs r zset_score_pairsrrsO 7;;|4+GKK8I5,QRO hB BOR01 22rc |s|St|jdt}t|}t t |t ||S)zRESP2-wire ZPOPMAX/ZPOPMIN -> legacy ``list[(member, score), ...]``. ZPOPMAX/ZPOPMIN always include scores, so this parser intentionally does not depend on a ``withscores`` option. r)rrr&rrErrsrs r zpop_score_pairsr~sD +GKK8I5,QRO hB BOR01 22rc |r|jds|St|jdt}|d||dgSzi If ``withscores`` is specified in the options, return the response as a [value, score] pair withscorerrr%rrr&r rurs r zset_score_for_rankrsE 7;;{3+GKK8I5,QRO 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 rrrr&r rurrgvals r zset_score_pairs_resp3rsN 7;;|4kk"3U;O:B C(YT3T?3' (( CC CsA c x|r|jds|S|jdt}|d||dgSrrrs r zset_score_for_rank_resp3rs@ 7;;{3kk"3U;O QK!5 66rct|tr|St|tr|jSt|tr|rdSdSt t |djS)aRe-encode a score back to the bytes form Redis returns on the RESP2 wire so that custom ``score_cast_func`` callables observe the same input type they would receive on a RESP2 connection when the wire protocol is RESP3 but legacy response shapes are requested. 10z.17g)rDbytesstrencodeboolformatr&)r(s r _score_to_resp2_bytesrsZ % %||~%t&$& %, ' . . 00rc |r|jds|St|jdt}|Dcgc]\}}||t|fc}}Scc}}w)aConvert RESP3 nested ``[[member, score], ...]`` to today's RESP2 ``list[(member, score)]`` shape: tuples instead of lists, scores re-encoded to bytes before being passed to ``score_cast_func`` so the cast receives the same input as on a RESP2 connection. rrrrr&rr rurmemberscores r &zset_score_pairs_resp3_to_resp2_legacyrsh 7;;|4+GKK8I5,QRO& %MFE !6u!=>?%  sAc |r|jds|Sg}|D]0\}}|j||jt|2|S)aConvert RESP3 nested ``[[member, score], ...]`` to the flat raw RESP2 wire shape ``[member, score_bytes, ...]`` used by ZDIFF in v8.0.0b1. ZDIFF historically did not propagate ``withscores`` to the response callback, so the legacy RESP2 callback was a no-op and the raw flat wire response was returned to the user. This helper reproduces that shape on RESP3 wires so ``legacy_responses=True`` keeps emitting the same Python value regardless of the underlying protocol. r)rr8r)r ruflatrrs r +zset_score_pairs_resp3_to_resp2_legacy_flatrsO 7;;|4 D!  F )%01" Krc |r|jds|St|jdt}|d|t|dgS)u9RESP3-wire ZRANK/ZREVRANK WITHSCORE → legacy RESP2 ``[rank, score]``. The shape ``[rank, score]`` is identical between RESP2 and RESP3; only the score is re-encoded to bytes before being passed to ``score_cast_func`` so the cast observes the same input type it would on a RESP2 connection. rrrr%rrs r )zset_score_for_rank_resp3_to_resp2_legacyrsK 7;;{3+GKK8I5,QRO QK)>x{)KL MMrc |r|jds|St|jdt}t|}t ||Dcgc]\}}||t|gc}}Scc}}w)uRESP2-wire WITHSCORES → unified ``list[[member, score], ...]``. Normalises RESP2 byte-string scores through ``float`` before applying ``score_cast_func`` so the cast receives the same input type as on a RESP3 connection. rr)rrr&rrr rurrrrs r zset_score_pairs_unifiedrsf 7;;|4+GKK8I5,QRO hBCFr2; O;ZS%S/%,/ 0; OO OsA0c |r|jds|St|jdt}|d|t|dgS)uRESP2-wire ZRANK/ZREVRANK WITHSCORE → unified ``[rank, score]``. Normalises the RESP2 byte-string score through ``float`` before applying ``score_cast_func`` so the cast receives the same input type as on a RESP3 connection. rrrr%rrs r zset_score_for_rank_unifiedrsJ 7;;{3+GKK8I5,QRO QKx{);< ==rc |s|St|jdt}t|}t ||Dcgc]\}}||t|gc}}Scc}}w)uRESP2-wire ZPOPMAX/ZPOPMIN → unified ``list[[member, score], ...]``. ZPOPMAX/ZPOPMIN always include scores; no ``withscores`` gate is required. Scores are normalised through ``float`` before applying ``score_cast_func`` for parity with RESP3. r)rrr&rrrs r zpop_score_pairs_unifiedrs[ +GKK8I5,QRO hBCFr2; O;ZS%S/%,/ 0; OO OsAc |s|S|jdt}t|dtr|Dcgc]\}}|||gc}}S|d||dggScc}}w)u!RESP3-wire ZPOPMAX/ZPOPMIN → unified ``list[[member, score], ...]``. Without ``count`` RESP3 returns a flat ``[member, score]``; with ``count`` it returns a nested ``[[member, score], ...]``. Both shapes are normalised to a nested list with ``score_cast_func`` applied. rrr%)rr&rDrErs r zpop_score_pairs_resp3_unifiedrso kk"3U;O(1+t$>FGhss+,hGG a[/(1+6 7 88HsAc |s|St|jdt}t|dtr&|Dcgc]\}}||t |fc}}S|d|t |dfgScc}}w)uYRESP3-wire ZPOPMAX/ZPOPMIN → legacy RESP2 ``list[(member, score), ...]``. Both RESP3 shapes (flat without ``count``; nested with ``count``) are converted to a list of tuples. Scores are re-encoded to bytes before being passed to ``score_cast_func`` so the cast observes the same input type it would on a RESP2 connection. rrr%)rrr&rDrErrs r &zpop_score_pairs_resp3_to_resp2_legacyr#s +GKK8I5,QRO(1+t$"* !) _%:5%AB C!)  a[/*? *LM N OO  sA7c 6|sy|d|dt|dgS)uBZPOPMAX/BZPOPMIN → unified ``[key, member, score]``. Works for both RESP2 (bytes score) and RESP3 (float score) wire shapes. Nrr%rrrts r bzpop_score_unifiedr6(  QK!eHQK&8 99rc 6|sy|d|dt|dfS)uRESP3-wire BZPOPMAX/BZPOPMIN → legacy RESP2 ``(key, member, score)``. Matches the v8.0.0b1 RESP2-wire callback shape (tuple, ``float`` score). Nrr%rrrts r !bzpop_score_resp3_to_resp2_legacyr@rrc f|s|S|d|dDcgc]\}}|t|gc}}gScc}}w)uRESP3-wire ZMPOP/BZMPOP → legacy RESP2 ``[name, [[member, b"score"], ...]]``. Re-encodes RESP3 native float scores back to the bytes form Redis returns on the RESP2 wire so callers observe today's RESP2 raw shape. rr%)rr rurrs r zmpop_resp3_to_resp2_legacyrJsE  EMa[Q[MFE&'. /[Q Q-c f|s|S|d|dDcgc]\}}|t|gc}}gScc}}w)uZMPOP/BZMPOP → unified ``[name, [[member, float_score], ...]]``. Used for the ``legacy_responses=False`` overlay on RESP2 wire to mirror RESP3's native float-score shape. rr%rrs r zmpop_unifiedrXsC  5=a[A[MFE&%, [A Arc |r|jds|St|dtr|St|}t ||Dcgc] \}}||g c}}Scc}}w)u)RESP2-wire HRANDFIELD WITHVALUES → unified ``list[[field, value], ...]``. Plain (no-values) responses — flat list of fields — pass through. The ``withvalues`` option (forwarded by the command method) selects the pairing branch so the no-values flat result is never misread. withvaluesr)rrDrErr)r rurrr(s r hrandfield_unifiedrfsY 7;;|4(1+t$ hB/22r{ ;{|ueUEN{ ;; ;sAc |r|jds|St|dts|Sg}|D]'\}}|j||j|)|S)uRESP3-wire HRANDFIELD WITHVALUES → legacy RESP2 flat ``[field, value, ...]``. Plain (no-values) responses — flat list of fields — pass through. rr)rrDrEr8)r rurrr(s r hrandfield_resp3_to_resp2_legacyrus\ 7;;|4 hqk4 ( D u E E! Krc h|Dcgc]"}|t|dt|dgnd$c}Scc}w)uGEOPOS → unified ``list[list[float, float] | None]``. Used for the ``legacy_responses=False`` overlay on RESP2 wire to mirror RESP3's native ``list[list]`` shape. Nrr%rr rulls r parse_geopos_unifiedrs< PX XxBNU2a5\5A< ( Dx XX X'/c h|Dcgc]"}|t|dt|dfnd$c}Scc}w)uRESP3-wire GEOPOS → legacy RESP2 ``list[tuple(float, float) | None]``. Matches today's RESP2-wire callback shape (tuple coordinates). Nrr%rrs r "parse_geopos_resp3_to_resp2_legacyrs< PX XxBNU2a5\5A< ( Dx XX Xrc t|tr4t|}t||Dcic]\}}t ||c}}St|t r-|j Dcic]\}}t ||c}}S|Scc}}wcc}}w)uLCS with IDX → unified ``dict``. Used for the ``legacy_responses=False`` overlay on RESP2 wire to mirror RESP3's native ``dict`` shape. Non-IDX responses (``bytes`` / ``int``) pass through unchanged. )rDrErrrrrC)r rurr;r(s r parse_lcs_idx_unifiedrs(D! (^;>r2;G;ZS% S!5(;GG(D!;C>>;KL;KZS% S!5(;KLL OHLs B(B c t|ts|Sg}|jD]'\}}|j||j|)|S)uRESP3-wire LCS with IDX → legacy RESP2 flat list shape. Reproduces today's RESP2 raw output (``[b"matches", [...], b"len", n]``). Non-IDX responses pass through unchanged. )rDrrCr8r rurr;r(s r #parse_lcs_idx_resp3_to_resp2_legacyrsK h %Cnn& U 3 5' Jrc t|tr-|jDcic]\}}t||}}}n4t |ddd|dddDcic]\}}t||}}}d|vr|dDcgc] }t|c}|d<d|vr|dDcgc] }t|c}|d<|Scc}}wcc}}wcc}wcc}w)uCLIENT TRACKINGINFO → unified ``dict[str, Any]``. Accepts either RESP2's flat ``[label, value, ...]`` list or RESP3's native ``dict`` and returns a ``dict`` with ``str`` keys. Nrr%rfprefixes)rDrrCrr)r rur;r(datarhprefixs r !parse_client_trackinginfo_unifiedr s (D!;C>>;KL;KZS% S!5(;KL"(3Q3-!$Q$@ @ U  u $@  $85) X &&rc V|jddr|dSt|d|d<|S)NrFr%rrts r parse_xautoclaimr"s1{{>5){#HQK0HQK Orc t|tr t|dS|jDcic]\}}t ||c}}Scc}}wr)rDrErBrCr)r rur,r)s r parse_arinfor$sG(D!X488+3>>+; <+;41aLOQ +; << a nQ&7&CDEkN&DRq aT:N&AkN$ K"(^+E16 > 1a!# >+DN K1AX & ?s/F7F%F+:F0!F;9F5F;5F;c X|gS|Dcgc]}|dt|dfi|gc}Scc}wr)r)r rurs r parse_xreadr3+s= @H I1QqT$QqT5W5 6 II Is'c t|iS|jDcic]\}}|t|fi|gc}}Scc}}wrqrCrr rur;r(s r parse_xread_resp3r71sM EM^^EU EUzsE11 22EU  4c |siSt|tr.|jDcic]\}}|t|fi|c}}S|Dcic]\}}|t|fi|c}}Scc}}wcc}}w)uXREAD/XREADGROUP → unified ``dict[stream, list[tuple[id, dict]]]``. Accepts either RESP2 (``list[[stream, entries]]``) or RESP3 (``dict[stream, entries]``) wire shape. Empty result is ``{}``. )rDrrCr)r rur;r(streamr's r parse_xread_unifiedr;9s  (D!GO~~GW GWeC"54G4 4GW  NV MU/&'!'5W55X   s A#A)c t|sgS|jDcgc]\}}|t|fi|gc}}Scc}}w)uRESP3-wire XREAD/XREADGROUP → legacy RESP2 ``list[[stream, entries]]``. Empty result ``{}`` is converted to ``[]`` to match today's RESP2 shape. r5r6s r !parse_xread_resp3_to_resp2_legacyr=JsI  EM^^EU EUzsE112EU  r8c |jddr t|S|dxsgDcgc]\}}|t|d}}}|d|d|d|dScc}}w) N parse_detailF)rgpendingrr%r)rAminmaxr()rparse_xpending_ranger)r rurpr(s r parse_xpendingrFVsr{{>5)#H--DLMHq1= Qd:HHM  / h/ 525Ns0c |siS|jDcic]"\}}| t|nd| t|nd$c}}Scc}}w)uRESP3-wire CONFIG GET → today's RESP2 ``dict[str, str]`` shape. On RESP3 the server returns a map; convert both keys and values via ``str_if_bytes`` so callers using ``r.config_get()["timeout"]`` keep working when the wire is RESP3 with ``legacy_responses=True``. NrPr6s r &parse_config_get_resp3_to_resp2_legacyr`sa  #..*  +JC!_ S$#(#4L $ ?+   s'Ac &|\}}t||fSrqr)r rucursorrs r parse_scanrcsIFA v;>rc |\}}|jdd}|r|xsg}n|xr t|xsi}t||fS)N no_valuesF)rrBr)r rurbrrepayloads r parse_hscanrgsJIFA K/I'r( a(.B v; rc t|jdt}|\}}t|}t |t t |t||fSNr)rrr&rrrErrs)r rurrbrrs r parse_zscanrjsL+GKK8I5,QROIFA aB v;SS"%=>? ??rc t|jdt}|\}}t|}t |t ||Dcgc]\}}||t|gc}}fScc}}wri)rrr&rrr)r rurrbrrr(rs r parse_zscan_unifiedrlso+GKK8I5,QROIFA aB v;CFr2;CN<5%e -.; s A+c F|Dcgc]}| t|ndc}Scc}wrqr)r rurs r parse_zmscorerns(EM NXEE-E%L4 7X NN Nsc p|jddrdndfd}|Dcgc] }|| c}Scc}w)Ndecode_responsesFrV 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_timedurationr@commandclient_address client_name complexity)rrDrEjoinr))r+respaces r parse_itemz%parse_slowlog_get..parse_itemsQs47|TRSWV d1gt $ % 47 3F9 4yA~+/7'((,Q}% $(7F< % 47 3F9 4yA~+/7'((,Q}% r)r)r rurr+rs @r parse_slowlog_getrs<;;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. r)Fidx withmatchlenr%r/Nrrr@)rrrErstupler)r rumatchmatchess r parse_stralgors{{5% 8}{{5% ;;~u -&a[(EeBi."T#eU3BZ*@%AA(  =EQKHK5tCu-.KGH ! %w ! %s8A;'7    !! Is 3C C"c |jddr t|S|jddr|jddr?|dDcgc].}t|dg|ddDcgc] }t|c}z0}}}n+|dDcgc]}|Dcgc] }t|c}}}}t|d|t|d t|d iSt|Scc}wcc}}wcc}wcc}}w) z Parse STRALGO into the approved unified shape. The legacy parser returns tuple ranges for IDX responses. Unified responses use list ranges so RESP2 and RESP3 produce the same value. r)Frrr%r/Nrrr@)rrrEr)r rurmrs r parse_stralgo_unifiedrs{{5% 8}{{5% ;;~u -&a[(EU2Y U3BZ#@ZDGZ#@@(  >Fa[I[E/AQ/[GI ! %w ! %s8A;'7    !!$A 0Is0 C&$C!6C& C1C, $C1!C&,C1c h|jddr t|S|jddrt|ts t |S|jd|jdg}|jd|jdd}|jddr<|Dcgc].}t|d g|d d Dcgc] }t |c}z0}}}n(|Dcgc]}|Dcgc] }t |c}}}}|t|d St |Scc}wcc}}wcc}wcc}}w) zEParse RESP3 STRALGO into the same value as ``parse_stralgo_unified``.r)Frrsmatchesslenrrr/N)rr))rrrDrrrE)r ru raw_matchesraw_lenrrrs r parse_stralgo_resp3_unifiedrs#{{5% 8}{{5% (D)) )ll9hll:r.JK ,,uhll61&=> ;;~u -)(EU2Y U3BZ#@ZDGZ#@@(  >II[E/AQ/[GI"3w<88  !! $A 0Is0&D#DD#" D.+D) =D.D#)D.c Xt|}td|jDS)Nc3DK|]}|s|jdywrr)rr:s r rz%parse_cluster_info..1sJ,ADT 3,As  )rrr4rts r parse_cluster_infor/s&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)NrV@rr"r% connectedTF) node_idhostnamerf master_idlast_ping_sentlast_pong_rcvdepochslots migrationsr rr)rr) _parse_slots)r: line_itemsraddrrfrpingpongrripr node_dictrrs r _parse_node_liner4sCJDHJJsOTVUVDWAGT5)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)slotrr~z-<- importing-)rr8) slot_rangesrrs_rangeslot_id dst_node_id src_node_idsls r rrKsB:E G #*1R=#6#6ua#@ G[    [;O g #*1R=#6#6ua#@ G[    [;O %,MM#$67$6br$6G7 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|ywrq)rr)rnodes r rz&parse_cluster_nodes..fsJ d!34s )rDrrr4rrts 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|dfSrrrs r z)parse_geosearch_generic..r!uuRU| .s1rrrrc|d|dSrrfvs r rz)parse_geosearch_generic..1be rKeyErrorrDrEr&rrsr)r ru response_listcastfors r parse_geosearch_genericris  7 w|4O 5 h %!  : w{';GJDW< D  A@ O@aGAJ$q'@ OOACP Q=aD,c!Qi8 9= QQ- * P Qs# B B$B$)'B) B! B!c Z |ds|dr|S t|tr|n|g}|ds |ds|ds|Stdtd}dg}|d Dcgc] }||s ||c}z }|Dcgc]"}tt d t ||$c}S#t$r|cYSwxYwcc}wcc}w) zF Parse GEOSEARCH/GEORADIUS responses using tuple coordinates. rrrrrc:t|dt|dfSrrrs r rz1parse_geosearch_generic_unified..rrrc|Srqrrs r rz1parse_geosearch_generic_unified..sqrrc|d|dSrrrs r rz1parse_geosearch_generic_unified..rrr)r rurrfuncsrrs r parse_geosearch_generic_unifiedrs 7 w|4O 5 !+8T :H M : w{';GJDW< D ME D SD!PQ d1gD SSEGT U}!D,c%m< =} UU T Us# B B#B#('B( B B c i}|D]}i}t|d}||d<t|d|d<|dDcgc] }t|c}|d<|d|d<|d |d <|d |d <t|d kDr|d Dcgc] }t|c}|d<t|dkDr|d|d<|d|d<|d|d<|||<|Scc}wcc}wNrrgr%arityrrfr@ first_key_posrx last_key_posrz step_countrwacl_categoriesr}tipsrkey_specificationsr subcommandsrrr))r rucommandsrvcmd_dictcmd_namerhcategorys r parse_commandrsH +# Oqz*7A8 X&z*H% & w>;KL;KZS% S!5(;KL\4=9:DMStK/@ABD#D$45D$v,$ 4<(GLf6<NO>Ndaa,q/1>NO 1!D  rjH #))#.&)Wn '"(//':R/ 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)NT client-infor age-seconds)rDrErBrparse_client_infor&r8rQ)r rur loglog_data client_infos r parse_acl_logrs(D!C$S$5H",,}b9K&7 &DH] #',H],C&DH] # KK ! Kx  Krc x|yt|ts t|Sg}|D]}t|tr-|j Dcic]\}}t ||}}}n t |dd}|jdd}t||d<t|d|d<|j||Scc}}w)uRESP3-wire ACL LOG → today's RESP2 parsed shape. Each log entry arrives as a ``dict`` on RESP3 wire instead of a flat list of pairs; convert ``client-info`` from a string blob into the parsed ``dict`` and ``age-seconds`` to ``float`` so the Python shape matches what :func:`parse_acl_log` produces from RESP2 wire. Also used as the unified callback (Set D): the legacy and unified shapes coincide for ACL LOG. NTrrr) rDrErQrrCrrBrrr&r8)r rur rr,r)rrs r #parse_acl_log_resp3_to_resp2_legacyr.s h %x  D c4 7:yy{C{tq! Q*{HC$S$5Hll="5 "3K"@"'(?"@ H KDs B6c |yt|ts t|Sg}|D]}t|tr-|j Dcic]\}}t ||}}}n t |dd}d|vrt|d|d<d|vrt|d|d<t|j D]\}}|dvs t |||<|j||Scc}}w)z4Parse RESP3 ACL LOG into the approved unified shape.NTrr)rr) rDrErQrrCrrBr&rr8) r rur r-r,r)rr;r(s r parse_acl_log_resp3_unifiedrJs h %x  D eT "7<{{}E}tq! Q*}HE$UD$7H H $&+H],C&DH] # H $&78O&PH] #x~~/0JC88 ,U 3 1 H KFs C#c t|fi|}||S|jd}|rEt|dtr2|Dcgc]#}t t |ddd|ddd%c}|d<|Scc}w)uACL GETUSER → unified shape with selectors as ``list[dict]``. On RESP2 wire each selector arrives as a flat ``[k, v, k, v, …]`` list; pair them into dicts to match the RESP3 wire shape. Nrrrr%)rrrDrErr)r rur rrs r parse_acl_getuser_unifiedras X 1 1D | %IZ ! d3FO FO(DXadd^Xadd^4 5i [ K s(A+c t|fi|}||S|jd}|rOt|dtr<|Dcgc])}|j Dcgc] }|D]}| c}}+c}}}|d<|Scc}}wcc}}}w)uRESP3-wire ACL GETUSER → today's RESP2 selectors as flat lists. Each selector arrives as a ``dict`` on RESP3 wire; flatten back to the interleaved ``[k, v, k, v, …]`` form produced by RESP2 wire. rr)rrrDrrC)r rur rrrr+s r 'parse_acl_getuser_resp3_to_resp2_legacyr rs X 1 1D | %IZ ! d3MV MVHNN, <,bTT, tot-memargv-mem qbuf-freedbrsageoblollsubidleomempsubqbufmulti)rstriprr)r(rr9r;int_keys r rrsw KU#))+113ZZ_ U C4  k !#&{7';#r9s?$5$0f  VsCs  C  # #scS33#3 c!" C#$/6%= PNY  @!& , 3 37D7 1 & N P > P 9P&::   <  YY  ( : 5<' = >J "  /  *,6 "  @O 3:":"0"(K .(K!RHV2.**5* (V$8.""@ 76@  7r