fix: add missing dependencies and imports for streaming output

- Add uffs-polars and chrono dependencies to uffs-cli
- Re-add progress bar helper functions (create_multi_progress, add_drive_progress)
- Fix imports: use uffs_polars for AnyValue/TimeUnit/Column types
- Add IntoLazy import for .lazy() method on DataFrame
- Use local col() import instead of uffs_mft::col()

These fixes resolve Windows cross-compilation errors where polars types
were not accessible through uffs_mft.

Author: githubrobbi

Cargo.lock

@@ -32,7 +32,7 @@ members = [
 # Workspace Package Metadata (inherited by all crates)
 # ─────────────────────────────────────────────────────────────────────────────
 [workspace.package]
-version = "0.2.8"
+version = "0.2.9"
 edition = "2024"
 rust-version = "1.85"
 license = "MPL-2.0 OR LicenseRef-UFFS-Commercial"

Cargo.toml

@@ -21,7 +21,7 @@ Traditional file search tools (including `os.walk`, `FindFirstFile`, etc.) work
 
 **UFFS reads the MFT directly** - once - and queries it in memory using Polars DataFrames. This is like reading the entire phonebook once instead of looking up each name individually.
 
-### Benchmark Results (v0.2.8)
+### Benchmark Results (v0.2.9)
 
 | Drive Type | Records | Time | Throughput |
 |------------|---------|------|------------|
@@ -33,7 +33,7 @@ Traditional file search tools (including `os.walk`, `FindFirstFile`, etc.) work
 
 | Comparison | Records | Time | Notes |
 |------------|---------|------|-------|
-| **UFFS v0.2.8** | **18.7 Million** | **~142 seconds** | All disks, fast mode |
+| **UFFS v0.2.9** | **18.7 Million** | **~142 seconds** | All disks, fast mode |
 | UFFS v0.1.30 | 18.7 Million | ~315 seconds | Baseline |
 | Everything | 19 Million | 178 seconds | All disks |
 | WizFile | 6.5 Million | 299 seconds | Single HDD |

README.md

@@ -46,6 +46,8 @@ tracing.workspace = true
 tracing-subscriber.workspace = true
 tracing-appender.workspace = true
 dirs-next.workspace = true
+uffs-polars = { version = "0.2.9", path = "../uffs-polars" }
+chrono.workspace = true
 
 # Memory allocator (Windows only - reduces fragmentation)
 [target.'cfg(windows)'.dependencies]

crates/uffs-cli/Cargo.toml

@@ -13,10 +13,49 @@ use std::sync::atomic::{AtomicBool, AtomicUsize, Ordering};
 use std::sync::{Arc, Mutex};
 
 use anyhow::{Context, Result, bail};
+#[cfg(windows)]
+use indicatif::MultiProgress;
 use indicatif::{ProgressBar, ProgressStyle};
 use tracing::info;
 use uffs_core::extensions::ExtensionFilter;
 
+/// Check if progress bars are disabled via `UFFS_NO_PROGRESS=1` environment
+/// variable.
+#[cfg(windows)]
+#[inline]
+fn is_progress_disabled() -> bool {
+    std::env::var("UFFS_NO_PROGRESS")
+        .map(|val| val == "1" || val.eq_ignore_ascii_case("true"))
+        .unwrap_or(false)
+}
+
+/// Create a multi-progress container for multiple drives.
+/// Returns `None` if progress is disabled via `UFFS_NO_PROGRESS=1`.
+#[cfg(windows)]
+fn create_multi_progress() -> Option<MultiProgress> {
+    if is_progress_disabled() {
+        None
+    } else {
+        Some(MultiProgress::new())
+    }
+}
+
+/// Add a drive progress bar to a multi-progress container.
+#[cfg(windows)]
+fn add_drive_progress(multi_progress: &MultiProgress, drive: char) -> ProgressBar {
+    let progress_bar = multi_progress.add(ProgressBar::new(0));
+    let template = format!(
+        "{{spinner:.cyan}} [{drive}:] [{{elapsed_precise}}] {{bar:30.cyan/blue}} {{bytes}}/{{total_bytes}} ({{eta}})"
+    );
+    progress_bar.set_style(
+        ProgressStyle::default_bar()
+            .template(&template)
+            .unwrap_or_else(|_| ProgressStyle::default_bar())
+            .progress_chars("━━╸"),
+    );
+    progress_bar
+}
+
 /// Streaming output writer for multi-drive search.
 ///
 /// Supports CSV (header + rows) and NDJSON (one JSON object per line) formats.
@@ -187,8 +226,8 @@ impl<W: Write> StreamingWriter<W> {
 
 /// Format a cell value for CSV output.
 #[cfg(windows)]
-fn format_cell_value(col: &uffs_mft::polars::prelude::Column, row_idx: usize) -> String {
-    use uffs_mft::polars::prelude::*;
+fn format_cell_value(col: &uffs_polars::Column, row_idx: usize) -> String {
+    use uffs_polars::{AnyValue, TimeUnit};
 
     let val = col.get(row_idx);
     match val {
@@ -212,8 +251,8 @@ fn format_cell_value(col: &uffs_mft::polars::prelude::Column, row_idx: usize) ->
 
 /// Format a cell value for JSON output.
 #[cfg(windows)]
-fn format_json_value(col: &uffs_mft::polars::prelude::Column, row_idx: usize) -> String {
-    use uffs_mft::polars::prelude::*;
+fn format_json_value(col: &uffs_polars::Column, row_idx: usize) -> String {
+    use uffs_polars::{AnyValue, TimeUnit};
 
     let val = col.get(row_idx);
     match val {
@@ -911,7 +950,7 @@ async fn search_multi_drive_streaming<W: Write + Send + 'static>(
     writer: W,
 ) -> Result<()> {
     use tokio::sync::mpsc;
-    use uffs_mft::lit;
+    use uffs_mft::{IntoLazy, col, lit};
 
     if drives.is_empty() {
         bail!("No drives specified for multi-drive search");
@@ -1060,7 +1099,7 @@ async fn search_multi_drive_streaming<W: Write + Send + 'static>(
                 .collect();
             let columns: Vec<_> = std::iter::once("drive".to_string())
                 .chain(column_names)
-                .map(|s| uffs_mft::col(&s))
+                .map(|s| col(&s))
                 .collect();
 
             if let Ok(reordered) = df.clone().lazy().select(columns).collect() {

crates/uffs-cli/src/commands.rs

@@ -23,6 +23,8 @@
 //! RUST_LOG=trace RUST_LOG_FILE=trace uffs search *.txt
 //! ```
 
+// Dependencies used in commands.rs for streaming output (Windows-only code
+// paths)
 use std::io::stdout;
 use std::path::PathBuf;
 
@@ -35,6 +37,7 @@ use mimalloc::MiMalloc;
 use tracing_subscriber::fmt::time::UtcTime;
 use tracing_subscriber::layer::SubscriberExt;
 use tracing_subscriber::{EnvFilter, Layer};
+use {chrono as _, uffs_polars as _};
 
 #[cfg(target_os = "windows")]
 #[global_allocator]