Pf,+ddlmZmZmZmZmZmZddlmZm Z ddl m Z erddl m Z GddZGddeZGd d eZd S) ) TYPE_CHECKINGAnyDictOptionalTupleUnion) RedisError ResponseError str_if_bytes) ClusterNodeceZdZdZdZdS)AbstractCommandsParserc0t|dkrdSd|D}|d}d}|dkr)|d}|dvr |dd}n)|dvrt|dd}n |d vr |dg}|S) 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 Nc,g|]}t|Sr ).0args I/var/www/html/env/lib/python3.11/site-packages/redis/_parsers/commands.py z;AbstractCommandsParser._get_pubsub_keys..s 222c S!!222rPUBSUB)CHANNELSNUMSUB SHARDCHANNELS SHARDNUMSUB) SUBSCRIBE PSUBSCRIBE UNSUBSCRIBE PUNSUBSCRIBE)PUBLISHSPUBLISH)lenupperlist)selfargscommandkeys pubsub_types r_get_pubsub_keysz'AbstractCommandsParser._get_pubsub_keys s t99q==422T222q'--// h  q'--//KTTTABBx R R RQRR>>DD / / /G9D rc Bi}t|d}||d<t|d|d<d|dD|d<|d|d <|d |d <|d |d <t|dkr!|d|d<|d|d<|d|d<|S)Nrnamerarityc,g|]}t|Srr )rflags rrz;AbstractCommandsParser.parse_subcommand..-s GGGD\$//GGGrrflags first_key_pos last_key_pos step_counttipskey_specifications subcommands)r intr%)r(r*optionscmd_dictcmd_names rparse_subcommandz'AbstractCommandsParser.parse_subcommand(s ++# OOGGGAJGGG$+AJ!#*1: !( w<i|_||dSN)commands initialize)r(redis_connections r__init__zCommandsParser.__init__As"  ()))))rc|}g}|D]0}td|Dr||1|D],}||||<-||_dS)Nc3>K|]}|VdSrK)isupper)rxs r z,CommandsParser.initialize..Is*,,1199;;,,,,,,r)r*anyappendpoplowerrL)r(rrLuppercase_commandscmds rrMzCommandsParser.initializeEs99;; / /C,,,,,,, /"))#...% 6 6C$,LL$5$5HSYY[[ ! !  rctdkrdSd}||jvr|}|d}||jvr|t ddznB||||jvr$t |d|j|}d|dvr|j |gR}nd|dvs |d dkr |j }n|d dkr||d dkrp|d dkrdd }d|vrZ|dd}|dD]2} t| d|kr| | }d}3|sdS|d } | dkrtt| z } t t|d | dz|d } fd| D}|S)p 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. rNrr( command doesn't exist in Redis commands movablekeysr3pubsubr/r9r5r7Fr?|Tc g|] }| Srrrposr)s rrz+CommandsParser.get_keys..222#DI222rr%rXrLsplitr'rMr r&get_get_moveable_keysr-r rDabsrange) r( redis_connr)rCcmd_name_splitr*r+ is_subcmd subcmd_namesubcmdr7keys_poss ` rget_keyszCommandsParser.get_keysRsb t99q==47==?? 4= ( (&^^--N%a(H4=((%T!""X6 +++4=00$#>>++UUU-##H-- GG, , ,*4*:====DD ) ) )WV_-H-H(4($/DD %**O,11N+q00!  G++%-"A"AQ "A"AK")-"8--'q 22kAA&*&;&;F&C&CG(,I! 4">2La"4yy3|+<+<< go. q0@',BWXXH3222222D rc|dt|ddz} |jdg|R}n6#t$r)}|}d|vsd|vrYd}~dS|d}~wwxYw|S)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)rgr'execute_commandr __str__)r(rlr)piecesr+emessages rriz!CommandsParser._get_moveable_keyssa4QRR>>1 -:-.?I&IIIDD   iikkG#w..5@@ttttt  sA A6 A1/A11A6N)rErFrG__doc__rOrMrrrirrrrIrI8s[***!!!???BrrIceZdZdZdZd dZddedddfdZd edee e d ffd Z d edee e d ffd Z dS)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. )rLnodereturnNci|_dSrK)rL)r(s rrOzAsyncCommandsParser.__init__s ?A rrr cK|r||_|jdd{V}d|D|_dS)NCOMMANDc>i|]\}}||Sr)rX)rr[r*s r z2AsyncCommandsParser.initialize..s&SSS,#wgSSSr)rrwitemsrL)r(rrLs rrMzAsyncCommandsParser.initializes_  DI229========SS(..BRBRSSS rr).cKtdkrdSd}||jvr|}|d}||jvr|t ddznG|d{V||jvr$t |d|j|}d|dvr|j d{V}nd|dvs |d dkr |j }n|d dkr||d dkrp|d dkrdd }d|vrZ|dd}|dD]2}t|d|kr| |}d}3|sdS|d } | dkrtt| z } t t|d | dz|d } fd| D}|S)r]rNrrr^r_r3r`r/r9r5r7Fr?raTc g|] }| Srrrcs rrz0AsyncCommandsParser.get_keys.. rerrf) r(r)rCrmr*r+rnrorpr7rqs ` rrrzAsyncCommandsParser.get_keyss} t99q==47==?? 4= ( (&^^--N%a(H4=((%T!""X6oo'''''''''4=00$#>>++UUU-##H-- GG, , ,00$7777777DD ) ) )WV_-H-H(4($/DD %**O,11N+q00!  G++%-"A"AQ "A"AK")-"8--'q 22kAA&*&;&;F&C&CG(,I! 4">2La"4yy3|+<+<< go. q0@',BWXXH3222222D rcK |jjdg|Rd{V}n6#t$r)}|}d|vsd|vrYd}~dS|d}~wwxYw|S)Nrtrurv)rrwr rx)r(r)r+rzr{s rriz&AsyncCommandsParser._get_moveable_keys s 223DLtLLLLLLLLLDD   iikkG#w..5@@ttttt  s AA  A  A)rNrK) rErFrGr| __slots__rOrrMrrstrrrrirrrr~r~s  %IBBBBTTXm%<TTTTT?C?HU38_,E????B c huS#X6O      rr~N)typingrrrrrrredis.exceptionsr r redis.utilsr redis.asyncio.clusterr rrIr~rrrrsCCCCCCCCCCCCCCCC66666666$$$$$$2111111++++++++\rrrrr+rrrjlllll0lllllr