Synnefo

        try:

            return func(self, *args, **kwargs)

        except (socket_error, spec_exceptions.ConnectionForced) as e:

            self.connect()

    return wrapper

    def connect(self, retries=0):

        if self.max_retries and retries >= self.max_retries:

            self.log.error("Aborting after %d retries", retries)

                                      % retries)

            return

                arguments = {'x-ha-policy': 'all'}

            elif isinstance(mirrored_nodes, list):

                arguments = {'x-ha-policy': 'nodes',

            else:

                raise AttributeError

        else:

                raise socket_error

        consume_promise = \

        self.consume_promises.append(consume_promise)

        return consume_promise

import logging

from django.utils import simplejson as json

from synnefo.lib.pool.http import get_http_connection

logger = logging.getLogger(__name__)

def retry(howmany):

    def execute(func):

        def f(*args, **kwargs):

        return f

    return execute

def call(token, url, headers={}, body=None, method='GET'):

    p = urlparse(url)

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

    if body:

        kwargs['body'] = body

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

    conn = get_http_connection(p.netloc, p.scheme)

    try:

        conn.request(method, p.path + '?' + p.query, **kwargs)

        response = conn.getresponse()

        headers = response.getheaders()

        length = response.getheader('content-length', None)

        data = response.read(length)

        status = int(response.status)

        override_users={}):

    if override_users:

    try:

        data = call(

    except:

        raise

    else:

        override_users={}):

    if override_users:

    try:

        data = call(

    except:

        raise

    else:

        return data.get('displayname_catalog')

def get_user_uuid(

        token,

        displayname,

    uuid_dict = get_displaynames(token, [uuid], url, override_users)

    return uuid_dict.get(uuid)

def user_for_token(token, authentication_url, override_users, usage=False):

    if not token:

        return None

            return None

        raise e

def get_user(

        request,

        authentication_url='http://127.0.0.1:8000/im/authenticate',

                       authentication_url)

        return None

    request.user_uniq = user['uuid']

    request.user = user

    request.user_id = user.get('displayname')

import re

def mail_admins_safe(subject, message, fail_silently=False, connection=None):

    '''

    Wrapper function to cleanse email body from sensitive content before

    '''

    HIDDEN_ALL = settings.HIDDEN_SETTINGS + "|" + settings.HIDDEN_COOKIES

    return mail.mail_admins_plain(subject, message, fail_silently, connection)

class CleanseSettingsMiddleware(object):

    def __init__(self):

        '''

class LoggingConfigMiddleware:

    def __init__(self):

        logging_setting = getattr(settings, 'LOGGING_SETUP', None)

        if logging_setting:

            # Disable handlers that are not used by any logger.

    key.

    """

    def process_request(self, request):

# Copyright 2011-2012 GRNET S.A. All rights reserved.

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

# without modification, are permitted provided that the following

# conditions are met:

#   1. Redistributions of source code must retain the above

#      copyright notice, this list of conditions and the following

#      disclaimer.

#   2. Redistributions in binary form must reproduce the above

#      copyright notice, this list of conditions and the following

#      disclaimer in the documentation and/or other materials

#      provided with the distribution.

# THIS SOFTWARE IS PROVIDED BY GRNET S.A. ``AS IS'' AND ANY EXPRESS

# OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED

# WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR

# LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN

# ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE

# POSSIBILITY OF SUCH DAMAGE.

# The views and conclusions contained in the software and

# documentation are those of the authors and should not be

# interpreted as representing official policies, either expressed

# or implied, of GRNET S.A.

class SecureMiddleware(object):

    def process_request(self, request):

        if 'HTTP_X_FORWARDED_PROTOCOL' in request.META:

from select import select

from httplib import (

)

from new import instancemethod

class HTTPConnectionPool(ObjectPool):

    _scheme_to_class = {

    }

    def __init__(self, scheme, netloc, size=None):

                  "netloc: %s", size, scheme, netloc)

        ObjectPool.__init__(self, size=size)

        self.id = hash.hexdigest()

    def format(self):

        ret = cls._singles[distinct]

        return ret

class ArgBasedSingleton(object):

    __metaclass__ = ArgBasedSingletonMeta

import datetime

def split_time(value):

def merge_time(timetuple):

def case_unique(iterable):

        return list(set(iterable) - set(icase))

    return []

# or implied, of GRNET S.A.

from synnefo.settings.default.admins import *

# interpreted as representing official policies, either expressed

# or implied, of GRNET S.A.

import dateutil.parser

class UTC(tzinfo):

    """

    Helper UTC time information object.

    since = dateutil.parser.parse(s)

    utc_since = since.astimezone(UTC()).replace(tzinfo=None)

    return utc_since

import sys

import pkg_resources

import types

import os

from collections import defaultdict

# List of python distribution names which entry points will get excluded

# from snf-common settings extension mechanism

def extend_module(module_name, attrs):

    module = sys.modules[module_name]

        setattr(module, k, v)

    if hasattr(object_or_func, '__call__'):

        obj = object_or_func()

        dct = {}

        for k in dir(obj):

            if k.startswith("__"):

def extend_list_from_entry_point(settings_object, ns, entry_point_name,

    settings_object = list(settings_object)

    for e in get_entry_points(ns, entry_point_name):

        obj = entry_point_to_object(e)

            if row in settings_object:

                continue

                if row.get('before', False):

                    position = settings_object.index(row.get('before'))

                    insert_at = position - 1

                inserts = row.get('insert', [])

                if not type(inserts) == list:

                for entry in inserts:

                    if not entry in settings_object:

        patterns += e.load()

    return patterns

# Copyright 2011 GRNET S.A. All rights reserved.

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

# without modification, are permitted provided that the following

# conditions are met:

#   1. Redistributions of source code must retain the above

#      copyright notice, this list of conditions and the following

#      disclaimer.

#   2. Redistributions in binary form must reproduce the above

#      copyright notice, this list of conditions and the following

#      disclaimer in the documentation and/or other materials

#      provided with the distribution.

# THIS SOFTWARE IS PROVIDED BY GRNET S.A. ``AS IS'' AND ANY EXPRESS

# OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED

# WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR

# LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN

# ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE

# POSSIBILITY OF SUCH DAMAGE.

# The views and conclusions contained in the software and

# documentation are those of the authors and should not be

# interpreted as representing official policies, either expressed

# or implied, of GRNET S.A.

from IPy import IP

# Adapted from NFDHCPD's mac2eui64 utility, repository commit:feca7bb95

def mac2eui64(mac, prefixstr):

    try:

        prefix = IP(prefixstr)

    if len(mac_parts) != 6:

        raise Exception("%s is not a valid MAC-48 address" % mac)

    eui64[0] = "%02x" % (int(eui64[0], 16) ^ 0x02)

    ip = ":".join(pfx_parts[:4])

    for l in range(0, len(eui64), 2):

    return IP(ip).strCompressed()

# interpreted as representing official policies, either expressed

# or implied, of GRNET S.A.

def strbigdec(bignum, nr_lsd=12):

    all_digits = str(bignum)

    ms_digits = all_digits[:-nr_lsd]

    else:

        display = "[%s%1.0e]" % (approx, ms_num)

    return display

uenc_encoding = 'UTF-8'

def uenc_set_encoding(encoding=None):

    """Set the default encoding for uenc()

    uenc_encoding = encoding

def uenc(thing, encoding=None):

    """Encode the argument into a string.

    return str(thing)

uenc_set_encoding()

import pkg_resources

import os

import pprint

def get_dist_from_module(modname):

    pkgroot = pkg_resources.get_provider(modname).egg_root

    """

    try:

        return get_dist(dist_name).version

        return 'unknown'

    try:

        try:

            return __import__('synnefo.versions.%s' % modname,

        except ImportError:

        return 'unknown'

    """

    import subprocess

    callgit = lambda(cmd): subprocess.Popen(

    branch = callgit('git branch | grep -Ei "\* (.*)" | cut -f2 -d" "')

    revno = callgit('git --no-pager log --oneline | wc -l')

    desc = callgit('git describe --tags')

def update_version_old(module, name='version', root="."):

    """

    Helper util to generate/replace a version.py file containing version

    """

    # exit early if not in development environment

    paths = [root] + module.split(".") + ["%s.py" % name]

    module_filename = os.path.join(*paths)

__version_info__ = __version__.split(".")

__version_vcs_info__ = %(vcs_info)s

    """ % dict(version=get_version_from_describe(vcs_info()[3]),

    module_file = file(module_filename, "w+")

    module_file.write(content)