X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;ds=sidebyside;f=common%2Fpython%2Frift%2Fmano%2Futils%2Fjuju_api.py;h=c4e3923bf15c8923e60856aa7358c36019726ad8;hb=4fc5a67859df32237ba349157cfefc38c91fee9a;hp=40ff14c9c9b73cb364d61495fccc34190897ffcc;hpb=6a599064c308e90ee8298db2d6ba0b3bfc468836;p=osm%2FSO.git

diff --git a/common/python/rift/mano/utils/juju_api.py b/common/python/rift/mano/utils/juju_api.py
index 40ff14c9..c4e3923b 100755
--- a/common/python/rift/mano/utils/juju_api.py
+++ b/common/python/rift/mano/utils/juju_api.py
@@ -150,7 +150,10 @@ class JujuApi(object):
         else:
             self.log = logging.getLogger(__name__)
 
-        self.log.debug('JujuApi instantiated')
+        # Quiet websocket traffic
+        logging.getLogger('websockets.protocol').setLevel(logging.INFO)
+
+        self.log.debug('JujuApi: instantiated')
 
         self.server = server
         self.port = port
@@ -174,6 +177,9 @@ class JujuApi(object):
 
     async def apply_config(self, config, application):
         """Apply a configuration to the application."""
+        self.log.debug("JujuApi: Applying configuration to {}.".format(
+            application
+        ))
         return await self.set_config(application=application, config=config)
 
     async def deploy_application(self, charm, name="", path=""):
@@ -184,6 +190,11 @@ class JujuApi(object):
         app = await self.get_application(name)
         if app is None:
             # TODO: Handle the error if the charm isn't found.
+            self.log.debug("JujuApi: Deploying charm {} ({}) from {}".format(
+                charm,
+                name,
+                path,
+            ))
             app = await self.model.deploy(
                 path,
                 application_name=name,
@@ -197,6 +208,7 @@ class JujuApi(object):
         if not self.authenticated:
             await self.login()
 
+        self.log.debug("JujuApi: Waiting for status of action uuid {}".format(uuid))
         action = await self.model.wait_for_action(uuid)
         return action.status
 
@@ -205,12 +217,15 @@ class JujuApi(object):
         if not self.authenticated:
             await self.login()
 
+        self.log.debug("JujuApi: Getting application {}".format(application))
         app = None
-        if application in self.model.applications:
-            app = self.model.applications[application]
+        if self.model:
+            if self.model.applications:
+                if application in self.model.applications:
+                    app = self.model.applications[application]
         return app
 
-    async def get_application_status(self, application, status=None):
+    async def get_application_status(self, application):
         """Get the status of an application."""
         if not self.authenticated:
             await self.login()
@@ -220,6 +235,10 @@ class JujuApi(object):
         if app:
             status = app.status
 
+        self.log.debug("JujuApi: Status of application {} is {}".format(
+            application,
+            str(status),
+        ))
         return status
     get_service_status = get_application_status
 
@@ -233,6 +252,11 @@ class JujuApi(object):
         if app:
             config = await app.get_config()
 
+        self.log.debug("JujuApi: Config of application {} is {}".format(
+            application,
+            str(config),
+        ))
+
         return config
 
     async def get_model(self, name='default'):
@@ -247,6 +271,11 @@ class JujuApi(object):
 
         uuid = await self.get_model_uuid(name)
 
+        self.log.debug("JujuApi: Connecting to model {} ({})".format(
+            model,
+            uuid,
+        ))
+
         await model.connect(
             self.endpoint,
             uuid,
@@ -268,6 +297,11 @@ class JujuApi(object):
         uuid = None
 
         models = await self.controller.get_models()
+
+        self.log.debug("JujuApi: Looking through {} models for model {}".format(
+            len(models.user_models),
+            name,
+        ))
         for model in models.user_models:
             if model.model.name == name:
                 uuid = model.model.uuid
@@ -288,6 +322,7 @@ class JujuApi(object):
             machines = {}
             relations = {}
 
+        self.log.debug("JujuApi: Getting model status")
         status = model_state()
         status.applications = self.model.applications
         status.machines = self.model.machines
@@ -303,6 +338,12 @@ class JujuApi(object):
         status = await self.get_application_status(application)
         if status and status in ['active']:
             state = True
+
+        self.log.debug("JujuApi: Application {} is {} active".format(
+            application,
+            "" if status else "not",
+        ))
+
         return state
     is_service_active = is_application_active
 
@@ -315,6 +356,12 @@ class JujuApi(object):
         status = await self.get_application_status(application)
         if status and status in ['blocked']:
             state = True
+
+        self.log.debug("JujuApi: Application {} is {} blocked".format(
+            application,
+            "" if status else "not",
+        ))
+
         return state
     is_service_blocked = is_application_blocked
 
@@ -327,6 +374,11 @@ class JujuApi(object):
         status = await self.get_application_status(application)
         if status and status in ['active']:
             state = True
+        self.log.debug("JujuApi: Application {} is {} deployed".format(
+            application,
+            "" if status else "not",
+        ))
+
         return state
     is_service_deployed = is_application_deployed
 
@@ -339,6 +391,11 @@ class JujuApi(object):
         status = await self.get_application_status(application)
         if status and status in ['error']:
             state = True
+        self.log.debug("JujuApi: Application {} is {} errored".format(
+            application,
+            "" if status else "not",
+        ))
+
         return state
     is_service_error = is_application_error
 
@@ -351,6 +408,11 @@ class JujuApi(object):
         status = await self.get_application_status(application)
         if status and status in ['maintenance']:
             state = True
+        self.log.debug("JujuApi: Application {} is {} in maintenence".format(
+            application,
+            "" if status else "not",
+        ))
+
         return state
     is_service_maint = is_application_maint
 
@@ -363,6 +425,10 @@ class JujuApi(object):
         status = await self.get_application_status(application)
         if status and status in ['active', 'blocked']:
             state = True
+        self.log.debug("JujuApi: Application {} is {} up".format(
+            application,
+            "" if status else "not",
+        ))
         return state
     is_service_up = is_application_up
 
@@ -373,6 +439,8 @@ class JujuApi(object):
         cacert = None
         self.controller = Controller()
 
+        self.log.debug("JujuApi: Logging into controller")
+
         if self.secret:
             await self.controller.connect(
                 self.endpoint,
@@ -407,15 +475,23 @@ class JujuApi(object):
 
         app = await self.get_application(name)
         if app:
+            self.log.debug("JujuApi: Destroying application {}".format(
+                name,
+            ))
+
             await app.destroy()
 
-    async def resolve_error(self, application=None, status=None):
+    async def resolve_error(self, application=None):
         """Resolve units in error state."""
         if not self.authenticated:
             await self.login()
 
         app = await self.get_application(application)
         if app:
+            self.log.debug("JujuApi: Resolving errors for application {}".format(
+                application,
+            ))
+
             for unit in app.units:
                 app.resolved(retry=True)
 
@@ -436,6 +512,11 @@ class JujuApi(object):
             # so use the first unit available.
             unit = app.units[0]
 
+            self.log.debug("JujuApi: Running Action {} against Application {}".format(
+                action_name,
+                application,
+            ))
+
             action = await unit.run_action(action_name, **params)
 
             # Wait for the action to complete
@@ -455,13 +536,28 @@ class JujuApi(object):
 
         app = await self.get_application(application)
         if app:
+            self.log.debug("JujuApi: Setting config for Application {}".format(
+                application,
+            ))
             await app.set_config(config)
 
+            # Verify the config is set
+            newconf = await app.get_config()
+            for key in config:
+                if config[key] != newconf[key]:
+                    self.log.debug("JujuApi: Config not set! Key {} Value {} doesn't match {}".format(key, config[key], newconf[key]))
+                    
+
     async def set_parameter(self, parameter, value, application=None):
         """Set a config parameter for a service."""
         if not self.authenticated:
             await self.login()
 
+        self.log.debug("JujuApi: Setting {}={} for Application {}".format(
+            parameter,
+            value,
+            application,
+        ))
         return await self.apply_config(
             {parameter: value},
             application=application,
@@ -474,6 +570,11 @@ class JujuApi(object):
 
         app = await self.get_application(name)
         if app:
+            self.log.debug("JujuApi: Waiting {} seconds for Application {}".format(
+                timeout,
+                name,
+            ))
+
             await self.model.block_until(
                 lambda: all(
                     unit.agent_status == 'idle'