Synnefo

        if shared and public:

            # get shared first

            shared = self._list_object_permissions(user, account, container, prefix, shared=True, public=False)

            if shared:

                path, node = self._lookup_container(account, container)

                shared = self._get_formatted_paths(shared)

            # get public

            objects.sort(key=lambda x: x[0])

            start, limit = self._list_limits([x[0] for x in objects], marker, limit)

    def _report_object_change(self, user, account, path, details={}):

        logger.debug("_report_object_change: %s %s %s %s", user, account, path, details)

        self.messages.append((QUEUE_MESSAGE_KEY_PREFIX % ('object',), account, QUEUE_INSTANCE_ID, 'object', path, details))

    def _report_sharing_change(self, user, account, path, details={}):

    #TODO unauthorized request

    def setUp(self):

        self.client = Pithos_Client(get_url(), get_auth(), get_user())

        self._clean_account()

        self.invalid_client = Pithos_Client(get_url(), get_auth(), 'invalid')

        #keep track of initial account meta

        self.initial_meta = self.client.retrieve_account_metadata(restricted=True)

        self.extended = {

            'container':(

                'name',

    def _clean_account(self):

        for c in self.client.list_containers():

    def assert_status(self, status, codes):

        l = [elem for elem in self.return_codes]

class AccountHead(BaseTestCase):

    def setUp(self):

        BaseTestCase.setUp(self)

        for item in self.containers:

            self.client.create_container(item)

        containers = self.client.list_containers()

        l = str(len(containers))

        self.assertEqual(meta['x-account-container-count'], l)

        for c in containers:

            m = self.client.retrieve_container_metadata(c)

    def test_get_account_403(self):

        self.assert_raises_fault(403,

    def setUp(self):

        BaseTestCase.setUp(self)

        #create some containers

        for item in self.containers:

            self.client.create_container(item)

        xml = self.client.list_containers(limit=l, marker=m, format='xml')

        self.assert_extended(xml, 'xml', 'container', l)

        nodes = xml.getElementsByTagName('name')

    def test_if_modified_since(self):

        t = datetime.datetime.utcnow()

                self.assertEqual(len(c), len(self.containers) + 1)

            except Fault, f:

                self.failIf(f.status == 304) #fail if not modified

    def test_if_modified_since_invalid_date(self):

        c = self.client.list_containers(if_modified_since='')

        self.assertEqual(len(c), len(self.containers))

class AccountPost(BaseTestCase):

    def setUp(self):

        BaseTestCase.setUp(self)

        for item in self.containers:

            self.client.create_container(item)

class ContainerPut(BaseTestCase):

    def setUp(self):

        BaseTestCase.setUp(self)

    def test_create(self):

        self.client.create_container(self.containers[0])

        containers = self.client.list_containers()

        self.client.create_container(self.containers[0])

        policy = {'quota':100}

        self.assertTrue('x-container-policy-quota' in meta)

        self.assertEqual(meta['x-container-policy-quota'], '100')

        kwargs = {'length':101}

        self.assert_raises_fault(413, self.upload_random_data, *args, **kwargs)

        #reset quota

        policy = {'quota':0}

class ContainerPost(BaseTestCase):

    def setUp(self):

class ContainerDelete(BaseTestCase):

    def setUp(self):

        BaseTestCase.setUp(self)

        for c in self.containers:

            self.client.create_container(c)

class ObjectGet(BaseTestCase):

    def setUp(self):

        BaseTestCase.setUp(self)

        #create some containers

        for c in self.containers:

            self.client.create_container(c)

class ObjectCopy(BaseTestCase):

    def setUp(self):

        BaseTestCase.setUp(self)

        for c in self.containers:

            self.client.create_container(c)

        self.obj = self.upload_random_data(self.containers[0], o_names[0])

class ObjectMove(BaseTestCase):

    def setUp(self):

        BaseTestCase.setUp(self)

        for c in self.containers:

            self.client.create_container(c)

        self.obj = self.upload_random_data(self.containers[0], o_names[0])

class ObjectPost(BaseTestCase):

    def setUp(self):

        BaseTestCase.setUp(self)

        for c in self.containers:

            self.client.create_container(c)

        self.obj = []

    def setUp(self):

        BaseTestCase.setUp(self)

        self.containers = ['c1', 'c2']

        for c in self.containers:

            self.client.create_container(c)

        self.obj = self.upload_random_data(self.containers[0], o_names[0])

                self.client.publish_object(c, 'o2')

    def test_shared_public(self):

        func, kwargs = self.client.list_containers, {'shared':True}

        l = func(**kwargs)

        self.assertEqual(l, [e['name'] for e in func(format='json', **kwargs)])

        func, kwargs = self.client.list_containers, {'public':True}

        l = func(**kwargs)

        self.assertEqual(l, [e['name'] for e in func(format='json', **kwargs)])

        func, kwargs = self.client.list_containers, {'shared':True, 'public':True}

        l = func(**kwargs)

        self.assertEqual(l, [e['name'] for e in func(format='json', **kwargs)])

        self.client.share_object(self.container, self.object, self.authorized)

        my_shared_containers = self.client.list_containers(shared=True)

        my_shared_objects = self.client.list_objects('c', shared=True)

        self.assertEqual(['o'], my_shared_objects)