keJi, UddlmZmZddlmZddlmZmZmZm Z m Z idee j e j dee j e j dee j e j dee j e j d ee j e j d ee j e j d ee j e j d ee j e j d ee j e j dee j e j dee j e j dee j e j dee j e j dee j e j dee j e j dee j e j dee j e j ee j e j ee j e j ee j e j ee j e j ee j e j ee j e j ee j e j ee j e j ddee j e j idZeed<GddeZGddeZGddeZGd d!eZGd"d#eZGd$d%eZGd&d'eZGd(d)eZd*S)+)ABCabstractmethod)Optional)CommandPoliciesCommandsParser PolicyRecords RequestPolicyResponsePolicy explaincli)request_policyresponse_policysuglenprofile dropindex aliasupdatealter aggregatesyndumpcreateexplainsuggetdictdelaliasadddictadd synupdatedropinfo)sugadddictdumpcursorsearchtagvalsaliasdelsugdel spellcheckcommand)ftcoreSTATIC_POLICIEScReZdZededeefdZeddZdS)PolicyResolver command_namereturncdSa  Resolves the command name and determines the associated command policies. Args: command_name: The name of the command to resolve. Returns: CommandPolicies: The policies associated with the specified command. Nselfr,s ]/var/www/html/movieo_spanner_bot/venv/lib/python3.11/site-packages/redis/commands/policies.pyresolvezPolicyResolver.resolve}  fallbackcdS)a Factory method to instantiate a policy resolver with a fallback resolver. Args: fallback: Fallback resolver Returns: PolicyResolver: Returns a new policy resolver with the specified fallback resolver. Nr0r2r7s r3 with_fallbackzPolicyResolver.with_fallbackr5r6Nr7r+r-r+ __name__ __module__ __qualname__rstrrrr4r:r0r6r3r+r+|se  C  H_,E    ^      ^    r6r+cReZdZededeefdZeddZdS)AsyncPolicyResolverr,r-c KdSr/r0r1s r3r4zAsyncPolicyResolver.resolves  r6r7cdS)a Factory method to instantiate an async policy resolver with a fallback resolver. Args: fallback: Fallback resolver Returns: AsyncPolicyResolver: Returns a new policy resolver with the specified fallback resolver. Nr0r9s r3r:z!AsyncPolicyResolver.with_fallbackr5r6Nr7rBr-rBr<r0r6r3rBrBse  #  (?2K    ^      ^    r6rBcjeZdZdZ d dedeeddfdZdedee fdZ e d d Z dS) BasePolicyResolverz* Base class for policy resolvers. Npoliciesr7r-c"||_||_dSN _policies _fallbackr2rHr7s r3__init__zBasePolicyResolver.__init__"!r6r,c2|d}t|dkrtd|t|dkr|n d|df\}}|j|d#|j|j|SdS|j||d#|j|j|SdS|j||SN.zWrong command or module name: r(rsplitlen ValueErrorrLgetrMr4r2r,partsmoduler&s r3r4zBasePolicyResolver.resolves""3'' u::>>LlLLMM M#&u::??%%q8J >  fd + + 3~)~--l;;;t >  f % % ) )'4 8 8 @~)~--l;;;t~!!&))--g666r6r+cdSrJr0r9s r3r:z BasePolicyResolver.with_fallback r6rJr;) r=r>r?__doc__rrr+rOr@rr4rr:r0r6r3rGrGs MQ""%"19.1I" """" 7C7H_,E7777,   ^   r6rGcjeZdZdZ d dedeeddfdZdedee fdZ e d d Z dS) AsyncBasePolicyResolverz0 Async base class for policy resolvers. NrHr7r-c"||_||_dSrJrKrNs r3rOz AsyncBasePolicyResolver.__init__rPr6r,cNK|d}t|dkrtd|t|dkr|n d|df\}}|j|d)|j |j|d{VSdS|j||d)|j |j|d{VSdS|j||SrRrUrZs r3r4zAsyncBasePolicyResolver.resolves/""3'' u::>>LlLLMM M#&u::??%%q8J >  fd + + 3~)!^33LAAAAAAAAAt >  f % % ) )'4 8 8 @~)!^33LAAAAAAAAAt~!!&))--g666r6rBcdSrJr0r9s r3r:z%AsyncBasePolicyResolver.with_fallbackr^r6rJrE) r=r>r?r_rrrBrOr@rr4rr:r0r6r3raras RV""%"19:M1N" """" 7#7(?2K7777,   ^   r6racHeZdZdZ d dedeeddffd Zd dZxZ S) DynamicPolicyResolverzB Resolves policy dynamically based on the COMMAND output. Ncommands_parserr7r-c~||_t||dS)z Parameters: commands_parser (CommandsParser): COMMAND output parser. fallback (Optional[PolicyResolver]): An optional resolver to be used when the primary policies cannot handle a specific request. N)_commands_parsersuperrOget_command_policies)r2rgr7 __class__s r3rOzDynamicPolicyResolver.__init__s9!0 ==??JJJJJr6r+c,t|j|SrJ)rfrir9s r3r:z#DynamicPolicyResolver.with_fallbacks$T%:HEEEr6rJr;) r=r>r?r_rrr+rOr: __classcell__rls@r3rfrfs UY K K- K9A.9Q K  K K K K K KFFFFFFFFr6rfcBeZdZdZddeeddffd Zd dZxZS) StaticPolicyResolverz? Resolves policy from a static list of policy records. Nr7r-cVtt|dS)z Parameters: fallback (Optional[PolicyResolver]): An optional fallback policy resolver used for resolving policies if static policies are inadequate. NrjrOr)r2r7rls r3rOzStaticPolicyResolver.__init__% (33333r6r+c t|SrJ)rqr9s r3r:z"StaticPolicyResolver.with_fallback"s#H---r6rJr;) r=r>r?r_rr+rOr:rnros@r3rqrqss44.!94T444444........r6rqcHeZdZdZ d dedeeddffd Zd dZxZ S) AsyncDynamicPolicyResolverz1 Async version of DynamicPolicyResolver. Npolicy_recordsr7r-cLt||dS)z Parameters: policy_records (PolicyRecords): Policy records. fallback (Optional[AsyncPolicyResolver]): An optional resolver to be used when the primary policies cannot handle a specific request. N)rjrO)r2ryr7rls r3rOz#AsyncDynamicPolicyResolver.__init__+s% 22222r6rBc,t|j|SrJ)rxrLr9s r3r:z(AsyncDynamicPolicyResolver.with_fallback8s)$.(CCCr6rJrE) r=r>r?r_rrrBrOr:rnros@r3rxrx&s37 3 3% 3./ 3  3 3 3 3 3 3DDDDDDDDr6rxcBeZdZdZddeeddffd Zd dZxZS) AsyncStaticPolicyResolverz0 Async version of StaticPolicyResolver. Nr7r-cVtt|dS)z Parameters: fallback (Optional[AsyncPolicyResolver]): An optional fallback policy resolver used for resolving policies if static policies are inadequate. Nrsrts r3rOz"AsyncStaticPolicyResolver.__init__Arur6rBc t|SrJ)r}r9s r3r:z'AsyncStaticPolicyResolver.with_fallbackIs(222r6rJrE) r=r>r?r_rrBrOr:rnros@r3r}r}<st44*=!>4$44444433333333r6r}N)abcrrtypingrredis._parsers.commandsrrrr r DEFAULT_KEYLESS DEFAULT_KEYEDSPECIALr)__annotations__r+rBrGrarfrqrxr}r0r6r3rs;#########e oo(8*:   e  //(6*8   e  ??(8*:   e  __(8*:   e " (8*:   #e * (8*:   +e 2 __(8*:   3e : ??(8*:   ;e B //(8*:   Ce J ??(8*:   Ke R //(6*8   Se Z ??(8*:   [e b OO(8*:   ce j ??(8*:   ke r __(8*:   se z (8*:   {e B (8*:   Ce J"/(6*8   $O(8*:   "/(0*:   "/(8*:   #?(8*:   $O(8*:   "/(6*8   &o(8*:   Ce e e N ??(8*:    Om"m"mmm`     S   8     #   8# # # # # # # # L# # # # # 1# # # LFFFFF.FFF*.....-..."DDDDD!8DDD,33333 733333r6