--- /dev/null
+# 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
+# PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL GRNET S.A OR
+# CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+# SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+# LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
+# USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED
+# AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
+# 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.
+
+import logging
+
+from functools import wraps
+from urlparse import urlparse
+
+from astakos.im.settings import QUEUE_CONNECTION
+
+if QUEUE_CONNECTION:
+ from synnefo.lib.queue import (exchange_connect, exchange_send,
+ exchange_close, UserEvent, Receipt
+ )
+
+QUEUE_CLIENT_ID = 3 # Astakos.
+INSTANCE_ID = '1'
+RESOURCE = 'addcredits'
+DEFAULT_CREDITS = 1000
+
+logging.basicConfig(format='%(asctime)s [%(levelname)s] %(name)s %(message)s',
+ datefmt='%Y-%m-%d %H:%M:%S'
+)
+logger = logging.getLogger('endpoint.aquarium')
+
+def wrapper(func):
+ @wraps(func)
+ def wrapper(*args, **kwargs):
+ if not QUEUE_CONNECTION:
+ return
+
+ try:
+ body, key = func(*args, **kwargs)
+ conn = exchange_connect(QUEUE_CONNECTION)
+ parts = urlparse(QUEUE_CONNECTION)
+ exchange = parts.path[1:]
+ routing_key = key % exchange
+ exchange_send(conn, routing_key, body)
+ exchange_close(conn)
+ except BaseException, e:
+ logger.exception(e)
+ return wrapper
+
+@wrapper
+def report_user_event(user, create=False):
+ eventType = 'create' if not create else 'modify'
+ body = UserEvent(QUEUE_CLIENT_ID, user.email, user.is_active, eventType, {}
+ ).format()
+ routing_key = '%s.user'
+ return body, routing_key
+
+@wrapper
+def report_user_credits_event(user):
+ body = Receipt(QUEUE_CLIENT_ID, user.email, INSTANCE_ID, RESOURCE,
+ DEFAULT_CREDITS, details={}
+ ).format()
+ routing_key = '%s.resource'
+ return body, routing_key
+
+def report_credits_event():
+ # better approach?
+ from astakos.im.models import AstakosUser
+ map(report_user_credits_event, AstakosUser.objects.all())
--- /dev/null
+# 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
+# PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL GRNET S.A OR
+# CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+# SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+# LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
+# USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED
+# AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
+# 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.
+
+import socket
+import logging
+
+from django.utils.translation import ugettext as _
+
+from commissioning.clients.quotaholder import QuotaholderHTTP
+
+from astakos.im.settings import QUOTA_HOLDER_URL, LOGGING_LEVEL
+
+ENTITY_KEY = '1'
+
+logger = logging.getLogger(__name__)
+
+def register_users(users, client=None):
+ if not users:
+ return
+
+ if not QUOTA_HOLDER_URL:
+ return
+
+ c = client or QuotaholderHTTP(QUOTA_HOLDER_URL)
+ data = []
+ append = data.append
+ for user in users:
+ try:
+ entity = user.email
+ except AttributeError:
+ continue
+ else:
+ args = entity, owner, key, ownerkey = (
+ entity, 'system', ENTITY_KEY, ''
+ )
+ append(args)
+
+ if not data:
+ return
+
+ rejected = c.create_entity(
+ context={},
+ create_entity=data,
+ )
+ msg = _('Create entities: %s - Rejected: %s' % (data, rejected,))
+ logger.log(LOGGING_LEVEL, msg)
+
+ created = filter(lambda u: unicode(u.email) not in rejected, users)
+ send_quota(created, c)
+ return rejected
+
+def send_quota(users, client=None):
+ if not users:
+ return
+
+ if not QUOTA_HOLDER_URL:
+ return
+
+ c = client or QuotaholderHTTP(QUOTA_HOLDER_URL)
+ data = []
+ append = data.append
+ for user in users:
+ try:
+ entity = user.email
+ except AttributeError:
+ continue
+ else:
+ for resource, limit in user.quota.iteritems():
+ args = entity, resource, key, quantity, capacity, import_limit , \
+ export_limit, flags =(
+ entity, resource, ENTITY_KEY, '0', str(limit), 0, 0, 0
+ )
+ append(args)
+
+ if not data:
+ return
+
+ rejected = c.set_quota(context={}, set_quota=data)
+ msg = _('Set quota: %s - Rejected: %s' % (data, rejected,))
+ logger.log(LOGGING_LEVEL, msg)
+ return rejected
+
+def get_quota(users, client=None):
+ if not users:
+ return
+
+ if not QUOTA_HOLDER_URL:
+ return
+
+ c = client or QuotaholderHTTP(QUOTA_HOLDER_URL)
+ data = []
+ append = data.append
+ for user in users:
+ try:
+ entity = user.email
+ except AttributeError:
+ continue
+ else:
+ for r in user.quota.keys():
+ args = entity, resource, key = entity, r, ENTITY_KEY
+ append(args)
+
+ if not data:
+ return
+
+ r = c.get_quota(context={}, get_quota=data)
+ msg = _('Get quota: %s' % data)
+ logger.log(LOGGING_LEVEL, msg)
+ return r
\ No newline at end of file
)
def handle(self, *args, **options):
- if args:
- raise CommandError("Command doesn't accept any arguments")
-
groups = AstakosGroup.objects.all()
if options.get('pending'):
dest='enable',
default=False,
help="Enable group"),
+ make_option('--disable',
+ action='store_true',
+ dest='disable',
+ default=False,
+ help="Disable group"),
)
def handle(self, *args, **options):
if options.get('enable'):
group.enable()
+ elif options.get('disable'):
+ group.disable()
+
except Exception, e:
raise CommandError(e)
\ No newline at end of file
--- /dev/null
+# Copyright 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
+# PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL GRNET S.A OR
+# CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+# SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+# LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
+# USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED
+# AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
+# 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 django.core.management.base import BaseCommand, CommandError
+from django.db.utils import IntegrityError
+
+from astakos.im.models import AstakosUser
+from astakos.im.endpoints.quotaholder import register_users
+
+class Command(BaseCommand):
+ help = "Send user information and resource quota in the Quotaholder"
+
+ def handle(self, *args, **options):
+ try:
+ r = register_users(AstakosUser.objects.all())
+ self.stdout.write("Rejected: %s\n" % r)
+ except BaseException, e:
+ print e
+ raise CommandError("Bootstrap failed.")
\ No newline at end of file
from django.db.utils import IntegrityError
from astakos.im.models import AstakosUser, AstakosGroup, Membership
+from astakos.im.endpoints.aquarium.producer import report_user_credits_event
from ._common import remove_user_permission, add_user_permission
class Command(BaseCommand):
make_option('--delete-permission',
dest='delete-permission',
help="Delete user permission"),
+ make_option('--refill-credits',
+ action='store_true',
+ dest='refill',
+ default=False,
+ help="Refill user credits"),
)
def handle(self, *args, **options):
if options['renew_token']:
user.renew_token()
+ if options['refill']:
+ report_user_credits_event(user)
+
try:
user.save()
except ValidationError, e:
from time import asctime
from datetime import datetime, timedelta
from base64 import b64encode
-from urlparse import urlparse
from random import randint
from collections import defaultdict
from django.utils.translation import ugettext as _
from django.core.exceptions import ValidationError
from django.db import transaction
-from django.db.models.signals import post_save, post_syncdb
+from django.db.models.signals import pre_save, post_save, post_syncdb, post_delete
+from django.dispatch import Signal
from django.db.models import Q
-from astakos.im.settings import DEFAULT_USER_LEVEL, INVITATIONS_PER_LEVEL, \
- AUTH_TOKEN_DURATION, BILLING_FIELDS, QUEUE_CONNECTION, \
- EMAILCHANGE_ACTIVATION_DAYS, LOGGING_LEVEL
+from astakos.im.settings import (DEFAULT_USER_LEVEL, INVITATIONS_PER_LEVEL,
+ AUTH_TOKEN_DURATION, BILLING_FIELDS, EMAILCHANGE_ACTIVATION_DAYS, LOGGING_LEVEL
+)
+from astakos.im.endpoints.quotaholder import register_users, send_quota
+from astakos.im.endpoints.aquarium.producer import report_user_event
-QUEUE_CLIENT_ID = 3 # Astakos.
+from astakos.im.tasks import propagate_groupmembers_quota
logger = logging.getLogger(__name__)
class AstakosGroup(Group):
kind = models.ForeignKey(GroupKind)
desc = models.TextField('Description', null=True)
- policy = models.ManyToManyField(Resource, null=True, blank=True, through='AstakosGroupQuota')
- creation_date = models.DateTimeField('Creation date', default=datetime.now())
+ policy = models.ManyToManyField(Resource, null=True, blank=True,
+ through='AstakosGroupQuota'
+ )
+ creation_date = models.DateTimeField('Creation date',
+ default=datetime.now()
+ )
issue_date = models.DateTimeField('Issue date', null=True)
expiration_date = models.DateTimeField('Expiration date', null=True)
- moderation_enabled = models.BooleanField('Moderated membership?', default=True)
- approval_date = models.DateTimeField('Activation date', null=True, blank=True)
- estimated_participants = models.PositiveIntegerField('Estimated #participants', null=True)
+ moderation_enabled = models.BooleanField('Moderated membership?',
+ default=True
+ )
+ approval_date = models.DateTimeField('Activation date', null=True,
+ blank=True
+ )
+ estimated_participants = models.PositiveIntegerField('Estimated #members',
+ null=True
+ )
@property
def is_disabled(self):
return False
return True
- @property
- def participants(self):
- return len(self.approved_members)
+# @property
+# def participants(self):
+# return len(self.approved_members)
def enable(self):
+ if self.is_enabled:
+ return
self.approval_date = datetime.now()
self.save()
+ quota_disturbed.send(sender=self, users=approved_members)
+ update_groupmembers_quota.apply_async(args=[self], eta=self.issue_date)
+ update_groupmembers_quota.apply_async(args=[self], eta=self.expiration_date)
def disable(self):
+ if self.is_disabled:
+ return
self.approval_date = None
self.save()
+ quota_disturbed.send(sender=self, users=self.approved_members)
def approve_member(self, person):
m, created = self.membership_set.get_or_create(person=person)
@property
def members(self):
- return map(lambda m:m.person, self.membership_set.all())
+ return [m.person for m in self.membership_set.all()]
@property
def approved_members(self):
- f = filter(lambda m:m.is_approved, self.membership_set.all())
- return map(lambda m:m.person, f)
+ return [m.person for m in self.membership_set.all() if m.is_approved]
@property
def quota(self):
return d
@property
- def has_undefined_policies(self):
- # TODO: can avoid query?
- return Resource.objects.filter(~Q(astakosgroup=self)).exists()
-
- @property
def owners(self):
return self.owner.all()
d = defaultdict(int)
for q in self.astakosuserquota_set.all():
d[q.resource.name] += q.limit
- for g in self.astakos_groups.all():
+ for m in self.membership_set.all():
+ if not m.is_approved:
+ continue
+ g = m.group
if not g.is_enabled:
continue
for r, limit in g.quota.iteritems():
self.username = username
if not self.provider:
self.provider = 'local'
- report_user_event(self)
self.validate_unique_email_isactive()
if self.is_active and self.activation_sent:
# reset the activation sent
def approve(self):
self.date_joined = datetime.now()
self.save()
-
+ quota_disturbed.send(sender=self, users=(self.person,))
+
def disapprove(self):
self.delete()
+ quota_disturbed.send(sender=self, users=(self.person,))
class AstakosGroupQuota(models.Model):
limit = models.PositiveIntegerField('Limit')
def __unicode__(self):
return '%s -> %s [%d]' % (self.inviter, self.username, self.code)
-def report_user_event(user):
- def should_send(user):
- # report event incase of new user instance
- # or if specific fields are modified
- if not user.id:
- return True
- try:
- db_instance = AstakosUser.objects.get(id = user.id)
- except AstakosUser.DoesNotExist:
- return True
- for f in BILLING_FIELDS:
- if (db_instance.__getattribute__(f) != user.__getattribute__(f)):
- return True
- return False
-
- if QUEUE_CONNECTION and should_send(user):
-
- from astakos.im.queue.userevent import UserEvent
- from synnefo.lib.queue import exchange_connect, exchange_send, \
- exchange_close
-
- eventType = 'create' if not user.id else 'modify'
- body = UserEvent(QUEUE_CLIENT_ID, user, eventType, {}).format()
- conn = exchange_connect(QUEUE_CONNECTION)
- parts = urlparse(QUEUE_CONNECTION)
- exchange = parts.path[1:]
- routing_key = '%s.user' % exchange
- exchange_send(conn, routing_key, body)
- exchange_close(conn)
-
-def _generate_invitation_code():
- while True:
- code = randint(1, 2L**63 - 1)
- try:
- Invitation.objects.get(code=code)
- # An invitation with this code already exists, try again
- except Invitation.DoesNotExist:
- return code
-
-def get_latest_terms():
- try:
- term = ApprovalTerms.objects.order_by('-id')[0]
- return term
- except IndexError:
- pass
- return None
-
class EmailChangeManager(models.Manager):
@transaction.commit_on_success
def change_email(self, activation_key):
owner = models.ForeignKey(AstakosUser)
email = models.EmailField()
+def _generate_invitation_code():
+ while True:
+ code = randint(1, 2L**63 - 1)
+ try:
+ Invitation.objects.get(code=code)
+ # An invitation with this code already exists, try again
+ except Invitation.DoesNotExist:
+ return code
+
+def get_latest_terms():
+ try:
+ term = ApprovalTerms.objects.order_by('-id')[0]
+ return term
+ except IndexError:
+ pass
+ return None
+
def create_astakos_user(u):
try:
AstakosUser.objects.get(user_ptr=u.pk)
extended_user.__dict__.update(u.__dict__)
extended_user.renew_token()
extended_user.save()
- except:
+ except BaseException, e:
+ logger.exception(e)
pass
-def superuser_post_syncdb(sender, **kwargs):
- # if there was created a superuser
- # associate it with an AstakosUser
+def fix_superusers(sender, **kwargs):
+ # Associate superusers with AstakosUser
admins = User.objects.filter(is_superuser=True)
for u in admins:
create_astakos_user(u)
-post_syncdb.connect(superuser_post_syncdb)
-
-def superuser_post_save(sender, instance, **kwargs):
- if instance.is_superuser:
- create_astakos_user(instance)
-
-post_save.connect(superuser_post_save, sender=User)
-
-def set_default_group(sender, instance, created, **kwargs):
+def user_post_save(sender, instance, created, **kwargs):
if not created:
return
+ create_astakos_user(instance)
+
+def set_default_group(user):
try:
default = AstakosGroup.objects.get(name = 'default')
- Membership(group=default, person=instance, date_joined=datetime.now()).save()
+ Membership(group=default, person=user, date_joined=datetime.now()).save()
except AstakosGroup.DoesNotExist, e:
logger.exception(e)
-post_save.connect(set_default_group, sender=AstakosUser)
-
-def get_resources():
- # use cache
- return Resource.objects.select_related().all()
\ No newline at end of file
+def astakosuser_pre_save(sender, instance, **kwargs):
+ instance.aquarium_report = False
+ instance.new = False
+ try:
+ db_instance = AstakosUser.objects.get(id = instance.id)
+ except AstakosUser.DoesNotExist:
+ # create event
+ instance.aquarium_report = True
+ instance.new = True
+ else:
+ get = AstakosUser.__getattribute__
+ l = filter(lambda f: get(db_instance, f) != get(instance, f),
+ BILLING_FIELDS
+ )
+ instance.aquarium_report = True if l else False
+
+def astakosuser_post_save(sender, instance, created, **kwargs):
+ if instance.aquarium_report:
+ report_user_event(instance, create=instance.new)
+ if not created:
+ return
+ set_default_group(instance)
+ # TODO handle socket.error & IOError
+ register_users((instance,))
+
+def send_quota_disturbed(sender, instance, **kwargs):
+ users = []
+ extend = users.extend
+ if sender == Membership:
+ if not instance.group.is_enabled:
+ return
+ extend([instance.person])
+ elif sender == AstakosUserQuota:
+ extend([instance.user])
+ elif sender == AstakosGroupQuota:
+ if not instance.group.is_enabled:
+ return
+ extend(instance.group.astakosuser_set.all())
+ elif sender == AstakosGroup:
+ if not instance.is_enabled:
+ return
+ quota_disturbed.send(sender=sender, users=users)
+
+def on_quota_disturbed(sender, users, **kwargs):
+ print '>>>', locals()
+ if not users:
+ return
+ send_quota(users)
+
+post_syncdb.connect(fix_superusers)
+post_save.connect(user_post_save, sender=User)
+pre_save.connect(astakosuser_pre_save, sender=AstakosUser)
+post_save.connect(astakosuser_post_save, sender=AstakosUser)
+
+quota_disturbed = Signal(providing_args=["users"])
+quota_disturbed.connect(on_quota_disturbed)
+
+post_delete.connect(send_quota_disturbed, sender=AstakosGroup)
+post_delete.connect(send_quota_disturbed, sender=Membership)
+post_save.connect(send_quota_disturbed, sender=AstakosUserQuota)
+post_delete.connect(send_quota_disturbed, sender=AstakosUserQuota)
+post_save.connect(send_quota_disturbed, sender=AstakosGroupQuota)
+post_delete.connect(send_quota_disturbed, sender=AstakosGroupQuota)
\ No newline at end of file
# Set the astakos main functions logging severity (None to disable)
from logging import INFO
LOGGING_LEVEL = getattr(settings, 'ASTAKOS_LOGGING_LEVEL', INFO)
+
+QUOTA_HOLDER_URL = getattr(settings, 'ASTAKOS_QUOTA_HOLDER_URL', '')
\ No newline at end of file
--- /dev/null
+# 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
+# PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL GRNET S.A OR
+# CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+# SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+# LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
+# USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED
+# AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
+# 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 celery.task import task, periodic_task
+from celery.schedules import crontab
+
+from functools import wraps
+
+from astakos.im.endpoints.quotaholder import send_quota
+from astakos.im.endpoints.aquarium.producer import report_credits_event, report_user_event
+
+import logging
+
+logger = logging.getLogger(__name__)
+
+def log(func):
+ @wraps(func)
+ def wrapper(*args, **kwargs):
+ logger.info('Starting the %s' % func)
+ return func(*args, **kwargs)
+ return wrapper
+
+#@periodic_task(run_every=crontab(day_of_month='1'))
+@periodic_task(run_every=crontab())
+@log
+def propagate_credits_update():
+ report_credits_event()
+
+@task
+@log
+def propagate_groupmembers_quota(group):
+ if group.is_disabled:
+ return
+ send_quota(group.approved_members)
Έχει δημιουργηθεί το παρακάτω group:
-Id: {{group.id}}}
-Name: {{group.name}}
-Type: {{group.kind}}
-Issue date: {{group.issue_date|date:"d/m/Y"}}
-Expiration date: {{group.expiration_date|date:"d/m/Y"}}
-Moderation: {{group.moderation_enabled}}
-Owner: {{owner}}
+Id: {{group.id}}
+Name: {{group.name}}
+Type: {{group.kind}}
+Issue date: {{group.issue_date|date:"d/m/Y"}}
+Expiration date: {{group.expiration_date|date:"d/m/Y"}}
+Moderation: {{group.moderation_enabled}}
+Owner: {{owner}}
+Expected participant number: {{group.estimated_participants}}
Policies:
{% for p in policies %}
{{p}}
The following account has been created:
-Id: {{group.id}}}
-Name: {{group.name}}
-Type: {{group.kind}}
-Issue date: {{group.issue_date|date:"d/m/Y"}}
-Expiration date: {{group.expiration_date|date:"d/m/Y"}}
-Moderation: {{group.moderation_enabled}}
-Owner: {{owner}}
+Id: {{group.id}}
+Name: {{group.name}}
+Type: {{group.kind}}
+Issue date: {{group.issue_date|date:"d/m/Y"}}
+Expiration date: {{group.expiration_date|date:"d/m/Y"}}
+Moderation: {{group.moderation_enabled}}
+Owner: {{owner}}
+Expected participant number: {{group.estimated_participants}}
Policies:
{% for p in policies %}
{{p}}
else:
now = datetime.now()
data = {
- 'kind':kind,
- 'issue_date':now,
- 'expiration_date':now + timedelta(days=30)
+ 'kind':kind
}
form = form_class(data, resources=resources)
template='im/astakosgroup_detail.html',
context_instance=get_context(request),
object=m.group,
- quota=m.group.quota,
- more_policies=m.group.has_undefined_policies
+ quota=m.group.quota
)
return wrapper
return decorator
'snf-common>=0.9.0',
'django-recaptcha',
'django-ratelimit==0.1'
+ 'django-ratelimit==0.1',
+ 'commissioning',
+ 'celery'
]
EXTRAS_REQUIRES = {
projects / astakos / commitdiff