From ecaf68d64151acfbafdb108823de5915b1b0db5f Mon Sep 17 00:00:00 2001
From: Chris <anzhengchao@gmail.com>
Date: Mon, 14 Sep 2026 06:57:54 +0800
Subject: [PATCH] fix: skip IAM migration when legacy volume is absent (#7792)

---
 crates/ecstore/src/bucket/migration.rs | 40 ++++++++++++++++++++++++--
 1 file changed, 38 insertions(+), 2 deletions(-)

diff --git a/crates/ecstore/src/bucket/migration.rs b/crates/ecstore/src/bucket/migration.rs
index cca13fb97..6724a408a 100644
--- a/crates/ecstore/src/bucket/migration.rs
+++ b/crates/ecstore/src/bucket/migration.rs
@@ -20,7 +20,7 @@ use crate::disk::{BUCKET_META_PREFIX, MIGRATING_META_BUCKET, RUSTFS_META_BUCKET}
 use crate::error::{Error, Result, is_err_strict_not_found, is_err_strict_volume_not_found};
 use crate::object_api::{GetObjectReader, ObjectInfo, ObjectOptions, PutObjReader};
 use crate::storage_api_contracts::{
-    bucket::{BucketOperations, BucketOptions},
+    bucket::{BucketInfo, BucketOperations, BucketOptions},
     list::{ListOperations, StorageListObjectVersionsInfo, StorageListObjectsV2Info, StorageObjectInfoOrErr, StorageWalkOptions},
     object::{DeletedObject, EcstoreObjectIO, EcstoreObjectOperations, ObjectIO, ObjectOperations, ObjectToDelete},
     range::HTTPRangeSpec,
@@ -356,7 +356,8 @@ where
 /// An absent legacy bucket is a no-op; migration errors prevent startup readiness.
 pub async fn try_migrate_iam_config<S>(store: Arc<S>, decrypt_fn: Option<LegacyBlobDecryptFn>) -> Result<()>
 where
-    S: ListOperations<
+    S: BucketOperations<Error = crate::error::Error>
+        + ListOperations<
             Error = crate::error::Error,
             ListObjectsV2Info = ListObjectsV2Info,
             ListObjectVersionsInfo = ListObjectVersionsInfo,
@@ -381,6 +382,21 @@ where
             DeletedObject = DeletedObject,
         >,
 {
+    if !legacy_iam_source_exists(
+        store
+            .get_bucket_info(
+                MIGRATING_META_BUCKET,
+                &BucketOptions {
+                    no_metadata: true,
+                    ..Default::default()
+                },
+            )
+            .await,
+    )? {
+        debug!("No legacy IAM volume found");
+        return Ok(());
+    }
+
     let opts = ObjectOptions {
         max_parity: true,
         no_lock: true,
@@ -458,6 +474,14 @@ where
     Ok(())
 }
 
+fn legacy_iam_source_exists(result: Result<BucketInfo>) -> Result<bool> {
+    match result {
+        Ok(_) => Ok(true),
+        Err(error) if is_err_strict_volume_not_found(&error) => Ok(false),
+        Err(error) => Err(error),
+    }
+}
+
 fn next_iam_migration_page(truncated: bool, previous: Option<String>, next: Option<String>) -> Result<Option<String>> {
     if !truncated {
         return Ok(None);
@@ -471,6 +495,18 @@ fn next_iam_migration_page(truncated: bool, previous: Option<String>, next: Opti
 
 #[cfg(test)]
 mod tests {
+    #[test]
+    fn legacy_iam_source_probe_skips_only_an_absent_volume() {
+        use super::{BucketInfo, Error, legacy_iam_source_exists};
+
+        assert!(!legacy_iam_source_exists(Err(Error::VolumeNotFound)).expect("absent legacy volume is a no-op"));
+        assert!(legacy_iam_source_exists(Ok(BucketInfo::default())).expect("existing legacy volume must be migrated"));
+        assert!(matches!(
+            legacy_iam_source_exists(Err(Error::ErasureReadQuorum)),
+            Err(Error::ErasureReadQuorum)
+        ));
+    }
+
     #[test]
     fn migration_errors_group_by_cause_and_retain_typed_record_context() {
         use super::{Error, MigrationMetadataError};