Skip to content

Commit

Permalink
Re-add XMR balance data events
Browse files Browse the repository at this point in the history
  • Loading branch information
pokkst committed Dec 21, 2023
1 parent db4464d commit 348d581
Showing 1 changed file with 13 additions and 0 deletions.
13 changes: 13 additions & 0 deletions swap/src/asb/event_loop.rs
Original file line number Diff line number Diff line change
Expand Up @@ -21,6 +21,7 @@ use std::sync::Arc;
use std::time::Duration;
use tokio::sync::mpsc;
use uuid::Uuid;
use crate::asb::asb_xmr_balance_data::AsbXmrBalanceData;

/// A future that resolves to a tuple of `PeerId`, `transfer_proof::Request` and
/// `Responder`.
Expand Down Expand Up @@ -155,7 +156,19 @@ where
}
}

let mut last_time_checked_in_secs = 0;
loop {
let current_time_in_secs = util::get_sys_time_in_secs();
let time_since_last_check = current_time_in_secs - last_time_checked_in_secs;
if time_since_last_check >= 5 {
let asb_xmr_balance_data = match self.monero_wallet.get_balance().await {
Ok(balance) => { AsbXmrBalanceData { total: balance.balance, unlocked: balance.unlocked_balance, error: String::new() } }
Err(err) => { AsbXmrBalanceData { total: 0, unlocked: 0, error: err.to_string() } }
};
tracing::info!(%asb_xmr_balance_data, "ASB_XMR_BALANCE_DATA");
last_time_checked_in_secs = util::get_sys_time_in_secs();
}

tokio::select! {
biased;
swarm_event = self.swarm.select_next_some() => {
Expand Down

0 comments on commit 348d581

Please sign in to comment.