fix missing path prefix in bulk_delete_impl

Adnan Alhomssi · Adnan Alhomssi · commit 278b8120a1cd · 2025-02-11T13:25:54.000+01:00
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "object_store_ffi"
-version = "0.12.0"
+version = "0.12.1"
 edition = "2021"
 
 [[bench]]
diff --git a/src/crud_ops.rs b/src/crud_ops.rs
@@ -229,6 +229,8 @@ impl Client {
     }
 
     async fn bulk_delete_impl(&self, paths: &Vec<Path>) -> crate::Result<Vec<(Path, crate::Error)>> {
+        // Add the client prefix to the provided paths if needed
+        let paths = paths.into_iter().map(|path| self.full_path(path)).collect::<Vec<Path>>();
         let stream = stream::iter(paths.iter().map(|path| Ok(path.clone()))).boxed();
         let results = self.store.delete_stream(stream)
             .collect::<Vec<_>>().await;

Original file line number	Diff line number	Diff line change
`@@ -229,6 +229,8 @@ impl Client {`
`229`	`229`	`}`
`230`	`230`
`231`	`231`	`async fn bulk_delete_impl(&self, paths: &Vec<Path>) -> crate::Result<Vec<(Path, crate::Error)>> {`
	`232`	`+ // Add the client prefix to the provided paths if needed`
	`233`	`+ let paths = paths.into_iter().map(\|path\| self.full_path(path)).collect::<Vec<Path>>();`
`232`	`234`	`let stream = stream::iter(paths.iter().map(\|path\| Ok(path.clone()))).boxed();`
`233`	`235`	`let results = self.store.delete_stream(stream)`
`234`	`236`	`.collect::<Vec<_>>().await;`