Have mobile-config track when the data for a mobile-radio changes (#902)

* Track when data for mobile radio changes
helium · Dec 4, 2024 · 44b26c5 · 44b26c5
1 parent cfa9afb
commit 44b26c5
Show file tree

Hide file tree

Showing 7 changed files with 365 additions and 2 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/mobile_config/Cargo.toml b/mobile_config/Cargo.toml
@@ -10,6 +10,7 @@ license.workspace = true
 anyhow = { workspace = true }
 async-trait = { workspace = true }
 base64 = { workspace = true }
+blake3 = { workspace = true }
 bs58 = { workspace = true }
 chrono = { workspace = true }
 clap = { workspace = true }
@@ -20,6 +21,8 @@ futures = { workspace = true }
 futures-util = { workspace = true }
 helium-crypto = { workspace = true, features = ["sqlx-postgres"] }
 helium-proto = { workspace = true }
+humantime = { workspace = true }
+humantime-serde = { workspace = true }
 hextree = { workspace = true }
 http = { workspace = true }
 http-serde = { workspace = true }
@@ -44,7 +47,6 @@ triggered = { workspace = true }
 task-manager = { path = "../task_manager" }
 solana-sdk = { workspace = true }
 custom-tracing = { path = "../custom_tracing", features = ["grpc"] }
-humantime-serde = { workspace = true }
 coverage-map = { path = "../coverage_map" }
 
 [dev-dependencies]

diff --git a/mobile_config/migrations/7_mobile_radio_tracker.sql b/mobile_config/migrations/7_mobile_radio_tracker.sql
@@ -0,0 +1,7 @@
+CREATE TABLE IF NOT EXISTS mobile_radio_tracker (
+    entity_key BYTEA NOT NULL,
+    hash TEXT NOT NULL,
+    last_changed_at TIMESTAMPTZ NOT NULL,
+    last_checked_at TIMESTAMPTZ NOT NULL,
+    PRIMARY KEY (entity_key)
+);
diff --git a/mobile_config/src/lib.rs b/mobile_config/src/lib.rs
@@ -15,6 +15,7 @@ pub mod gateway_service;
 pub mod hex_boosting_service;
 
 pub mod key_cache;
+pub mod mobile_radio_tracker;
 pub mod settings;
 pub mod telemetry;
 

diff --git a/mobile_config/src/main.rs b/mobile_config/src/main.rs
@@ -10,7 +10,7 @@ use mobile_config::{
     admin_service::AdminService, authorization_service::AuthorizationService,
     carrier_service::CarrierService, entity_service::EntityService,
     gateway_service::GatewayService, hex_boosting_service::HexBoostingService, key_cache::KeyCache,
-    settings::Settings,
+    mobile_radio_tracker::MobileRadioTracker, settings::Settings,
 };
 use std::{net::SocketAddr, path::PathBuf, time::Duration};
 use task_manager::{ManagedTask, TaskManager};
@@ -108,6 +108,11 @@ impl Daemon {
 
         TaskManager::builder()
             .add_task(grpc_server)
+            .add_task(MobileRadioTracker::new(
+                pool.clone(),
+                metadata_pool.clone(),
+                settings.mobile_radio_tracker_interval,
+            ))
             .build()
             .start()
             .await