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

Merge pull request #16 from uqbar-dao/da/qns-fix

Browse Source 
parsing fix
This commit is contained in:
tadad 2023-10-11 15:59:47 +03:00 committed by GitHub
commit 9e025382af
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 13 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -8,6 +8,7 @@ use alloy_primitives::FixedBytes;
use alloy_sol_types::{sol, SolEvent}; use alloy_sol_types::{sol, SolEvent};
use hex; use hex;
use std::collections::HashMap; use std::collections::HashMap;
use std::string::FromUtf8Error;
mod process_lib; mod process_lib;
@ -225,18 +226,15 @@ impl UqProcess for Component {
let node = &e.topics[1]; let node = &e.topics[1];
let decoded = NodeRegistered::decode_data(&decode_hex_to_vec(&e.data), true).unwrap(); let decoded = NodeRegistered::decode_data(&decode_hex_to_vec(&e.data), true).unwrap();
let name = dnswire_decode(decoded.0); let Ok(name) = dnswire_decode(decoded.0.clone()) else {
bindings::print_to_terminal(0, &format!("qns_indexer: failed to decode name: {:?}", decoded.0));
// bindings::print_to_terminal(0, format!("qns_indexer: NODE1: {:?}", node).as_str()); continue;
// bindings::print_to_terminal(0, format!("qns_indexer: NAME: {:?}", name.to_string()).as_str()); };
state.names.insert(node.to_string(), name); state.names.insert(node.to_string(), name);
} }
WsChanged::SIGNATURE_HASH => { WsChanged::SIGNATURE_HASH => {
// bindings::print_to_terminal(0, format!("qns_indexer: got WsChanged event: {:?}", e).as_str());
let node = &e.topics[1]; let node = &e.topics[1];
// bindings::print_to_terminal(0, format!("qns_indexer: NODE2: {:?}", node.to_string()).as_str());
let decoded = WsChanged::decode_data(&decode_hex_to_vec(&e.data), true).unwrap(); let decoded = WsChanged::decode_data(&decode_hex_to_vec(&e.data), true).unwrap();
let public_key = hex::encode(decoded.0); let public_key = hex::encode(decoded.0);
let ip = decoded.1; let ip = decoded.1;
@ -253,12 +251,10 @@ impl UqProcess for Component {
}) })
.collect::<Vec<String>>(); .collect::<Vec<String>>();
let name = state.names.get(node).unwrap(); let Some(name) = state.names.get(node) else {
// bindings::print_to_terminal(0, format!("qns_indexer: NAME: {:?}", name).as_str()); bindings::print_to_terminal(0, &format!("qns_indexer: failed to find name for node during WsChanged: {:?}", node));
// bindings::print_to_terminal(0, format!("qns_indexer: DECODED: {:?}", decoded).as_str()); continue;
// bindings::print_to_terminal(0, format!("qns_indexer: PUB KEY: {:?}", public_key).as_str()); };
// bindings::print_to_terminal(0, format!("qns_indexer: IP PORT: {:?} {:?}", ip, port).as_str());
// bindings::print_to_terminal(0, format!("qns_indexer: ROUTERS: {:?}", routers).as_str());
let json_payload = json!({ let json_payload = json!({
"QnsUpdate": { "QnsUpdate": {
@ -342,7 +338,7 @@ fn hex_to_u64(hex: &str) -> Result<u64, std::num::ParseIntError> {
u64::from_str_radix(without_prefix, 16) u64::from_str_radix(without_prefix, 16)
} }
fn dnswire_decode(wire_format_bytes: Vec<u8>) -> String { fn dnswire_decode(wire_format_bytes: Vec<u8>) -> Result<String, FromUtf8Error> {
let mut i = 0; let mut i = 0;
let mut result = Vec::new(); let mut result = Vec::new();
@ -358,12 +354,12 @@ fn dnswire_decode(wire_format_bytes: Vec<u8>) -> String {
let flat: Vec<_> = result.into_iter().flatten().collect(); let flat: Vec<_> = result.into_iter().flatten().collect();
let name = String::from_utf8(flat).unwrap(); let name = String::from_utf8(flat)?;
// Remove the trailing '.' if it exists (it should always exist) // Remove the trailing '.' if it exists (it should always exist)
if name.ends_with('.') { if name.ends_with('.') {
name[0..name.len()-1].to_string() Ok(name[0..name.len()-1].to_string())
} else { } else {
name Ok(name)
} }
} }