Introduce lifecycle operator to snmp app

Following hooks were necessary:
  pre-apply-rbd, pre-apply-resource, post-remove-rbd,
  post-remove-resource, post-apply, post-remove

Change-Id: I533f2bd41c5627f83a004ffbf4543dd3c26d06b7
Story: 2007960
Task: 41579
Signed-off-by: Dan Voiculeasa <dan.voiculeasa@windriver.com>

python-k8sapp-snmp/k8sapp_snmp/k8sapp_snmp/armada/manifest_snmp.py

@@ -16,6 +16,7 @@ class SnmpArmadaManifestOperator(base.ArmadaManifestOperator):
   APP = constants.HELM_APP_SNMP
   ARMADA_MANIFEST = 'armada-manifest'
 
+  # TODO: remove this once Ic83fbd25d23ae34889cb288330ec448f920bda39 merges
   def app_lifecycle_actions(self, context, conductor_obj, dbapi, operation, relative_timing):
     if operation == constants.APP_APPLY_OP or operation == constants.APP_REMOVE_OP:
       if relative_timing == constants.APP_LIFECYCLE_POST:

python-k8sapp-snmp/k8sapp_snmp/k8sapp_snmp/lifecycle/__init__.py

@@ -0,0 +1,5 @@
+#
+# Copyright (c) 2021 Wind River Systems, Inc.
+#
+# SPDX-License-Identifier: Apache-2.0
+#

python-k8sapp-snmp/k8sapp_snmp/k8sapp_snmp/lifecycle/lifecycle_snmp.py

@@ -0,0 +1,88 @@
+#
+# Copyright (c) 2021 Wind River Systems, Inc.
+#
+# SPDX-License-Identifier: Apache-2.0
+#
+# All Rights Reserved.
+#
+
+""" System inventory App lifecycle operator."""
+
+from oslo_log import log as logging
+from sysinv.common import constants
+from sysinv.helm import lifecycle_base as base
+from sysinv.helm import lifecycle_utils as lifecycle_utils
+
+LOG = logging.getLogger(__name__)
+
+
+class SnmpAppLifecycleOperator(base.AppLifecycleOperator):
+    def app_lifecycle_actions(self, context, conductor_obj, app_op, app, hook_info):
+        """ Perform lifecycle actions for an operation
+
+        :param context: request context
+        :param conductor_obj: conductor object
+        :param app_op: AppOperator object
+        :param app: AppOperator.Application object
+        :param hook_info: LifecycleHookInfo object
+
+        """
+        # Operation
+        if hook_info.lifecycle_type == constants.APP_LIFECYCLE_TYPE_OPERATION:
+            if hook_info.operation == constants.APP_APPLY_OP:
+                if hook_info.relative_timing == constants.APP_LIFECYCLE_TIMING_POST:
+                    return self.post_apply(context, conductor_obj, hook_info)
+            elif hook_info.operation == constants.APP_REMOVE_OP:
+                if hook_info.relative_timing == constants.APP_LIFECYCLE_TIMING_POST:
+                    return self.post_remove(context, conductor_obj, hook_info)
+
+        # Rbd
+        elif hook_info.lifecycle_type == constants.APP_LIFECYCLE_TYPE_RBD:
+            if hook_info.operation == constants.APP_APPLY_OP and \
+                    hook_info.relative_timing == constants.APP_LIFECYCLE_TIMING_PRE:
+                return lifecycle_utils.create_rbd_provisioner_secrets(app_op, app, hook_info)
+            elif hook_info.operation == constants.APP_REMOVE_OP and \
+                    hook_info.relative_timing == constants.APP_LIFECYCLE_TIMING_POST:
+                return lifecycle_utils.delete_rbd_provisioner_secrets(app_op, app, hook_info)
+
+        # Resources
+        elif hook_info.lifecycle_type == constants.APP_LIFECYCLE_TYPE_RESOURCE:
+            if hook_info.operation == constants.APP_APPLY_OP and \
+                    hook_info.relative_timing == constants.APP_LIFECYCLE_TIMING_PRE:
+                return lifecycle_utils.create_local_registry_secrets(app_op, app, hook_info)
+            elif hook_info.operation == constants.APP_REMOVE_OP and \
+                    hook_info.relative_timing == constants.APP_LIFECYCLE_TIMING_POST:
+                return lifecycle_utils.delete_local_registry_secrets(app_op, app, hook_info)
+
+        # Use the default behaviour for other hooks
+        super(SnmpAppLifecycleOperator, self).app_lifecycle_actions(context, conductor_obj, app_op, app, hook_info)
+
+    def post_apply(self, context, conductor_obj, hook_info):
+        """Post apply actions
+
+        :param context: request context
+        :param conductor_obj: conductor object
+        :param hook_info: LifecycleHookInfo object
+
+        """
+        config_dict = {
+            "personalities": [constants.CONTROLLER],
+            "classes": ['platform::fm::runtime']
+        }
+        config_uuid = conductor_obj._config_update_hosts(context, config_dict['personalities'])
+        conductor_obj._config_apply_runtime_manifest(context, config_uuid, config_dict)
+
+    def post_remove(self, context, conductor_obj, hook_info):
+        """Post remove actions
+
+        :param context: request context
+        :param conductor_obj: conductor object
+        :param hook_info: LifecycleHookInfo object
+
+        """
+        config_dict = {
+            "personalities": [constants.CONTROLLER],
+            "classes": ['platform::fm::runtime']
+        }
+        config_uuid = conductor_obj._config_update_hosts(context, config_dict['personalities'])
+        conductor_obj._config_apply_runtime_manifest(context, config_uuid, config_dict)

python-k8sapp-snmp/k8sapp_snmp/setup.cfg

@@ -38,5 +38,8 @@ systemconfig.helm_plugins.snmp =
 systemconfig.armada.manifest_ops =
     snmp = k8sapp_snmp.armada.manifest_snmp:SnmpArmadaManifestOperator
 
+systemconfig.app_lifecycle =
+    snmp = k8sapp_snmp.lifecycle.lifecycle_snmp:SnmpAppLifecycleOperator
+
 [wheel]
 universal = 1