Synnefo » Pithos

    if not limit:

        limit = 10000

    if request.serialization == 'text':

        if len(accounts) == 0:

    account_meta = []

    for x in accounts:

            continue

        try:

        except NotAllowedError:

            raise Forbidden('Not allowed')

        else:

    until = get_int_parameter(request.GET.get('until'))

    try:

    except NotAllowedError:

        raise Forbidden('Not allowed')

        replace = False

    if groups:

        try:

                                                    groups, replace)

        except NotAllowedError:

            raise Forbidden('Not allowed')

            raise BadRequest('Invalid groups header')

    if meta or replace:

        try:

                                                'pithos', meta, replace)

        except NotAllowedError:

            raise Forbidden('Not allowed')

    until = get_int_parameter(request.GET.get('until'))

    try:

    except NotAllowedError:

        raise Forbidden('Not allowed')

        shared = True

    try:

                                                marker, limit, shared, until)

    except NotAllowedError:

        raise Forbidden('Not allowed')

    container_meta = []

    for x in containers:

        try:

                                                        x, 'pithos', until, include_user_defined=False)

                                                            v_account, x)

        except NotAllowedError:

            raise Forbidden('Not allowed')

    until = get_int_parameter(request.GET.get('until'))

    try:

                                                    v_container, 'pithos', until)

                                                v_account, v_container, 'pithos', until)

                                                        v_container)

    except NotAllowedError:

        raise Forbidden('Not allowed')

    meta, policy = get_container_headers(request)

    try:

        ret = 201

    except NotAllowedError:

        raise Forbidden('Not allowed')

    if ret == 202 and policy:

        try:

                                            v_container, policy, replace=False)

        except NotAllowedError:

            raise Forbidden('Not allowed')

            raise BadRequest('Invalid policy header')

    if meta:

        try:

                                            v_container, 'pithos', meta, replace=False)

        except NotAllowedError:

            raise Forbidden('Not allowed')

        replace = False

    if policy:

        try:

                                                v_container, policy, replace)

        except NotAllowedError:

            raise Forbidden('Not allowed')

            raise BadRequest('Invalid policy header')

    if meta or replace:

        try:

                                                    v_container, 'pithos', meta, replace)

        except NotAllowedError:

            raise Forbidden('Not allowed')

    until = get_int_parameter(request.GET.get('until'))

    try:

                                            until)

    except NotAllowedError:

        raise Forbidden('Not allowed')

    until = get_int_parameter(request.GET.get('until'))

    try:

                                                    v_container, 'pithos', until)

                                                v_account, v_container, 'pithos', until)

                                                        v_container)

    except NotAllowedError:

        raise Forbidden('Not allowed')

    if request.serialization == 'text':

        try:

                                        v_container, prefix, delimiter, marker,

                                        limit, virtual, 'pithos', keys, shared, until)

        except NotAllowedError:

        return response

    try:

                                    v_container, prefix, delimiter, marker,

                                    limit, virtual, 'pithos', keys, shared, until)

        object_permissions = {}

        object_public = {}

        if until is None:

            name_idx = len('/'.join((v_account, v_container, '')))

                                    v_account, v_container, prefix):

                object = x[name_idx:]

                object_permissions[object] = request.backend.get_object_permissions(

                                    v_account, v_container, prefix).iteritems():

                object_public[k[name_idx:]] = v

    except NotAllowedError:

    version = request.GET.get('version')

    try:

                                                v_container, v_object, 'pithos', version)

        if version is None:

                                            v_account, v_container, v_object)

                                                        v_container, v_object)

        else:

            permissions = None

            raise BadRequest('No format specified for version list.')

        try:

                                                v_container, v_object)

        except NotAllowedError:

            raise Forbidden('Not allowed')

        return response

    try:

                                                v_container, v_object, 'pithos', version)

        if version is None:

                                            v_account, v_container, v_object)

                                                        v_container, v_object)

        else:

            permissions = None

    if 'X-Object-Manifest' in meta and not hashmap_reply:

        try:

            src_container, src_name = split_container_object_string('/' + meta['X-Object-Manifest'])

                                src_container, prefix=src_name, virtual=False)

        except NotAllowedError:

            raise Forbidden('Not allowed')

        try:

            for x in objects:

                                        v_account, src_container, x[0], x[1])

                sizes.append(s)

                hashmaps.append(h)

            raise ItemNotFound('Version does not exist')

    else:

        try:

                                                v_container, v_object, version)

            sizes.append(s)

            hashmaps.append(h)

    # Evaluate conditions.

    if request.META.get('HTTP_IF_MATCH') or request.META.get('HTTP_IF_NONE_MATCH'):

        try:

                                                        v_container, v_object, 'pithos')

        except NotAllowedError:

            raise Forbidden('Not allowed')

        src_account = request.META.get('HTTP_X_SOURCE_ACCOUNT')

        if not src_account:

        if move_from:

            try:

                src_container, src_name = split_container_object_string(move_from)

            raise UnprocessableEntity('Object ETag does not match')

    try:

                        v_account, v_container, v_object, size, content_type,

                        hashmap, checksum, 'pithos', meta, True, permissions)

    except NotAllowedError:

        # Update the MD5 after the hashmap, as there may be missing hashes.

        checksum = hashmap_md5(request, hashmap, size)

        try:

                            v_account, v_container, v_object, version_id, checksum)

        except NotAllowedError:

            raise Forbidden('Not allowed')

    if public is not None:

        try:

                                                v_container, v_object, public)

        except NotAllowedError:

            raise Forbidden('Not allowed')

    checksum = file.etag

    try:

                        v_account, v_container, v_object, file.size, file.content_type,

                        file.hashmap, checksum, 'pithos', {}, True)

    except NotAllowedError:

    dest_account = request.META.get('HTTP_DESTINATION_ACCOUNT')

    if not dest_account:

    dest_path = request.META.get('HTTP_DESTINATION')

    if not dest_path:

        raise BadRequest('Missing Destination header')

    if request.META.get('HTTP_IF_MATCH') or request.META.get('HTTP_IF_NONE_MATCH'):

        src_version = request.META.get('HTTP_X_SOURCE_VERSION')

        try:

                                            v_container, v_object, 'pithos', src_version)

        except NotAllowedError:

            raise Forbidden('Not allowed')

    dest_account = request.META.get('HTTP_DESTINATION_ACCOUNT')

    if not dest_account:

    dest_path = request.META.get('HTTP_DESTINATION')

    if not dest_path:

        raise BadRequest('Missing Destination header')

    # Evaluate conditions.

    if request.META.get('HTTP_IF_MATCH') or request.META.get('HTTP_IF_NONE_MATCH'):

        try:

                                                    v_container, v_object, 'pithos')

        except NotAllowedError:

            raise Forbidden('Not allowed')

    content_type, meta, permissions, public = get_object_headers(request)

    try:

                                                    v_container, v_object, 'pithos')

    except NotAllowedError:

        raise Forbidden('Not allowed')

        # Do permissions first, as it may fail easier.

        if permissions is not None:

            try:

                                v_account, v_container, v_object, permissions)

            except NotAllowedError:

                raise Forbidden('Not allowed')

                raise BadRequest('Invalid sharing header')

        if public is not None:

            try:

                                                v_container, v_object, public)

            except NotAllowedError:

                raise Forbidden('Not allowed')

                raise ItemNotFound('Object does not exist')

        if meta or replace:

            try:

                                v_account, v_container, v_object, 'pithos', meta, replace)

            except NotAllowedError:

                raise Forbidden('Not allowed')

        raise RangeNotSatisfiable('Invalid Content-Range header')

    try:

                                            v_account, v_container, v_object)

    except NotAllowedError:

        raise Forbidden('Not allowed')

    if src_object:

        src_account = request.META.get('HTTP_X_SOURCE_ACCOUNT')

        if not src_account:

        src_container, src_name = split_container_object_string(src_object)

        src_version = request.META.get('HTTP_X_SOURCE_VERSION')

        try:

                                        src_account, src_container, src_name, src_version)

        except NotAllowedError:

            raise Forbidden('Not allowed')

        hashmap = hashmap[:(int((size - 1) / request.backend.block_size) + 1)]

    checksum = hashmap_md5(request, hashmap, size)

    try:

                        v_account, v_container, v_object, size, prev_meta['type'],

                        hashmap, checksum, 'pithos', meta, replace, permissions)

    except NotAllowedError:

        raise RequestEntityTooLarge('Quota exceeded')

    if public is not None:

        try:

                                                v_container, v_object, public)

        except NotAllowedError:

            raise Forbidden('Not allowed')

    until = get_int_parameter(request.GET.get('until'))

    try:

                                        v_object, until)

    except NotAllowedError:

        raise Forbidden('Not allowed')