update deps, send start time in file operations

Author: 0x7d8

Cargo.lock

@@ -117,6 +117,7 @@ mod post {
                     path: PathBuf::from(&data.root),
                     files: data.files.iter().map(PathBuf::from).collect(),
                     destination_path: PathBuf::from(&data.root).join(archive_name),
+                    start_time: chrono::Utc::now(),
                     progress: progress.clone(),
                     total: total.clone(),
                 },

application/src/routes/api/servers/_server_/files/compress.rs

@@ -172,6 +172,7 @@ mod post {
                 crate::server::filesystem::operations::FilesystemOperation::Copy {
                     path: path.clone(),
                     destination_path: file_name,
+                    start_time: chrono::Utc::now(),
                     progress: progress.clone(),
                     total: total.clone(),
                 },

application/src/routes/api/servers/_server_/files/copy.rs

@@ -67,6 +67,7 @@ mod post {
                 crate::server::filesystem::operations::FilesystemOperation::CopyMany {
                     path: PathBuf::from(&data.root),
                     files: data.files.clone(),
+                    start_time: chrono::Utc::now(),
                     progress: progress.clone(),
                     total: total.clone(),
                 },

application/src/routes/api/servers/_server_/files/copy_many.rs

@@ -146,6 +146,7 @@ mod post {
                         files: data.files.iter().map(PathBuf::from).collect(),
                         destination_server: data.destination_server,
                         destination_path: PathBuf::from(&data.destination_path),
+                        start_time: chrono::Utc::now(),
                         progress: progress.clone(),
                         total: total.clone(),
                     },
@@ -279,6 +280,7 @@ mod post {
                         files: data.files.iter().map(PathBuf::from).collect(),
                         destination_server: data.destination_server,
                         destination_path: PathBuf::from(data.destination_path),
+                        start_time: chrono::Utc::now(),
                         progress: progress.clone(),
                         total: total.clone(),
                     },
@@ -348,6 +350,7 @@ mod post {
                         files: data.files.iter().map(PathBuf::from).collect(),
                         destination_server: data.destination_server,
                         destination_path: PathBuf::from(data.destination_path),
+                        start_time: chrono::Utc::now(),
                         progress: progress.clone(),
                         total: total.clone(),
                     },

application/src/routes/api/servers/_server_/files/copy_remote.rs

@@ -108,6 +108,7 @@ mod post {
                 crate::server::filesystem::operations::FilesystemOperation::Decompress {
                     path: source,
                     destination_path: root.clone(),
+                    start_time: chrono::Utc::now(),
                     progress: progress.clone(),
                     total: total.clone(),
                 },

application/src/routes/api/servers/_server_/files/decompress.rs

@@ -147,6 +147,7 @@ mod post {
                     files: root_files.into_iter().map(PathBuf::from).collect(),
                     destination_server: server.uuid,
                     destination_path: PathBuf::from(&payload.destination_path),
+                    start_time: chrono::Utc::now(),
                     progress: progress.clone(),
                     total: total.clone(),
                 },

application/src/routes/api/transfers/files.rs

@@ -22,6 +22,7 @@ pub enum FilesystemOperation {
         files: Vec<PathBuf>,
         destination_path: PathBuf,
 
+        start_time: chrono::DateTime<chrono::Utc>,
         #[serde(serialize_with = "serialize_arc")]
         progress: Arc<AtomicU64>,
         #[serde(serialize_with = "serialize_arc")]
@@ -31,6 +32,7 @@ pub enum FilesystemOperation {
         path: PathBuf,
         destination_path: PathBuf,
 
+        start_time: chrono::DateTime<chrono::Utc>,
         #[serde(serialize_with = "serialize_arc")]
         progress: Arc<AtomicU64>,
         #[serde(serialize_with = "serialize_arc")]
@@ -39,6 +41,7 @@ pub enum FilesystemOperation {
     Pull {
         destination_path: PathBuf,
 
+        start_time: chrono::DateTime<chrono::Utc>,
         #[serde(serialize_with = "serialize_arc")]
         progress: Arc<AtomicU64>,
         #[serde(serialize_with = "serialize_arc")]
@@ -48,6 +51,7 @@ pub enum FilesystemOperation {
         path: PathBuf,
         destination_path: PathBuf,
 
+        start_time: chrono::DateTime<chrono::Utc>,
         #[serde(serialize_with = "serialize_arc")]
         progress: Arc<AtomicU64>,
         #[serde(serialize_with = "serialize_arc")]
@@ -57,6 +61,7 @@ pub enum FilesystemOperation {
         path: PathBuf,
         files: Vec<crate::models::CopyFile>,
 
+        start_time: chrono::DateTime<chrono::Utc>,
         #[serde(serialize_with = "serialize_arc")]
         progress: Arc<AtomicU64>,
         #[serde(serialize_with = "serialize_arc")]
@@ -69,6 +74,7 @@ pub enum FilesystemOperation {
         destination_server: uuid::Uuid,
         destination_path: PathBuf,
 
+        start_time: chrono::DateTime<chrono::Utc>,
         #[serde(serialize_with = "serialize_arc")]
         progress: Arc<AtomicU64>,
         #[serde(serialize_with = "serialize_arc")]

application/src/server/filesystem/operations.rs

@@ -252,6 +252,7 @@ impl Download {
             .add_operation(
                 super::operations::FilesystemOperation::Pull {
                     destination_path: self.destination.clone(),
+                    start_time: chrono::Utc::now(),
                     progress: self.progress.clone(),
                     total: Arc::new(AtomicU64::new(self.total)),
                 },

application/src/server/filesystem/pull/mod.rs

@@ -136,7 +136,6 @@ impl DiskUsage {
         Some(current.space)
     }
 
-    #[tracing::instrument(skip(self))]
     pub fn update_size(&mut self, path: &Path, delta: SpaceDelta) {
         if crate::unlikely(path == Path::new("") || path == Path::new("/")) {
             return;
@@ -147,8 +146,6 @@ impl DiskUsage {
             let key = component.as_os_str().to_str().unwrap_or_default();
             let entry = current.upsert_entry(key);
 
-            tracing::debug!(?component, "applying path delta");
-
             if delta.real >= 0 {
                 entry.space.add_real(delta.real as u64);
             } else {