Synnefo » Pithos

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

Revision                   Description

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

\                          Change policy/meta formatting in JSON/XML replies.

\                          Document that all non-ASCII characters in headers should be URL-encoded.

\                          Support metadata-based queries when listing objects at the container level.

\                          Note Content-Type issue when using the internal django web server.

0.7 (Nov 21, 2011)         Suggest upload/download methods using hashmaps.

\                          Propose syncing algorithm.

\                          Support cross-account object copy and move.

content-disposition         The presentation style of the object (optional)

last_modified               The last object modification date (regardless of version)

x_object_hash               The Merkle hash

x_object_version            The object's version identifier

x_object_version_timestamp  The object's version timestamp

x_object_modified_by        The user that committed the object's version

    "last_modified": "2011-12-02T08:10:41.565891+00:00",

    "x_object_meta": {"asdf": "qwerty"},

    "x_object_hash": "e3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855",

    "x_object_version": 98,

    "x_object_version_timestamp": "1322813441.565891",

    "x_object_modified_by": "user"}, ...]

        <key>asdf</key><value>qwerty</value>

      </x_object_meta>

      <x_object_hash>e3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855</x_object_hash>

      <x_object_version>98</x_object_version>

      <x_object_version_timestamp>1322813441.565891</x_object_version_timestamp>

      <x_object_modified_by>chazapis</x_object_modified_by>

Content-Encoding            The encoding of the object (optional)

Content-Disposition         The presentation style of the object (optional)

X-Object-Hash               The Merkle hash

X-Object-Version            The object's version identifier

X-Object-Version-Timestamp  The object's version timestamp

X-Object-Modified-By        The user that comitted the object's version

Content-Encoding            The encoding of the object (optional)

Content-Disposition         The presentation style of the object (optional)

X-Object-Hash               The Merkle hash

X-Object-Version            The object's version identifier

X-Object-Version-Timestamp  The object's version timestamp

X-Object-Modified-By        The user that comitted the object's version

* Object hashmap retrieval through ``GET`` and the ``format`` parameter.

* Object create via hashmap through ``PUT`` and the ``format`` parameter.

* The object's Merkle hash is always returned in the ``X-Object-Hash`` header.

* Object create using ``POST`` to support standard HTML forms.

* Partial object updates through ``POST``, using the ``Content-Length``, ``Content-Type``, ``Content-Range`` and ``Transfer-Encoding`` headers. Use another object's data to update with ``X-Source-Object`` and ``X-Source-Version``. Truncate with ``X-Object-Bytes``. New ETag corresponds to the Merkle hash of the object's hashmap.

* Include new version identifier in replies for object replace/change requests.

            else:

                rename_meta_key(meta, 'hash', 'x_object_hash') # Will be replaced by ETag.

                rename_meta_key(meta, 'ETag', 'hash')

                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')

    response['Last-Modified'] = http_date(int(meta['modified']))

    if not restricted:

        response['X-Object-Hash'] = meta['hash']

        response['X-Object-Modified-By'] = smart_str(meta['modified_by'], strings_only=True)

        response['X-Object-Version'] = meta['version']

        response['X-Object-Version-Timestamp'] = http_date(int(meta['version_timestamp']))

        """

        return []

    def get_public(self, user, public):

        """Return the (account, container, name) for the public id given.

        """Return a sequence of values for the properties of

           the version specified by serial and the keys, in the order given.

           If keys is empty, return all properties in the order

        """

        v = self.versions.alias()

        rp = self.conn.execute(s)

        r = rp.fetchone()

        rp.close()

        rp.close()

        return matches, prefixes

        """Return a sequence of values for the properties of

           the version specified by serial and the keys, in the order given.

           If keys is empty, return all properties in the order

        """

             "from versions "

             "where serial = ?")

        self.execute(q, (serial,))

        q = ("select distinct a.key "

             "from attributes a, versions v, nodes n "

             "where v.serial = (select max(serial) "

             "and v.cluster != ? "

             "and v.node in (select node "

             "and a.serial = v.serial "

             "and a.domain = ? "

             "and n.node = v.node")

        q = ("select distinct n.path, v.serial "

             "from attributes a, versions v, nodes n "

             "where v.serial = (select max(serial) "

             "and v.cluster != ? "

             "and v.node in (select node "

             "and a.serial = v.serial "

             "and n.node = v.node "

             "and n.path > ? and n.path < ?")

            execute(q, args)

        return matches, prefixes

import sys

import os

import time

import logging

import binascii

        for x in ['READ', 'WRITE']:

            setattr(self, x, getattr(self.db_module, x))

        self.node = self.db_module.Node(**params)

            setattr(self, x, getattr(self.db_module, x))

        __import__(block_module)

        return [[x[self.SERIAL], x[self.MTIME]] for x in versions if x[self.CLUSTER] != CLUSTER_DELETED]

    @backend_method

    def get_public(self, user, public):

        """Return the (account, container, name) for the public id given."""

        logger.debug("get_public: %s", public)

        if public is None or public < ULTIMATE_ANSWER:

            raise NameError

        path = self.permissions.public_path(public - ULTIMATE_ANSWER)

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

        self._can_read(user, account, container, name)

        return (account, container, name)

    # Path functions.

    def _put_object_node(self, path, parent, name):

        path = '/'.join((path, name))

        if size is None:

            hash = src_hash # This way hash can be set to None.

            size = src_size

        if src_version_id is not None:

            self.node.version_recluster(src_version_id, CLUSTER_HISTORY)

        return src_version_id, dest_version_id

    def _put_metadata_duplicate(self, src_version_id, dest_version_id, domain, meta, replace=False):