chore: remove workspace test

.github/workflows/client_api_check.yml

@@ -29,10 +29,6 @@ jobs:
         working-directory: ./libs/client-api
         run: cargo build --features "enable_brotli"
 
-      - name: Build ClientAPI WASM
-        working-directory: ./libs/client-api
-        run: wasm-pack build
-
       - name: Check ClientAPI Dependencies
         working-directory: ./libs/client-api
         run: bash ../../script/client_api_deps_check.sh

libs/client-api/src/lib.rs

@@ -1,7 +1,7 @@
 mod http;
 mod http_ai;
 mod http_billing;
-pub mod http_blob;
+
 mod http_collab;
 mod http_history;
 mod http_member;

libs/client-api/src/http_blob.rs → libs/client-api/src/native/http_blob.rs

@@ -403,7 +403,7 @@ impl FileDir for FileDirImpl<'_> {
 
 #[cfg(test)]
 mod tests {
-  use crate::http_blob::ChunkedBytes;
+  use crate::ChunkedBytes;
   use bytes::Bytes;
   use std::env::temp_dir;
   use tokio::io::AsyncWriteExt;

libs/client-api/src/native/mod.rs

@@ -1,7 +1,9 @@
+mod http_blob;
 mod http_native;
 mod ping;
 mod retry;
 
+pub use http_blob::*;
 #[allow(unused_imports)]
 pub use http_native::*;
 pub(crate) use ping::*;

libs/database/src/file/file_storage.rs

@@ -10,7 +10,7 @@ use database_entity::file_dto::{
   CompleteUploadRequest, CreateUploadRequest, CreateUploadResponse, FileDir, UploadPartRequest,
   UploadPartResponse,
 };
-use tracing::{instrument, warn};
+use tracing::{info, instrument, warn};
 use uuid::Uuid;
 
 pub trait ResponseBlob {
@@ -58,6 +58,7 @@ where
   }
 
   pub async fn remove_dir(&self, dir: &str) -> Result<(), AppError> {
+    info!("removing dir: {}", dir);
     self.client.remove_dir(dir).await?;
     Ok(())
   }

libs/database/src/file/s3_client_impl.rs

@@ -279,6 +279,12 @@ impl BucketClient for AwsS3BucketClientImpl {
         })
         .collect();
 
+      trace!(
+        "objects_to_delete: {:?} at directory: {}",
+        objects_to_delete.len(),
+        dir
+      );
+
       // Step 2: Delete the listed objects in batches of 1000
       while !objects_to_delete.is_empty() {
         let batch = if objects_to_delete.len() > 1000 {
@@ -287,6 +293,15 @@ impl BucketClient for AwsS3BucketClientImpl {
           Vec::new()
         };
 
+        trace!(
+          "Deleting {} objects: {:?}",
+          dir,
+          objects_to_delete
+            .iter()
+            .map(|object| &object.key)
+            .collect::<Vec<&String>>()
+        );
+
         let delete = Delete::builder()
           .set_objects(Some(objects_to_delete))
           .build()
@@ -314,9 +329,15 @@ impl BucketClient for AwsS3BucketClientImpl {
         objects_to_delete = batch;
       }
 
-      if list_objects.is_truncated.is_none() {
-        break;
+      match list_objects.is_truncated {
+        None => break,
+        Some(is_truncated) => {
+          if !is_truncated {
+            break;
+          }
+        },
       }
+
       continuation_token = list_objects.next_continuation_token;
     }