Synnefo

from httplib import HTTPConnection, HTTP

from sys import stdin

from xml.dom import minidom

import json

import types

        self.token = token

    def _req(self, method, path, body=None, headers={}, format='text', params={}):

        for k,v in params.items():

            if v:

        return self._req('POST', path, body, headers=headers, format=format,

                        params=params)

    def _list(self, path, format='text', params={}, **headers):

        status, headers, data = self.get(path, format=format, headers=headers,

    def retrieve_object_hashmap(self, container, object, params={},

                        account=None, **headers):

        """returns the hashmap representing object's data"""

        for elem in ['self', 'container', 'object']:

            args.pop(elem)

        data = self.retrieve_object(container, object, format='json', **args)

                                              **h)

    def create_object(self, container, object, f=stdin, format='text', meta={},

                      content_disposition=None, account=None, **headers):

        """creates a zero-length object"""

        account = account or self.account

        for k,v in meta.items():

            headers['x-object-meta-%s' %k.strip()] = v.strip()

        data = f.read() if f else None

    def create_zero_length_object(self, container, object, meta={}, etag=None,

                                  content_type=None, content_encoding=None,

                                  content_disposition=None, account=None,

                                  **headers):

        account = account or self.account

        for elem in ['self', 'container', 'headers', 'account']:

            args.pop(elem)

        args.update(headers)

        params = {'until':until, 'meta':meta}

        if shared:

            params['shared'] = None

        for elem in ['self', 'container', 'params', 'until', 'meta']:

            args.pop(elem)

        return OOS_Client.list_objects(self, container, params=params, **args)

        l = [elem for elem in l if eval(elem)]

        for elem in l:

            headers.update({elem:eval(elem)})

        return OOS_Client.retrieve_object(self, container, object,

                                          account=account, format=format,

                                          params=params, **headers)

                                account=None):

        """returns a specific object version"""

        account = account or self.account

        l = ['self', 'container', 'object']

        for elem in l:

            args.pop(elem)

                                    if_unmodified_since=None, account=None):

        """returns the object version list"""

        account = account or self.account

        l = ['self', 'container', 'object']

        for elem in l:

            args.pop(elem)

                                  x_object_public=None, account=None):

        """createas a zero length object"""

        account = account or self.account

        for elem in ['self', 'container', 'object']:

            args.pop(elem)

        return OOS_Client.create_zero_length_object(self, container, object,

                                                    **args)

                      content_encoding=None, content_disposition=None,

                      x_object_manifest=None, x_object_sharing=None,

                      x_object_public=None, account=None):

        """creates an object"""

        account = account or self.account

        for elem in ['self', 'container', 'object']:

            args.pop(elem)

        return OOS_Client.create_object(self, container, object, **args)

        return self._chunked_transfer(path, 'PUT', f, headers=headers,

                                      blocksize=blocksize)

                                 meta={}, etag=None, content_encoding=None,

                                 content_disposition=None, content_type=None,

                                 x_object_sharing=None, x_object_manifest=None,

                                 x_object_public = None, account=None):

        """creates an object by uploading hashes representing data instead of data"""

        account = account or self.account

            args.pop(elem)

    def create_manifestation(self, container, object, manifest, account=None):

        """creates a manifestation"""

                      x_source_object=None, account=None):

        """updates an object"""

        account = account or self.account

        for elem in ['self', 'container', 'object', 'replace']:

            args.pop(elem)

        if not replace:

                                   x_object_public=None, account=None):

        """updates an object (incremental upload)"""

        account = account or self.account

        for elem in ['self', 'container', 'object', 'replace']:

            args.pop(elem)

        if not replace:

                      x_object_sharing=None, x_object_public=None, account=None):

        """updates an object"""

        account = account or self.account

        for elem in ['self', 'container', 'object', 'source']:

            args.pop(elem)