uqbar-dao/nectar
1
1
Fork 0
mirror of https://github.com/uqbar-dao/nectar.git synced 2024-12-02 08:02:23 +03:00
Code Issues Packages Projects Releases Wiki Activity

removed unused json now that eth provider is used for indexing

Browse Source
This commit is contained in:
commercium-sys 2023-12-27 19:10:37 -05:00
parent 67b9a9fc0d
commit 177c23f573
1 changed files with 0 additions and 38 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
modules/qns_indexer/qns_indexer/src/lib.rs
View File

@ -85,47 +85,15 @@ impl TryInto<Vec<u8>> for NetActions {
sol! {
// Logged whenever a QNS node is created
event NodeRegistered(bytes32 indexed node, bytes name);
event KeyUpdate(bytes32 indexed node, bytes32 key);
event IpUpdate(bytes32 indexed node, uint128 ip);
event WsUpdate(bytes32 indexed node, uint16 port);
event WtUpdate(bytes32 indexed node, uint16 port);
event TcpUpdate(bytes32 indexed node, uint16 port);
event UdpUpdate(bytes32 indexed node, uint16 port);
event RoutingUpdate(bytes32 indexed node, bytes32[] routers);
}
fn subscribe_to_qns(from_block: u64) -> Vec<u8> {
json!({
"SubscribeEvents": {
"addresses": [
// QNSRegistry on sepolia
"0x4C8D8d4A71cE21B4A16dAbf4593cDF30d79728F1",
],
"from_block": from_block,
"to_block": null,
"events": [
"NodeRegistered(bytes32,bytes)",
"KeyUpdate(bytes32,bytes32)",
"IpUpdate(bytes32,uint128)",
"WsUpdate(bytes32,uint16)",
"WtUpdate(bytes32,uint16)",
"TcpUpdate(bytes32,uint16)",
"UdpUpdate(bytes32,uint16)",
"RoutingUpdate(bytes32,bytes32[])",
],
"topic1": null,
"topic2": null,
"topic3": null,
}
})
.to_string()
.as_bytes()
.to_vec()
}
impl Guest for Component {
fn init(our: String) {
let our = Address::from_str(&our).unwrap();
@ -163,12 +131,6 @@ fn main(our: Address, mut state: State) -> anyhow::Result<()> {
))?
.send()?;
// Request::new()
// .target((&our.node, "eth_rpc", "sys", "uqbar"))
// .ipc(subscribe_to_qns(state.block - 1))
// .expects_response(5)
// .send()?;
let qns_registry_addr = EthAddress::from_str("0x4C8D8d4A71cE21B4A16dAbf4593cDF30d79728F1")?;
SubscribeLogsRequest::new()