feat(fileTransfer): add a file store module to read and write files

Signed-off-by: Joshua Chapman <joshua.chapman@secomind.com>

Author: joshuachp

Cargo.lock

@@ -100,7 +100,6 @@ webpki-roots = [
 vendored = ["edgehog-store/vendored"]
 # Recreates the C bindings at buildtime, requires cmake, clang, and  bindgen-cli
 bindgen = [
-  "dep:aws-lc-rs",
   "aws-lc-rs/bindgen",
   "edgehog-store?/bindgen",
 ]
@@ -110,6 +109,7 @@ cross = ["vendored", "bindgen"]
 
 [dependencies]
 astarte-device-sdk = { workspace = true, features = ["derive"] }
+aws-lc-rs.workspace = true
 bytes.workspace = true
 cfg-if.workspace = true
 clap = { workspace = true, features = ["derive", "env"] }
@@ -122,6 +122,8 @@ edgehog-store = { workspace = true, optional = true }
 edgehog-tls.workspace = true
 eyre.workspace = true
 futures.workspace = true
+hex.workspace = true
+pin-project-lite.workspace = true
 rustls.workspace = true
 serde.workspace = true
 serde_json.workspace = true
@@ -132,14 +134,14 @@ tokio-stream.workspace = true
 tokio-util = { workspace = true, features = ["rt"] }
 toml.workspace = true
 tracing.workspace = true
+tracing-error.workspace = true
 tracing-subscriber = { workspace = true, features = ["env-filter"] }
 url.workspace = true
 uuid = { workspace = true, features = ["v5", "v4", "serde"] }
 wifiscanner = { workspace = true, optional = true }
 zbus = { workspace = true, optional = true, default-features = false, features = ["tokio"] }
 
 # C dependencies
-aws-lc-rs = { workspace = true, optional = true }
 rusqlite = { workspace = true, optional = true }
 
 [dependencies.reqwest]
@@ -209,13 +211,15 @@ indexmap = "2.11.4"
 insta = "1.46.3"
 itertools = "0.14.0"
 mockall = "0.14.0"
+pin-project-lite = "0.2.17"
 pretty_assertions = "1.4.1"
 procfs = "0.18.0"
 reqwest = { version = "0.13.1", default-features = false }
 rstest = "0.26.1"
 # Version required by diesel
 rusqlite = "0.36.0"
 rustc_version = "0.4.1"
+rustix = "1.1.4"
 rustls = "0.23.32"
 rustls-native-certs = "0.8.1"
 rustls-pemfile = "2.2.0"
@@ -233,6 +237,7 @@ tokio-tungstenite = "0.28.0"
 tokio-util = "0.7.16"
 toml = "1.0.2"
 tracing = "0.1.41"
+tracing-error = "0.2.1"
 tracing-subscriber = "0.3.20"
 udev = "0.9.3"
 url = "2.5.7"

Cargo.toml

@@ -38,6 +38,12 @@ AstarteObject {
                 "tar.gz",
             ),
         ),
+        (
+            "fileSizeBytes",
+            LongInteger(
+                4096,
+            ),
+        ),
         (
             "progress",
             Boolean(

snapshots/edgehog_device_runtime__file_transfer__interface__tests__from_and_to_event_download.snap

@@ -110,7 +110,8 @@ impl<C> Runtime<C> {
 
         tasks.spawn(telemetry.spawn(telemetry_rx));
 
-        let file_transfer = Self::file_transfer(tasks);
+        // TODO: Add configuration
+        let file_transfer = Self::file_transfer(tasks, opts.store_directory.join("file-store"));
 
         #[cfg(feature = "containers")]
         let containers_tx = Self::setup_containers(
@@ -153,10 +154,13 @@ impl<C> Runtime<C> {
         })
     }
 
-    fn file_transfer(tasks: &mut JoinSet<eyre::Result<()>>) -> mpsc::Sender<FileTransferEvent> {
+    fn file_transfer(
+        tasks: &mut JoinSet<eyre::Result<()>>,
+        store_dir: std::path::PathBuf,
+    ) -> mpsc::Sender<FileTransferEvent> {
         let (tx, rx) = mpsc::channel(EVENT_BUFFER);
 
-        tasks.spawn(FileTransfer::new().spawn(rx));
+        tasks.spawn(FileTransfer::new(store_dir).spawn(rx));
 
         tx
     }