X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=osmclient%2Fsol005%2Fclient.py;h=b6f12b375024fce3e1e878499e04b7780c562135;hb=3984c7f63e1a92853c87175ef6d1d72b38d3f0ac;hp=495c42591db552b9e8c7a68da323aa9f60897006;hpb=95686bbc69ded243c346f94dceb0bee567572fb7;p=osm%2Fosmclient.git diff --git a/osmclient/sol005/client.py b/osmclient/sol005/client.py index 495c425..b6f12b3 100644 --- a/osmclient/sol005/client.py +++ b/osmclient/sol005/client.py @@ -35,9 +35,12 @@ from osmclient.sol005 import user as usermodule from osmclient.sol005 import role from osmclient.sol005 import pdud from osmclient.sol005 import k8scluster +from osmclient.sol005 import vca from osmclient.sol005 import repo from osmclient.sol005 import osmrepo +from osmclient.sol005 import subscription from osmclient.common import package_tool +from osmclient.common.exceptions import ClientException import json import logging @@ -95,15 +98,17 @@ class Client(object): self.role = role.Role(self._http_client, client=self) self.pdu = pdud.Pdu(self._http_client, client=self) self.k8scluster = k8scluster.K8scluster(self._http_client, client=self) + self.vca = vca.VCA(self._http_client, client=self) self.repo = repo.Repo(self._http_client, client=self) self.osmrepo = osmrepo.OSMRepo(self._http_client, client=self) self.package_tool = package_tool.PackageTool(client=self) + self.subscription = subscription.Subscription(self._http_client, client=self) """ self.vca = vca.Vca(http_client, client=self, **kwargs) self.utils = utils.Utils(http_client, **kwargs) """ - def get_token(self): + def get_token(self, pwd_change=None): self._logger.debug("") if self._token is None: postfields_dict = { @@ -125,6 +130,8 @@ class Client(object): # raise ClientException(message) token = json.loads(resp) if resp else None + if token.get("message") == "change_password" and not pwd_change: + raise ClientException("Password Expired. Please update the password using change_password option") self._token = token["id"] if self._token is not None: @@ -149,9 +156,9 @@ class Client(object): def set_default_params(self, **kwargs): host = kwargs.pop("host", None) - if host != None: + if host is not None: self._host = host port = kwargs.pop("port", None) - if port != None: + if port is not None: self._so_port = port self._http_client.set_query_admin(**kwargs)