Method spawn_scan_task

src-tauri/src/scanner/mod.rs:48–77

(&self, app: AppHandle, scan_duration_s: u64)

impl ScanTask {
    pub fn spawn_scan_task(&self, app: AppHandle, scan_duration_s: u64) {
        {
            let mut cancellation_token = self.cancellation_token.lock().unwrap();
            if let Some(cancellation_token) = cancellation_token.as_mut() {
                cancellation_token.store(true, std::sync::atomic::Ordering::Release);
            }
        }

        let cancellation_token = Arc::new(AtomicBool::new(false));
        let cancellation_token_inner = Arc::clone(&cancellation_token);

        thread::spawn(move || loop {
            thread::sleep(Duration::from_secs(scan_duration_s));

            tracing::info!("Running scan task - {}s", scan_duration_s);
            if cancellation_token_inner.load(std::sync::atomic::Ordering::Acquire) {
                tracing::info!("Scan task cancelled - {}s", scan_duration_s);
                break;
            }

            let app = app.clone();
            let res = start_scan(app, None);
            if let Err(e) = res {
                tracing::error!("Scan failed: {:?}", e);
            }
        });

        let mut cancellation_token_lock = self.cancellation_token.lock().unwrap();
        *cancellation_token_lock = Some(cancellation_token);
    }
}

#[tracing::instrument(level = "debug", skip(app, paths))]