persisting root cid after all operations

Author: ehsan6sha

crates/fula-cli/src/handlers/batch.rs

@@ -56,6 +56,11 @@ pub async fn delete_objects(
 
     bucket.flush().await?;
 
+    // Persist the bucket registry so the updated root CID survives restarts
+    if let Err(e) = state.bucket_manager.persist_registry().await {
+        tracing::warn!(error = %e, "Failed to persist bucket registry after batch delete");
+    }
+
     // Build response
     let xml_response = if quiet && errors.is_empty() {
         // Quiet mode - only return errors

crates/fula-cli/src/handlers/object.rs

@@ -97,6 +97,11 @@ pub async fn put_object(
             e
         })?;
 
+    // Persist the bucket registry so the new root CID survives restarts
+    if let Err(e) = state.bucket_manager.persist_registry().await {
+        tracing::warn!(error = %e, "Failed to persist bucket registry after put_object");
+    }
+
     // Pin the BUCKET ROOT CID to ensure tree structure survives GC.
     // This recursively pins all tree nodes AND all referenced object data.
     // NOTE: Pinning is async (fire-and-forget) to avoid blocking the response.
@@ -346,6 +351,11 @@ pub async fn delete_object(
     bucket.delete_object(&key).await?;
     bucket.flush().await?;
 
+    // Persist the bucket registry so the updated root CID survives restarts
+    if let Err(e) = state.bucket_manager.persist_registry().await {
+        tracing::warn!(error = %e, "Failed to persist bucket registry after delete_object");
+    }
+
     Ok(StatusCode::NO_CONTENT.into_response())
 }
 
@@ -408,6 +418,11 @@ pub async fn copy_object(
     dest_bucket_handle.put_object(dest_key, dest_metadata.clone()).await?;
     dest_bucket_handle.flush().await?;
 
+    // Persist the bucket registry so the updated root CID survives restarts
+    if let Err(e) = state.bucket_manager.persist_registry().await {
+        tracing::warn!(error = %e, "Failed to persist bucket registry after copy_object");
+    }
+
     let xml_response = xml::copy_object_result(
         dest_metadata.last_modified,
         &dest_metadata.etag,