refactoring

Author: pacmancoder

devolutions-session/src/dvc/task.rs

@@ -770,12 +770,6 @@ impl MessageProcessor {
 
         info!("Starting window recording");
 
-        let poll_interval_ms = if start_msg.poll_interval > 0 {
-            u64::from(start_msg.poll_interval)
-        } else {
-            1000 // Default to 1000ms (1 second) if not specified.
-        };
-
         let track_title_changes = start_msg.flags.contains(WindowRecStartFlags::TRACK_TITLE_CHANGE);
 
         // Create shutdown channel for window monitor.
@@ -786,11 +780,18 @@ impl MessageProcessor {
 
         // Spawn window monitor task.
         let event_tx = self.io_notification_tx.clone();
+        let poll_interval = start_msg.poll_interval;
         let window_monitor_handle = tokio::task::spawn(async move {
-            let config = WindowMonitorConfig::new(event_tx, track_title_changes, shutdown_rx)
-                .with_poll_interval_ms(poll_interval_ms);
+            let mut config = WindowMonitorConfig::new(event_tx, track_title_changes, shutdown_rx);
 
-            run_window_monitor(config).await;
+            // Only set custom poll interval if specified (non-zero).
+            if poll_interval > 0 {
+                config = config.with_poll_interval_ms(u64::from(poll_interval));
+            }
+
+            if let Err(error) = run_window_monitor(config).await {
+                error!(%error, "Window monitor failed");
+            }
         });
 
         self.window_monitor_handle = Some(window_monitor_handle);