From 9de5d7213a1879fbf312e05eb673f2b9152f3012 Mon Sep 17 00:00:00 2001 From: dynco-nym <173912580+dynco-nym@users.noreply.github.com> Date: Mon, 24 Feb 2025 18:06:03 +0100 Subject: [PATCH] Another total_stake SQL fix (#5516) --- Cargo.lock | 2 +- nym-node-status-api/nym-node-status-api/Cargo.toml | 2 +- .../nym-node-status-api/src/db/queries/packet_stats.rs | 2 +- nym-node-status-api/nym-node-status-api/src/monitor/mod.rs | 6 +++++- 4 files changed, 8 insertions(+), 4 deletions(-) diff --git a/Cargo.lock b/Cargo.lock index fe998ecfe2..654fb80097 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -6366,7 +6366,7 @@ dependencies = [ [[package]] name = "nym-node-status-api" -version = "1.0.1" +version = "1.0.2" dependencies = [ "ammonia", "anyhow", diff --git a/nym-node-status-api/nym-node-status-api/Cargo.toml b/nym-node-status-api/nym-node-status-api/Cargo.toml index bd73ec9f06..0642149101 100644 --- a/nym-node-status-api/nym-node-status-api/Cargo.toml +++ b/nym-node-status-api/nym-node-status-api/Cargo.toml @@ -3,7 +3,7 @@ [package] name = "nym-node-status-api" -version = "1.0.1" +version = "1.0.2" authors.workspace = true repository.workspace = true homepage.workspace = true diff --git a/nym-node-status-api/nym-node-status-api/src/db/queries/packet_stats.rs b/nym-node-status-api/nym-node-status-api/src/db/queries/packet_stats.rs index 601cb9e026..6041103096 100644 --- a/nym-node-status-api/nym-node-status-api/src/db/queries/packet_stats.rs +++ b/nym-node-status-api/nym-node-status-api/src/db/queries/packet_stats.rs @@ -169,7 +169,7 @@ pub(crate) async fn insert_daily_node_stats( packets_sent, packets_dropped ) VALUES (?, ?, ?, ?, ?, ?) ON CONFLICT(node_id, date_utc) DO UPDATE SET - total_stake = nym_node_daily_mixing_stats.total_stake, + total_stake = excluded.total_stake, packets_received = nym_node_daily_mixing_stats.packets_received + excluded.packets_received, packets_sent = nym_node_daily_mixing_stats.packets_sent + excluded.packets_sent, packets_dropped = nym_node_daily_mixing_stats.packets_dropped + excluded.packets_dropped diff --git a/nym-node-status-api/nym-node-status-api/src/monitor/mod.rs b/nym-node-status-api/nym-node-status-api/src/monitor/mod.rs index d771b6bf51..564d1fbf95 100644 --- a/nym-node-status-api/nym-node-status-api/src/monitor/mod.rs +++ b/nym-node-status-api/nym-node-status-api/src/monitor/mod.rs @@ -130,7 +130,11 @@ impl Monitor { .await .log_error("get_all_basic_nodes")?; - queries::insert_nym_nodes(&self.db_pool, nym_nodes.clone(), &bonded_node_info).await?; + queries::insert_nym_nodes(&self.db_pool, nym_nodes.clone(), &bonded_node_info) + .await + .map(|_| { + tracing::debug!("{} nym nodes written to DB!", nym_nodes.len()); + })?; let mut gateway_geodata = Vec::new(); for gateway in gateways.iter() {