Synnefo

from django.db.models import Q

from synnefo_branding.utils import render_to_string

from synnefo.lib import join_urls

from astakos.im.models import AstakosUser, Invitation, ProjectMembership, \

                                             owner__in=users)

    apps_d = _partition_by(lambda a: a.owner.uuid, apps)

    for user in users:

        uuid = user.uuid

    return usage

import astakos.quotaholder_app.callpoint as qh

from astakos.quotaholder_app.exception import NoCapacityError

from django.db.models import Q

PROJECT_TAG = "project:"

USER_TAG = "user:"

def mk_quota_dict(users_counters, project_counters):

    for (holder, source, resource), u_value in users_counters.iteritems():

        p_value = project_counters[(source, None, resource)]

        values_dict = from_holding(u_value)

        values_dict.update(from_holding(p_value, is_project=True))

    return quota

def mk_limits_dict(counters):

    return quota

def mk_project_quota_dict(project_counters):

    for (holder, _, resource), p_value in project_counters.iteritems():

        values_dict = from_holding(p_value, is_project=True)

    return quota

        "person", "project")

    memberships_d = _partition_by(lambda m: m.project_id, memberships)

    for project in projects:

        pr_ref = get_project_ref(project)

        project_memberships = memberships_d.get(project.id, [])

        for grant in project_grants:

            resource = grant.resource.name

            val = grant.project_capacity if state == Project.NORMAL else 0

            for membership in project_memberships:

                u_ref = get_user_ref(membership.person)

                val = grant.member_capacity if membership.is_active() else 0

    return project_quota, user_quota

    u_ref = get_user_ref(membership.person)

    objs = ProjectResourceQuota.objects.select_related()

    grants = objs.filter(project=project)

    is_active = membership.is_active()

    for grant in grants:

        resource = grant.resource.name

        value = grant.member_capacity if is_active else 0

    return user_quota

from synnefo.db.models import VirtualMachine, Network, IPAddress

from synnefo.quotas import Quotaholder

MiB = 2 ** 20

GiB = 2 ** 30

def get_db_holdings(user=None, project=None):

    """Get holdings from Cyclades DB."""

    vms = VirtualMachine.objects.filter(deleted=False)

    networks = Network.objects.filter(deleted=False)

               "cyclades.total_cpu": vm_res["total_cpu"],

               "cyclades.disk": vm_res["disk"] * GiB,

               "cyclades.total_ram": vm_res["total_ram"] * MiB}

    vm_active_resources = vms.values("userid", "project")\

        .filter(Q(operstate="STARTED") | Q(operstate="BUILD") |

    for vm_res in vm_active_resources.iterator():

        user = vm_res['userid']

        project = vm_res['project']

    # Get resources related with networks

    net_resources = networks.values("userid", "project")\

        if user is None:

            continue

        project = net_res['project']

    floating_ips_resources = floating_ips.values("userid", "project")\

                                         .annotate(num=Count("id"))

    for floating_ip_res in floating_ips_resources.iterator():

        user = floating_ip_res["userid"]

        project = floating_ip_res["project"]

    return holdings

def get_db_project_holdings(project=None):

    """Get holdings from Cyclades DB."""

    vms = VirtualMachine.objects.filter(deleted=False)

    networks = Network.objects.filter(deleted=False)

               "cyclades.total_cpu": vm_res["total_cpu"],

               "cyclades.disk": vm_res["disk"] * GiB,

               "cyclades.total_ram": vm_res["total_ram"] * MiB}

    vm_active_resources = vms.values("project")\

        .filter(Q(operstate="STARTED") | Q(operstate="BUILD") |

    for vm_res in vm_active_resources.iterator():

        project = vm_res['project']

    # Get resources related with networks

    net_resources = networks.values("project").annotate(num=Count("id"))

        project = net_res['project']

        if project is None:

            continue

    floating_ips_resources = floating_ips.values("project")\

        .annotate(num=Count("id"))

    for floating_ip_res in floating_ips_resources.iterator():

        project = floating_ip_res["project"]

    return holdings