mirror/spacedrive
1
0
Fork 0
mirror of https://github.com/spacedriveapp/spacedrive.git synced 2026-02-20 07:37:26 -05:00
Code Issues Packages Projects Releases Wiki Activity

[END-1309] Fix explorer query invalidation (#1604)

Browse Source 
fix
This commit is contained in:
Jamie Pine
2023-10-16 20:54:41 -07:00
committed by GitHub
parent aa354f684e
commit bbe0bd1bb7
6 changed files with 18 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
core/src/api/files.rs
View File

@@ -258,6 +258,7 @@ pub(crate) fn mount() -> AlphaRouter<Ctx> {
.await?;
invalidate_query!(library, "search.paths");
invalidate_query!(library, "search.objects");
Ok(())
})
})
@@ -274,6 +275,7 @@ pub(crate) fn mount() -> AlphaRouter<Ctx> {
.exec()
.await?;
invalidate_query!(library, "search.objects");
invalidate_query!(library, "search.paths");
Ok(())
})
@@ -479,6 +481,7 @@ pub(crate) fn mount() -> AlphaRouter<Ctx> {
fs::remove_file(path.as_ref()).await.map_err(|e| {
// Let's also invalidate the query here, because we succeeded in converting the file
invalidate_query!(library, "search.paths");
invalidate_query!(library, "search.objects");
FileIOError::from((
path.as_ref(),
@@ -489,6 +492,7 @@ pub(crate) fn mount() -> AlphaRouter<Ctx> {
}
invalidate_query!(library, "search.paths");
invalidate_query!(library, "search.objects");
Ok(())
})

1
core/src/location/indexer/shallow.rs
View File

@@ -186,6 +186,7 @@ pub async fn shallow(
.map_err(IndexerError::from)?;
invalidate_query!(library, "search.paths");
invalidate_query!(library, "search.objects");
}
library.orphan_remover.invoke().await;

11
core/src/location/manager/watcher/utils.rs
View File

@@ -131,6 +131,7 @@ pub(super) async fn create_dir(
scan_location_sub_path(node, library, location, &children_materialized_path).await?;
invalidate_query!(library, "search.paths");
invalidate_query!(library, "search.objects");
Ok(())
}
@@ -319,6 +320,7 @@ async fn inner_create_file(
}
invalidate_query!(library, "search.paths");
invalidate_query!(library, "search.objects");
Ok(())
}
@@ -365,7 +367,10 @@ pub(super) async fn update_file(
)
.await
}
.map(|_| invalidate_query!(library, "search.paths"))
.map(|_| {
invalidate_query!(library, "search.paths");
invalidate_query!(library, "search.objects");
})
}
async fn inner_update_file(
@@ -572,6 +577,7 @@ async fn inner_update_file(
}
invalidate_query!(library, "search.paths");
invalidate_query!(library, "search.objects");
}
Ok(())
@@ -664,6 +670,7 @@ pub(super) async fn rename(
.await?;
invalidate_query!(library, "search.paths");
invalidate_query!(library, "search.objects");
}
Ok(())
@@ -741,6 +748,7 @@ pub(super) async fn remove_by_file_path(
}
invalidate_query!(library, "search.paths");
invalidate_query!(library, "search.objects");
Ok(())
}
@@ -845,6 +853,7 @@ pub(super) async fn recalculate_directories_size(
if should_invalidate {
invalidate_query!(library, "search.paths");
invalidate_query!(library, "search.objects");
}
candidates.extend(buffer.drain(..));

1
core/src/location/mod.rs
View File

@@ -781,6 +781,7 @@ pub async fn delete_directory(
library.orphan_remover.invoke().await;
invalidate_query!(library, "search.paths");
invalidate_query!(library, "search.objects");
Ok(())
}

1
core/src/object/file_identifier/shallow.rs
View File

@@ -114,6 +114,7 @@ pub async fn shallow(
}
invalidate_query!(library, "search.paths");
invalidate_query!(library, "search.objects");
Ok(())
}

1
core/src/object/media/media_processor/shallow.rs
View File

@@ -113,6 +113,7 @@ pub async fn shallow(
if run_metadata.media_data.extracted > 0 {
invalidate_query!(library, "search.paths");
invalidate_query!(library, "search.objects");
}
Ok(())