Fix node election rate unit

chaindexing · Mar 10, 2024 · ab87d8b · ab87d8b
1 parent 23c8dfc
commit ab87d8b
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/chaindexing/src/nodes.rs b/chaindexing/src/nodes.rs
@@ -15,11 +15,11 @@ pub struct Node {
 }
 
 impl Node {
-    pub fn get_min_active_at(node_election_rate_ms: u64) -> i64 {
-        let now = chrono::Utc::now().timestamp_millis();
+    pub fn get_min_active_at_in_secs(node_election_rate_ms: u64) -> i64 {
+        let now_ms = chrono::Utc::now().timestamp_millis();
 
         // Not active if not kept active at least 2 elections away
-        now - node_election_rate_ms as i64
+        (now_ms - node_election_rate_ms as i64) / 1_000
     }
 
     fn is_leader(&self, leader: &Node) -> bool {

diff --git a/chaindexing/src/repos/postgres_repo.rs b/chaindexing/src/repos/postgres_repo.rs
@@ -231,7 +231,7 @@ impl Repo for PostgresRepo {
         use crate::diesels::schema::chaindexing_nodes::dsl::*;
 
         chaindexing_nodes
-            .filter(last_active_at.gt(Node::get_min_active_at(node_election_rate_ms)))
+            .filter(last_active_at.gt(Node::get_min_active_at_in_secs(node_election_rate_ms)))
             .load(conn)
             .await
             .unwrap()