julienfroidefond/stripstream-librarian
1
0
Fork 0
Code Issues 4 Pull Requests Actions Packages Projects Releases Wiki Activity

fix(indexer): File watcher not watching directories

Browse Source 
The setup_watcher function was creating a watcher object but never
calling .watch() on the library directories. Now it properly watches
all directories recursively and detects file changes.
This commit is contained in:
Julien Froidefond
2026-03-06 14:23:17 +01:00
parent 323661f770
commit b6cd8a895d
1 changed files with 10 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
apps/indexer/src/main.rs
View File

@@ -250,12 +250,14 @@ fn setup_watcher(
libraries: HashMap<Uuid, String>, libraries: HashMap<Uuid, String>,
tx: mpsc::Sender<(Uuid, String)>, tx: mpsc::Sender<(Uuid, String)>,
) -> anyhow::Result<RecommendedWatcher> { ) -> anyhow::Result<RecommendedWatcher> {
let watcher = notify::recommended_watcher(move |res: Result<Event, notify::Error>| { let libraries_for_closure = libraries.clone();
let mut watcher = notify::recommended_watcher(move |res: Result<Event, notify::Error>| {
match res { match res {
Ok(event) => { Ok(event) => {
if event.kind.is_modify() || event.kind.is_create() || event.kind.is_remove() { if event.kind.is_modify() || event.kind.is_create() || event.kind.is_remove() {
for path in event.paths { for path in event.paths {
if let Some((library_id, _)) = libraries.iter().find(|(_, root)| { if let Some((library_id, _)) = libraries_for_closure.iter().find(|(_, root)| {
path.starts_with(root) path.starts_with(root)
}) { }) {
let path_str = path.to_string_lossy().to_string(); let path_str = path.to_string_lossy().to_string();
@@ -270,6 +272,12 @@ fn setup_watcher(
} }
})?; })?;
// Actually watch the library directories
for (_, root_path) in &libraries {
info!("[WATCHER] Watching directory: {}", root_path);
watcher.watch(std::path::Path::new(root_path), RecursiveMode::Recursive)?;
}
Ok(watcher) Ok(watcher)
} }