X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=client%2Fescalatorclient%2Fv1%2Fversions.py;h=811e577fd73c135de42afcd6d8970fc5917f65d8;hb=a0d08d9962ddae946f83f81659d6bad2446db2a7;hp=f54ea2390f1e009e8d792af3c512c5357d788c70;hpb=3f262284f3ce78ce23b4e3c8e9fed112fc56e37d;p=escalator.git

diff --git a/client/escalatorclient/v1/versions.py b/client/escalatorclient/v1/versions.py
index f54ea23..811e577 100644
--- a/client/escalatorclient/v1/versions.py
+++ b/client/escalatorclient/v1/versions.py
@@ -22,6 +22,7 @@ import six.moves.urllib.parse as urlparse
 
 from escalatorclient.common import utils
 from escalatorclient.openstack.common.apiclient import base
+from escalatorclient.common.http import HTTPClient
 
 CREATE_PARAMS = ('id', 'name', 'description', 'type', 'version', 'size',
                  'checksum', 'status', 'os_status', 'version_patch')
@@ -53,8 +54,14 @@ class Version(base.Resource):
 class VersionManager(base.ManagerWithFind):
     resource_class = Version
 
+    def get_version_client(self):
+        endpoint = "http://127.0.0.1:19292"
+        client = HTTPClient(endpoint)
+        return client
+
     def _list(self, url, response_key, obj_class=None, body=None):
-        resp, body = self.client.get(url)
+        version_client = self.get_version_client()
+        resp, body = version_client.get(url)
 
         if obj_class is None:
             obj_class = self.resource_class
@@ -98,23 +105,6 @@ class VersionManager(base.ManagerWithFind):
                     pass
         return meta
 
-    def get(self, version, **kwargs):
-        """Get the metadata for a specific version.
-
-        :param version: image object or id to look up
-        :rtype: :class:`version`
-        """
-        version_id = base.getid(version)
-        resp, body = self.client.get('/v1/versions/%s'
-                                     % urlparse.quote(str(version_id)))
-        # meta = self._version_meta_from_headers(resp.headers)
-        return_request_id = kwargs.get('return_req_id', None)
-        if return_request_id is not None:
-            return_request_id.append(resp.headers.get(OS_REQ_ID_HDR, None))
-        # return version(self, meta)
-        return Version(self, self._format_version_meta_for_user(
-            body['version']))
-
     def _build_params(self, parameters):
         params = {'limit': parameters.get('page_size', DEFAULT_PAGE_SIZE)}
 
@@ -216,70 +206,12 @@ class VersionManager(base.ManagerWithFind):
             params['marker'] = last_version
             seen_last_page = 0
 
-    def add(self, **kwargs):
-        """Add a version
-
-        TODO(bcwaldon): document accepted params
-        """
-
-        fields = {}
-        for field in kwargs:
-            if field in CREATE_PARAMS:
-                fields[field] = kwargs[field]
-            elif field == 'return_req_id':
-                continue
-            else:
-                msg = 'create() got an unexpected keyword argument \'%s\''
-                raise TypeError(msg % field)
-
-        hdrs = self._version_meta_to_headers(fields)
-
-        resp, body = self.client.post('/v1/versions',
-                                      headers=None,
-                                      data=hdrs)
-        return_request_id = kwargs.get('return_req_id', None)
-        if return_request_id is not None:
-            return_request_id.append(resp.headers.get(OS_REQ_ID_HDR, None))
-
-        return Version(self, self._format_version_meta_for_user(
-            body['version']))
-
-    def delete(self, version, **kwargs):
-        """Delete an version."""
-        url = "/v1/versions/%s" % base.getid(version)
-        resp, body = self.client.delete(url)
-        return_request_id = kwargs.get('return_req_id', None)
-        if return_request_id is not None:
-            return_request_id.append(resp.headers.get(OS_REQ_ID_HDR, None))
-
-    def update(self, version, **kwargs):
-        """Update an version
-
-        TODO(bcwaldon): document accepted params
-        """
-        hdrs = {}
-        fields = {}
-        for field in kwargs:
-            if field in CREATE_PARAMS:
-                fields[field] = kwargs[field]
-            elif field == 'return_req_id':
-                continue
-        hdrs.update(self._version_meta_to_headers(fields))
-
-        url = '/v1/versions/%s' % base.getid(version)
-        resp, body = self.client.put(url, headers=None, data=hdrs)
-        return_request_id = kwargs.get('return_req_id', None)
-        if return_request_id is not None:
-            return_request_id.append(resp.headers.get(OS_REQ_ID_HDR, None))
-
-        return Version(self, self._format_version_meta_for_user(
-            body['version_meta']))
-
     def version(self, **kwargs):
         """Get internal or external version of escalator.
 
         TODO(bcwaldon): document accepted params
         """
+        version_client = HTTPClient("http://127.0.0.1:19393")
         fields = {}
         for field in kwargs:
             if field in VERSION_PARAMS:
@@ -288,7 +220,7 @@ class VersionManager(base.ManagerWithFind):
                 msg = 'install() got an unexpected keyword argument \'%s\''
                 raise TypeError(msg % field)
 
-        url = '/v1/version'
-        hdrs = self._restore_meta_to_headers(fields)
-        resp, body = self.client.post(url, headers=None, data=hdrs)
+        url = '/v1/versions'
+        hdrs = self._version_meta_to_headers(fields)
+        resp, body = version_client.post(url, headers=None, data=hdrs)
         return Version(self, body)