Synnefo

# 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 THE REGENTS AND CONTRIBUTORS ``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 THE REGENTS 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 datetime

from django.conf import settings

from django.db import models

class SynnefoUser(models.Model):

    #TODO: Amend this when we have groups

    ACCOUNT_TYPE = (

        ('STUDENT', 'Student'),

        ('PROFESSOR', 'Professor'),

        ('USER', 'Generic User'),

        ('HELPDESK', 'Helpdesk User'),

        ('ADMIN', 'Admin User')

    )

    ACCOUNT_STATE = (

        ('ACTIVE', 'Active'),

        ('DELETED', 'Deleted'),

        ('SUSPENDED', 'Suspended')

    )

    name = models.CharField('Synnefo Username', max_length=255, default='')

    realname = models.CharField('Real Name', max_length=255, default='')

    uniq = models.CharField('External Unique ID', max_length=255,null=True)

    credit = models.IntegerField('Credit Balance')

    auth_token = models.CharField('Authentication Token', max_length=32,

            null=True)

    auth_token_created = models.DateTimeField('Time of auth token creation',

            auto_now_add=True, null=True)

    auth_token_expires = models.DateTimeField('Time of auth token expiration',

            auto_now_add=True, null=True)

    tmp_auth_token = models.CharField('Temporary authentication token',

            max_length=32, null=True)

    tmp_auth_token_expires = models.DateTimeField('Time of temporary auth '

            'token expiration', auto_now_add=True, null=True)

    type = models.CharField('Account type', choices=ACCOUNT_TYPE,

            max_length=30)

    state = models.CharField('Account state', choices=ACCOUNT_STATE,

            max_length=30, default='ACTIVE')

    created = models.DateTimeField('Time of creation', auto_now_add=True)

    updated = models.DateTimeField('Time of last update', auto_now=True)

    max_invitations = models.IntegerField('Max number of invitations',

            null=True)

    def __unicode__(self):

        return self.name

    def get_limit(self, limit_name):

        """Returns the limit value for the specified limit"""

        limit_objs = Limit.objects.filter(name=limit_name, user=self)

        if len(limit_objs) == 1:

            return limit_objs[0].value

        return 0

    @property

    def credit_quota(self):

        """Internal getter function for credit quota"""

        return self.get_limit('QUOTA_CREDIT')

    @property

    def monthly_rate(self):

        """Internal getter function for monthly credit issue rate"""

        return self.get_limit('MONTHLY_RATE')

    @property

    def min_credits(self):

        """Internal getter function for maximum number of violations"""

        return self.get_limit('MIN_CREDITS')

class Image(models.Model):

    IMAGE_STATES = (

        ('ACTIVE', 'Active'),

        ('SAVING', 'Saving'),

        ('DELETED', 'Deleted')

    )

    # The list of supported Image formats

    FORMATS = (

        ('dump', 'ext3 dump'),

        ('extdump', 'Raw ext2/3/4 dump'),

        ('lvm', 'lvm snapshot'),

        ('ntfsclone', 'Windows Image produced by ntfsclone'),

        ('ntfsdump', 'Raw NTFS dump'),

        ('diskdump', 'Raw dump of a hard disk')

    )

    name = models.CharField('Image name', max_length=255)

    state = models.CharField('Current Image State', choices=IMAGE_STATES,

            max_length=30)

    owner = models.ForeignKey(SynnefoUser, blank=True, null=True)

    created = models.DateTimeField('Time of creation', auto_now_add=True)

    updated = models.DateTimeField('Time of last update', auto_now=True)

    sourcevm = models.ForeignKey('VirtualMachine', null=True)

    backend_id = models.CharField(max_length=50, default='debian_base')

    format = models.CharField(choices=FORMATS, max_length=30, default='dump')

    public = models.BooleanField(default=False)

    def __unicode__(self):

        return self.name

class ImageMetadata(models.Model):

    meta_key = models.CharField('Image metadata key name', max_length=50)

    meta_value = models.CharField('Image metadata value', max_length=500)

    image = models.ForeignKey(Image, related_name='metadata')

    class Meta:

        unique_together = (('meta_key', 'image'),)

        verbose_name = u'Key-value pair of Image metadata.'

    def __unicode__(self):

        return u'%s: %s' % (self.meta_key, self.meta_value)

class Limit(models.Model):

    LIMITS = (

        ('QUOTA_CREDIT', 'Maximum amount of credits per user'),

        ('MIN_CREDITS', 'Minimum amount of credits per user'),

        ('MONTHLY_RATE', 'Monthly credit issue rate')

    )

    user = models.ForeignKey(SynnefoUser)

    name = models.CharField('Limit key name', choices=LIMITS, max_length=30,

            null=False)

    value = models.IntegerField('Limit current value')

    class Meta:

        verbose_name = u'Enforced limit for user'

    def __unicode__(self):

        return u'Limit %s for user %s: %d' % (self.value, self.user,

                self.value)

class Flavor(models.Model):

    cpu = models.IntegerField('Number of CPUs', default=0)

    ram = models.IntegerField('RAM size in MiB', default=0)

    disk = models.IntegerField('Disk size in GiB', default=0)

    disk_template = models.CharField('Disk template', max_length=32,

            default=settings.DEFAULT_GANETI_DISK_TEMPLATE)

    deleted = models.BooleanField('Deleted', default=False)

    class Meta:

        verbose_name = u'Virtual machine flavor'

        unique_together = ('cpu', 'ram', 'disk')

    @property

    def name(self):

        """Returns flavor name (generated)"""

        return u'C%dR%dD%d' % (self.cpu, self.ram, self.disk)

    def _current_cost(self, active):

        """Returns active/inactive cost value

        set active = True to get active cost and False for the inactive.

        """

        costs = FlavorCost.objects.filter(flavor=self)

        fch_list = costs.order_by('-effective_from')

        if len(fch_list) > 0:

            if active:

                return fch_list[0].cost_active

            else:

                return fch_list[0].cost_inactive

        return 0

    @property

    def current_cost_active(self):

        """Returns current active cost (property method)"""

        return self._current_cost(True)

    @property

    def current_cost_inactive(self):

        """Returns current inactive cost (property method)"""

        return self._current_cost(False)

    def __unicode__(self):

        return self.name

class FlavorCost(models.Model):

    cost_active = models.PositiveIntegerField('Active Cost')

    cost_inactive = models.PositiveIntegerField('Inactive Cost')

    effective_from = models.DateTimeField()

    flavor = models.ForeignKey(Flavor)

    class Meta:

        verbose_name = u'Pricing history for flavors'

    def __unicode__(self):

        return u'Costs (up, down)=(%d, %d) for %s since %s' % (

                int(self.cost_active), int(self.cost_inactive),

                self.flavor.name, self.effective_from)

class VirtualMachine(models.Model):

    # The list of possible actions for a VM

    ACTIONS = (

       ('CREATE', 'Create VM'),

       ('START', 'Start VM'),

       ('STOP', 'Shutdown VM'),

       ('SUSPEND', 'Admin Suspend VM'),

       ('REBOOT', 'Reboot VM'),

       ('DESTROY', 'Destroy VM')

    )

    # The internal operating state of a VM

    OPER_STATES = (

        ('BUILD', 'Queued for creation'),

        ('ERROR', 'Creation failed'),

        ('STOPPED', 'Stopped'),

        ('STARTED', 'Started'),

        ('DESTROYED', 'Destroyed')

    )

    # The list of possible operations on the backend

    BACKEND_OPCODES = (

        ('OP_INSTANCE_CREATE', 'Create Instance'),

        ('OP_INSTANCE_REMOVE', 'Remove Instance'),

        ('OP_INSTANCE_STARTUP', 'Startup Instance'),

        ('OP_INSTANCE_SHUTDOWN', 'Shutdown Instance'),

        ('OP_INSTANCE_REBOOT', 'Reboot Instance'),

        # These are listed here for completeness,

        # and are ignored for the time being

        ('OP_INSTANCE_SET_PARAMS', 'Set Instance Parameters'),

        ('OP_INSTANCE_QUERY_DATA', 'Query Instance Data'),

        ('OP_INSTANCE_REINSTALL', 'Reinstall Instance'),

        ('OP_INSTANCE_ACTIVATE_DISKS', 'Activate Disks'),

        ('OP_INSTANCE_DEACTIVATE_DISKS', 'Deactivate Disks'),

        ('OP_INSTANCE_REPLACE_DISKS', 'Replace Disks'),

        ('OP_INSTANCE_MIGRATE', 'Migrate Instance'),

        ('OP_INSTANCE_CONSOLE', 'Get Instance Console'),

        ('OP_INSTANCE_RECREATE_DISKS', 'Recreate Disks'),

        ('OP_INSTANCE_FAILOVER', 'Failover Instance')

    )

    # A backend job may be in one of the following possible states

    BACKEND_STATUSES = (

        ('queued', 'request queued'),

        ('waiting', 'request waiting for locks'),

        ('canceling', 'request being canceled'),

        ('running', 'request running'),

        ('canceled', 'request canceled'),

        ('success', 'request completed successfully'),

        ('error', 'request returned error')

    )

    # The operating state of a VM,

    # upon the successful completion of a backend operation.

    # IMPORTANT: Make sure all keys have a corresponding

    # entry in BACKEND_OPCODES if you update this field, see #1035, #1111.

    OPER_STATE_FROM_OPCODE = {

        'OP_INSTANCE_CREATE': 'STARTED',

        'OP_INSTANCE_REMOVE': 'DESTROYED',

        'OP_INSTANCE_STARTUP': 'STARTED',

        'OP_INSTANCE_SHUTDOWN': 'STOPPED',

        'OP_INSTANCE_REBOOT': 'STARTED',

        'OP_INSTANCE_SET_PARAMS': None,

        'OP_INSTANCE_QUERY_DATA': None,

        'OP_INSTANCE_REINSTALL' : None,

        'OP_INSTANCE_ACTIVATE_DISKS' : None,

        'OP_INSTANCE_DEACTIVATE_DISKS': None,

        'OP_INSTANCE_REPLACE_DISKS' : None,

        'OP_INSTANCE_MIGRATE': None,

        'OP_INSTANCE_CONSOLE': None,

        'OP_INSTANCE_RECREATE_DISKS': None,

        'OP_INSTANCE_FAILOVER': None

    }

    # This dictionary contains the correspondence between

    # internal operating states and Server States as defined

    # by the Rackspace API.

    RSAPI_STATE_FROM_OPER_STATE = {

        "BUILD": "BUILD",

        "ERROR": "ERROR",

        "STOPPED": "STOPPED",

        "STARTED": "ACTIVE",

        "DESTROYED": "DELETED"

    }

    name = models.CharField('Virtual Machine Name', max_length=255)

    owner = models.ForeignKey(SynnefoUser)

    created = models.DateTimeField(auto_now_add=True)

    updated = models.DateTimeField(auto_now=True)

    charged = models.DateTimeField(default=datetime.datetime.now())

    imageid = models.CharField(max_length=100, null=False)

    hostid = models.CharField(max_length=100)

    flavor = models.ForeignKey(Flavor)

    deleted = models.BooleanField('Deleted', default=False)

    suspended = models.BooleanField('Administratively Suspended',

            default=False)

    # VM State 

    # The following fields are volatile data, in the sense

    # that they need not be persistent in the DB, but rather

    # get generated at runtime by quering Ganeti and applying

    # updates received from Ganeti.

    # In the future they could be moved to a separate caching layer

    # and removed from the database.

    # [vkoukis] after discussion with [faidon].

    action = models.CharField(choices=ACTIONS, max_length=30, null=True)

    operstate = models.CharField(choices=OPER_STATES, max_length=30, null=True)

    backendjobid = models.PositiveIntegerField(null=True)

    backendopcode = models.CharField(choices=BACKEND_OPCODES, max_length=30,

            null=True)

    backendjobstatus = models.CharField(choices=BACKEND_STATUSES,

            max_length=30, null=True)

    backendlogmsg = models.TextField(null=True)

    buildpercentage = models.IntegerField(default=0)

    # Error classes

    class InvalidBackendIdError(Exception):

         def __init__(self, value):

            self.value = value

         def __str__(self):

            return repr(self.value)

    class InvalidBackendMsgError(Exception):

         def __init__(self, opcode, status):

            self.opcode = opcode

            self.status = status

         def __str__(self):

            return repr('<opcode: %s, status: %s>' % (self.opcode,

                    self.status))

    class InvalidActionError(Exception):

         def __init__(self, action):

            self._action = action

         def __str__(self):

            return repr(str(self._action))

    class DeletedError(Exception):

        pass

    class BuildingError(Exception):

        pass

    def __init__(self, *args, **kw):

        """Initialize state for just created VM instances."""

        super(VirtualMachine, self).__init__(*args, **kw)

        # This gets called BEFORE an instance gets save()d for

        # the first time.

        if not self.pk: 

            self.action = None

            self.backendjobid = None

            self.backendjobstatus = None

            self.backendopcode = None

            self.backendlogmsg = None

            self.operstate = 'BUILD'

    @property

    def backend_id(self):

        """Returns the backend id for this VM by prepending backend-prefix."""

        if not self.id:

            raise VirtualMachine.InvalidBackendIdError("self.id is None")

        return '%s%s' % (settings.BACKEND_PREFIX_ID, self.id)

    class Meta:

        verbose_name = u'Virtual machine instance'

        get_latest_by = 'created'

    def __unicode__(self):

        return self.name

class VirtualMachineGroup(models.Model):

    """Groups of VMs for SynnefoUsers"""

    name = models.CharField(max_length=255)

    created = models.DateTimeField('Time of creation', auto_now_add=True)

    updated = models.DateTimeField('Time of last update', auto_now=True)

    owner = models.ForeignKey(SynnefoUser)

    machines = models.ManyToManyField(VirtualMachine)

    class Meta:

        verbose_name = u'Virtual Machine Group'

        verbose_name_plural = 'Virtual Machine Groups'

        ordering = ['name']

    def __unicode__(self):

        return self.name

class VirtualMachineMetadata(models.Model):

    meta_key = models.CharField(max_length=50)

    meta_value = models.CharField(max_length=500)

    vm = models.ForeignKey(VirtualMachine, related_name='metadata')

    class Meta:

        unique_together = (('meta_key', 'vm'),)

        verbose_name = u'Key-value pair of metadata for a VM.'

    def __unicode__(self):

        return u'%s: %s' % (self.meta_key, self.meta_value)

class Debit(models.Model):

    when = models.DateTimeField()

    user = models.ForeignKey(SynnefoUser)

    vm = models.ForeignKey(VirtualMachine)

    description = models.TextField()

    class Meta:

        verbose_name = u'Accounting log'

    def __unicode__(self):

        return u'%s - %s - %s - %s' % (self.user.id, self.vm.name,

                self.when, self.description)

class Disk(models.Model):

    name = models.CharField(max_length=255)

    created = models.DateTimeField('Time of creation', auto_now_add=True)

    updated = models.DateTimeField('Time of last update', auto_now=True)

    size = models.PositiveIntegerField('Disk size in GBs')

    vm = models.ForeignKey(VirtualMachine, blank=True, null=True)

    owner = models.ForeignKey(SynnefoUser, blank=True, null=True)  

    class Meta:

        verbose_name = u'Disk instance'

    def __unicode__(self):

        return self.name

class Network(models.Model):

    NETWORK_STATES = (

        ('ACTIVE', 'Active'),

        ('DELETED', 'Deleted')

    )

    name = models.CharField(max_length=255)

    created = models.DateTimeField(auto_now_add=True)

    updated = models.DateTimeField(auto_now=True)

    owner = models.ForeignKey(SynnefoUser, null=True)

    state = models.CharField(choices=NETWORK_STATES, max_length=30)

    public = models.BooleanField(default=False)

    link = models.ForeignKey('NetworkLink', related_name='+')

    machines = models.ManyToManyField(VirtualMachine,

            through='NetworkInterface')

    def __unicode__(self):

        return self.name

class Invitations(models.Model):

    source = models.ForeignKey(SynnefoUser, related_name="source")

    target = models.ForeignKey(SynnefoUser, related_name="target")

    accepted = models.BooleanField('Is the invitation accepted?',

            default=False)

    created = models.DateTimeField(auto_now_add=True)

    updated = models.DateTimeField(auto_now=True)

    level = models.IntegerField('Invitation depth level', null=True)

    def __unicode__(self):

        return "From: %s, To: %s" % (self.source, self.target)

class NetworkInterface(models.Model):

    FIREWALL_PROFILES = (

        ('ENABLED', 'Enabled'),

        ('DISABLED', 'Disabled'),

        ('PROTECTED', 'Protected')

    )

    machine = models.ForeignKey(VirtualMachine, related_name='nics')

    network = models.ForeignKey(Network, related_name='nics')

    created = models.DateTimeField(auto_now_add=True)

    updated = models.DateTimeField(auto_now=True)

    index = models.IntegerField(null=True)

    mac = models.CharField(max_length=17, null=True)

    ipv4 = models.CharField(max_length=15, null=True)

    ipv6 = models.CharField(max_length=100, null=True)

    firewall_profile = models.CharField(choices=FIREWALL_PROFILES,

            max_length=30, null=True)

    def __unicode__(self):

        return '%s@%s' % (self.machine.name, self.network.name)

class NetworkLink(models.Model):

    network = models.ForeignKey(Network, null=True, related_name='+')

    index = models.IntegerField()

    name = models.CharField(max_length=255)

    available = models.BooleanField(default=True)

    def __unicode__(self):

        return self.name