- **mod.rs** -- Public API (`init()`, `start_indexing()`, `stop_indexing()`, `clear_index()`), `IndexPhase` state machine, `IndexManager` (coordinates all subsystems), `DebugStats` (shared atomic counters for the debug window + phase timeline via `set_phase()`/`close_phase_with_stats()`). `start_scan()` takes a `scan_trigger: &str` parameter describing why the scan was initiated.

- **enrichment.rs** -- `ReadPool` (lock-free thread-local read connections for enrichment and verification), `enrich_entries_with_index()` (called when entries are stored in the listing cache — streaming, watcher update, re-sort — NOT on `get_file_range`; index freshness is handled by `index-dir-updated` → `refreshIndexSizes` → `getDirStatsBatch`). Integer-keyed fast path: resolve parent dir once → batch-fetch child dir stats by ID → match by name. Falls back to individual path resolution for edge cases.

- **event_loop.rs** -- `run_live_event_loop` (real-time FSEvents/inotify processing after scan completes), `run_replay_event_loop` (cold-start journal replay with two-phase approach), `run_background_verification` (post-replay bidirectional readdir diff), `merge_fs_events` (deduplication with flag priority), `process_live_batch`. All bounded-buffer constants live here.

- **store.rs** -- SQLite schema v6 (integer-keyed entries with `name_folded` column on macOS, dir_stats by entry_id, meta), platform_case collation, read queries, DB open/migrate. `resolve_component` uses the composite index directly: on macOS queries by `(parent_id, name_folded)`, on Linux/Windows by `(parent_id, name)`. Schema version check: mismatch triggers drop+rebuild. Both path-keyed (backward compat) and integer-keyed APIs.

- **memory_watchdog.rs** -- Background task monitoring resident memory via `mach_task_info` (macOS). Warns at 8 GB, stops indexing at 16 GB, emits `index-memory-warning` event to frontend. No-op stub on non-macOS. Started from `start_indexing()`.

- **writer.rs** -- Single writer thread, owns the write connection, processes `WriteMessage` channel (bounded `sync_channel`, 20K capacity, backpressure via blocking). `WRITER_GENERATION: AtomicU64` (initialized to 1) bumped on every mutation (`InsertEntriesV2`, `UpsertEntryV2`, `DeleteEntryById`, `DeleteSubtreeById`, `TruncateData`) for search index staleness detection. Priority: `UpdateDirStats` before `InsertEntries`. `Flush` variant + async `flush()` method let callers wait for all prior writes to commit. Has both integer-keyed variants (`InsertEntriesV2`, `UpsertEntryV2`, `DeleteEntryById`, `DeleteSubtreeById`, `PropagateDeltaById`) and path-keyed backward-compat variants. The integer-keyed delete/subtree-delete handlers auto-propagate negative deltas via the `parent_id` chain (same pattern as the path-keyed variants). `propagate_delta_by_id` walks the parent chain using `get_parent_id` lookups. `UpsertEntryV2` initializes a zero-valued `dir_stats` row when inserting a NEW directory, so enrichment always has a row (subsequent `PropagateDeltaById` calls update it incrementally). Maintains `AccumulatorMaps` during `InsertEntriesV2` processing (two HashMaps: direct children stats and child dir relationships + an `entries_inserted` counter), cleared on `TruncateData`. On `ComputeAllAggregates`, passes accumulated maps to `aggregator::compute_all_aggregates_with_maps()` to skip expensive full-table-scan SQL queries. Accepts an optional `AppHandle` at spawn time to emit `index-aggregation-progress` events during aggregation (phase, current, total). Also emits `saving_entries` phase progress during `InsertEntriesV2` processing when the expected total is set via `set_expected_total_entries()` (an `Arc<AtomicU64>` shared between the writer thread and the `IndexWriter` handle). No index drop/recreate dance — the composite indexes (`idx_parent_name_folded` on macOS, `idx_parent_name` on Linux) use binary collation and stay present during scans.

use super::DEBUG_STATS;

use super::enrichment::get_read_pool;

use super::firmlinks;

use super::reconciler::{self, EventReconciler};

use super::scanner;

},

);

// Emit a single batched index-dir-updated with all collected paths.

// If affected_paths overflowed, emit a full refresh notification with

// just "/" so the frontend refreshes everything.

pub estimated_total: Option<u64>,

mod macos_icons;

mod mcp;

mod menu;

mod mtp;

mod network;

// Fill directory sizes from the DB

if result.entries.iter().any(|e| e.is_directory)

// Post-filter: remove directories that don't match size criteria

let has_size_filter = query.min_size.is_some() || query.max_size.is_some();

}

}

let query = SearchQuery {

name_pattern: translate_result.query.name_pattern,

getAggregationCurrent(): number

getAggregationTotal(): number

getAggregationStartedAt(): number // Date.now() timestamp

initIndexState(): Promise<void> // call once at app mount

destroyIndexState(): void // call at app teardown

Module-level `$state` variables (`scanning`, `entriesScanned`, `dirsFound`, `aggregating`, `aggregationPhase`,

| Event | Payload | Effect |

| ---------------------------- | --------------------------------------------------- | ------------------------------------------------------- |

| `index-scan-started` | `{ volumeId }` | `scanning = true`, counters reset |

| `index-scan-progress` | `{ volumeId, entriesScanned, dirsFound }` | Update counters |

| `index-scan-complete` | `{ volumeId, totalEntries, totalDirs, durationMs }` | `scanning = false`, set final counts, reset aggregation |

| `index-rescan-notification` | `{ volumeId, reason, details }` | Show info toast with reason-specific message |

| `index-aggregation-progress` | `{ phase, current, total }` | `aggregating = true`, update phase/progress/ETA |

| `index-aggregation-complete` | `()` | Reset aggregation state, dismiss overlay |

Uses `formatNumber` from selection-info-utils for number formatting (uses `'en-US'` locale, hardcoded via

`toLocaleString('en-US')`).

**Decision**: "Listen first, then query" initialization pattern in `initIndexState`. **Why**: The Rust indexer starts in

- `$lib/tauri-commands` — `listen`, `UnlistenFn`

- `$lib/ui/toast` — `addToast` (rescan notification toasts)

- `$lib/file-explorer/selection/selection-info-utils` — `formatNumber` (overlay only)