Synnefo

from django.utils.encoding import smart_str

from django.views.decorators.csrf import csrf_exempt

from snf_django.lib.astakos import get_uuids as _get_uuids

from snf_django.lib import api

    get_content_range, socket_read_iterator, SaveToBackendHandler,

    object_data_response, put_object_block, hashmap_md5, simple_list_response,

    api_method, is_uuid,

    get_pithos_usage

)

@csrf_exempt

def object_demux(request, v_account, v_container, v_object):

    if TRANSLATE_UUIDS:

        if not is_uuid(v_account):

            uuids = get_uuids([v_account])

    elif request.method == 'MOVE':

        return object_move(request, v_account, v_container, v_object)

    elif request.method == 'POST':

            return object_write_form(request, v_account, v_container, v_object)

        return object_update(request, v_account, v_container, v_object)

    elif request.method == 'DELETE':

    if request.serialization == 'text':

        if TRANSLATE_UUIDS:

            accounts = retrieve_displaynames(

        if len(accounts) == 0:

            # The cloudfiles python bindings expect 200 if json/xml.

            response.status_code = 204

    if TRANSLATE_UUIDS:

        uuids = list(d['name'] for d in account_meta)

        catalog = retrieve_displaynames(

        for meta in account_meta:

            meta['name'] = catalog.get(meta.get('name'))

        if TRANSLATE_UUIDS:

            for k in groups:

                groups[k] = retrieve_displaynames(

        policy = request.backend.get_account_policy(

            request.user_uniq, v_account, external_quota=usage)

    except NotAllowedError:

        if TRANSLATE_UUIDS:

            try:

                groups[k] = retrieve_uuids(

            except ItemNotExists, e:

                raise faults.BadRequest(

        else:

            try:

                retrieve_displaynames(

                    fail_silently=False)

            except ItemNotExists, e:

                raise faults.BadRequest(

    replace = True

    if 'update' in request.GET:

        replace = False

    try:

        meta = request.backend.get_container_meta(request.user_uniq, v_account,

                                                  v_container, 'pithos', until)

        policy = request.backend.get_container_policy(

            request.user_uniq, v_account,

            v_container)

    if meta:

        try:

            request.backend.update_container_meta(request.user_uniq, v_account,

        except NotAllowedError:

            raise faults.Forbidden('Not allowed')

        except ItemNotExists:

    if meta or replace:

        try:

            request.backend.update_container_meta(request.user_uniq, v_account,

        except NotAllowedError:

            raise faults.Forbidden('Not allowed')

        except ItemNotExists:

            request.META.get('CONTENT_LENGTH', 0))

    content_type = request.META.get('CONTENT_TYPE')

    hashmap = []

        for data in socket_read_iterator(request, content_length,

                                         request.backend.block_size):

            # TODO: Raise 408 (Request Timeout) if this takes too long.

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

    response = HttpResponse(status=202)

    try:

        meta = request.backend.get_container_meta(request.user_uniq, v_account,

                                                  v_container, 'pithos', until)

        policy = request.backend.get_container_policy(

            request.user_uniq, v_account,

            v_container)

        if until is None:

            name = '/'.join((v_account, v_container, ''))

            name_idx = len(name)

                # filter out objects which are not under the container

                if name != x[:name_idx]:

                    continue

                object = x[name_idx:]

            if public_granted:

                for k, v in request.backend.list_object_public(

            modified_by = meta.get('modified_by')

            if modified_by:

                l = retrieve_displaynames(

                if l is not None and len(l) == 1:

                    meta['modified_by'] = l[0]

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

    try:

        meta = request.backend.get_object_meta(request.user_uniq, v_account,

        if version is None:

            permissions = request.backend.get_object_permissions(

                request.user_uniq,

    try:

        meta = request.backend.get_object_meta(request.user_uniq, v_account,

        if version is None:

            permissions = request.backend.get_object_permissions(

                request.user_uniq,

        try:

            for x in objects:

                sizes.append(s)

                hashmaps.append(h)

        except NotAllowedError:

        response = HttpResponse(data, status=200)

        put_object_headers(

        response['Content-Length'] = len(data)

        return response

    #                       requestentitytoolarge (413)

    # Evaluate conditions.

        try:

            meta = request.backend.get_object_meta(

                request.user_uniq, v_account,

                raise faults.BadRequest('Invalid X-Move-From header')

            version_id = copy_or_move_object(

                request, src_account, src_container, src_name,

        else:

            try:

                src_container, src_name = split_container_object_string(

                raise faults.BadRequest('Invalid X-Copy-From header')

            version_id = copy_or_move_object(

                request, src_account, src_container, src_name,

        response = HttpResponse(status=201)

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

        return response

        for data in socket_read_iterator(request, content_length,

                                         request.backend.block_size):

            # TODO: Raise 408 (Request Timeout) if this takes too long.

            size += len(data)

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

            md5.update(data)

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

    try:

    except NotAllowedError:

        raise faults.Forbidden('Not allowed')

    except IndexError, e:

        checksum = hashmap_md5(request.backend, hashmap, size)

        try:

            request.backend.update_object_checksum(request.user_uniq,

        except NotAllowedError:

            raise faults.Forbidden('Not allowed')

    if public is not None:

    checksum = file.etag

    try:

    except NotAllowedError:

        raise faults.Forbidden('Not allowed')

    except ItemNotExists:

        raise faults.BadRequest('Invalid Destination header')

    # Evaluate conditions.

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

        try:

            meta = request.backend.get_object_meta(

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

    version_id = copy_or_move_object(request, v_account, v_container, v_object,

    response = HttpResponse(status=201)

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

    return response

        raise faults.BadRequest('Invalid Destination header')

    # Evaluate conditions.

        try:

            meta = request.backend.get_object_meta(

                request.user_uniq, v_account,

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

    version_id = copy_or_move_object(request, v_account, v_container, v_object,

    response = HttpResponse(status=201)

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

    return response

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

    # Evaluate conditions.

        validate_matching_preconditions(request, prev_meta)

    replace = True

    # A Content-Type or X-Source-Object header indicates data updates.

    src_object = request.META.get('HTTP_X_SOURCE_OBJECT')

        response = HttpResponse(status=202)

        # Do permissions first, as it may fail easier.

        if permissions is not None:

            try:

                request.backend.update_object_permissions(request.user_uniq,

            except NotAllowedError:

                raise faults.Forbidden('Not allowed')

            except ItemNotExists:

        raise faults.RangeNotSatisfiable('Invalid Content-Range header')

    try:

    except NotAllowedError:

        raise faults.Forbidden('Not allowed')

    except ItemNotExists:

    if offset is None:

        offset = size

    elif offset > size:

    if src_object:

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

        if not src_account:

        if length is None:

            length = src_size

        elif length > src_size:

    else:

        # Require either a Content-Length, or 'chunked' Transfer-Encoding.

        content_length = -1

                # TODO: Get up to length bytes in chunks.

                length = content_length

            elif length != content_length:

        raise faults.RangeNotSatisfiable(

            'Supplied range will change provided object limits')

        for d in socket_read_iterator(request, length,

                                      request.backend.block_size):

            # TODO: Raise 408 (Request Timeout) if this takes too long.

            data += d

            bytes = put_object_block(request, hashmap, data, offset)

            offset += bytes

    checksum = hashmap_md5(

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

    try:

    except NotAllowedError:

        raise faults.Forbidden('Not allowed')

    except ItemNotExists: