Synnefo

# 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.

import string

from optparse import make_option

from django.core import management

from django.db import transaction

from django.core.management.base import BaseCommand, CommandError

from django.contrib.auth.models import Group

from django.core.exceptions import ValidationError

from django.core.validators import validate_email

from synnefo.util import units

from astakos.im.models import AstakosUser, AstakosUserQuota

from astakos.im import quotas

from astakos.im import activation_backends

from ._common import (remove_user_permission, add_user_permission, is_uuid,

                      show_resource_value)

activation_backend = activation_backends.get_backend()

class Command(BaseCommand):

    args = "<user ID>"

    help = "Modify a user's attributes"

    option_list = BaseCommand.option_list + (

        make_option('--invitations',

                    dest='invitations',

                    metavar='NUM',

                    help="Update user's invitations"),

        make_option('--level',

                    dest='level',

                    metavar='NUM',

                    help="Update user's level"),

        make_option('--password',

                    dest='password',

                    metavar='PASSWORD',

                    help="Set user's password"),

        make_option('--renew-token',

                    action='store_true',

                    dest='renew_token',

                    default=False,

                    help="Renew the user's token"),

        make_option('--renew-password',

                    action='store_true',

                    dest='renew_password',

                    default=False,

                    help="Renew the user's password"),

        make_option('--set-admin',

                    action='store_true',

                    dest='admin',

                    default=False,

                    help="Give user admin rights"),

        make_option('--set-noadmin',

                    action='store_true',

                    dest='noadmin',

                    default=False,

                    help="Revoke user's admin rights"),

        make_option('--set-active',

                    action='store_true',

                    dest='active',

                    default=False,

                    help="Change user's state to active"),

        make_option('--set-inactive',

                    action='store_true',

                    dest='inactive',

                    default=False,

                    help="Change user's state to inactive"),

        make_option('--inactive-reason',

                    dest='inactive_reason',

                    help="Reason user got inactive"),

        make_option('--add-group',

                    dest='add-group',

                    help="Add user group"),

        make_option('--delete-group',

                    dest='delete-group',

                    help="Delete user group"),

        make_option('--add-permission',

                    dest='add-permission',

                    help="Add user permission"),

        make_option('--delete-permission',

                    dest='delete-permission',

                    help="Delete user permission"),

        make_option('--accept',

                    dest='accept',

                    action='store_true',

                    help="Accept user"),

        make_option('--verify',

                    dest='verify',

                    action='store_true',

                    help="Verify user email"),

        make_option('--reject',

                    dest='reject',

                    action='store_true',

                    help="Reject user"),

        make_option('--reject-reason',

                    dest='reject_reason',

                    help="Reason user got rejected"),

        make_option('--set-base-quota',

                    dest='set_base_quota',

                    metavar='<resource> <capacity>',

                    nargs=2,

                    help=("Set base quota for a specified resource. "

                          "The special value 'default' sets the user base "

                          "quota to the default value.")

                    ),

        make_option('-f', '--no-confirm',

                    action='store_true',

                    default=False,

                    dest='force',

                    help="Do not ask for confirmation"),

        make_option('--set-email',

                    dest='set-email',

                    help="Change user's email"),

        make_option('--delete',

                    dest='delete',

                    action='store_true',

                    help="Delete user"),

    )

    @transaction.commit_on_success

    def handle(self, *args, **options):

        if len(args) != 1:

            raise CommandError("Please provide a user ID")

        if args[0].isdigit():

            try:

                user = AstakosUser.objects.get(id=int(args[0]))

            except AstakosUser.DoesNotExist:

                raise CommandError("Invalid user ID")

        elif is_uuid(args[0]):

            try:

                user = AstakosUser.objects.get(uuid=args[0])

            except AstakosUser.DoesNotExist:

                raise CommandError("Invalid user UUID")

        else:

            raise CommandError(("Invalid user identification: "

                                "you should provide a valid user ID "

                                "or a valid user UUID"))

        if options.get('admin'):

            user.is_superuser = True

        elif options.get('noadmin'):

            user.is_superuser = False

        if options.get('reject'):

            reject_reason = options.get('reject_reason', None)

            res = activation_backend.handle_moderation(

                user,

                accept=False,

                reject_reason=reject_reason)

            activation_backend.send_result_notifications(res, user)

            if res.is_error():

                print "Failed to reject.", res.message

            else:

                print "Account rejected"

        if options.get('verify'):

            res = activation_backend.handle_verification(

                user,

                user.verification_code)

            #activation_backend.send_result_notifications(res, user)

            if res.is_error():

                print "Failed to verify.", res.message

            else:

                print "Account verified (%s)" % res.status_display()

        if options.get('accept'):

            res = activation_backend.handle_moderation(user, accept=True)

            activation_backend.send_result_notifications(res, user)

            if res.is_error():

                print "Failed to accept.", res.message

            else:

                print "Account accepted and activated"

        if options.get('active'):

            res = activation_backend.activate_user(user)

            if res.is_error():

                print "Failed to activate.", res.message

            else:

                print "Account %s activated" % user.username

        elif options.get('inactive'):

            res = activation_backend.deactivate_user(

                user,

                reason=options.get('inactive_reason', None))

            if res.is_error():

                print "Failed to deactivate,", res.message

            else:

                print "Account %s deactivated" % user.username

        invitations = options.get('invitations')

        if invitations is not None:

            user.invitations = int(invitations)

        groupname = options.get('add-group')

        if groupname is not None:

            try:

                group = Group.objects.get(name=groupname)

                user.groups.add(group)

            except Group.DoesNotExist, e:

                self.stdout.write(

                    "Group named %s does not exist\n" % groupname)

        groupname = options.get('delete-group')

        if groupname is not None:

            try:

                group = Group.objects.get(name=groupname)

                user.groups.remove(group)

            except Group.DoesNotExist, e:

                self.stdout.write(

                    "Group named %s does not exist\n" % groupname)

        pname = options.get('add-permission')

        if pname is not None:

            try:

                r, created = add_user_permission(user, pname)

                if created:

                    self.stdout.write(

                        'Permission: %s created successfully\n' % pname)

                if r > 0:

                    self.stdout.write(

                        'Permission: %s added successfully\n' % pname)

                elif r == 0:

                    self.stdout.write(

                        'User has already permission: %s\n' % pname)

            except Exception, e:

                raise CommandError(e)

        pname = options.get('delete-permission')

        if pname is not None and not user.has_perm(pname):

            try:

                r = remove_user_permission(user, pname)

                if r < 0:

                    self.stdout.write(

                        'Invalid permission codename: %s\n' % pname)

                elif r == 0:

                    self.stdout.write('User has not permission: %s\n' % pname)

                elif r > 0:

                    self.stdout.write(

                        'Permission: %s removed successfully\n' % pname)

            except Exception, e:

                raise CommandError(e)

        level = options.get('level')

        if level is not None:

            user.level = int(level)

        password = options.get('password')

        if password is not None:

            user.set_password(password)

        password = None

        if options['renew_password']:

            password = AstakosUser.objects.make_random_password()

            user.set_password(password)

        if options['renew_token']:

            user.renew_token()

        try:

            user.save()

        except ValidationError, e:

            raise CommandError(e)

        if password:

            self.stdout.write('User\'s new password: %s\n' % password)

        force = options['force']

        set_base_quota = options.get('set_base_quota')

        if set_base_quota is not None:

            resource, capacity = set_base_quota

            self.set_limit(user, resource, capacity, force)

        delete = options.get('delete')

        if delete:

            management.call_command('user-show', str(user.pk),

                                    list_quotas=True)

            m = "Are you sure you want to permanently delete the user " \

                "(yes/no) ? "

            self.stdout.write("\n")

            confirm = raw_input(m)

            if confirm == "yes":

                user.delete()

        # Change users email address

        newemail = options.get('set-email', None)

        if newemail is not None:

            newemail = newemail.strip()

            try:

                validate_email(newemail)

            except ValidationError:

                m = "Invalid email address."

                raise CommandError(m)

            if AstakosUser.objects.user_exists(newemail):

                m = "A user with this email address already exists."

                raise CommandError(m)

            user.email = newemail

            user.save()

    def set_limit(self, user, resource, capacity, force):

        style = None

        if capacity != 'default':

            try:

                capacity, style = units.parse_with_style(capacity)

            except:

                m = "Please specify capacity as a decimal integer or 'default'"

                raise CommandError(m)

        try:

            quota = user.get_resource_policy(resource)

        except AstakosUserQuota.DoesNotExist:

            raise CommandError("No such resource: %s" % resource)

        default_capacity = quota.resource.uplimit

        if not force:

            s_default = show_resource_value(default_capacity, resource, style)

            s_current = show_resource_value(quota.capacity, resource, style)

            s_capacity = (show_resource_value(capacity, resource, style)

                          if capacity != 'default' else capacity)

            self.stdout.write("user: %s (%s)\n" % (user.uuid, user.username))

            self.stdout.write("default capacity: %s\n" % s_default)

            self.stdout.write("current capacity: %s\n" % s_current)

            self.stdout.write("new capacity: %s\n" % s_capacity)

            self.stdout.write("Confirm? (y/n) ")

            response = raw_input()

            if string.lower(response) not in ['y', 'yes']:

                self.stdout.write("Aborted.\n")

                return

        if capacity == 'default':

            capacity = default_capacity

        quotas.update_base_quota(quota, capacity)