Connect tracker

Author: macpie

iot_config/src/cli/daemon.rs

@@ -1,5 +1,6 @@
 use std::sync::Arc;
 
+use crate::gateway::tracker::Tracker;
 use crate::grpc_server::GrpcServer;
 use crate::sub_dao_service::SubDaoService;
 use crate::{
@@ -61,7 +62,7 @@ impl Daemon {
             region_updater,
         )?;
 
-        let subdao_svc = SubDaoService::new(settings, auth_cache, metadata_pool)?;
+        let subdao_svc = SubDaoService::new(settings, auth_cache, metadata_pool.clone())?;
 
         let listen_addr = settings.listen;
         let pubkey = settings
@@ -70,6 +71,12 @@ impl Daemon {
         tracing::debug!("listening on {listen_addr}");
         tracing::debug!("signing as {pubkey}");
 
+        let tracker = Tracker::new(
+            pool.clone(),
+            metadata_pool.clone(),
+            settings.gateway_tracker_interval,
+        );
+
         let grpc_server = GrpcServer::new(
             listen_addr,
             gateway_svc,
@@ -82,6 +89,7 @@ impl Daemon {
         let db_cleaner = DbCleaner::new(pool.clone(), settings.deleted_entry_retention);
 
         TaskManager::builder()
+            .add_task(tracker)
             .add_task(grpc_server)
             .add_task(db_cleaner)
             .build()

iot_config/src/settings.rs

@@ -21,6 +21,8 @@ pub struct Settings {
     #[serde(with = "humantime_serde", default = "default_deleted_entry_retention")]
     pub deleted_entry_retention: Duration,
     pub database: db_store::Settings,
+    #[serde(with = "humantime_serde", default = "default_gateway_tracker_interval")]
+    pub gateway_tracker_interval: std::time::Duration,
     /// Settings passed to the db_store crate for connecting to
     /// the database for Solana on-chain data
     pub metadata: db_store::Settings,
@@ -39,6 +41,10 @@ fn default_deleted_entry_retention() -> Duration {
     humantime::parse_duration("48 hours").unwrap()
 }
 
+fn default_gateway_tracker_interval() -> std::time::Duration {
+    humantime::parse_duration("1 hour").unwrap()
+}
+
 impl Settings {
     /// Settings can be loaded from a given optional path and
     /// can be overridden with environment variables.