blob: 30285c6ea02f5f6421712a553de479279f984d0d [file] [log] [blame]
from django.db import models
from plstackapi.openstack.shell import OpenStackShell
# Create your models here.
class PlCoreBase(models.Model):
created = models.DateTimeField(auto_now_add=True)
updated = models.DateTimeField(auto_now=True)
class Meta:
abstract = True
class Site(PlCoreBase):
tenant_id = models.CharField(max_length=200, help_text="Keystone tenant id")
name = models.CharField(max_length=200, unique=True, help_text="Name for this Site")
site_url = models.URLField(help_text="Site's Home URL Page")
enabled = models.BooleanField(default=True, help_text="Status for this Site")
longitude = models.FloatField(null=True, blank=True)
latitude = models.FloatField(null=True, blank=True)
login_base = models.CharField(max_length=50, help_text="Prefix for Slices associated with this Site")
is_public = models.BooleanField(default=True, help_text="Indicates the visibility of this site to other members")
abbreviated_name = models.CharField(max_length=80)
def __unicode__(self): return u'%s' % (self.name)
def save(self, *args, **kwargs):
os_shell = OpenStackShell()
tenant_fields = {'name': self.login_base,
'enabled': self.enabled,
'description': self.name}
if not self.id:
# check if keystone tenant record exists
tenants = os_shell.keystone.tenants.findall(name=self.login_base)
if not tenants:
tenant = os_shell.keystone.tenants.create(**tenant_fields)
else:
tenant = tenants[0]
self.tenant_id = tenants.id
else:
# update record
os_shell.keystone.tenants.update(self.tenant_id, **tenant_fields)
super(Site, self).save(*args, **kwargs)
def delete(self, *args, **kwds):
# delete keystone tenant
os_shell = OpenStackShell()
tenant = os_shell.keystone.tenants.find(id=self.tenant_id)
os_shell.keystone.tenants.delete(tenant)
super(Site, self).delete(*args, **kwargs)
class Slice(PlCoreBase):
tenant_id = models.CharField(max_length=200, help_text="Keystone tenant id")
name = models.CharField(help_text="The Name of the Slice", max_length=80)
SLICE_CHOICES = (('plc', 'PLC'), ('delegated', 'Delegated'), ('controller','Controller'), ('none','None'))
instantiation = models.CharField(help_text="The instantiation type of the slice", max_length=80, choices=SLICE_CHOICES)
omf_friendly = models.BooleanField()
description=models.TextField(blank=True,help_text="High level description of the slice and expected activities", max_length=1024)
slice_url = models.URLField(blank=True)
site = models.ForeignKey(Site, related_name='slices', help_text="The Site this Node belongs too")
def __unicode__(self): return u'%s' % (self.name)
def save(self, *args, **kwds):
# sync keystone tenant
os_shell = OpenStackShell()
tenant_fields = {'name': self.name,
'enabled': self.enabled,
'description': self.description}
if not self.id:
# check if keystone tenant record exists
tenants = os_shell.keystone.tenants.findall(name=self.name)
if not tenants:
tenant = os_shell.keystone.tenants.create(**tenant_fields)
else:
tenant = tenants[0]
self.tenant_id = tenants.id
else:
# update record
os_shell.keystone.tenants.update(self.tenant_id, **tenant_fields)
super(Site, self).save(*args, **kwargs)
def delete(self, *args, **kwds):
# delete keystone tenant
os_shell = OpenStackShell()
tenant = os_shell.keystone.tenants.find(id=self.tenant_id)
os_shell.keystone.tenants.delete(tenant)
super(Slice, self).delete(*args, **kwargs)
class DeploymentNetwork(PlCoreBase):
name = models.CharField(max_length=200, unique=True, help_text="Name of the Deployment Network")
def __unicode__(self): return u'%s' % (self.name)
class SiteDeploymentNetwork(PlCoreBase):
class Meta:
unique_together = ['site', 'deploymentNetwork']
site = models.ForeignKey(Site, related_name='deploymentNetworks')
deploymentNetwork = models.ForeignKey(DeploymentNetwork, related_name='sites')
name = models.CharField(default="Blah", max_length=100)
def __unicode__(self): return u'%s::%s' % (self.site, self.deploymentNetwork)
class Sliver(PlCoreBase):
tenant_id = models.CharField(max_length=200, help_text="Keystone tenant id")
name = models.CharField(max_length=200, unique=True)
slice = models.ForeignKey(Slice)
siteDeploymentNetwork = models.ForeignKey(SiteDeploymentNetwork)
def __unicode__(self): return u'%s::%s' % (self.slice, self.siteDeploymentNetwork)
class Node(PlCoreBase):
name = models.CharField(max_length=200, unique=True, help_text="Name of the Node")
siteDeploymentNetwork = models.ForeignKey(SiteDeploymentNetwork, help_text="The Site and Deployment Network this Node belongs too.")
def __unicode__(self): return u'%s' % (self.name)
class Network(PlCoreBase):
slice = models.ForeignKey(Slice, related_name='slice')
name = models.CharField(max_length=200, unique=True)
quantum_id = models.CharField(max_length=200, unique=True)
def __unicode__(self): return u'%s' % (self.name)
def save(self, *args, **kwargs):
os_shell = OpenStackShell()
network_fields = {'name': self.name}
if not self.id:
# check if quantum network record exists
networks = os_shell.quantum.list_networks(name=self.name)
if not networks:
network = os_shell.quantum.create_network(name=self.name,
admin_state_up=False)
else:
network = networks[0]
self.quantum_id = network.id
super(Network, self).save(*args, **kwargs)
def delete(self, *args, **kwargs):
# delete quantum network
os_shell = OpenStackShell()
os_shell.quantum.delete_network(self.quantum_id)
super(Network, self).delete(*args, **kwargs)
class SubNet(PlCoreBase):
network = models.ForeignKey(Network, related_name='network')
name = models.CharField(max_length=200, unique=True)
quantum_id = models.CharField(max_length=200, unique=True)
cidr = models.CharField(max_length=20)
ip_version = models.IntegerField()
start = models.IPAddressField()
end = models.IPAddressField()
def __unicode__(self): return u'%s' % (self.name)
def save(self, *args, **kwargs):
os_shell = OpenStackShell()
subnet_fields = {'network_id': self.network.quantum_id,
'name' : self.name,
'ip_version': self.ip_version,
'cidr': self.cidr,
'allocation_pools': {'start': self.start,
'end': self.end}
}
if not self.id:
subnets = os_shell.quantum.list_subnets(name=self.name)
if not subnets:
subnet = os_shell.quantum.create_subnet(**subnet_fields)
else:
subnet = subnets[0]
self.quantum_id = subnet.id
super(SubNet, self).save(*args, **kwargs)
def delete(self, *args, **kwargs):
# delete quantum network
os_shell = OpenStackShell()
os_shell.quantum.delete_subnet(self.quantum_id)
super(SubNet, self).delete(*args, **kwargs)