feat: restart download post reboot

bytebeamio · Mar 27, 2024 · 10ac386 · 10ac386
1 parent c477468
commit 10ac386
Show file tree

Hide file tree

Showing 3 changed files with 286 additions and 182 deletions.
diff --git a/uplink/src/base/mod.rs b/uplink/src/base/mod.rs
@@ -6,6 +6,7 @@ use tokio::join;
 use self::bridge::{ActionsLaneCtrlTx, DataLaneCtrlTx};
 use self::mqtt::CtrlTx as MqttCtrlTx;
 use self::serializer::CtrlTx as SerializerCtrlTx;
+use crate::collector::downloader::CtrlTx as DownloaderCtrlTx;
 
 pub mod actions;
 pub mod bridge;
@@ -26,6 +27,7 @@ pub struct CtrlTx {
     pub data_lane: DataLaneCtrlTx,
     pub mqtt: MqttCtrlTx,
     pub serializer: SerializerCtrlTx,
+    pub downloader: DownloaderCtrlTx,
 }
 
 impl CtrlTx {
@@ -34,7 +36,8 @@ impl CtrlTx {
             self.actions_lane.trigger_shutdown(),
             self.data_lane.trigger_shutdown(),
             self.mqtt.trigger_shutdown(),
-            self.serializer.trigger_shutdown()
+            self.serializer.trigger_shutdown(),
+            self.downloader.trigger_shutdown()
         );
     }
 }