+h,+ddlmZmZmZmZmZmZddlmZm Z ddl m Z erddl m Z GddZGddeZGd d eZy ) ) TYPE_CHECKINGAnyDictOptionalTupleUnion) RedisError ResponseError) str_if_bytes) ClusterNodeceZdZdZdZy)AbstractCommandsParserc t|dkry|Dcgc] }t|}}|dj}d}|dk(r|dj}|dvr|dd}|S|dvrt|dd}|S|dvr|dg}|Scc}w) z Get the keys from pubsub command. Although PubSub commands have predetermined key locations, they are not supported in the 'COMMAND's output, so the key positions are hardcoded in this method NrPUBSUB)CHANNELSNUMSUB SHARDCHANNELS SHARDNUMSUB) SUBSCRIBE PSUBSCRIBE UNSUBSCRIBE PUNSUBSCRIBE)PUBLISHSPUBLISH)lenr upperlist)selfargsargcommandkeys pubsub_types J/var/www/html/venv/lib/python3.12/site-packages/redis/_parsers/commands.py_get_pubsub_keysz'AbstractCommandsParser._get_pubsub_keys s t9q=-12c S!22q'--/ h q'--/KTTABx R RQR>D  / /G9D #3sBc 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)Nrnamerarityrflags first_key_pos last_key_pos step_counttipskey_specifications subcommands)r intr)r r#optionscmd_dictcmd_nameflags r&parse_subcommandz'AbstractCommandsParser.parse_subcommand(s +# Oz,CommandsParser.initialize..Is,1199;,s)r#anyappendpoplowerrG)r rrGuppercase_commandscmds r&rHzCommandsParser.initializeEso99; /C,,,"))#. /& 6C$,LL$5HSYY[ ! 6  rBcrt|dkry|dj}||jvrp|j}|d}||jvr|t |ddz}n;|j |||jvrt |jd|jj|}d|dvr|j|g|}|Sd|dvs|d dk(r|j|}|S|d dk(r`|d dk(rX|d dk(rPd }d|vrG|d|dj}|dD]'} t| d|k(s|j| }d})|sy|d } | dkrt|t| z } t t|d | dz|d } | D cgc]} ||  }} |Scc} wap Get the keys from the passed command. NOTE: Due to a bug in redis<7.0, this function does not work properly for EVAL or EVALSHA when the `numkeys` arg is 0. - issue: https://github.com/redis/redis/issues/9493 - fix: https://github.com/redis/redis/pull/9733 So, don't use this function with EVAL or EVALSHA. rNrrz( command doesn't exist in Redis commands movablekeysr+pubsubr)r1r-r/Fr7|TrrTrGsplitrrHr rget_get_moveable_keysr'r r=absrange) r redis_connr!r;cmd_name_splitr#r$ is_subcmd subcmd_namesubcmdr/keys_posposs r&get_keyszCommandsParser.get_keysRs t9q=7==? 4== (&^^-N%a(H4==(%T!"X6 +4==0$#>>+,,TU--##H- GG, ,*4**:==D8 7) )WV_-H(4(($/D4 / %*O,1N+q0!  G+%-JaQ /@"AK")-"8-'q 2kA&*&;&;F&CG(,I- !">2La"4y3|+<< go. q0@',BWXH*22#DI2D2 3s$ F4c|djt|ddz} |jdg|}|S#t$r$}|j }d|vsd|vrYd}~y|d}~wwxYw)aA NOTE: Due to a bug in redis<7.0, this function does not work properly for EVAL or EVALSHA when the `numkeys` arg is 0. - issue: https://github.com/redis/redis/issues/9493 - fix: https://github.com/redis/redis/pull/9733 So, don't use this function with EVAL or EVALSHA. rrNCOMMAND GETKEYSInvalid arguments The command has no key arguments)r^rexecute_commandr __str__)r rcr!piecesr$emessages r&r`z!CommandsParser._get_moveable_keyss{a4QR>1 -:--.?I&ID  iikG#w.5@ s9 A&A!A!!A&N)r>r?r@__doc__rJrHrjr`rArBr&rDrD8s*!?BrBrDcteZdZdZdZd dZddedddfdZd edee e d ffd Z d edee e d ffd Z y)AsyncCommandsParsera% Parses Redis commands to get command keys. COMMAND output is used to determine key locations. Commands that do not have a predefined key location are flagged with 'movablekeys', and these commands' keys are determined by the command 'COMMAND GETKEYS'. NOTE: Due to a bug in redis<7.0, this does not work properly for EVAL or EVALSHA when the `numkeys` arg is 0. - issue: https://github.com/redis/redis/issues/9493 - fix: https://github.com/redis/redis/pull/9733 So, don't use this with EVAL or EVALSHA. )rGnodereturnNci|_yrF)rG)r s r&rJzAsyncCommandsParser.__init__s ?A rBrwr cK|r||_|jjdd{}|jDcic]\}}|j|c}}|_y7Ss!(A/A'A/A) A/)A/r!.cKt|dkry|dj}||jvrw|j}|d}||jvr|t |ddz}nB|j d{||jvrt |jd|jj|}d|dvr|j|d{}|Sd|dvs|d dk(r|j|}|S|d dk(r`|d dk(rX|d dk(rPd }d|vrG|d|dj}|dD]'}t|d|k(s|j|}d})|sy|d } | dkrt|t| z } t t|d | dz|d } | D cgc]} ||  }} |S7F7cc} wwrYr]) r r!r;rdr#r$rerfrgr/rhris r&rjzAsyncCommandsParser.get_keyss% t9q=7==? 4== (&^^-N%a(H4==(%T!"X6oo'''4==0$#>>+,,TU--##H- GG, ,000$77D8 7) )WV_-H(4(($/D4 / %*O,1N+q0!  G+%-JaQ /@"AK")-"8-'q 2kA&*&;&;F&CG(,I- !">2La"4y3|+<< go. q0@',BWXH*22#DI2D2 I(843s?A9G ;Gr?r@rt __slots__rJrrHrrstrrjr`rArBr&rvrvsp %IBTXm%<TT?C?HU38_,E?B c huS#X6O rBrvN)typingrrrrrrredis.exceptionsr r redis.utilsr redis.asyncio.clusterr rrDrvrArBr&rsACC6$1++\r+rjl0lrB