summaryrefslogtreecommitdiff
path: root/openstackclient/object
diff options
context:
space:
mode:
authorDean Troyer <dtroyer@gmail.com>2013-08-30 17:55:37 -0500
committerDean Troyer <dtroyer@gmail.com>2013-09-26 13:34:11 -0500
commitad59b03be6af9da31230689af268139b12b548e7 (patch)
tree0394d365ab2b1d847ae20f46b0c208a71e5dd9a3 /openstackclient/object
parent74f4e3138996e258d4bdce1a162a5dade62a0c15 (diff)
downloadpython-openstackclient-ad59b03be6af9da31230689af268139b12b548e7.tar.gz
Add object-store show commands
* Add lib.container.show_container() and lib.object.show_object() * Add container and object show commands Change-Id: I963d664c55b59739453345f0f353aa2eaf1bf70e
Diffstat (limited to 'openstackclient/object')
-rw-r--r--openstackclient/object/v1/container.py29
-rw-r--r--openstackclient/object/v1/lib/container.py36
-rw-r--r--openstackclient/object/v1/lib/object.py51
-rw-r--r--openstackclient/object/v1/object.py34
4 files changed, 149 insertions, 1 deletions
diff --git a/openstackclient/object/v1/container.py b/openstackclient/object/v1/container.py
index 8c4db66a..68b14fc5 100644
--- a/openstackclient/object/v1/container.py
+++ b/openstackclient/object/v1/container.py
@@ -17,8 +17,10 @@
import logging
+import six
from cliff import lister
+from cliff import show
from openstackclient.common import utils
from openstackclient.object.v1.lib import container as lib_container
@@ -91,10 +93,35 @@ class ListContainer(lister.Lister):
self.app.client_manager.object.endpoint,
**kwargs
)
- #print "data: %s" % data
return (columns,
(utils.get_dict_properties(
s, columns,
formatters={},
) for s in data))
+
+
+class ShowContainer(show.ShowOne):
+ """Show container information"""
+
+ log = logging.getLogger(__name__ + '.ShowContainer')
+
+ def get_parser(self, prog_name):
+ parser = super(ShowContainer, self).get_parser(prog_name)
+ parser.add_argument(
+ 'container',
+ metavar='<container>',
+ help='Container name to display',
+ )
+ return parser
+
+ def take_action(self, parsed_args):
+ self.log.debug('take_action(%s)' % parsed_args)
+
+ data = lib_container.show_container(
+ self.app.restapi,
+ self.app.client_manager.object.endpoint,
+ parsed_args.container,
+ )
+
+ return zip(*sorted(six.iteritems(data)))
diff --git a/openstackclient/object/v1/lib/container.py b/openstackclient/object/v1/lib/container.py
index f30533c8..5103d9d4 100644
--- a/openstackclient/object/v1/lib/container.py
+++ b/openstackclient/object/v1/lib/container.py
@@ -16,6 +16,11 @@
"""Object v1 API library"""
+try:
+ from urllib.parse import urlparse
+except ImportError:
+ from urlparse import urlparse
+
def list_containers(
api,
@@ -75,3 +80,34 @@ def list_containers(
url = "%s?%s" % (object_url, query)
response = api.request('GET', url)
return response.json()
+
+
+def show_container(
+ api,
+ url,
+ container,
+):
+ """Get container details
+
+ :param api: a restapi object
+ :param url: endpoint
+ :param container: name of container to show
+ :returns: dict of returned headers
+ """
+
+ object_url = "%s/%s" % (url, container)
+ url_parts = urlparse(url)
+ response = api.request('HEAD', object_url)
+ data = {
+ 'account': url_parts.path.split('/')[-1],
+ 'container': container,
+ }
+ data['object_count'] = response.headers.get(
+ 'x-container-object-count', None)
+ data['bytes_used'] = response.headers.get('x-container-bytes-used', None)
+ data['read_acl'] = response.headers.get('x-container-read', None)
+ data['write_acl'] = response.headers.get('x-container-write', None)
+ data['sync_to'] = response.headers.get('x-container-sync-to', None)
+ data['sync_key'] = response.headers.get('x-container-sync-key', None)
+
+ return data
diff --git a/openstackclient/object/v1/lib/object.py b/openstackclient/object/v1/lib/object.py
index d7c4a1ce..8ad5e5a5 100644
--- a/openstackclient/object/v1/lib/object.py
+++ b/openstackclient/object/v1/lib/object.py
@@ -16,6 +16,13 @@
"""Object v1 API library"""
+import six
+
+try:
+ from urllib.parse import urlparse
+except ImportError:
+ from urlparse import urlparse
+
def list_objects(
api,
@@ -95,3 +102,47 @@ def list_objects(
url = "%s/%s?%s" % (object_url, container, query)
response = api.request('GET', url)
return response.json()
+
+
+def show_object(
+ api,
+ url,
+ container,
+ obj,
+):
+ """Get object details
+
+ :param api: a restapi object
+ :param url: endpoint
+ :param container: container name to get a listing for
+ :returns: dict of object properties
+ """
+
+ object_url = "%s/%s/%s" % (url, container, obj)
+ url_parts = urlparse(url)
+ response = api.request('HEAD', object_url)
+ data = {
+ 'account': url_parts.path.split('/')[-1],
+ 'container': container,
+ 'object': obj,
+ }
+ #print "data: %s" % data
+ data['content-type'] = response.headers.get('content-type', None)
+ if 'content-length' in response.headers:
+ data['content-length'] = response.headers.get('content-length', None)
+ if 'last-modified' in response.headers:
+ data['last-modified'] = response.headers.get('last-modified', None)
+ if 'etag' in response.headers:
+ data['etag'] = response.headers.get('etag', None)
+ if 'x-object-manifest' in response.headers:
+ data['x-object-manifest'] = response.headers.get(
+ 'x-object-manifest', None)
+ for key, value in six.iteritems(response.headers):
+ if key.startswith('x-object-meta-'):
+ data[key[len('x-object-meta-'):].title()] = value
+ elif key not in (
+ 'content-type', 'content-length', 'last-modified',
+ 'etag', 'date', 'x-object-manifest'):
+ data[key.title()] = value
+
+ return data
diff --git a/openstackclient/object/v1/object.py b/openstackclient/object/v1/object.py
index c6bd755b..426a52ad 100644
--- a/openstackclient/object/v1/object.py
+++ b/openstackclient/object/v1/object.py
@@ -17,8 +17,10 @@
import logging
+import six
from cliff import lister
+from cliff import show
from openstackclient.common import utils
from openstackclient.object.v1.lib import object as lib_object
@@ -116,3 +118,35 @@ class ListObject(lister.Lister):
s, columns,
formatters={},
) for s in data))
+
+
+class ShowObject(show.ShowOne):
+ """Show object information"""
+
+ log = logging.getLogger(__name__ + '.ShowObject')
+
+ def get_parser(self, prog_name):
+ parser = super(ShowObject, self).get_parser(prog_name)
+ parser.add_argument(
+ 'container',
+ metavar='<container>',
+ help='Container name for object to display',
+ )
+ parser.add_argument(
+ 'object',
+ metavar='<object>',
+ help='Object name to display',
+ )
+ return parser
+
+ def take_action(self, parsed_args):
+ self.log.debug('take_action(%s)' % parsed_args)
+
+ data = lib_object.show_object(
+ self.app.restapi,
+ self.app.client_manager.object.endpoint,
+ parsed_args.container,
+ parsed_args.object,
+ )
+
+ return zip(*sorted(six.iteritems(data)))