Synnefo

Changelog

=========

v0.10.0

------

* improve sql queries

v0.9.7

------

* Delegate feedback post request to Identity Provider (astakos)

  work.

* Change API calls to include public objects in shared by me

v0.9.5

------

v0.9.4

------

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

Name                             Default value                                          Description

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

PITHOS_USER_CATALOG_URL          \http://127.0.0.1:8000/im/service/api/v2.0/users/      Astakos User Catalog URL

PITHOS_USER_FEEDBACK_URL         \http://127.0.0.1:8000/im/service/api/v2.0/feedback/   Astakos User Feedback URL

PITHOS_USER_LOGIN_URL            \http://127.0.0.1:8000/login/                          Astakos User Login URL

PITHOS_BACKEND_VERSIONING        auto                                                   Default versioning policy for containers

PITHOS_BACKEND_FREE_VERSIONING   True                                                   Default versioning debit policy (default free)

PITHOS_UPDATE_MD5                True                                                   Update object checksums when using hashmaps

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

To update checksums asynchronously, enable the queue, install snf-pithos-tools and use ``pithos-dispatcher``::

# Disable if checksums are not required or are computed asynchronously by an external process.

#PITHOS_UPDATE_MD5 = True

from django.views.decorators.csrf import csrf_exempt

from pithos.api.settings import (

from synnefo.lib.pool.http import get_http_connection

    copy_or_move_object, get_int_parameter, get_content_length,

    get_content_range, socket_read_iterator, SaveToBackendHandler,

    object_data_response, put_object_block, hashmap_md5, simple_list_response,

from pithos.api.settings import UPDATE_MD5

            response.status_code = 204

            return response

        response.status_code = 200

        response.content = '\n'.join(accounts) + '\n'

        return response

        except NotAllowedError:

            raise Forbidden('Not allowed')

        else:

            rename_meta_key(meta, 'modified', 'last_modified')

            rename_meta_key(

                meta, 'until_timestamp', 'x_account_until_timestamp')

            external_quota=request.user_usage)

        groups = request.backend.get_account_groups(

            request.user_uniq, v_account)

        policy = request.backend.get_account_policy(

            request.user_uniq, v_account, external_quota=request.user_usage)

    except NotAllowedError:

    #                       badRequest (400)

    meta, groups = get_account_headers(request)

    replace = True

    if 'update' in request.GET:

        replace = False

    object_meta = []

    for meta in objects:

        if len(meta) == 1:

            # Virtual objects/directories.

            object_meta.append(meta)

# Update object checksums when using hashmaps.

UPDATE_MD5 = getattr(settings, 'PITHOS_UPDATE_MD5', True)

RADOS_STORAGE = getattr(settings, 'PITHOS_RADOS_STORAGE', False)

RADOS_POOL_BLOCKS= getattr(settings, 'PITHOS_RADOS_POOL_BLOCKS', 'blocks')

RADOS_POOL_MAPS = getattr(settings, 'PITHOS_RADOS_POOL_MAPS', 'maps')

                                 BACKEND_QUOTA, BACKEND_VERSIONING,

                                 BACKEND_FREE_VERSIONING,

                                 AUTHENTICATION_URL, AUTHENTICATION_USERS,

                                 RADOS_STORAGE, RADOS_POOL_BLOCKS,

                                 RADOS_POOL_MAPS)

from pithos.backends import connect_backend

    return meta, groups

def put_account_headers(response, meta, groups, policy):

    if 'count' in meta:

        response['X-Account-Container-Count'] = meta['count']

    if not restricted:

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

        response['X-Object-UUID'] = meta['uuid']

        response['X-Object-Modified-By'] = smart_str(

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

        response['X-Object-Version-Timestamp'] = http_date(

            int(meta['version_timestamp']))

    else:

       return True

    try:

        return get_displayname(

    except:

        # if it fails just leave the input intact

        return uuid

    return get_displaynames(

    if is_uuid(displayname):

        return displayname

    uuid = get_user_uuid(

    if not uuid:

        raise ItemNotExists(displayname)

    return uuid

    return get_uuids(

    try:

        # check first for a group permission

        account, group = holder.split(':')

    else:

        return ':'.join([retrieve_uuid(account), group])

    try:

        # check first for a group permission

        account, group = holder.split(':')

    if len(perms) == 0:

        return

    ret = []

                'Bad X-Object-Sharing header value: missing prefix')

    # replace displayname with uuid

    # Keep duplicates only in write list.

    dups = [x for x in ret.get(

                    if  getattr(request, 'user', None) is None:

                        raise Unauthorized('Access denied')

                    assert getattr(request, 'user_uniq', None) != None

                # The args variable may contain up to (account, container, object).

                if len(args) > 1 and len(args[1]) > 256:

                    raise BadRequest('Container name too large.')