Synnefo

from httplib import HTTPConnection, HTTP

from sys import stdin

import json

import types

        kwargs['headers']['X-Auth-Token'] = self.token

        if body:

            kwargs['body'] = body

            kwargs['headers']['content-type'] = ''

        kwargs['headers'].setdefault('content-length', len(body) if body else 0)

        kwargs['headers'].setdefault('content-type', 'application/octet-stream')

    def put(self, path, body=None, format='text', headers=None):

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

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

                                         params=params)

            data = json.loads(data) if data else ''

        else:

            data = data.strip().split('\n') if data else ''

        return data

        return ll

class OOS_Client(Client):

    def _update_metadata(self, path, entity, **meta):

        """adds new and updates the values of previously set metadata"""

    # Storage Account Services

                        **headers):

        """lists containers"""

        if not params:

            params = {}

        params.update({'limit':limit, 'marker':marker})

    def retrieve_account_metadata(self, restricted=False, **params):

        """returns the account metadata"""

    def _filter_trashed(self, l):

        return self._filter(l, {'trash':'true'})

                     prefix=None, delimiter=None, path=None,

                     include_trashed=False, params={}, **headers):

        """returns a list with the container objects"""

        params.update({'limit':limit, 'marker':marker, 'prefix':prefix,

                       'delimiter':delimiter, 'path':path})

            l = self._filter_trashed(l)

        return l

    # Storage Object Services

                        **headers):

        """returns tuple containing the status, headers and data response for an object request"""

        path = '/%s/%s' % (container, object)

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

        return status, headers, data

                             **headers):

        """returns an object's data"""

        return t[2]

    def create_directory_marker(self, container, object):

        headers = {}

        prefix = 'x-%s-meta-' % entity

        for m in meta:

        return self.post(path, headers=headers, params=params)

    # Storage Account Services

                        if_unmodified_since=None, limit=1000, marker=None,

                        until=None):

        """returns a list with the account containers"""

        params = {'until':until} if until else None

        headers = {'if-modified-since':if_modified_since,

                   'if-unmodified-since':if_unmodified_since}

                                          marker=marker, params=params,

                                          **headers)

    # Storage Container Services

                     prefix=None, delimiter=None, path=None,

                     include_trashed=False, params={}, if_modified_since=None,

                     if_unmodified_since=None, meta={}, until=None):

    # Storage Object Services

                        if_range=None, if_match=None, if_none_match=None,

                        if_modified_since=None, if_unmodified_since=None,

                        **headers):

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

        for elem in l:

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

                                          params=params, **headers)

    def retrieve_object_version(self, container, object, version, detail=False,