Synnefo

from synnefo.plankton.backend import ImageBackend

from contextlib import contextmanager

def plankton_method(func):

    """Decorator function for API methods using ImageBackend.

# or implied, of GRNET S.A.

from xml.dom import minidom

from django.http import HttpResponse

from django.template.loader import render_to_string

from django.utils import simplejson as json

from synnefo.lib.astakos import get_user, get_uuids as _get_uuids

from snf_django.lib.api import faults

from pithos.api.util import (

    get_content_range, socket_read_iterator, SaveToBackendHandler,

    object_data_response, put_object_block, hashmap_md5, simple_list_response,

    api_method, is_uuid,

)

from pithos.api.settings import (UPDATE_MD5, TRANSLATE_UUIDS,

from pithos.backends.filter import parse_filters

import hashlib

logger = logging.getLogger(__name__)

                return authenticate(request)

        return account_list(request)

    else:

@csrf_exempt

    elif request.method == 'GET':

        return container_list(request, v_account)

    else:

@csrf_exempt

    elif request.method == 'GET':

        return object_list(request, v_account, v_container)

    else:

@csrf_exempt

    elif request.method == 'DELETE':

        return object_delete(request, v_account, v_container, v_object)

    else:

def authenticate(request):

    # Normal Response Codes: 204

    # Error Response Codes: internalServerError (500),

    return response

def account_list(request):

    # Normal Response Codes: 200, 204

    # Error Response Codes: internalServerError (500),

    for x in accounts:

        if x == request.user_uniq:

            continue

        try:

            meta = request.backend.get_account_meta(

                request.user_uniq, x, 'pithos', include_user_defined=False,

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

        except NotAllowedError:

            raise faults.Forbidden('Not allowed')

    return response

def account_meta(request, v_account):

    # Normal Response Codes: 204

    # Error Response Codes: internalServerError (500),

    #                       badRequest (400)

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

    try:

        meta = request.backend.get_account_meta(

            request.user_uniq, v_account, 'pithos', until,

        groups = request.backend.get_account_groups(

            request.user_uniq, v_account)

                groups[k] = retrieve_displaynames(

                        getattr(request, 'token', None), groups[k])

        policy = request.backend.get_account_policy(

    except NotAllowedError:

        raise faults.Forbidden('Not allowed')

    return response

def account_update(request, v_account):

    # Normal Response Codes: 202

    # Error Response Codes: internalServerError (500),

    return HttpResponse(status=202)

def container_list(request, v_account):

    # Normal Response Codes: 200, 204

    # Error Response Codes: internalServerError (500),

    #                       badRequest (400)

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

    try:

        meta = request.backend.get_account_meta(

            request.user_uniq, v_account, 'pithos', until,

        groups = request.backend.get_account_groups(

            request.user_uniq, v_account)

        policy = request.backend.get_account_policy(

    except NotAllowedError:

        raise faults.Forbidden('Not allowed')

    return response

def container_meta(request, v_account, v_container):

    # Normal Response Codes: 204

    # Error Response Codes: internalServerError (500),

    return response

def container_create(request, v_account, v_container):

    # Normal Response Codes: 201, 202

    # Error Response Codes: internalServerError (500),

    return HttpResponse(status=ret)

def container_update(request, v_account, v_container):

    # Normal Response Codes: 202

    # Error Response Codes: internalServerError (500),

    return response

def container_delete(request, v_account, v_container):

    # Normal Response Codes: 204

    # Error Response Codes: internalServerError (500),

    return HttpResponse(status=204)

def object_list(request, v_account, v_container):

    # Normal Response Codes: 200, 204

    # Error Response Codes: internalServerError (500),

    return response

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

    # Normal Response Codes: 204

    # Error Response Codes: internalServerError (500),

    return response

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

    # Normal Response Codes: 200, 206

    # Error Response Codes: internalServerError (500),

    return object_data_response(request, sizes, hashmaps, meta)

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

    # Normal Response Codes: 201

    # Error Response Codes: internalServerError (500),

    return response

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

    # Normal Response Codes: 201

    # Error Response Codes: internalServerError (500),

    return response

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

    # Normal Response Codes: 201

    # Error Response Codes: internalServerError (500),

    return response

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

    # Normal Response Codes: 201

    # Error Response Codes: internalServerError (500),

    return response

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

    # Normal Response Codes: 202, 204

    # Error Response Codes: internalServerError (500),

    return response

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

    # Normal Response Codes: 204

    # Error Response Codes: internalServerError (500),

    except QuotaError, e:

        raise faults.RequestEntityTooLarge('Quota error: %s' % e)

    return HttpResponse(status=204)

#

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

# without modification, are permitted provided that the following

# interpreted as representing official policies, either expressed

# or implied, of GRNET S.A.

from django.http import HttpResponse

from django.views.decorators.csrf import csrf_exempt

from snf_django.lib.api import faults

from pithos.api.util import (put_object_headers, update_manifest_meta,

                             validate_matching_preconditions,

                             object_data_response, api_method,

                             split_container_object_string)

logger = logging.getLogger(__name__)

@csrf_exempt

def public_demux(request, v_public):

    if request.method == 'HEAD':

        return public_meta(request, v_public)

    elif request.method == 'GET':

        return public_read(request, v_public)

    else:

def public_meta(request, v_public):

    # Normal Response Codes: 204

    # Error Response Codes: internalServerError (500),

    return response

def public_read(request, v_public):

    # Normal Response Codes: 200, 206

    # Error Response Codes: internalServerError (500),

        try:

            for x in objects:

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

                sizes.append(s)

                hashmaps.append(h)

        except:

        meta['Content-Disposition'] = 'attachment; filename=%s' % (name,)

    return object_data_response(request, sizes, hashmaps, meta, True)

# or implied, of GRNET S.A.

from functools import wraps

from traceback import format_exc

from urllib import quote, unquote

from django.conf import settings

from django.core.files.uploadedfile import UploadedFile

from synnefo.lib.parsedate import parse_http_date_safe, parse_http_date

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

                                 BACKEND_BLOCK_MODULE, BACKEND_BLOCK_PATH,

                                 RADOS_POOL_MAPS, TRANSLATE_UUIDS,

                                 PUBLIC_URL_SECURITY,

                                 PUBLIC_URL_ALPHABET)

from pithos.backends.base import (NotAllowedError, QuotaError, ItemNotExists,

                                  VersionNotExists)

from synnefo.lib.astakos import (get_user_uuid, get_displayname,

logger = logging.getLogger(__name__)

def json_encode_decimal(obj):

    if isinstance(obj, decimal.Decimal):

        return str(obj)

    raise TypeError(repr(obj) + " is not JSON serializable")

def rename_meta_key(d, old, new):

    if old not in d:

        return

    """

    if 'last_modified' in d and d['last_modified']:

            datetime.fromtimestamp(d['last_modified']))

    return dict([(k.lower().replace('-', '_'), v) for k, v in d.iteritems()])

        public_url_security=PUBLIC_URL_SECURITY,

        public_url_alphabet=PUBLIC_URL_ALPHABET)

def get_backend():

    backend = _pithos_backend_pool.pool_get()

    backend.default_policy['quota'] = BACKEND_QUOTA

def update_response_headers(request, response):

    if (not response.has_header('Content-Length') and

        not (response.has_header('Content-Type') and

             response['Content-Type'].startswith('multipart/byteranges'))):

            response[quote(k)] = quote(v, safe='/=,:@; ')

    for u in usage:

        if u.get('name') == 'pithos+.diskspace':

            return u

    def decorator(func):

        @wraps(func)

        def wrapper(request, *args, **kwargs):

                request.backend = get_backend()

                response = func(request, *args, **kwargs)

                update_response_headers(request, response)

                return response

            finally:

                    request.backend.close()

        return wrapper

    return decorator