X-Git-Url: https://osm.etsi.org/gitweb/?p=osm%2Fosmclient.git;a=blobdiff_plain;f=osmclient%2Fsol005%2Fvnf.py;fp=osmclient%2Fsol005%2Fvnf.py;h=edae35835b6efdccc8ab97159d34442bb7acfb55;hp=b7ac856e6620fc9581f8036ce9062332840f2d5b;hb=da8d1cbf1c2531b7a823a7aca1a8c77051b19d60;hpb=e7c35ebebd990277d29bfa54eff31c0cccaed78d diff --git a/osmclient/sol005/vnf.py b/osmclient/sol005/vnf.py index b7ac856..edae358 100644 --- a/osmclient/sol005/vnf.py +++ b/osmclient/sol005/vnf.py @@ -20,13 +20,15 @@ OSM vnf API handling from osmclient.common import utils from osmclient.common.exceptions import NotFound - +import logging +import json class Vnf(object): def __init__(self, http=None, client=None): self._http = http self._client = client + self._logger = logging.getLogger('osmclient') self._apiName = '/nslcm' self._apiVersion = '/v1' self._apiResource = '/vnfrs' @@ -36,6 +38,7 @@ class Vnf(object): def list(self, ns=None, filter=None): """Returns a list of VNF instances """ + self._logger.debug("") self._client.get_token() filter_string = '' if filter: @@ -46,15 +49,16 @@ class Vnf(object): filter_string += ',nsr-id-ref={}'.format(ns_instance['_id']) else: filter_string = '?nsr-id-ref={}'.format(ns_instance['_id']) - resp = self._http.get_cmd('{}{}'.format(self._apiBase,filter_string)) + _, resp = self._http.get2_cmd('{}{}'.format(self._apiBase,filter_string)) #print('RESP: {}'.format(resp)) if resp: - return resp + return json.loads(resp) return list() def get(self, name): """Returns a VNF instance based on name or id """ + self._logger.debug("") self._client.get_token() if utils.validate_uuid4(name): for vnf in self.list(): @@ -62,11 +66,12 @@ class Vnf(object): return vnf else: for vnf in self.list(): - if name == vnf['name']: + if name == vnf.get('name'): return vnf raise NotFound("vnf {} not found".format(name)) def get_individual(self, name): + self._logger.debug("") self._client.get_token() vnf_id = name if not utils.validate_uuid4(name): @@ -74,9 +79,11 @@ class Vnf(object): if name == vnf['name']: vnf_id = vnf['_id'] break - resp = self._http.get_cmd('{}/{}'.format(self._apiBase, vnf_id)) - #print('RESP: {}'.format(resp)) - if resp: - return resp - raise NotFound("vnf {} not found".format(name)) - + try: + _, resp = self._http.get2_cmd('{}/{}'.format(self._apiBase, vnf_id)) + #print('RESP: {}'.format(resp)) + if resp: + return json.loads(resp) + except NotFound: + raise NotFound("vnf '{}' not found".format(name)) + raise NotFound("vnf '{}' not found".format(name))