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

fix TYPO that had me losing mind

Browse Source
This commit is contained in:
dr-frmr 2024-05-17 23:15:44 -06:00
parent 9fd7c09b9a
commit ae72c115ca
No known key found for this signature in database
3 changed files with 277 additions and 332 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

591
Cargo.lock generated
View File

File diff suppressed because it is too large Load Diff

2
kinode/packages/kns_indexer/kns_indexer/Cargo.toml
View File

@ -12,7 +12,7 @@ alloy-primitives = "0.7.0"
alloy-sol-types = "0.7.0"
bincode = "1.3.3"
hex = "0.4.3"
kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", ref = "900428d" }
kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "900428d" }
rmp-serde = "1.1.2"
serde = { version = "1.0", features = ["derive"] }
serde_json = "1.0"

16
kinode/packages/kns_indexer/kns_indexer/src/lib.rs
View File

@ -336,8 +336,8 @@ fn handle_log(our: &Address, state: &mut State, log: &eth::Log) -> anyhow::Resul
owner: "".to_string(),
node: node_id.to_string(),
public_key: "".to_string(),
ip: "".to_string(),
port: 0,
ips: vec![],
ports: BTreeMap::new(),
routers: vec![],
});
@ -352,19 +352,19 @@ fn handle_log(our: &Address, state: &mut State, log: &eth::Log) -> anyhow::Resul
}
IpUpdate::SIGNATURE_HASH => {
let ip = IpUpdate::decode_log_data(log.data(), true).unwrap().ip;
node.ip = format!(
node.ips = vec![format!(
"{}.{}.{}.{}",
(ip >> 24) & 0xFF,
(ip >> 16) & 0xFF,
(ip >> 8) & 0xFF,
ip & 0xFF
);
)];
// when we get ip data, we should delete any router data,
// since the assignment of ip indicates an direct node
node.routers = vec![];
}
WsUpdate::SIGNATURE_HASH => {
node.port = WsUpdate::decode_log_data(log.data(), true).unwrap().port;
node.ports.insert("ws".to_string(), WsUpdate::decode_log_data(log.data(), true).unwrap().port);
// when we get port data, we should delete any router data,
// since the assignment of port indicates an direct node
node.routers = vec![];
@ -378,8 +378,8 @@ fn handle_log(our: &Address, state: &mut State, log: &eth::Log) -> anyhow::Resul
.collect::<Vec<String>>();
// when we get routing data, we should delete any ws/ip data,
// since the assignment of routers indicates an indirect node
node.ip = "".to_string();
node.port = 0;
node.ips = vec![];
node.ports.clear();
}
_ => {
send = false;
@ -387,7 +387,7 @@ fn handle_log(our: &Address, state: &mut State, log: &eth::Log) -> anyhow::Resul
}
if node.public_key != ""
&& ((node.ip != "" && node.port != 0) || node.routers.len() > 0)
&& ((!node.ips.is_empty() && !node.ports.is_empty()) || node.routers.len() > 0)
&& send
{
Request::new()