o Lj$I @sUdZddlmZmZmZddlmZmZmZm Z ddl m Z ddl m Z mZmZmZmZmZmZmZmZmZmZmZmZmZmZmZmZmZmZm 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-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;mZ>m?Z?m@Z@mAZAmBZBmCZCmDZDmEZEmFZFmGZGmHZHmIZImJZJmKZKmLZLmMZMmNZNmOZOmPZPmQZQmRZRmSZSmTZTmUZUmVZVmWZWmXZXmYZYmZZZm[Z[m\Z\m]Z]m^Z^m_Z_m`Z`maZambZbmcZcmdZdmeZemfZfmgZgmhZhmiZimjZjmkZkmlZlmmZmmnZnie^deoe^depe^d e e^d eUe^d e.e^d ePid ede dede de dededede de de deode de de de de ide de d e d!e#d"e#d#e d$e d%e d&e d'e d(e#d)e$d*e d+e d,e d-e d.e id/eee e e eeqeeqd0e0d1e1d2e_d3e d4eod5eod6d7d8d9e9d:e9d;e dd?d8d@e dAe dBe dCe dDe dEe dFe;dGe dHe dIe dJe dKeLdLe dMe]dNe:dOdPd8eQeRe eoe eeSeTe[dQ Zrie^dRdSd8e^dTeje^dUebe^dVefe^dWee^dXdYd8e^dZd[d8e^d\d]d8id^d_d8d`e dadbd8dcddd8dedfd8dge dhe didjd8dkdld8dmdnd8doe'dpe)dqdrd8dsdtd8dudvd8dwdxd8dye6dzd8e edeCdeHdeHdeOiZuevewedeffexd<iete^deke^dUede^d\ee^d eXe^d e/ide\dekd^dd8d`e dadd8dcdd8dededd8dge dhe diede"d)e&de+dqdd8de3de e?eDeIeIeNdZyevewedeffexd<ie^dRdd8e^dTelememde^dUece^d\ee^dVehe^dXdd8e^d eWe^dZdd8e^de`ided^dd8d`e d edadd8dcdd8dededd8dge dhe diedkdd8de!dmdd8doe(dpe)de*dd8e,e2e7e e=eBeGeGe5e5d Zzevewedeffexd<deeqdeodevewedefffddZ{dS)uUResponse-callback dictionaries and the protocol/legacy selector. This module is the single source of truth for the mapping between Redis command names and the Python-side callbacks that post-process raw parser output into user-facing values. Six dictionaries are defined: * ``_RedisCallbacks`` — entries that produce the same Python value regardless of wire protocol or legacy-response selection. * ``_RedisCallbacksRESP2`` — RESP2 wire, legacy Python shapes. * ``_RedisCallbacksRESP3`` — RESP3 wire, Python shapes from the previous RESP3 callbacks. * ``_RedisCallbacksRESP2Unified`` — RESP2 wire, unified Python shapes (``legacy_responses=False``). * ``_RedisCallbacksRESP3Unified`` — RESP3 wire, unified Python shapes (``legacy_responses=False``). * ``_RedisCallbacksRESP3toRESP2Legacy`` — RESP3 wire converted back to the legacy RESP2 Python shapes for users who keep ``legacy_responses=True`` on a RESP3 connection. ``get_response_callbacks`` merges ``_RedisCallbacks`` with the appropriate protocol-specific overlay. Callers wrap the returned dict in ``CaseInsensitiveDict``. )AnyCallableOptional)HIMPORT_DISCARDHIMPORT_DISCARDALLHIMPORT_PREPARE HIMPORT_SET str_if_bytes)bbool_ok!bzpop_score_resp3_to_resp2_legacybzpop_score_unified float_or_none hrandfield_resp3_to_resp2_legacyhrandfield_unified pairs_to_dictparse_acl_getuser'parse_acl_getuser_resp3_to_resp2_legacyparse_acl_getuser_unified parse_acl_log#parse_acl_log_resp3_to_resp2_legacyparse_acl_log_resp3_unified parse_arinfoparse_client_infoparse_client_killparse_client_list/parse_client_trackinginfo_resp3_to_resp2_legacy!parse_client_trackinginfo_unifiedparse_cluster_info)parse_cluster_links_resp3_to_resp2_legacyparse_cluster_links_unifiedparse_cluster_nodes parse_commandparse_command_resp3parse_command_unifiedparse_config_get&parse_config_get_resp3_to_resp2_legacyparse_debug_object)parse_function_list_resp3_to_resp2_legacyparse_function_list_unified"parse_geopos_resp3_to_resp2_legacyparse_geopos_unifiedparse_geosearch_genericparse_geosearch_generic_unified parse_hscan parse_info#parse_lcs_idx_resp3_to_resp2_legacyparse_lcs_idx_unifiedparse_list_of_dictsparse_list_of_dicts_resp3parse_memory_statsparse_memory_stats_resp3parse_memory_stats_unifiedparse_pubsub_numsub parse_scanparse_sentinel_get_masterparse_sentinel_master+parse_sentinel_master_resp3_to_resp2_legacyparse_sentinel_master_unified#parse_sentinel_master_unified_resp3parse_sentinel_mastersparse_sentinel_masters_resp3,parse_sentinel_masters_resp3_to_resp2_legacyparse_sentinel_masters_unified$parse_sentinel_masters_unified_resp3#parse_sentinel_slaves_and_sentinels)parse_sentinel_slaves_and_sentinels_resp39parse_sentinel_slaves_and_sentinels_resp3_to_resp2_legacy+parse_sentinel_slaves_and_sentinels_unified1parse_sentinel_slaves_and_sentinels_unified_resp3parse_sentinel_state_resp3parse_set_resultparse_slowlog_get parse_stralgoparse_stralgo_resp3_unifiedparse_stralgo_unifiedparse_stream_listparse_xautoclaim parse_xclaimparse_xinfo_streamparse_xpending parse_xreadparse_xread_resp3!parse_xread_resp3_to_resp2_legacyparse_xread_unified parse_zadd parse_zmscore parse_zscanparse_zscan_unifiedsort_return_tuplesstring_keys_to_dicttimestamp_to_datetimezmpop_resp3_to_resp2_legacy zmpop_unifiedzpop_score_pairs&zpop_score_pairs_resp3_to_resp2_legacyzpop_score_pairs_resp3_unifiedzpop_score_pairs_unifiedzset_score_for_rankzset_score_for_rank_resp3)zset_score_for_rank_resp3_to_resp2_legacyzset_score_for_rank_unifiedzset_score_pairszset_score_pairs_resp3&zset_score_pairs_resp3_to_resp2_legacy+zset_score_pairs_resp3_to_resp2_legacy_flatzset_score_pairs_unifiedzoAUTH COPY EXPIRE EXPIREAT HEXISTS HMSET MOVE MSETNX PERSIST PSETEX PEXPIRE PEXPIREAT RENAMENX SETEX SETNX SMOVEzHINCRBYFLOAT INCRBYFLOATz{ASKING FLUSHALL FLUSHDB LSET LTRIM MSET PFMERGE READONLY READWRITE RENAME SAVE SELECT SHUTDOWN SLAVEOF SWAPDB WATCH UNWATCHzXREAD XREADGROUPz%GEORADIUS GEORADIUSBYMEMBER GEOSEARCHzXRANGE XREVRANGEz ACL GETUSERzACL LOADACL LOGz ACL SETUSERzACL SAVEz CLIENT INFOz CLIENT KILLz CLIENT LISTz CLIENT PAUSEzCLIENT SETINFOzCLIENT SETNAMEzCLIENT UNBLOCKzCLUSTER ADDSLOTSzCLUSTER ADDSLOTSRANGEzCLUSTER DELSLOTSzCLUSTER DELSLOTSRANGEzCLUSTER FAILOVERzCLUSTER FORGETz CLUSTER INFOz CLUSTER MEETz CLUSTER NODESzCLUSTER REPLICASzCLUSTER REPLICATEz CLUSTER RESETzCLUSTER SAVECONFIGzCLUSTER SET-CONFIG-EPOCHzCLUSTER SETSLOTzCLUSTER SLAVESCOMMANDzCONFIG RESETSTATz CONFIG SETzFUNCTION DELETEzFUNCTION FLUSHzFUNCTION RESTOREGEODISTHSCANINFOLASTSAVEz MEMORY PURGEz MODULE LOADz MODULE UNLOADPINGcCs t|dkS)NPONGr rrx_/home/djax/ivt_ai_plugin/venv/lib/python3.10/site-packages/redis/_parsers/response_callbacks.pys rzz PUBSUB NUMSUBzPUBSUB SHARDNUMSUBQUITSETSCANz SCRIPT EXISTScCttt|SN)listmapboolrvrxrxryrzz SCRIPT FLUSHz SCRIPT KILLz SCRIPT LOADzSENTINEL CKQUORUMzSENTINEL FAILOVERzSENTINEL FLUSHCONFIGz SENTINEL GET-MASTER-ADDR-BY-NAMEzSENTINEL MONITORzSENTINEL RESETzSENTINEL REMOVEz SENTINEL SETz SLOWLOG GETz SLOWLOG RESETSORTSSCANTIMEcCst|dt|dfSNrr )int)xrxrxryrzs) XAUTOCLAIMXCLAIMz XGROUP CREATEzXGROUP DESTROYz XGROUP SETIDARINFOz XINFO STREAMXPENDINGZSCANzSDIFF SINTER SMEMBERS SUNIONcC|rt|ptSrsetrvrxrxryrzz=ZINTER ZRANGE ZRANGEBYSCORE ZREVRANGE ZREVRANGEBYSCORE ZUNIONzZPOPMAX ZPOPMINzZREVRANK ZRANKzZINCRBY ZSCOREzBGREWRITEAOF BGSAVEcCdSNTrxrvrxrxryrzz BLPOP BRPOPcC|rt|pdSrtuplervrxrxryrzzBZPOPMAX BZPOPMINcCs"|r|d|dt|dfpdS)Nrr floatrvrxrxryrzs"zACL CATcCr~rrrr rvrxrxryrzrz ACL GENPASSzACL HELPcCr~rrrvrxrxryrzrzACL LISTcCr~rrrvrxrxryrzrz ACL USERScCr~rrrvrxrxryrzrz ACL WHOAMIzCLIENT GETNAMEzCLIENT TRACKINGINFOcCr~rrrvrxrxryrzrzCLUSTER GETKEYSINSLOTcCr~rrrvrxrxryrzrzCOMMAND GETKEYScCr~rrrvrxrxryrzr CONFIG GETz DEBUG OBJECTGEOHASHcCr~rrrvrxrxryrz rGEOPOScCsttdd|S)NcSs$|durt|dt|dfSdSrr)llrxrxryrz s$z..)rrrvrxrxryrz s HGETALLcCs|rt|piSrrrvrxrxryrzrz HOTKEYS GETcCdd|DS)NcSg|]}t|qSrxr.0mrxrxry ..rxrvrxrxryrzr MEMORY STATScCr)NcSrrxrrrxrxryrrrrxrvrxrxryrzr) z MODULE LISTRESETSENTINEL MASTERSENTINEL MASTERSSENTINEL SENTINELSSENTINEL SLAVESSTRALGOXINFO CONSUMERS XINFO GROUPSZADDZMSCOREcCrrrrvrxrxryrz"rz0ZRANGE ZINTER ZPOPMAX ZPOPMIN HGETALL XREADGROUPcK|Srrxrwkwargsrxrxryrz&rz6ZRANGE ZRANGEBYSCORE ZREVRANGE ZREVRANGEBYSCORE ZUNIONcCs t|tr dd|DSt|S)NcSsg|] }dd|DqS)cSi|] \}}t|t|qSrxr rkeyvaluerxrxry 3z'...)items)rrrxrxryr2sr) isinstancerr rvrxrxryrz1s cKs$t|trdd|DSt|S)NcSrrxr rrxrxryrArz..)rdictrr )rwoptionsrxrxryrz@s) rnrorrrrrrrrrzCZDIFF ZINTER ZRANGE ZRANGEBYSCORE ZREVRANGE ZREVRANGEBYSCORE ZUNIONcCs|pdSrrxrvrxrxryrzbsz ZMPOP BZMPOPr ZRANDMEMBER HRANDFIELDcKrrrxrrxrxryrzirz CLUSTER LINKScKrrrxrrxrxryrzlrz FUNCTION LISTLCSrrrrr._RedisCallbacksRESP2UnifiedcCr~rrrvrxrxryrzrcCr~rrrvrxrxryrzrcCr~rrrvrxrxryrzrcCr~rrrvrxrxryrzrcCr~rrrvrxrxryrzrr)rrrrr_RedisCallbacksRESP3UnifiedcCrrrrvrxrxryrzr)ZDIFFrcCrrrxrvrxrxryrzrcCrrrrvrxrxryrzrcCr~rrrvrxrxryrzrcCr~rrrvrxrxryrzrcCr~rrrvrxrxryrzrcCr~rrrvrxrxryrzrcCr~rrrvrxrxryrzrcCr~rrrvrxrxryrzrcCr~rrrvrxrxryrzr) rrrrrrrrrrr!_RedisCallbacksRESP3toRESP2Legacy user_protocollegacy_responsesreturncCsrtt}|r#|dur|t|S|dvr|t|S|t|S|dus+|dvr2|t|S|t|S)aReturn the merged callback dict for the given (protocol, legacy) combination. ``user_protocol`` is the value the user supplied to the client constructor (``None`` means "not specified"). ``legacy_responses`` defaults to ``True`` and selects today's RESP2-style Python shapes even when the wire protocol is RESP3. Callers wrap the returned dict in ``CaseInsensitiveDict``. N)3)r_RedisCallbacksupdater_RedisCallbacksRESP3_RedisCallbacksRESP2rr)rr callbacksrxrxryget_response_callbackss      rN)|__doc__typingrrr redis.himportrrrr redis.utilsr helpersr r rrrrrrrrrrrrrrrrrrr r!r"r#r$r%r&r'r(r)r*r+r,r-r.r/r0r1r2r3r4r5r6r7r8r9r:r;r<r=r>r?r@rArBrCrDrErFrGrHrIrJrKrLrMrNrOrPrQrRrSrTrUrVrWrXrYrZr[r\r]r^r_r`rarbrcrdrerfrgrhrirjrkrlrmrrrrrrrrstr__annotations__rrrrxrxrxrys e   !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVb     #$%&4 +   !"#$%&'()*/  !"#$ 1    !"#$%&'()*+ 9