testnet/brain-mock
3
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix: update list_operator app_nodes assignment to reflect actual length and vec of app nodes in inpsect operator

Browse Source
This commit is contained in:
Noor 2025-03-21 22:08:45 +05:30
parent 04fa52c2b1
commit d8ca1c4968
Signed by: noormohammedb
GPG Key ID: D83EFB8B3B967146
1 changed files with 18 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
src/data.rs
View File

@ -1107,7 +1107,7 @@ impl BrainData {
pubkey: op.key().to_string(), pubkey: op.key().to_string(),
escrow: op.escrow / 1_000_000_000, escrow: op.escrow / 1_000_000_000,
email: op.email.clone(), email: op.email.clone(),
app_nodes: 0, app_nodes: op.app_nodes.len() as u64,
vm_nodes: op.vm_nodes.len() as u64, vm_nodes: op.vm_nodes.len() as u64,
reports: self.total_operator_reports(op.key()) as u64, reports: self.total_operator_reports(op.key()) as u64,
}) })
@ -1121,18 +1121,23 @@ impl BrainData {
.into_iter() .into_iter()
.map(|n| n.into()) .map(|n| n.into())
.collect(); .collect();
let app_nodes = self
.find_app_nodes_by_operator(wallet)
.into_iter()
.map(|n| n.into())
.collect();
InspectOperatorResp { InspectOperatorResp {
operator: Some(ListOperatorsResp { operator: Some(ListOperatorsResp {
pubkey: op.key().to_string(), pubkey: op.key().to_string(),
escrow: op.escrow, escrow: op.escrow,
email: op.email.clone(), email: op.email.clone(),
app_nodes: 0, app_nodes: op.app_nodes.len() as u64,
vm_nodes: op.vm_nodes.len() as u64, vm_nodes: op.vm_nodes.len() as u64,
reports: self.total_operator_reports(op.key()) as u64, reports: self.total_operator_reports(op.key()) as u64,
}), }),
vm_nodes, vm_nodes,
// TODO: fix app node list app_nodes,
app_nodes: Vec::new(),
} }
}) })
} }
@ -1216,6 +1221,15 @@ impl BrainData {
}); });
} }
pub fn find_app_nodes_by_operator(&self, operator_wallet: &str) -> Vec<AppNode> {
let nodes = self.app_nodes.read().unwrap();
nodes
.iter()
.filter(|node| node.operator_wallet == operator_wallet)
.cloned()
.collect()
}
pub fn find_app_nodes_by_filters(&self, filters: &AppNodeFilters) -> Vec<AppNode> { pub fn find_app_nodes_by_filters(&self, filters: &AppNodeFilters) -> Vec<AppNode> {
let nodes = self.app_nodes.read().unwrap(); let nodes = self.app_nodes.read().unwrap();
nodes nodes