From 278b8120a1cd930dd934bfff4a6437ca155f2ed8 Mon Sep 17 00:00:00 2001
From: Adnan Alhomssi <adnan.alhomssi@relational.ai>
Date: Tue, 11 Feb 2025 13:15:35 +0100
Subject: [PATCH] fix missing path prefix in bulk_delete_impl

---
 Cargo.lock      | 2 +-
 Cargo.toml      | 2 +-
 src/crud_ops.rs | 2 ++
 3 files changed, 4 insertions(+), 2 deletions(-)

diff --git a/Cargo.lock b/Cargo.lock
index 729a53f..08e54fe 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -1402,7 +1402,7 @@ dependencies = [
 
 [[package]]
 name = "object_store_ffi"
-version = "0.12.0"
+version = "0.12.1"
 dependencies = [
  "anyhow",
  "async-channel",
diff --git a/Cargo.toml b/Cargo.toml
index ecbd3e9..cfa5ede 100644
--- 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
index 4ea4c97..85eb2ae 100644
--- 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;