X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;ds=sidebyside;f=osmclient%2Fv1%2Fclient.py;fp=osmclient%2Fv1%2Fclient.py;h=cad9c94863d1403703ba3226647e793aaf84203e;hb=95686bbc69ded243c346f94dceb0bee567572fb7;hp=ba765e1d9c1fcbb3f0368cdb36a07ea980a47b6e;hpb=52424a2ae26db69c5a97d01e84454ffdd4d31228;p=osm%2Fosmclient.git diff --git a/osmclient/v1/client.py b/osmclient/v1/client.py index ba765e1..cad9c94 100644 --- a/osmclient/v1/client.py +++ b/osmclient/v1/client.py @@ -31,59 +31,60 @@ from osmclient.common import package_tool class Client(object): - def __init__( self, host=None, so_port=8008, - so_project='default', + so_project="default", ro_host=None, ro_port=9090, upload_port=8443, - **kwargs): - self._user = 'admin' - self._password = 'admin' + **kwargs + ): + self._user = "admin" + self._password = "admin" - if len(host.split(':')) > 1: + if len(host.split(":")) > 1: # backwards compatible, port provided as part of host - self._host = host.split(':')[0] - self._so_port = host.split(':')[1] + self._host = host.split(":")[0] + self._so_port = host.split(":")[1] else: self._host = host self._so_port = so_port self._so_project = so_project - http_client = http.Http( - 'https://{}:{}/'.format( - self._host, - self._so_port)) + http_client = http.Http("https://{}:{}/".format(self._host, self._so_port)) http_client.set_http_header( - ['Accept: application/vnd.yand.data+json', - 'Content-Type: application/json']) + ["Accept: application/vnd.yand.data+json", "Content-Type: application/json"] + ) self._so_version = self.get_so_version(http_client) if ro_host is None: ro_host = host - ro_http_client = http.Http('http://{}:{}/'.format(ro_host, ro_port)) + ro_http_client = http.Http("http://{}:{}/".format(ro_host, ro_port)) ro_http_client.set_http_header( - ['Accept: application/vnd.yand.data+json', - 'Content-Type: application/json']) - - upload_client_url = 'https://{}:{}/composer/upload?api_server={}{}'.format( - self._host, - upload_port, - 'https://localhost&upload_server=https://', - self._host) - - if self._so_version == 'v3': - upload_client_url = 'https://{}:{}/composer/upload?api_server={}{}&project_name={}'.format( - self._host, - upload_port, - 'https://localhost&upload_server=https://', - self._host, - self._so_project) + ["Accept: application/vnd.yand.data+json", "Content-Type: application/json"] + ) + + upload_client_url = "https://{}:{}/composer/upload?api_server={}{}".format( + self._host, + upload_port, + "https://localhost&upload_server=https://", + self._host, + ) + + if self._so_version == "v3": + upload_client_url = ( + "https://{}:{}/composer/upload?api_server={}{}&project_name={}".format( + self._host, + upload_port, + "https://localhost&upload_server=https://", + self._host, + self._so_project, + ) + ) upload_client = http.Http(upload_client_url) @@ -92,37 +93,31 @@ class Client(object): self.ns = ns.Ns(http=http_client, client=self, **kwargs) self.nsd = nsd.Nsd(http_client, client=self, **kwargs) self.vim = vim.Vim( - http=http_client, - ro_http=ro_http_client, - client=self, - **kwargs) + http=http_client, ro_http=ro_http_client, client=self, **kwargs + ) self.package = package.Package( - http=http_client, - upload_http=upload_client, - client=self, - **kwargs) + http=http_client, upload_http=upload_client, client=self, **kwargs + ) self.vca = vca.Vca(http_client, client=self, **kwargs) self.utils = utils.Utils(http_client, **kwargs) self.package_tool = package_tool.PackageTool(client=self) @property def so_rbac_project_path(self): - if self._so_version == 'v3': - return 'project/{}/'.format(self._so_project) + if self._so_version == "v3": + return "project/{}/".format(self._so_project) else: - return '' + return "" def get_so_version(self, http_client): try: - resp = http_client.get_cmd('api/operational/version') - if not resp or 'rw-base:version' not in resp: - return 'v2' + resp = http_client.get_cmd("api/operational/version") + if not resp or "rw-base:version" not in resp: + return "v2" - if resp['rw-base:version']['version'].split('.')[0] == '5': + if resp["rw-base:version"]["version"].split(".")[0] == "5": # SO Version 5.x.x.x.x translates to OSM V3 - return 'v3' - return 'v2' + return "v3" + return "v2" except Exception: - return 'v2' - - + return "v2"