[zksync2==0.6.0] <use python sdk to listen contract event error> #80
-
EnvironmentTestnet Acknowledgement
Issue DescriptionValueError: {'code': -32602, 'message': 'Filter not found'} Expected Behaviorcontract event list Code Exampleaddress = '0x2E5f01AEB81924014d225F62ab611FD544E0c636' Repo Link (Optional)No response |
Beta Was this translation helpful? Give feedback.
Answered by
danijelTxFusion
Aug 31, 2023
Replies: 11 comments 9 replies
-
|
Hey @rnsKelvin Can you provide more details on your setup, ideally a minimal example that I can use to reproduce the issue? |
Beta Was this translation helpful? Give feedback.
2 replies
-
|
Hi @dutterbutter |
Beta Was this translation helpful? Give feedback.
-
|
Reviewing the python SDK the error your are experiencing is expected as we do not have full support for listening on contract events yet. This is actively being worked and will be supported in the future. The docs will also be updated with provided examples. My apologies for any inconvenience. |
Beta Was this translation helpful? Give feedback.
-
|
I am using python to listen for contract events without any issues. But I'm not using the zkSync python SDK, I simply use web3.py. |
Beta Was this translation helpful? Give feedback.
2 replies
-
|
Hi, @equalogix |
Beta Was this translation helpful? Give feedback.
-
|
|
Beta Was this translation helpful? Give feedback.
-
|
Here is the code that I use, (simplified as much as possible but not tested) transfer_event_signature_hash = web3.keccak(
text="Transfer(address,address,uint256)"
).hex()
filter_dict = {
'address': [ CONTRACT_ADDRESS ],
'topics': [[
transfer_event_signature_hash,
]],
'fromBlock': 0,
'toBlock': 2048,
}
filter_obj = web3.eth.filter(filter_dict)
for event in web3.eth.get_filter_changes(filter_obj.filter_id):
print(f"Event: {event}")
# ...do something with the event obj... |
Beta Was this translation helpful? Give feedback.
5 replies
-
|
Hi @equalogix w3 = Web3(Web3.HTTPProvider('https://zksync2-testnet.zksync.dev'))
transfer_event_signature_hash = w3.keccak(
ext="RNSAddressAuthorized"
).hex()
filter_dict = {
'address': ['0x2E5f01AEB81924014d225F62ab611FD544E0c636'],
'topics': [[
transfer_event_signature_hash,
]],
'fromBlock': 0,
'toBlock': 10483560,
}
filter_obj = w3.eth.filter(filter_dict)
all_events = w3.eth.get_filter_changes(filter_obj.filter_id) |
Beta Was this translation helpful? Give feedback.
-
|
Your event signature hash needs to include the types of the data returned. It should look something like this: transfer_event_signature_hash = w3.keccak(
text="RNSAddressAuthorized(address)"
).hex()The exact types will be determined by what is defined in the smart contract. The data types can also be found in the ABI. |
Beta Was this translation helpful? Give feedback.
-
|
Hi @equalogix thanks for response here is my code: w3 = Web3(Web3.HTTPProvider('https://zksync2-testnet.zksync.dev'))
transfer_event_signature_hash = w3.keccak(
ext="RNSAddressAuthorized(string,address)"
).hex()
filter_dict = {
'address': ['0x2E5f01AEB81924014d225F62ab611FD544E0c636'],
'topics': [[
transfer_event_signature_hash,
]],
'fromBlock': 0,
'toBlock': 10483560,
}
filter_obj = w3.eth.filter(filter_dict)
all_events = w3.eth.get_filter_changes(filter_obj.filter_id)here is event of ABI {
"anonymous": false,
"inputs": [
{
"indexed": false,
"internalType": "string",
"name": "_rnsId",
"type": "string"
},
{
"indexed": true,
"internalType": "address",
"name": "_wallet",
"type": "address"
}
],
"name": "RNSAddressAuthorized",
"type": "event"
} |
Beta Was this translation helpful? Give feedback.
-
|
When I look at the contract code in the block explorer for the contract address you used in the your code above, I can't find the event your calling. Either you used the wrong contract address or there was an error during deployment. This coincides with the error message, Also, on the block explorer in the event tab you should be able to see emitted events, in this case there were no events emitted for this contract. |
Beta Was this translation helpful? Give feedback.
-
|
Hi @equalogix w3 = Web3(Web3.HTTPProvider('https://zksync2-testnet.zksync.dev'))
transfer_event_signature_hash = w3.keccak(
text="RNSAddressAuthorized(string,address)"
).hex()
filter_dict = {
'address': ['0x9eBFd3E73C96aC28F8c9bB67C4D1d9F660DFE091'],
'topics': [[
transfer_event_signature_hash,
]],
'fromBlock': 0,
'toBlock': 10483560,
}
filter_obj = w3.eth.filter(filter_dict)
all_events = w3.eth.get_filter_changes(filter_obj.filter_id)contract link https://goerli.explorer.zksync.io/address/0x9eBFd3E73C96aC28F8c9bB67C4D1d9F660DFE091#events
|
Beta Was this translation helpful? Give feedback.
-
|
I think you need to add Here are the docs: I didn't include it in my initial code post, because I wasn't sure if it was required, but it seems that it is. |
Beta Was this translation helpful? Give feedback.
0 replies
-
|
The solution that @equalogix proposed works on zkSync Era correctly because that part is compatible with zk_web3 = ZkSyncBuilder.build("https://zksync2-testnet.zksync.dev")
zk_web3.middleware_onion.inject(geth_poa_middleware, layer=0)
zk_web3.middleware_onion.add(local_filter_middleware)
filter_dict = {
"address": [zk_web3.to_checksum_address(L2_ETH_TOKEN_ADDRESS)],
"topics": [
zk_web3.keccak(text="Transfer(address,address,uint256)").hex(),
],
}
filter_obj = zk_web3.zksync.filter(filter_dict)
for i in range(5):
time.sleep(10) # wait for node to filter result
# every time you call get_filter_changes() with the same filter ID,
# it will give you events that occurred after the last event you
# fetched using that filter.
print(f"Events fetch in interation: {i}")
events = zk_web3.zksync.get_filter_changes(filter_obj.filter_id)
for event in events:
print(f"Event: {event}")
# When you're finished with the filtering, make sure to close the filter on the node
# in order to conserve computational resources.
zk_web3.zksync.uninstall_filter(filter_obj.filter_id)Results: In some iterations, there is no result because the node did not have enough time to prepare them. |
Beta Was this translation helpful? Give feedback.
0 replies
Answer selected by
idea404
This comment was marked as spam.
This comment was marked as spam.
This comment was marked as spam.
This comment was marked as spam.
This comment was marked as spam.
This comment was marked as spam.
This comment was marked as spam.
This comment was marked as spam.
This comment was marked as spam.
This comment was marked as spam.
This comment was marked as spam.
This comment was marked as spam.
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
The solution that @equalogix proposed works on zkSync Era correctly because that part is compatible with
Web3.py.zksync2SDK can be used in the same way. Here is the example on how to filterTransferevent onETH_TOKENsmart contract on L2.