Synnefo

Revision                   Description

=========================  ================================

0.14 (Jun 18, 2013)        Forbidden response for public listing by non path owners

0.13 (Mar 27, 2013)        Restrict public object listing only to the owner.

\                          Do not propagate public URL information in shared objects.

0.13 (Jan 21, 2013)        Proxy identity management services

\                          UUID to displayname translation

0.10 (Jul 18, 2012)        Support for bulk COPY/MOVE/DELETE

\                          Optionally include public objects in listings.

0.9 (Feb 17, 2012)         Change permissions model.

==========================  ===============================

Reply Header Name           Value

==========================  ===============================

X-Object-Version            The object's new version

==========================  ===============================

409 (Conflict)                  The object can not be created from the provided hashmap (a list of missing hashes will be included in the reply)

411 (Length Required)           Missing ``Content-Length`` or ``Content-Type`` in the request

413 (Request Entity Too Large)  Insufficient quota to complete the request

==============================  ==============================

==========================  ===============================

Reply Header Name           Value

==========================  ===============================

X-Object-Version            The object's new version

==========================  ===============================

    copy_or_move_object, get_int_parameter, get_content_length,

    get_content_range, socket_read_iterator, SaveToBackendHandler,

    object_data_response, put_object_block, hashmap_md5, simple_list_response,

)

from pithos.api.settings import (UPDATE_MD5, TRANSLATE_UUIDS,

from pithos.api import settings

from pithos.backends.base import (

    NotAllowedError, QuotaError, ContainerNotEmpty, ItemNotExists,

    VersionNotExists, ContainerExists)

from pithos.backends.filter import parse_filters

import logging

logger = logging.getLogger(__name__)

        validate_matching_preconditions(request, meta)

    except faults.NotModified:

        response = HttpResponse(status=304)

        return response

    response = HttpResponse(status=200)

        validate_matching_preconditions(request, meta)

    except faults.NotModified:

        response = HttpResponse(status=304)

        return response

    hashmap_reply = False

        checksum = ''  # Do not set to None (will copy previous value).

    else:

        size = 0

        hashmap = []

        for data in socket_read_iterator(request, content_length,

            #       and we stop before getting this much data.

            size += len(data)

            hashmap.append(request.backend.put_block(data))

        if etag and parse_etags(etag)[0].lower() != checksum:

            raise faults.UnprocessableEntity('Object ETag does not match')

    try:

    except NotAllowedError:

        raise faults.Forbidden('Not allowed')

    except IndexError, e:

            raise faults.ItemNotFound('Object does not exist')

    response = HttpResponse(status=201)

    response['X-Object-Version'] = version_id

    return response

    checksum = file.etag

    try:

    except NotAllowedError:

        raise faults.Forbidden('Not allowed')

    except ItemNotExists:

        raise faults.RequestEntityTooLarge('Quota error: %s' % e)

    response = HttpResponse(status=201)

    response['X-Object-Version'] = version_id

    response.content = checksum

    return response

    checksum = hashmap_md5(

        request.backend, hashmap, size) if UPDATE_MD5 else ''

    try:

    except NotAllowedError:

        raise faults.Forbidden('Not allowed')

    except ItemNotExists:

            raise faults.ItemNotFound('Object does not exist')

    response = HttpResponse(status=204)

    response['X-Object-Version'] = version_id

    return response

# interpreted as representing official policies, either expressed

# or implied, of GRNET S.A.

import re

import os

        return self.backend._lookup_account(account, create=True)

    def create_update_object(self, account, container, name, content_type,

        meta = meta or {}

        permissions = permissions or {}

        size = 0

        hashmap = []

        for block_data in data_read_iterator(data, self.backend.block_size):

            size += len(block_data)

            hashmap.append(self.backend.put_block(block_data))

        request_user = request_user or account

        return self.backend.update_object_hashmap(request_user, account,

                                                   'object1',

                                                   'application/octet-stream',

                                                   data))

                          self.utils.list_past_versions('account1',

                                                        'container1',

                                                        'object1'))

                               dry=False, silent=True)

        expected = {'meta': meta,

                    'permissions': permissions}

        self._verify_object('account1', 'container1', 'object1', expected)

                    'permissions': permissions}

        for c, o_dict in versions.iteritems():

            for o, versions in o_dict.iteritems():

                self._verify_object('account1', c, o, expected)

    def test_merge_existing_dest_container(self):

            self.fail(e)

        expected = {'meta': meta,

                    'permissions': permissions}

        self._verify_object('account1', 'container1', 'object1', expected)

        expected = {'meta': meta,

                    'permissions': permissions,

        self._verify_object('account1', container, object, expected,

                            strict=False)

                                 BACKEND_BLOCK_SIZE, BACKEND_HASH_ALGORITHM,

                                 RADOS_STORAGE, RADOS_POOL_BLOCKS,

                                 RADOS_POOL_MAPS, TRANSLATE_UUIDS,

from pithos.api.resources import resources

from pithos.backends.base import (NotAllowedError, QuotaError, ItemNotExists,

                                  VersionNotExists)

def put_object_headers(response, meta, restricted=False, token=None):

    response['Content-Length'] = meta['bytes']

    response.override_serialization = True

    response['Content-Type'] = meta.get('type', 'application/octet-stream')

                request.user_uniq, v_account,

                src_container, prefix=src_name, virtual=False)

            for x in objects:

                bytes += src_meta['bytes']

        except:

            # Ignore errors.

def validate_matching_preconditions(request, meta):

    """Check that the ETag conforms with the preconditions set."""

    if not etag:

        etag = None

        if len(self.data) >= length:

            block = self.data[:length]

            self.file.hashmap.append(self.backend.put_block(block))

            self.data = self.data[length:]

    def new_file(self, field_name, file_name, content_type,

                 content_length, charset=None):

        self.data = ''

        self.file = UploadedFile(

            name=file_name, content_type=content_type, charset=charset)

        l = len(self.data)

        if l > 0:

            self.put_data(l)

        return self.file

                raise Exception(response)

        return wrapper

    return decorator

            raise ie

        hash = map.hash()

        self.store.map_put(hash, map)

    def update_object_checksum(self, user, account, container, name, version, checksum):

        """Update an object's checksum."""