Synnefo

#!/usr/bin/env python

# Copyright 2011-2012 GRNET S.A. All rights reserved.

# Redistribution and use in source and binary forms, with or

# without modification, are permitted provided that the following

# conditions are met:

#   1. Redistributions of source code must retain the above

#      copyright notice, this list of conditions and the following

#      disclaimer.

#   2. Redistributions in binary form must reproduce the above

#      copyright notice, this list of conditions and the following

#      disclaimer in the documentation and/or other materials

#      provided with the distribution.

# THIS SOFTWARE IS PROVIDED BY GRNET S.A. ``AS IS'' AND ANY EXPRESS

# OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED

# WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR

# LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN

# ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE

# POSSIBILITY OF SUCH DAMAGE.

# The views and conclusions contained in the software and

# documentation are those of the authors and should not be

# interpreted as representing official policies, either expressed

from pithos.backends.modular import ModularBackend

class Migration(object):

    def __init__(self, db):

        self.engine = create_engine(db)

        self.metadata = MetaData(self.engine)

        #self.engine.echo = True

        self.conn = self.engine.connect()

        options = getattr(settings, 'BACKEND', None)[1]

        self.backend = ModularBackend(*options)

    def execute(self):

        pass

class Cache():

    def __init__(self, db):

        self.engine = create_engine(db)

        metadata = MetaData(self.engine)

        columns.append(Column('path', String(2048), primary_key=True))

        columns.append(Column('hash', String(255)))

        self.files = Table('files', metadata, *columns)

        self.conn = self.engine.connect()

        self.engine.echo = True

        metadata.create_all(self.engine)

    def put(self, path, hash):

        # Insert or replace.

        r = self.conn.execute(s)

        r.close()

        s = self.files.insert()

        r = self.conn.execute(s, {'path': path, 'hash': hash})

        r.close()

    def get(self, path):

        s = select([self.files.c.hash], self.files.c.path == path)

        r = self.conn.execute(s)

        except ImportError:

            return _do_download(version, download_base, to_dir, download_delay)

        try:

            return

        except pkg_resources.VersionConflict:

            e = sys.exc_info()[1]

            if was_imported:

                sys.stderr.write(

                sys.exit(2)

            else:

                del pkg_resources, sys.modules['pkg_resources']    # reload ok

        if not no_fake:

            _create_fake_setuptools_pkg_info(to_dir)

def download_setuptools(version=DEFAULT_VERSION, download_base=DEFAULT_URL,

                        to_dir=os.curdir, delay=15):

    """Download distribute from a specified location and return its filename

                dst.close()

    return os.path.realpath(saveto)

def _no_sandbox(function):

    def __no_sandbox(*args, **kw):

        try:

    return __no_sandbox

def _patch_file(path, content):

    """Will backup the file then patch it"""

    existing_content = open(path).read()

_patch_file = _no_sandbox(_patch_file)

def _same_content(path, content):

    return open(path).read() == content

def _rename_path(path):

    new_name = path + '.OLD.%s' % time.time()

    log.warn('Renaming %s into %s', path, new_name)

    os.rename(path, new_name)

    return new_name

def _remove_flat_installation(placeholder):

    if not os.path.isdir(placeholder):

        log.warn('Unkown installation at %s', placeholder)

_remove_flat_installation = _no_sandbox(_remove_flat_installation)

def _after_install(dist):

    log.warn('After install bootstrap.')

    placeholder = dist.get_command_obj('install').install_purelib

    _create_fake_setuptools_pkg_info(placeholder)

def _create_fake_setuptools_pkg_info(placeholder):

    if not placeholder or not os.path.exists(placeholder):

        log.warn('Could not find the install location')

        return

    pyver = '%s.%s' % (sys.version_info[0], sys.version_info[1])

    setuptools_file = 'setuptools-%s-py%s.egg-info' % \

    pkg_info = os.path.join(placeholder, setuptools_file)

    if os.path.exists(pkg_info):

        log.warn('%s already exists', pkg_info)

    finally:

        f.close()

def _patch_egg_dir(path):

    # let's check if it's already patched

_patch_egg_dir = _no_sandbox(_patch_egg_dir)

def _before_install():

    log.warn('Before install bootstrap.')

    _fake_setuptools()

def _under_prefix(location):

    if 'install' not in sys.argv:

        return True

    for index, arg in enumerate(args):

        for option in ('--root', '--prefix'):

            if arg.startswith('%s=' % option):

                return location.startswith(top_dir)

            elif arg == option:

                if len(args) > index:

                    return location.startswith(top_dir)

        if arg == '--user' and USER_SITE is not None:

            return location.startswith(USER_SITE)

                                  replacement=False))

    except TypeError:

        # old distribute API

    if setuptools_dist is None:

        log.warn('No setuptools distribution found')

        log.warn('Egg installation')

        pkg_info = os.path.join(setuptools_location, 'EGG-INFO', 'PKG-INFO')

        if (os.path.exists(pkg_info) and

            log.warn('Already patched.')

            return

        log.warn('Patching...')

            # Extract directories with a safe mode.

            directories.append(tarinfo)

            tarinfo = copy.copy(tarinfo)

        self.extract(tarinfo, path)

    # Reverse sort directories.

# Copyright 2011-2012 GRNET S.A. All rights reserved.

# Redistribution and use in source and binary forms, with or

# without modification, are permitted provided that the following

# conditions are met:

#   1. Redistributions of source code must retain the above

#      copyright notice, this list of conditions and the following

#      disclaimer.

#   2. Redistributions in binary form must reproduce the above

#      copyright notice, this list of conditions and the following

#      disclaimer in the documentation and/or other materials

#      provided with the distribution.

# THIS SOFTWARE IS PROVIDED BY GRNET S.A. ``AS IS'' AND ANY EXPRESS

# OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED

# WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR

# LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN

# ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE

# POSSIBILITY OF SUCH DAMAGE.

# The views and conclusions contained in the software and

# documentation are those of the authors and should not be

# interpreted as representing official policies, either expressed

logger = logging.getLogger(__name__)

def delegate_to_login_service(request):

    url = AUTHENTICATION_URL

    users = AUTHENTICATION_USERS

    if users or not url:

        return HttpResponseNotFound()

    p = urlparse(url)

    if request.is_secure():

        proto = 'https://'

    uri = proto + p.netloc + '/login?' + urlencode(params)

    return HttpResponseRedirect(uri)

@csrf_exempt

def delegate_to_feedback_service(request):

    url = AUTHENTICATION_URL

    users = AUTHENTICATION_USERS

    if users or not url:

        return HttpResponseNotFound()

    p = urlparse(url)

    if request.is_secure():

        proto = 'https://'

    else:

        proto = 'http://'

    uri = proto + p.netloc + '/im/service/api/v2.0/feedback'

    values = dict([(k, v) for k, v in request.POST.items()])

    data = urllib.urlencode(values)

    req = urllib2.Request(uri, data, headers)

    except urllib2.URLError, e:

        logger.exception(e)

        return HttpResponse(status=e.reason)

from pithos.api.settings import (BACKEND_DB_MODULE, BACKEND_DB_CONNECTION,

from pithos.backends import connect_backend

from pithos.api.util import hashmap_md5

import socket

from smtplib import SMTPException

def update_md5(m):

    if m['resource'] != 'object' or m['details']['action'] != 'object update':

        return

    backend = connect_backend(db_module=BACKEND_DB_MODULE,

                              db_connection=BACKEND_DB_CONNECTION,

                              block_module=BACKEND_BLOCK_MODULE,

                              queue_connection=BACKEND_QUEUE_CONNECTION)

    backend.default_policy['quota'] = BACKEND_QUOTA

    backend.default_policy['versioning'] = BACKEND_VERSIONING

    path = m['value']

    account, container, name = path.split('/', 2)

    version = m['details']['version']

    meta = None

    try:

        if meta['checksum'] == '':

            checksum = hashmap_md5(backend, hashmap, size)

            print 'INFO: Updated checksum for path "%s"' % (path,)

    except Exception, e:

        print 'WARNING: Can not update checksum for path "%s" (%s)' % (path, e)

    backend.close()

def send_sharing_notification(m):

    if m['resource'] != 'sharing':

        return

    members = m['details']['members']

    user = m['details']['user']

    path = m['value']

    account, container, name = path.split('/', 2)

    subject = 'Invitation to a Pithos+ shared object'

    from_email = DEFAULT_FROM_EMAIL

    recipient_list = members

    try:

        send_mail(subject, message, from_email, recipient_list)

    except (SMTPException, socket.error) as e:

# Copyright 2011-2012 GRNET S.A. All rights reserved.

# Redistribution and use in source and binary forms, with or

# without modification, are permitted provided that the following

# conditions are met:

#   1. Redistributions of source code must retain the above

#      copyright notice, this list of conditions and the following

#      disclaimer.

#   2. Redistributions in binary form must reproduce the above

#      copyright notice, this list of conditions and the following

#      disclaimer in the documentation and/or other materials

#      provided with the distribution.

# THIS SOFTWARE IS PROVIDED BY GRNET S.A. ``AS IS'' AND ANY EXPRESS

# OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED

# WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR

# LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN

# ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE

# POSSIBILITY OF SUCH DAMAGE.

# The views and conclusions contained in the software and

# documentation are those of the authors and should not be

# interpreted as representing official policies, either expressed

# or implied, of GRNET S.A.

def camelCase(s):

    return s[0].lower() + s[1:]

        self.details = details

        self.name = name or camelCase(self.__class__.__name__)

class NotModified(Fault):

    code = 304

class BadRequest(Fault):

    code = 400

class Unauthorized(Fault):

    code = 401

class Forbidden(Fault):

    code = 403

class ItemNotFound(Fault):

    code = 404

class Conflict(Fault):

    code = 409

class LengthRequired(Fault):

    code = 411

class PreconditionFailed(Fault):

    code = 412

class RequestEntityTooLarge(Fault):

    code = 413

class RangeNotSatisfiable(Fault):

    code = 416

class UnprocessableEntity(Fault):

    code = 422

class InternalServerError(Fault):

    code = 500

class NotImplemented(Fault):

    code = 501

# Copyright 2011-2012 GRNET S.A. All rights reserved.

# Redistribution and use in source and binary forms, with or

# without modification, are permitted provided that the following

# conditions are met:

#   1. Redistributions of source code must retain the above

#      copyright notice, this list of conditions and the following

#      disclaimer.

#   2. Redistributions in binary form must reproduce the above

#      copyright notice, this list of conditions and the following

#      disclaimer in the documentation and/or other materials

#      provided with the distribution.

# THIS SOFTWARE IS PROVIDED BY GRNET S.A. ``AS IS'' AND ANY EXPRESS

# OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED

# WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR

# LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN

# ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE

# POSSIBILITY OF SUCH DAMAGE.

# The views and conclusions contained in the software and

# documentation are those of the authors and should not be

# interpreted as representing official policies, either expressed

from synnefo.lib.astakos import get_user

    LengthRequired, PreconditionFailed, RequestEntityTooLarge, RangeNotSatisfiable, UnprocessableEntity)

    get_account_headers, put_account_headers, get_container_headers, put_container_headers, get_object_headers,

    put_object_headers, update_manifest_meta, update_sharing_meta, update_public_meta,

    validate_modification_preconditions, validate_matching_preconditions, split_container_object_string,

@csrf_exempt

def top_demux(request):

    if request.method == 'GET':

    else:

        return method_not_allowed(request)

@csrf_exempt

def account_demux(request, v_account):

    if request.method == 'HEAD':

    else:

        return method_not_allowed(request)

@csrf_exempt

def container_demux(request, v_account, v_container):

    if request.method == 'HEAD':

    else:

        return method_not_allowed(request)

@csrf_exempt

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

    # Helper to avoid placing the token in the URL when loading objects from a browser.

    else:

        return method_not_allowed(request)

@api_method('GET', user_required=False)

def authenticate(request):

    # Normal Response Codes: 204

    # Error Response Codes: internalServerError (500),

    #                       forbidden (403),

    #                       badRequest (400)

    x_auth_user = request.META.get('HTTP_X_AUTH_USER')

    x_auth_key = request.META.get('HTTP_X_AUTH_KEY')

    if not x_auth_user or not x_auth_key:

        raise BadRequest('Missing X-Auth-User or X-Auth-Key header')

    response = HttpResponse(status=204)

    uri = request.build_absolute_uri()

    if '?' in uri:

        uri = uri[:uri.find('?')]

    response['X-Auth-Token'] = x_auth_key

    return response

@api_method('GET', format_allowed=True)

def account_list(request):

    # Normal Response Codes: 200, 204

    # Error Response Codes: internalServerError (500),

    #                       badRequest (400)

    response = HttpResponse()

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

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

    if not limit:

        limit = 10000

    accounts = request.backend.list_accounts(request.user_uniq, marker, limit)

    if request.serialization == 'text':

        if len(accounts) == 0:

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

        response.status_code = 200

        response.content = '\n'.join(accounts) + '\n'

        return response

    account_meta = []

    for x in accounts:

        if x == request.user_uniq:

            continue

        try:

            groups = request.backend.get_account_groups(request.user_uniq, x)

        except NotAllowedError:

            raise Forbidden('Not allowed')

        else:

            rename_meta_key(meta, 'modified', 'last_modified')

            if groups:

            account_meta.append(printable_header_dict(meta))

    if request.serialization == 'xml':

        data = render_to_string('accounts.xml', {'accounts': account_meta})

        data = json.dumps(account_meta)

    response.status_code = 200

    response.content = data

    return response

@api_method('HEAD')

def account_meta(request, v_account):

    # Normal Response Codes: 204

    # Error Response Codes: internalServerError (500),

    #                       forbidden (403),

    #                       badRequest (400)

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

    try:

    except NotAllowedError:

        raise Forbidden('Not allowed')

    validate_modification_preconditions(request, meta)

    response = HttpResponse(status=204)

    put_account_headers(response, meta, groups, policy)

    return response

@api_method('POST')

def account_update(request, v_account):

    # Normal Response Codes: 202

    # Error Response Codes: internalServerError (500),

    #                       forbidden (403),

    #                       badRequest (400)

    meta, groups = get_account_headers(request)

    replace = True

    if 'update' in request.GET:

    if groups:

        try:

            request.backend.update_account_groups(request.user_uniq, v_account,

        except NotAllowedError:

            raise Forbidden('Not allowed')

        except ValueError:

            raise Forbidden('Not allowed')

    return HttpResponse(status=202)

@api_method('GET', format_allowed=True)

def container_list(request, v_account):

    # Normal Response Codes: 200, 204

    #                       itemNotFound (404),

    #                       forbidden (403),

    #                       badRequest (400)

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

    try:

    except NotAllowedError:

        raise Forbidden('Not allowed')

    validate_modification_preconditions(request, meta)

    response = HttpResponse()

    put_account_headers(response, meta, groups, policy)

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

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

    if not limit:

        limit = 10000

    shared = False

    if 'shared' in request.GET:

        shared = True

    public = False

    if 'public' in request.GET:

        public = True

    try:

    except NotAllowedError:

        raise Forbidden('Not allowed')

    except NameError:

        containers = []

    if request.serialization == 'text':

        if len(containers) == 0:

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

        response.status_code = 200

        response.content = '\n'.join(containers) + '\n'

        return response

    container_meta = []

    for x in containers:

        try:

            policy = request.backend.get_container_policy(request.user_uniq,

        except NotAllowedError:

            raise Forbidden('Not allowed')

        except NameError:

            pass

        else:

            rename_meta_key(meta, 'modified', 'last_modified')

            if policy:

            container_meta.append(printable_header_dict(meta))

    if request.serialization == 'xml':

        data = json.dumps(container_meta)

    response.status_code = 200

    response.content = data

    return response

@api_method('HEAD')

def container_meta(request, v_account, v_container):

    # Normal Response Codes: 204

    #                       itemNotFound (404),

    #                       forbidden (403),

    #                       badRequest (400)

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

    try:

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

        meta['object_meta'] = request.backend.list_container_meta(request.user_uniq,

    except NotAllowedError:

        raise Forbidden('Not allowed')

    except ItemNotExists:

        raise ItemNotFound('Container does not exist')

    validate_modification_preconditions(request, meta)

    response = HttpResponse(status=204)

    put_container_headers(request, response, meta, policy)

    return response

@api_method('PUT')

def container_create(request, v_account, v_container):

    # Normal Response Codes: 201, 202

    #                       itemNotFound (404),

    #                       forbidden (403),

    #                       badRequest (400)

    meta, policy = get_container_headers(request)

    try:

        ret = 201

    except NotAllowedError:

        raise Forbidden('Not allowed')

        raise BadRequest('Invalid policy header')

    except NameError:

        ret = 202

    if ret == 202 and policy:

        try:

        except NotAllowedError:

            raise Forbidden('Not allowed')

        except ItemNotExists:

    if meta:

        try:

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

        except NotAllowedError:

            raise Forbidden('Not allowed')

        except ItemNotExists:

            raise ItemNotFound('Container does not exist')

    return HttpResponse(status=ret)

@api_method('POST', format_allowed=True)

def container_update(request, v_account, v_container):

    # Normal Response Codes: 202

    #                       itemNotFound (404),

    #                       forbidden (403),

    #                       badRequest (400)

    meta, policy = get_container_headers(request)

    replace = True

    if 'update' in request.GET:

        replace = False

    if policy:

        try:

        except NotAllowedError:

            raise Forbidden('Not allowed')

        except ItemNotExists:

    if meta or replace:

        try:

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

        except NotAllowedError:

            raise Forbidden('Not allowed')

        except ItemNotExists:

            raise ItemNotFound('Container does not exist')

    content_length = -1

    if request.META.get('HTTP_TRANSFER_ENCODING') != 'chunked':

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

    hashmap = []

    if content_type and content_type == 'application/octet-stream' and content_length != 0:

        for data in socket_read_iterator(request, content_length,

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

            # TODO: Raise 499 (Client Disconnect) if a length is defined and we stop before getting this much data.

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

    response = HttpResponse(status=202)

    if hashmap:

        response.content = simple_list_response(request, hashmap)

    return response

@api_method('DELETE')

def container_delete(request, v_account, v_container):

    # Normal Response Codes: 204

    #                       itemNotFound (404),

    #                       forbidden (403),

    #                       badRequest (400)

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

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

    try:

    except NotAllowedError:

        raise Forbidden('Not allowed')

    except ItemNotExists:

        raise Conflict('Container is not empty')

    return HttpResponse(status=204)

@api_method('GET', format_allowed=True)

def object_list(request, v_account, v_container):

    # Normal Response Codes: 200, 204

    #                       itemNotFound (404),

    #                       forbidden (403),

    #                       badRequest (400)

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

    try:

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

        meta['object_meta'] = request.backend.list_container_meta(request.user_uniq,

    except NotAllowedError:

        raise Forbidden('Not allowed')

    except ItemNotExists:

        raise ItemNotFound('Container does not exist')

    validate_modification_preconditions(request, meta)

    response = HttpResponse()

    put_container_headers(request, response, meta, policy)

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

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

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

    # Path overrides prefix and delimiter.

    virtual = True

    if path:

        prefix = path

        delimiter = '/'

        virtual = False

    # Naming policy.

    if prefix and delimiter and not prefix.endswith(delimiter):

        prefix = prefix + delimiter

    if not prefix:

        prefix = ''

    prefix = prefix.lstrip('/')

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

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

    if not limit:

        limit = 10000

    keys = request.GET.get('meta')

    if keys:

        included, excluded, opers = parse_filters(keys)

        keys = []

        keys += [format_header_key('X-Object-Meta-' + x) for x in included]

    else:

        keys = []

    shared = False

    if 'shared' in request.GET:

        shared = True

    public = False

    if 'public' in request.GET:

        public = True

    if request.serialization == 'text':

        try:

        except NotAllowedError:

            raise Forbidden('Not allowed')

        except ItemNotExists:

            raise ItemNotFound('Container does not exist')

        if len(objects) == 0:

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

            response.status_code = 204

        return response

    try:

        object_permissions = {}

        object_public = {}

        if until is None:

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

            for x in request.backend.list_object_permissions(request.user_uniq,

                object = x[name_idx:]

                object_permissions[object] = request.backend.get_object_permissions(

            for k, v in request.backend.list_object_public(request.user_uniq,

                object_public[k[name_idx:]] = v

    except NotAllowedError:

        raise Forbidden('Not allowed')

    except ItemNotExists:

        raise ItemNotFound('Container does not exist')

    object_meta = []

    for meta in objects:

        if len(meta) == 1:

            # Virtual objects/directories.

            object_meta.append(meta)

        else:

            rename_meta_key(meta, 'checksum', 'hash')

            rename_meta_key(meta, 'type', 'content_type')

            rename_meta_key(meta, 'uuid', 'x_object_uuid')

                rename_meta_key(meta, 'modified', 'last_modified')

            rename_meta_key(meta, 'modified_by', 'x_object_modified_by')

            rename_meta_key(meta, 'version', 'x_object_version')

            permissions = object_permissions.get(meta['name'], None)

            if permissions:

            public = object_public.get(meta['name'], None)

            if public:

                update_public_meta(public, meta)

            object_meta.append(printable_header_dict(meta))

    if request.serialization == 'xml':

        data = json.dumps(object_meta, default=json_encode_decimal)

    response.status_code = 200

    response.content = data

    return response

@api_method('HEAD')

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

    # Normal Response Codes: 204

    #                       itemNotFound (404),

    #                       forbidden (403),

    #                       badRequest (400)

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

    try:

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

        if version is None:

        else:

            permissions = None

            public = None

        raise ItemNotFound('Object does not exist')

    except VersionNotExists:

        raise ItemNotFound('Version does not exist')

    update_manifest_meta(request, v_account, meta)

    update_public_meta(public, meta)

    # Evaluate conditions.

    validate_modification_preconditions(request, meta)

    try:

        response = HttpResponse(status=304)

        response['ETag'] = meta['checksum']

        return response

    response = HttpResponse(status=200)

    put_object_headers(response, meta)

    return response

@api_method('GET', format_allowed=True)

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

    # Normal Response Codes: 200, 206

    #                       forbidden (403),

    #                       badRequest (400),

    #                       notModified (304)

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

    # Reply with the version list. Do this first, as the object may be deleted.

    if version == 'list':

        if request.serialization == 'text':

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

        try:

            v = request.backend.list_versions(request.user_uniq, v_account,

        except NotAllowedError:

            raise Forbidden('Not allowed')

        d = {'versions': v}

        if request.serialization == 'xml':

            d['object'] = v_object

            data = render_to_string('versions.xml', d)

            data = json.dumps(d, default=json_encode_decimal)

        response = HttpResponse(data, status=200)

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

        return response

    try:

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

        if version is None:

        else:

            permissions = None

            public = None

        raise ItemNotFound('Object does not exist')

    except VersionNotExists:

        raise ItemNotFound('Version does not exist')

    update_manifest_meta(request, v_account, meta)

    update_public_meta(public, meta)

    # Evaluate conditions.

    validate_modification_preconditions(request, meta)

    try:

        response = HttpResponse(status=304)

        response['ETag'] = meta['checksum']

        return response

    hashmap_reply = False

    if 'hashmap' in request.GET and request.serialization != 'text':

        hashmap_reply = True

    sizes = []

    hashmaps = []

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

        try:

        except NotAllowedError:

            raise Forbidden('Not allowed')

        except ValueError:

            raise BadRequest('Invalid X-Object-Manifest header')

        except ItemNotExists:

            raise ItemNotFound('Container does not exist')

        try:

            for x in objects:

                s, h = request.backend.get_object_hashmap(request.user_uniq,

                sizes.append(s)

                hashmaps.append(h)

        except NotAllowedError:

            raise ItemNotFound('Version does not exist')

    else:

        try:

            sizes.append(s)

            hashmaps.append(h)

        except NotAllowedError:

            raise ItemNotFound('Object does not exist')

        except VersionNotExists:

            raise ItemNotFound('Version does not exist')

    # Reply with the hashmap.

    if hashmap_reply:

        size = sum(sizes)

        if request.serialization == 'xml':

            d['object'] = v_object

            data = render_to_string('hashes.xml', d)

            data = json.dumps(d)

        response = HttpResponse(data, status=200)

        put_object_headers(response, meta)

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

        return response

    return object_data_response(request, sizes, hashmaps, meta)

@api_method('PUT', format_allowed=True)

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

    # Normal Response Codes: 201

    #                       itemNotFound (404),

    #                       forbidden (403),

    #                       badRequest (400)

    # Evaluate conditions.

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

        try:

        except NotAllowedError:

            raise Forbidden('Not allowed')

        except NameError:

            meta = {}

        validate_matching_preconditions(request, meta)

    copy_from = request.META.get('HTTP_X_COPY_FROM')

    move_from = request.META.get('HTTP_X_MOVE_FROM')

    if copy_from or move_from:

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

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

        if not src_account:

            src_account = request.user_uniq

        if move_from:

            try:

            except ValueError:

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

        else:

            try:

            except ValueError:

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

        response = HttpResponse(status=201)

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

        return response

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

    content_length = -1

    if request.META.get('HTTP_TRANSFER_ENCODING') != 'chunked':

    # Should be BadRequest, but API says otherwise.

    if content_type is None:

        raise LengthRequired('Missing Content-Type header')

    if 'hashmap' in request.GET:

        if request.serialization not in ('json', 'xml'):

            raise BadRequest('Invalid hashmap format')

        data = ''

        for block in socket_read_iterator(request, content_length,