object_store: exposes the prefix parameter

The prefix parameter can be used to filter the list of containers or
objects. Without it, its mostly impossible to handle container with
large amount of objects.

Change-Id: Id39cedd3d7a7e402e325ac476d0c80bb42aa4a4d

openstack/cloud/openstackcloud.py

@@ -7412,7 +7412,7 @@ class _OpenStackCloudMixin(_normalize.Normalizer):
 
         return True
 
-    def list_containers(self, full_listing=True):
+    def list_containers(self, full_listing=True, prefix=None):
         """List containers.
 
         :param full_listing: Ignored. Present for backwards compat
@@ -7421,7 +7421,8 @@ class _OpenStackCloudMixin(_normalize.Normalizer):
 
         :raises: OpenStackCloudException on operation error.
         """
-        response = self.object_store.get('/', params=dict(format='json'))
+        params = dict(format='json', prefix=prefix)
+        response = self.object_store.get('/', params=params)
         return self._get_and_munchify(None, _adapter._json_response(response))
 
     def search_containers(self, name=None, filters=None):
@@ -7971,18 +7972,21 @@ class _OpenStackCloudMixin(_normalize.Normalizer):
                 container=container, object=name),
             headers=headers)
 
-    def list_objects(self, container, full_listing=True):
+    def list_objects(self, container, full_listing=True, prefix=None):
         """List objects.
 
         :param container: Name of the container to list objects in.
         :param full_listing: Ignored. Present for backwards compat
+        :param string prefix:
+            only objects with this prefix will be returned.
+            (optional)
 
         :returns: list of Munch of the objects
 
         :raises: OpenStackCloudException on operation error.
         """
-        data = self._object_store_client.get(
-            container, params=dict(format='json'))
+        params = dict(format='json', prefix=prefix)
+        data = self._object_store_client.get(container, params=params)
         return self._get_and_munchify(None, data)
 
     def search_objects(self, container, name=None, filters=None):

openstack/object_store/v1/container.py

@@ -37,6 +37,10 @@ class Container(_base.BaseResource):
     allow_list = True
     allow_head = True
 
+    _query_mapping = resource.QueryParameters(
+        'prefix',
+    )
+
     # Container body data (when id=None)
     #: The name of the container.
     name = resource.Body("name", alternate_id=True, alias='id')

openstack/object_store/v1/obj.py

@@ -39,6 +39,10 @@ class Object(_base.BaseResource):
     allow_list = True
     allow_head = True
 
+    _query_mapping = resource.QueryParameters(
+        'prefix',
+    )
+
     # Data to be passed during a POST call to create an object on the server.
     # TODO(mordred) Make a base class BaseDataResource that can be used here
     # and with glance images that has standard overrides for dealing with

openstack/tests/functional/cloud/test_object.py

@@ -42,6 +42,8 @@ class TestObject(base.BaseFunctionalTest):
         self.user_cloud.create_container(container_name)
         self.assertEqual(container_name,
                          self.user_cloud.list_containers()[0]['name'])
+        self.assertEqual([],
+                         self.user_cloud.list_containers(prefix='somethin'))
         sizes = (
             (64 * 1024, 1),  # 64K, one segment
             (64 * 1024, 5)   # 64MB, 5 segments
@@ -90,6 +92,10 @@ class TestObject(base.BaseFunctionalTest):
             self.assertEqual(
                 name,
                 self.user_cloud.list_objects(container_name)[0]['name'])
+            self.assertEqual(
+                [],
+                self.user_cloud.list_objects(container_name,
+                                             prefix='abc'))
             self.assertTrue(
                 self.user_cloud.delete_object(container_name, name))
         self.assertEqual([], self.user_cloud.list_objects(container_name))

openstack/tests/unit/cloud/test_object.py

@@ -282,6 +282,25 @@ class TestObject(BaseTestObject):
         self.assert_calls()
         self.assertEqual(objects, ret)
 
+    def test_list_objects_with_prefix(self):
+        endpoint = '{endpoint}?format=json&prefix=test'.format(
+            endpoint=self.container_endpoint)
+
+        objects = [{
+            u'bytes': 20304400896,
+            u'last_modified': u'2016-12-15T13:34:13.650090',
+            u'hash': u'daaf9ed2106d09bba96cf193d866445e',
+            u'name': self.object,
+            u'content_type': u'application/octet-stream'}]
+
+        self.register_uris([dict(method='GET', uri=endpoint, complete_qs=True,
+                                 json=objects)])
+
+        ret = self.cloud.list_objects(self.container, prefix='test')
+
+        self.assert_calls()
+        self.assertEqual(objects, ret)
+
     def test_list_objects_exception(self):
         endpoint = '{endpoint}?format=json'.format(
             endpoint=self.container_endpoint)