(iwPBddlmZmZmZmZmZmZmZmZm Z m Z m Z ddl m Z mZddlmZddlmZmZddlmZddlmZddlmZmZddlmZmZdd lmZdd l m!Z!dd l"m#Z#dd l$m%Z%dd l&m'Z'm(Z(ddl)m*Z*ddl+m,Z,m-Z-m.Z.ddl/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8ddl9m:Z:m;Z;mZ>m?Z?m@Z@mAZAddlBmCZCmDZDmEZEmFZFddlGmHZHmIZImJZJmKZKer ddlLmMZMddlNmOZOGdde3ZPGdde4ePZQGdde5ZRGdde6eRZSGdde0ZTGd d!e1ZUGd"d#e2ZVy$)%) TYPE_CHECKINGAny AwaitableCallableDictIterableListOptionalSequenceTypecast)ABIChecksumAddress) combomethod)abi_to_signatureget_abi_input_names)partial)HexBytes)fallback_func_abi_existsreceive_func_abi_exists) FallbackFn ReceiveFn)async_fill_transaction_defaults)Self)async_parse_block_identifier)PropertyCheckingFactory)AsyncEventFilterBuilderget_event_data)AsyncLogFilter) normalize_abinormalize_address_no_ensnormalize_bytecode) BaseContractBaseContractCallerBaseContractConstructorBaseContractEventBaseContractEventsBaseContractFunctionBaseContractFunctionsNonExistentFallbackFunctionNonExistentReceiveFunction)$async_build_transaction_for_functionasync_call_contract_functionasync_estimate_gas_for_function%async_transact_with_contract_functionfind_events_by_identifierfind_functions_by_identifierget_event_by_identifierget_function_by_identifier)Web3AttributeError Web3TypeErrorWeb3ValidationErrorWeb3ValueError)BlockIdentifier EventData StateOverrideTxParams)AsyncENS) AsyncWeb3ceZdZUded<e ddeeeefdee dee dee de e e f d Zeddd ddd deeeefdee de d eed eeedef dZedefdZy)AsyncContractEventAsyncWeb3[Any]w3Nargument_filters from_blockto_block block_hashreturnc K|Btj t fd|jDs t dj j||||}j jj|d{}tfd|D}jj||}t|d} t| d} tttt| S7ow)a  Get events for this contract instance using eth_getLogs API. This is a stateless method, as opposed to createFilter. It can be safely called against nodes which do not provide eth_newFilter API, like Infura nodes. If there are many events, like ``Transfer`` events for a popular token, the Ethereum node might be overloaded and timeout on the underlying JSON-RPC call. Example - how to get all ERC-20 token transactions for the latest 10 blocks: .. code-block:: python from = max(mycontract.web3.eth.block_number - 10, 1) to = mycontract.web3.eth.block_number events = mycontract.events.Transfer.get_logs(from_block=from, to_block=to) for e in events: print(e["args"]["from"], e["args"]["to"], e["args"]["value"]) The returned processed log values will look like: .. code-block:: python ( AttributeDict({ 'args': AttributeDict({}), 'event': 'LogNoArguments', 'logIndex': 0, 'transactionIndex': 0, 'transactionHash': HexBytes('...'), 'address': '0xF2E246BB76DF876Cef8b38ae84130F4F55De395b', 'blockHash': HexBytes('...'), 'blockNumber': 3 }), AttributeDict(...), ... ) See also: :func:`web3.middleware.filter.LocalFilterMiddleware`. :param argument_filters: Filter by argument values. Indexed arguments are filtered by the node while non-indexed arguments are filtered by the library. :param from_block: block number or "latest", defaults to "latest" :param to_block: block number or "latest". Defaults to "latest" :param block_hash: block hash. Cannot be set at the same time as ``from_block`` or ``to_block`` :yield: Tuple of :class:`AttributeDict` instances Nc3&K|]}|v ywN).0argevent_arg_namess M/var/www/br/venv/lib/python3.12/site-packages/web3/contract/async_contract.py z.AsyncContractEvent.get_logs..sQ#so-QszaWhen filtering by argument names, all argument names must be present in the contract's event ABI.c3tK|]/}tjjj|1ywrI)rrAcodecabi)rKentryselfs rNrOz.AsyncContractEvent.get_logs..s+ ?DN477==$((E : s58c |dS)NlogIndexrJes rNz-AsyncContractEvent.get_logs..s !J-)keyc |dS)N blockNumberrJrWs rNrYz-AsyncContractEvent.get_logs..s -8HrZ)rrRallkeysr6_get_event_filter_paramsrAethget_logstuple"_process_get_logs_argument_filterssortedr rrr9) rTrBrCrDrE_filter_paramslogsall_event_logs filtered_logs sorted_logsrMs ` @rNrbzAsyncContractEvent.get_logslsB  '1$((;OQ9I9N9N9PQQ); 66 HH& Hj WW[[)).99 HL  ?? HH   ]0GH [.HI Ihy12K@@:sB DDA0Dlatest)rBrCrDaddresstopicsrlrmcDKt|j|jj}|j |||||||j |jd{}t |jj|j|_||_|S7<w)zW Create filter object that tracks logs emitted by this contract event. N) rrRrArQ_set_up_filter_builderdeployrlog_entry_formatterbuilder)rTrBrCrDrlrmfilter_builder log_filters rN create_filterz AsyncContractEvent.create_filters1477==I ##        *0099 )7 txx)P &+  :sAB !B"=B ct|j|jjt |jj|j}|j |_|S)N) formatter)rrRrArQrrl)rTrrs rN build_filterzAsyncContractEvent.build_filtersF) HH GGMM$TWW]]DHH=  ,,rZNNNN)__name__ __module__ __qualname____annotations__rr rstrrr8rrrr9rbrr rrurrxrJrZrNr?r?hs*6:04.2)- YA"4S>2YA_-YA?+ YA X& YA 8I& ' YAYAv6:04$,-1*.#4S>2_-  "  /* #' 65rZr?c :eZdZ ddedddeeddffd ZxZS) AsyncContractEventsNrRrAr@rlrFc2t|||t|yrI)super__init__r?)rTrRrArl __class__s rNrzAsyncContractEvents.__init__s b"4g>rZrI)rzr{r|rr rr __classcell__rs@rNrrs5SW??,?7?7P? ??rZrc eZdZUded< ddeededeedeede f d Z ddeede fd Z ddeedeedeede fd Z ddeedefd Ze dd edddeeddfdZe dd edddeeddfdZy)AsyncContractFunctionr@rAN transactionblock_identifierstate_overrideccip_read_enabledrFc K|j|}t|j|d{}t|j}t |j|j |j||||j|j|||jg |jxsdi|jxsid{S77w)a Execute a contract function call using the `eth_call` interface. This method prepares a ``Caller`` object that exposes the contract functions and public variables as callable Python functions. Reading a public ``owner`` address variable example: .. code-block:: python ContractFactory = w3.eth.contract( abi=wallet_contract_definition["abi"] ) # Not a real contract address contract = ContractFactory("0x2f70d3d26829e412A602E83FE8EeBF80255AEeA5") # Read "owner" public variable addr = contract.functions.owner().call() :param transaction: Dictionary of transaction info for web3 interface :param block_identifier TODO :param state_override TODO :param ccip_read_enabled TODO :return: ``Caller`` object that has contract public functions and variables exposed as Python methods NrJ) _get_call_txparamsrrArrRr-rl_return_data_normalizers contract_abi decode_tuplesargskwargs)rTrrrrcall_transactionblock_idabi_element_identifiers rNcallzAsyncContractFunction.callsD 22;?5dgg?OPP!1$((!;1 GG LL  ) ) "      HH      YY_" kkR   Q s"+CCB C;C<CCcK|j|}t|j}t|j|j |||j |jg|jxsdi|jxsid{S7wNrJ) _transactrrRr/rlrArrr)rTrsetup_transactionrs rNtransactzAsyncContractFunction.transact2s NN;7!1$((!;: LL GG "     HH  YY_"  kkR    BB B B c K|j|}t|j}t|j|j |||j |j||g|jxsdi|jxsid{S7wr) _estimate_gasrrRr.rlrArrr)rTrrrrrs rN estimate_gasz"AsyncContractFunction.estimate_gas@s !..{;!1$((!;4 LL GG "     HH    YY_"  kkR    sBB B B cK|j|}t|j}t|j|j |||j |jg|jxsdi|jxsid{S7wr) _build_transactionrrRr,rlrArrr)rTrbuilt_transactionrs rNbuild_transactionz'AsyncContractFunction.build_transactionUs!33K@!1$((!;9 LL GG "     HH  YY_"  kkR    rrRasync_w3rlc|r-t|r"tjd|||tSt tt S)NfallbackrArrlr)rrfactoryrr r*rRrrls rNget_fallback_functionz+AsyncContractFunction.get_fallback_functionesO +C0(00 '1 1 )+F+HIIrZc|r-t|r"tjd|||tSt tt S)Nreceiver)rrrrr r+rs rNget_receive_functionz*AsyncContractFunction.get_receive_functionusO *3/(00 '0 1 )+E+GHHrZryrINNN)rzr{r|r}r r;r8r:boolrrrrintrr staticmethodrrrrrJrZrNrrsf+/,026,0 6 h'6 *6 !/ 6 $D> 6 6 p  (8*<    +/6:26  h' #?3 !/   ,15 #H-  .2 J  J" J/* J ! J J.2 I  I" I/* I ! I IrZrc FeZdZ d dedddeedeeddf fd ZxZS) AsyncContractFunctionsNrRrAr@rlrrFc4t|||t||yrI)rrr)rTrRrArlrrs rNrzAsyncContractFunctions.__init__s b"7-PrZ)NF) rzr{r|rr rrrrrs@rNrrsU .2(- Q Q Q/* Q  ~ Q  QQrZrc ^eZdZUdZeed<dZded<ded<dZeed<dde e d dfd Z e dddd e e d ed eefd Ze ded ed dfdZededdde dedefd edf dZededde d dfdZededdde dedefd edf dZededde d dfdZy) AsyncContractN functionsAsyncContractCallercallerr@rAeventsrlrFc|j td|rt||_|js t dt |j |j|j|j|_t|j |j|j|j|j|_ t|j |j|j|_ tj|j |jt|j|_tj#|j |jt|j|_y)zv Create a new smart contract proxy object. :param address: Contract address as 0x hex string NzwThe `Contract` class has not been initialized. Please use the `web3.contract` interface to create your contract class.z;The address argument is required to instantiate a contract.rrcontract_functions)rAr4r!rlr5rrRrrrrrrrrrrrr)rTrls rNrzAsyncContract.__init__s 77?$K  3G;P   rZfns identifierct||SrI)r3)rrrs rNr3z(AsyncContract.get_function_by_identifiers*#z::rZr?c(t||||tSrI)r0r?rs rNr0z'AsyncContract.find_events_by_identifiers) "g~7I  rZct||SrI)r2)rrrs rNr2z%AsyncContract.get_event_by_identifier's'vz::rZrI)rzr{r|rrr}rrrr rr classmethodr~rr rrrrrrr r1r r3r0r2rJrZrNrrs(,I%,$(F !( #'F &#  9# T# J?C4!4/7}4OR4 d44l X Xs X7Q X X       !  !c*  % &    ;23;AD; ;;        !  !c*  " #    ;23;AD; ;;rZrceZdZUded< ddedddedeededee d ee d ee d dffd Z ddeededee d dfd Z xZ S)rr@rANrRrlrrrrrrFc 0t ||||||jrv|i}|t||||}|j|_|j D]<} t |j| |||} t|t| j| >yy)Nr)rrr) rrrRr _functions__iter__r call_functionsetattrr~r) rTrRrArlrrrrrfn caller_methodrs rNrzAsyncContractCaller.__init__2s b'G 88" !)%;WM&"1;;DO(113 M '&& +%5&7 ! c"";";M ~M%%;<M MF+/,0,0  h' * $D>    rZrceZdZUded<ed deedefdZe d deedefdZ e d deedee de fd Z y) rr@rANrrFcK|jjj|j|d{S7wrI)rArasend_transaction_get_transaction)rTrs rNrz!AsyncContractConstructor.transactjs0WW[[11$2G2G 2TUUUUs8A?AclK|j|}t|j|d{S7w)zB Build the transaction dictionary without sending N)rrrA)rTrrs rNrz*AsyncContractConstructor.build_transactionns1!33K@4TWW>OPPPPs +424rcK|j|}|jjj||d{S7w)N)r)rrArar)rTrrs rNrz%AsyncContractConstructor.estimate_gasxsH ((5 WW[[-- *:.    srs           D*DN?,-?@?MI0MI`Q23HIQZ;LZ;z5 ,5 p 6 rZ