feat(topology): restrict from deleting create-by label on pools

Signed-off-by: sinhaashish <[email protected]>

Author: sinhaashish

control-plane/agents/src/bin/core/pool/pool_operations.rs

@@ -16,6 +16,7 @@ use stor_port::{
         transport::{CreatePool, CtrlPoolState, DestroyPool, Pool},
     },
 };
+use utils::dsp_created_by_key;
 
 #[async_trait::async_trait]
 impl ResourceLifecycle for OperationGuardArc<PoolSpec> {
@@ -169,6 +170,13 @@ impl ResourceLabel for OperationGuardArc<PoolSpec> {
         registry: &Registry,
         label_key: String,
     ) -> Result<Self::UnlabelOutput, SvcError> {
+        if label_key == dsp_created_by_key() {
+            return Err(SvcError::InvalidLabelCreatedBy {
+                labels: label_key,
+                resource_kind: ResourceKind::Pool,
+            }
+            .into());
+        }
         let cloned_pool_spec = self.lock().clone();
         let spec_clone = self
             .start_update(

control-plane/agents/src/bin/core/pool/service.rs

@@ -98,6 +98,7 @@ impl PoolOperations for Service {
             }
             .into());
         }
+
         let pool = Context::spawn(async move { service.unlabel(&req).await }).await??;
         Ok(pool)
     }

control-plane/agents/src/common/errors.rs

@@ -208,6 +208,11 @@ pub enum SvcError {
         labels: String,
         resource_kind: ResourceKind,
     },
+    #[snafu(display("Invalid {}, labels: {} . Cannot delete `created-by` label as it is used for identifying mayastor pools", resource_kind, labels))]
+    InvalidLabelCreatedBy {
+        labels: String,
+        resource_kind: ResourceKind,
+    },
     #[snafu(display("Multiple nexuses not supported"))]
     MultipleNexuses {},
     #[snafu(display("Storage Error: {}", source))]
@@ -801,6 +806,12 @@ impl From<SvcError> for ReplyError {
                 source,
                 extra,
             },
+            SvcError::InvalidLabelCreatedBy { resource_kind, .. } => ReplyError {
+                kind: ReplyErrorKind::InvalidArgument,
+                resource: resource_kind,
+                source,
+                extra,
+            },
             SvcError::MultipleNexuses { .. } => ReplyError {
                 kind: ReplyErrorKind::InvalidArgument,
                 resource: ResourceKind::Unknown,