From cbbc3af633484667a128fc8afcbc245fa46aafbf Mon Sep 17 00:00:00 2001
From: Nizamudeen A <nia@redhat.com>
Date: Fri, 7 Jun 2024 18:43:00 +0530
Subject: [PATCH] mgr/dashboard: get  bucket replication info

- Show bucket replication status and replication policy in the details
view

Fixes: https://tracker.ceph.com/issues/66241
Signed-off-by: Nizamudeen A <nia@redhat.com>
(cherry picked from commit 9cdb55c2d2ed6f6ca4ab51d0cd40943107d90c0d)
---
 src/pybind/mgr/dashboard/controllers/rgw.py         |  5 +++++
 .../rgw-bucket-details.component.html               | 10 ++++++++++
 .../rgw-bucket-details.component.ts                 |  3 +++
 .../rgw-bucket-form/rgw-bucket-form.component.html  |  3 ++-
 .../rgw-bucket-form/rgw-bucket-form.component.ts    |  8 ++++++++
 src/pybind/mgr/dashboard/services/rgw_client.py     | 13 +++++++++++++
 6 files changed, 41 insertions(+), 1 deletion(-)

diff --git a/src/pybind/mgr/dashboard/controllers/rgw.py b/src/pybind/mgr/dashboard/controllers/rgw.py
index 2240e08aa66..d0831239fbb 100644
--- a/src/pybind/mgr/dashboard/controllers/rgw.py
+++ b/src/pybind/mgr/dashboard/controllers/rgw.py
@@ -409,6 +409,10 @@ class RgwBucket(RgwRESTController):
             multisite.create_dashboard_admin_sync_group(zonegroup_name=zonegroup_name)
         return rgw_client.set_bucket_replication(bucket_name, replication)
 
+    def _get_replication(self, bucket_name: str):
+        rgw_client = RgwClient.admin_instance()
+        return rgw_client.get_bucket_replication(bucket_name)
+
     @staticmethod
     def strip_tenant_from_bucket_name(bucket_name):
         # type (str) -> str
@@ -463,6 +467,7 @@ class RgwBucket(RgwRESTController):
         result['mfa_delete'] = versioning['MfaDelete']
         result['bucket_policy'] = self._get_policy(bucket_name)
         result['acl'] = self._get_acl(bucket_name, daemon_name, result['owner'])
+        result['replication'] = self._get_replication(bucket_name)
 
         # Append the locking configuration.
         locking = self._get_locking(result['owner'], daemon_name, bucket_name)
diff --git a/src/pybind/mgr/dashboard/frontend/src/app/ceph/rgw/rgw-bucket-details/rgw-bucket-details.component.html b/src/pybind/mgr/dashboard/frontend/src/app/ceph/rgw/rgw-bucket-details/rgw-bucket-details.component.html
index a68ea5661e2..f0b5f1872bc 100644
--- a/src/pybind/mgr/dashboard/frontend/src/app/ceph/rgw/rgw-bucket-details/rgw-bucket-details.component.html
+++ b/src/pybind/mgr/dashboard/frontend/src/app/ceph/rgw/rgw-bucket-details/rgw-bucket-details.component.html
@@ -20,6 +20,11 @@
                   class="bold">Encryption</td>
               <td>{{ selection.encryption }}</td>
             </tr>
+            <tr>
+              <td i18n
+                  class="bold">Replication</td>
+              <td>{{ replicationStatus }}</td>
+            </tr>
             <tr>
               <td i18n
                   class="bold">MFA Delete</td>
@@ -130,6 +135,11 @@
                   class="bold w-25">Bucket policy</td>
               <td><pre>{{ selection.bucket_policy | json}}</pre></td>
             </tr>
+            <tr>
+              <td i18n
+                  class="bold w-25">Replication policy</td>
+              <td><pre>{{ selection.replication | json}}</pre></td>
+            </tr>
             <tr>
               <td i18n
                   class="bold w-25">ACL</td>
diff --git a/src/pybind/mgr/dashboard/frontend/src/app/ceph/rgw/rgw-bucket-details/rgw-bucket-details.component.ts b/src/pybind/mgr/dashboard/frontend/src/app/ceph/rgw/rgw-bucket-details/rgw-bucket-details.component.ts
index 451a7dd3811..1a709f8644f 100644
--- a/src/pybind/mgr/dashboard/frontend/src/app/ceph/rgw/rgw-bucket-details/rgw-bucket-details.component.ts
+++ b/src/pybind/mgr/dashboard/frontend/src/app/ceph/rgw/rgw-bucket-details/rgw-bucket-details.component.ts
@@ -14,6 +14,7 @@ export class RgwBucketDetailsComponent implements OnChanges {
   selection: any;
 
   aclPermissions: Record<string, string[]> = {};
+  replicationStatus = $localize`Disabled`;
 
   constructor(private rgwBucketService: RgwBucketService) {}
 
@@ -23,6 +24,8 @@ export class RgwBucketDetailsComponent implements OnChanges {
         bucket['lock_retention_period_days'] = this.rgwBucketService.getLockDays(bucket);
         this.selection = bucket;
         this.aclPermissions = this.parseXmlAcl(this.selection.acl, this.selection.owner);
+        if (this.selection.replication?.['Rule']?.['Status'])
+          this.replicationStatus = this.selection.replication?.['Rule']?.['Status'];
       });
     }
   }
diff --git a/src/pybind/mgr/dashboard/frontend/src/app/ceph/rgw/rgw-bucket-form/rgw-bucket-form.component.html b/src/pybind/mgr/dashboard/frontend/src/app/ceph/rgw/rgw-bucket-form/rgw-bucket-form.component.html
index 22b094d6bd5..87dbee26dc2 100644
--- a/src/pybind/mgr/dashboard/frontend/src/app/ceph/rgw/rgw-bucket-form/rgw-bucket-form.component.html
+++ b/src/pybind/mgr/dashboard/frontend/src/app/ceph/rgw/rgw-bucket-form/rgw-bucket-form.component.html
@@ -408,7 +408,8 @@
               <cd-help-text>
                 <span i18n>Enables replication for the objects in the bucket.</span>
               </cd-help-text>
-              <div class="mt-1">
+              <div class="mt-1"
+                   *ngIf="!editing">
                 <cd-alert-panel type="info"
                                 *ngIf="!multisiteStatus.status.available && !multisiteStatus.isDefaultZg"
                                 class="me-1"
diff --git a/src/pybind/mgr/dashboard/frontend/src/app/ceph/rgw/rgw-bucket-form/rgw-bucket-form.component.ts b/src/pybind/mgr/dashboard/frontend/src/app/ceph/rgw/rgw-bucket-form/rgw-bucket-form.component.ts
index 59f6dd6e399..7b92dfb964c 100644
--- a/src/pybind/mgr/dashboard/frontend/src/app/ceph/rgw/rgw-bucket-form/rgw-bucket-form.component.ts
+++ b/src/pybind/mgr/dashboard/frontend/src/app/ceph/rgw/rgw-bucket-form/rgw-bucket-form.component.ts
@@ -271,6 +271,14 @@ export class RgwBucketFormComponent extends CdForm implements OnInit, AfterViewC
                 .get('bucket_policy')
                 .setValue(JSON.stringify(value['bucket_policy'], null, 2));
             }
+            if (value['replication']) {
+              const replicationConfig = value['replication'];
+              if (replicationConfig?.['Rule']?.['Status'] === 'Enabled') {
+                this.bucketForm.get('replication').setValue(true);
+              } else {
+                this.bucketForm.get('replication').setValue(false);
+              }
+            }
             this.filterAclPermissions();
           }
         }
diff --git a/src/pybind/mgr/dashboard/services/rgw_client.py b/src/pybind/mgr/dashboard/services/rgw_client.py
index 3872c9073ac..17fa33f7508 100644
--- a/src/pybind/mgr/dashboard/services/rgw_client.py
+++ b/src/pybind/mgr/dashboard/services/rgw_client.py
@@ -1040,6 +1040,19 @@ class RgwClient(RestClient):
         except RequestException as e:
             raise DashboardException(msg=str(e), component='rgw')
 
+    @RestClient.api_get('/{bucket_name}?replication')
+    def get_bucket_replication(self, bucket_name, request=None):
+        # pylint: disable=unused-argument
+        try:
+            result = request()
+            return result
+        except RequestException as e:
+            if e.content:
+                content = json_str_to_object(e.content)
+                if content.get('Code') == 'ReplicationConfigurationNotFoundError':
+                    return None
+            raise e
+
 
 class SyncStatus(Enum):
     enabled = 'enabled'
-- 
2.39.5