o Lj, @sUddlmZmZddlmZddlmZmZmZm Z m Z idee j e j ddee j e j ddee j e j ddee j e j dd ee j e j dd ee j e j dd ee j e j dd ee j e j dd ee j e j ddee j e j ddee j e j ddee j e j ddee j e j ddee j e j ddee j e j ddee j e j ddee 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 dee j e j dd dee j e j didZeed<GdddeZGdddeZGdddeZGd d!d!eZGd"d#d#eZGd$d%d%eZGd&d'd'eZGd(d)d)eZd*S)+)ABCabstractmethod)Optional)CommandPoliciesCommandsParser PolicyRecords RequestPolicyResponsePolicy explaincli)request_policyresponse_policysuglenprofile dropindex aliasupdatealter aggregatesyndumpcreateexplainsuggetdictdelaliasadddictadd synupdatedropinfo) sugadddictdumpcursorsearchtagvalsaliasdel aliaslistsugdel spellcheckcommand)ftcoreSTATIC_POLICIESc@4eZdZededeefddZed ddZdS) PolicyResolver command_namereturncCdSa  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,r0r0U/home/djax/ivt_ai_plugin/venv/lib/python3.10/site-packages/redis/commands/policies.pyresolve zPolicyResolver.resolvefallbackcCr.)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. Nr0r2r6r0r0r3 with_fallbackr5zPolicyResolver.with_fallbackNr6r+r-r+ __name__ __module__ __qualname__rstrrrr4r8r0r0r0r3r+  r+c@r*) AsyncPolicyResolverr,r-csdSr/r0r1r0r0r3r4s zAsyncPolicyResolver.resolver6cCr.)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. Nr0r7r0r0r3r8r5z!AsyncPolicyResolver.with_fallbackNr6r@r-r@r:r0r0r0r3r@r?r@c@ReZdZdZ ddedeeddfddZdedee fd d Z e dd d Z dS)BasePolicyResolverz* Base class for policy resolvers. Npoliciesr6r-cC||_||_dSN _policies _fallbackr2rDr6r0r0r3__init__ zBasePolicyResolver.__init__r,cCs|d}t|dkrtd|t|dkr|nd|df\}}|j|ddur8|jdur6|j|SdS|j||ddurQ|jdurO|j|SdS|j||SN.zWrong command or module name: r(rsplitlen ValueErrorrHgetrIr4r2r,partsmoduler&r0r0r3r4s       zBasePolicyResolver.resolver+cCdSrFr0r7r0r0r3r8z BasePolicyResolver.with_fallbackrFr9) r;r<r=__doc__rrr+rKr>rr4rr8r0r0r0r3rC rCc@rB)AsyncBasePolicyResolverz0 Async base class for policy resolvers. NrDr6r-cCrErFrGrJr0r0r3rKrLz AsyncBasePolicyResolver.__init__r,cs|d}t|dkrtd|t|dkr|nd|df\}}|j|ddur<|jdur:|j|IdHSdS|j||ddurX|jdurV|j|IdHSdS|j||SrMrPrUr0r0r3r4s     zAsyncBasePolicyResolver.resolver@cCrXrFr0r7r0r0r3r8rYz%AsyncBasePolicyResolver.with_fallbackrFrA) r;r<r=rZrrr@rKr>rr4rr8r0r0r0r3r\r[r\c@eZdZdZ d dedeeddffdd Zd d d ZZ S) DynamicPolicyResolverzB Resolves policy dynamically based on the COMMAND output. Ncommands_parserr6r-cs||_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_parsersuperrKget_command_policies)r2r_r6 __class__r0r3rK s zDynamicPolicyResolver.__init__r+cC t|j|SrF)r^r`r7r0r0r3r8 z#DynamicPolicyResolver.with_fallbackrFr9) r;r<r=rZrrr+rKr8 __classcell__r0r0rcr3r^s r^c:eZdZdZd deeddffdd Zd dd ZZS) StaticPolicyResolverz? Resolves policy from a static list of policy records. Nr6r-ctt|dS)z Parameters: fallback (Optional[PolicyResolver]): An optional fallback policy resolver used for resolving policies if static policies are inadequate. NrarKr)r7rcr0r3rKzStaticPolicyResolver.__init__r+cCt|SrF)rir7r0r0r3r8&z"StaticPolicyResolver.with_fallbackrFr9) r;r<r=rZrr+rKr8rgr0r0rcr3riricr]) AsyncDynamicPolicyResolverz1 Async version of DynamicPolicyResolver. Npolicy_recordsr6r-cst||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)rarK)r2rqr6rcr0r3rK/s z#AsyncDynamicPolicyResolver.__init__r@cCrerF)rprHr7r0r0r3r8<rfz(AsyncDynamicPolicyResolver.with_fallbackrFrA) r;r<r=rZrrr@rKr8rgr0r0rcr3rp*s rpcrh) AsyncStaticPolicyResolverz0 Async version of StaticPolicyResolver. Nr6r-crj)z Parameters: fallback (Optional[AsyncPolicyResolver]): An optional fallback policy resolver used for resolving policies if static policies are inadequate. Nrkr7rcr0r3rKErlz"AsyncStaticPolicyResolver.__init__r@cCrmrF)rrr7r0r0r3r8Mrnz'AsyncStaticPolicyResolver.with_fallbackrFrA) r;r<r=rZrr@rKr8rgr0r0rcr3rr@rorrN)abcrrtypingrredis._parsers.commandsrrrrr DEFAULT_KEYLESS DEFAULT_KEYEDSPECIALr)__annotations__r+r@rCr\r^rirprrr0r0r0r3s    !%)-159=AEkt&&