X-Git-Url: https://osm.etsi.org/gitweb/?p=osm%2FN2VC.git;a=blobdiff_plain;f=n2vc%2Flibjuju.py;h=0fb82e7d3a7c042b3aed3dc9c5d276c97a4b4790;hp=98e31d8518d448fac634165bc3fb52b0c73df8fa;hb=cdf0b8e857e1373410e61bc72cd1a9f5c1ab7ca7;hpb=7c6840b23b5d6d8bc14eb7e76d1262c4ccde3097 diff --git a/n2vc/libjuju.py b/n2vc/libjuju.py index 98e31d8..0fb82e7 100644 --- a/n2vc/libjuju.py +++ b/n2vc/libjuju.py @@ -44,6 +44,7 @@ from n2vc.exceptions import ( JujuControllerFailedConnecting, JujuApplicationExists, JujuInvalidK8sConfiguration, + JujuError ) from n2vc.utils import DB_DATA from osm_common.dbbase import DbException @@ -201,6 +202,68 @@ class Libjuju: await self.disconnect_model(model) await self.disconnect_controller(controller) + async def get_executed_actions(self, model_name: str) -> list: + """ + Get executed/history of actions for a model. + + :param: model_name: Model name, str. + :return: List of executed actions for a model. + """ + model = None + executed_actions = [] + controller = await self.get_controller() + try: + model = await self.get_model(controller, model_name) + # Get all unique action names + actions = {} + for application in model.applications: + application_actions = await self.get_actions(application, model_name) + actions.update(application_actions) + # Get status of all actions + for application_action in actions: + app_action_status_list = await model.get_action_status(name=application_action) + for action_id, action_status in app_action_status_list.items(): + executed_action = {"id": action_id, "action": application_action, + "status": action_status} + # Get action output by id + action_status = await model.get_action_output(executed_action["id"]) + for k, v in action_status.items(): + executed_action[k] = v + executed_actions.append(executed_action) + except Exception as e: + raise JujuError("Error in getting executed actions for model: {}. Error: {}" + .format(model_name, str(e))) + finally: + if model: + await self.disconnect_model(model) + await self.disconnect_controller(controller) + return executed_actions + + async def get_application_configs(self, model_name: str, application_name: str) -> dict: + """ + Get available configs for an application. + + :param: model_name: Model name, str. + :param: application_name: Application name, str. + + :return: A dict which has key - action name, value - action description + """ + model = None + application_configs = {} + controller = await self.get_controller() + try: + model = await self.get_model(controller, model_name) + application = self._get_application(model, application_name=application_name) + application_configs = await application.get_config() + except Exception as e: + raise JujuError("Error in getting configs for application: {} in model: {}. Error: {}" + .format(application_name, model_name, str(e))) + finally: + if model: + await self.disconnect_model(model) + await self.disconnect_controller(controller) + return application_configs + async def get_model( self, controller: Controller, model_name: str, id=None ) -> Model: