o Zh @spddlZddlZddlmZmZddlmZddlmZm Z ddl m Z m Z GdddeZ Gdd d e ZdS) N)OptionalType)AsyncCallbackManagerForToolRun) BaseModelField) AINBaseTool OperationTypec@sNeZdZUdZedZeed<edddZe ed<edddZ e e ed <dS) RuleSchemazSchema for owner operations..typez-Path on the blockchain where the rule applies) descriptionpathNz#eval string to determine permissioneval) __name__ __module__ __qualname____doc__rr r__annotations__r strr rrr_/var/www/html/lang_env/lib/python3.10/site-packages/langchain_community/tools/ainetwork/rule.pyr s r c @sfeZdZUdZdZeed<dZeed<eZ e e ed<  dde d ed e ed e ed ef d dZdS) AINRuleOpszTool for owner operations.Z AINruleOpsnamea Covers the write `rule` for the AINetwork Blockchain database. The SET type specifies write permissions using the `eval` variable as a JavaScript eval string. In order to AINvalueOps with SET at the path, the execution result of the `eval` string must be true. ## Path Rules 1. Allowed characters for directory: `[a-zA-Z_0-9]` 2. Use `$` for template variables as directory. ## Eval String Special Variables - auth.addr: Address of the writer for the path - newData: New data for the path - data: Current data for the path - currentTime: Time in seconds - lastBlockNumber: Latest processed block number ## Eval String Functions - getValue() - getRule() - getOwner() - getFunction() - evalRule(, , auth, currentTime) - evalOwner(, 'write_owner', auth) ## SET Example - type: SET - path: /apps/langchain_project_1/$from/$to/$img - eval: auth.addr===$from&&!getValue('/apps/image_db/'+$img) ## GET Example - type: GET - path: /apps/langchain_project_1 r args_schemaNr r r run_managerreturnc sddlm}zE|tjur+|durtd|jj|j|dd|iiddIdH}n|tj ur=|jj| IdH}ntd|d t j |d d WSt yk}zt|jd t|WYd}~Sd}~ww) Nr)ValueOnlyTransactionInputz%'eval' is required for SET operation.z.rulewrite)value)ZtransactionInputzUnsupported 'type': .F) ensure_asciiz: )Z ain.typesrrZSET ValueError interfacedbrefZsetRuleGETZgetRulejsondumps Exceptionbuiltinsr rr)selfr r r rrreserrr_arun9s&    &zAINRuleOps._arun)NN)rrrrrrrr r rrrrrrr,rrrrrs$    r)r(r%typingrrZlangchain_core.callbacksrZpydanticrrZ(langchain_community.tools.ainetwork.baserrr rrrrrs