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

Compare commits

base: testnet:eb9a89d1c580178b0900bfd9d8d08620d687d610
Branches Tags
testnet:main
testnet:staging
..
compare: testnet:10d0b7b06470dae669de51a0cb8f01e2f4f37cae
Branches Tags
testnet:main
testnet:staging

No commits in common. "eb9a89d1c580178b0900bfd9d8d08620d687d610" and "10d0b7b06470dae669de51a0cb8f01e2f4f37cae" have entirely different histories.
eb9a89d1c5 ... 10d0b7b064

1 changed files with 2 additions and 11 deletions
Show Stats Expand all files Collapse all files

13
src/data.rs
View File

@ -1452,7 +1452,7 @@ impl BrainData {
let mut nodes = self.app_nodes.write().unwrap(); let mut nodes = self.app_nodes.write().unwrap();
let mut app_contracts = self.app_contracts.write().unwrap(); let mut app_contracts = self.app_contracts.write().unwrap();
for node in nodes.iter_mut() { for node in nodes.iter_mut() {
if self.app_daemon_tx.contains_key(&node.node_pubkey) { if self.daemon_tx.contains_key(&node.node_pubkey) {
node.offline_minutes = 0; node.offline_minutes = 0;
continue; continue;
} }
@ -1501,17 +1501,8 @@ impl BrainData {
log::debug!("Running app contracts cron..."); log::debug!("Running app contracts cron...");
{ {
let mut app_contracts = self.app_contracts.write().unwrap(); let mut app_contracts = self.app_contracts.write().unwrap();
let app_nodes = self.app_nodes.read().unwrap();
app_contracts.retain_mut(|c| { app_contracts.retain_mut(|c| {
let node = match app_nodes let node = self.find_app_node_by_pubkey(&c.node_pubkey).unwrap();
.iter()
.find(|n| n.node_pubkey == c.node_pubkey)
.cloned()
{
Some(n) => n,
None => return c.locked_nano > 0,
};
if node.offline_minutes == 0 { if node.offline_minutes == 0 {
let operator_wallet = node.operator_wallet.clone(); let operator_wallet = node.operator_wallet.clone();
let minutes_to_collect = (Utc::now() - c.collected_at).num_minutes() as u64; let minutes_to_collect = (Utc::now() - c.collected_at).num_minutes() as u64;