ZTh"ddlmZddlmZddlmZddlmZddlm Z m Z m Z ddl m ZerddlZddlmZdd lmZGd d eZy) ) annotations) TYPE_CHECKING)RulesLowLevelClient) ResourceBase)Rule RuleAction RuleUpdate) cel_utilsN) SiftClient)ChannelReferencecHeZdZdZdfd Zddd ddZddddddd ddZdd Z d dd Z d dd Z ddddd  dd Z ddd ddZ ddd ddZ ddd ddZ xZS) RulesAPIAsyncaHigh-level API for interacting with rules. This class provides a Pythonic, notebook-friendly interface for interacting with the RulesAPI. It handles automatic handling of gRPC services, seamless type conversion, and clear error handling. All methods in this class use the Rule class from the low-level wrapper, which is a user-friendly representation of a rule using standard Python data structures and types. cnt||t|jj|_y)zaInitialize the RulesAPI. Args: sift_client: The Sift client to use. ) grpc_clientN)super__init__rclientr_low_level_client)self sift_client __class__s `/home/www/backend.miabetepe.com/venv/lib/python3.12/site-packages/sift_client/resources/rules.pyrzRulesAPIAsync.__init__s) %!4AXAX!YNrule_id client_keyczK|jj||d{}|j|S7w)zGet a Rule. Args: rule_id: The ID of the rule. client_key: The client key of the rule. Returns: The Rule. rN)rget_rule_apply_client_to_instance)rrrrules rgetzRulesAPIAsync.get$s>++44WQ[4\\--d33] !;9;F)name name_contains name_regexorder_bylimitinclude_deletedcPKt|dut|duzt|duzdkDr tdg}|r%|jtjd||r%|jtj d||r%|jtj d||s$|jtjd|rdj|nd}|jj||||d{} |j| S7w) aList rules with optional filtering. Args: name: Exact name of the rule. name_contains: Partial name of the rule. name_regex: Regular expression string to filter rules by name. order_by: How to order the retrieved rules. limit: How many rules to retrieve. If None, retrieves all matches. include_deleted: Include deleted rules. Returns: A list of Rules that matches the filter. Nz@Must use EITHER name, name_contains, or name_regex, not multipler# deleted_datez && ) filter_queryr& max_results page_size) int ValueErrorappendcelequalscontainsmatch equals_nulljoinrlist_all_rules_apply_client_to_instances) rr#r$r%r&r'r(filters filter_strruless rlist_zRulesAPIAsync.list_6s. t4 3}D'@#A AC Z^H^D_ _bc c_` `  NN3::fd3 4  NN3<< > ?  NN399VZ8 9 NN3??>: ;-4V[[)" ,,;;# <   ..u55  sD D&D$D&cK|jdi|d{}t|dkDr tdt|dk(r|dSy71w)aFind a single rule matching the given query. Takes the same arguments as `list`. If more than one rule is found, raises an error. Args: **kwargs: Keyword arguments to pass to `list`. Returns: The Rule found or None. Nr*zMultiple rules found for queryr)r>lenr1)rkwargsr=s rfindzRulesAPIAsync.findbsQ!djj*6** u:>=> > Z1_8O +sA A 2A c K|jj||||||||| |  d{} |j| S7w)zCreate a new rule.) r# descriptionorganization_id expressionactionchannel_referencesr asset_idscontextual_channels is_externalN)r create_ruler) rr#rErGrIrHrFrrJrKrL created_rules rcreatezRulesAPIAsync.createss_"33??#+!1! 3#@   --l;;  s)AAAcKt|tr|j|d{}t|trt j |}|j j|||d{}|j|S7_7w)zUpdate a Rule. Args: rule: The Rule or rule ID to update. update: Updates to apply to the Rule. version_notes: Notes to include in the rule version. Returns: The updated Rule. rN) isinstancestrr!dictr model_validater update_ruler)rr update version_notes updated_rules rrWzRulesAPIAsync.updatesy dC $//D fd #..v6F!33??fm\\ --l;; 0 ]s"&B BA B 2B 3B  B )r r=rule_ids client_keyscK|rdt|tr/|jj|jd{y|jj|d{y|r}t |dk(r2|jj|djd{y|jj |Dcgc]}|jc}d{y|r[t |dk(r(|jj|dd{y|jj |d{y|r%|jj |d{ytd7977cc}w77k7H7#w)zArchive a rule or multiple. Args: rule: The Rule to archive. rules: The Rules to archive. rule_ids: The rule IDs to archive. client_keys: The client keys to archive. rQNr*r)rZ)r[z7Either rules, rule_ids, or client_keys must be provided)rRrr archive_ruleid_rAbatch_archive_rulesr1)rr r=rZr[rs rarchivezRulesAPIAsync.archivesa $%,,99$((9KKK,,99$9GGG 5zQ,,99%(,,9OOO,,@@-23aee3A8}!,,99(1+9NNN,,@@(@SSS ((<<<U U UVW W%LGP4 OS UsrCrOrWrarerirl __classcell__)rs@rrrs'Z#!% 44 4  4* $(.2# %*6*6" *6 , *6  *6*6*6 *6X0'+!%&*04!<<< < 3 <  <$<<$<.<< <:X\<<(9rs4" N4DD- -?u6Lu6r