Synnefo

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

Revision                   Description

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

\                          Propose syncing algorithm.

\                          Support cross-account object copy and move.

\                          Pass token as a request parameter when using ``POST`` via an HTML form.

\                          Optionally use source account to update object from another object.

\                          Use container ``POST`` to upload missing blocks of data.

\                          Report policy in account headers.

0.6 (Sept 13, 2011)        Reply with Merkle hash as the ETag when updating objects.

\                          Include version id in object replace/change replies.

\                          Change conflict (409) replies format to text.

The ``X-Object-Sharing`` header may include either a ``read=...`` comma-separated user/group list, or a ``write=...`` comma-separated user/group list, or both separated by a semicolon (``;``). Groups are specified as ``<account>:<group>``. To publish the object, set ``X-Object-Public`` to ``true``. To unpublish, set to ``false``, or use an empty header value.

COPY

|

MOVE

|

The ``POST`` method can also be used for creating an object via a standard HTML form. If the request ``Content-Type`` is ``multipart/form-data``, none of the above headers will be processed. The form should have an ``X-Object-Data`` field, as in the following example. The token is passed as a request parameter. ::

|

DELETE

from xml.dom import minidom

from pithos.api.faults import (Fault, NotModified, BadRequest, Unauthorized, ItemNotFound, Conflict,

from pithos.api.util import (rename_meta_key, format_header_key, printable_header_dict, 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,

    get_int_parameter, get_content_length, get_content_range, socket_read_iterator,

    object_data_response, put_object_block, hashmap_hash, api_method, json_encode_decimal)

from pithos.backends import connect_backend

logger = logging.getLogger(__name__)

        raise BadRequest('Invalid sharing header')

    except AttributeError, e:

        raise Conflict('\n'.join(e.data) + '\n')

    if public is not None:

        try:

            request.backend.update_object_public(request.user, v_account,

        raise Unauthorized('Access denied')

    except NameError:

        raise ItemNotFound('Container does not exist')

    response = HttpResponse(status=201)

    response['ETag'] = meta['hash']

        raise BadRequest('Invalid sharing header')

    except AttributeError, e:

        raise Conflict('\n'.join(e.data) + '\n')

    if public is not None:

        try:

            request.backend.update_object_public(request.user, v_account,

from pithos.api.compat import parse_http_date_safe, parse_http_date

from pithos.api.faults import (Fault, NotModified, BadRequest, Unauthorized, ItemNotFound,

from pithos.backends import connect_backend

import logging

import re

        raise BadRequest('Invalid sharing header')

    except AttributeError, e:

        raise Conflict('\n'.join(e.data) + '\n')

    if public is not None:

        try:

            request.backend.update_object_public(request.user, dest_account, dest_container, dest_name, public)

class NotAllowedError(Exception):

    pass

class BaseBackend(object):

    """Abstract backend class that serves as a reference for actual implementations.

            ValueError: Invalid users/groups in permissions

            AttributeError: Can not set permissions

        """

        return ''

            ValueError: Invalid users/groups in permissions

            AttributeError: Can not set permissions

        """

        return ''

            ValueError: Invalid users/groups in permissions

            AttributeError: Can not set permissions

        """

        return ''

import hashlib

import binascii

from lib.hashfiler import Mapper, Blocker

( CLUSTER_NORMAL, CLUSTER_HISTORY, CLUSTER_DELETED ) = range(3)

            if (account_quota > 0 and self._get_statistics(account_node)[1] + size_delta > account_quota) or \

               (container_quota > 0 and self._get_statistics(container_node)[1] + size_delta > container_quota):

                # This must be executed in a transaction, so the version is never created if it fails.

        if not replace_meta and src_version_id is not None:

            self.node.attribute_copy(src_version_id, dest_version_id)