plstackapi/core/api/slivers.py

   1 import re
   2 from plstackapi.openstack.client import OpenStackClient
   3 from plstackapi.openstack.driver import OpenStackDriver
   4 from plstackapi.core.api.auth import auth_check
   5 from plstackapi.core.models import Sliver, Slice
   6 from plstackapi.core.api.flavors import _get_flavors
   7 from plstackapi.core.api.images import _get_images
   8 from plstackapi.core.api.keys import _get_keys
   9 from plstackapi.core.api.slices import _get_slices
  10 from plstackapi.core.api.deployment_networks import _get_deployment_networks
  11 from plstackapi.core.api.nodes import _get_nodes
  12
  13
  14 def _get_slivers(filter):
  15     if isinstance(filter, int):
  16         slivers = Sliver.objects.filter(id=filter)
  17     elif isinstance(filter, StringTypes):
  18         slivers = Sliver.objects.filter(name=filter)
  19     elif isinstance(filer, dict):
  20         slivers = Sliver.objects.filter(**filter)
  21     else:
  22         slivers = []
  23     return slivers
  24
  25 def add_sliver(auth, fields):
  26     driver = OpenStackDriver(client = auth_check(auth))
  27
  28     flavors = _get_flavor(fields.get('flavor'))
  29     if flavors: fields['flavor'] = flavors[0]
  30     images = _get_images(fields.get('image'))
  31     if images: fields['image'] = images[0]
  32     keys = _get_keys(fields.get('get'))
  33     if keys: fields['key'] = keys[0]
  34     slices = _get_slices(fields.get('slice'))
  35     if slices: fields['slice'] = slices[0]
  36     deployment_networks = _get_deployment_networks(field.get('deployment_network'))
  37     if deployment_networks: fields['deployment_network'] = deployment_networks[0]
  38     nodes = _get_nodes(fields.get('node'))
  39     if nodes: fields['node'] = nodess[0]
  40
  41     sliver = Sliver(**fields)
  42     # create quantum sliver
  43     sliver = driver.spawn_instance(name=sliver.name,
  44                                    key_name = sliver.key.name,
  45                                    flavor=sliver.flavor.name,
  46                                    image = sliver.image.name,
  47                                    hostname = sliver.node.hostname )
  48
  49     sliver.instance_id=sliver.id
  50
  51     sliver.save()
  52     return sliver
  53
  54 def update_sliver(auth, sliver, **fields):
  55     return
  56
  57 def delete_sliver(auth, filter={}):
  58     driver = OpenStackDriver(client = auth_check(auth))
  59     slivers = _get_slivers(filter)
  60     for sliver in slivers:
  61         driver.destroy_instance(sliver.sliver_id)
  62         sliver.delete()
  63     return 1
  64
  65 def get_slivers(auth, filter={}):
  66     client = auth_check(auth)
  67     if 'slice' in filter:
  68         slices = _get_slices(filter.get('slice'))
  69         if slices: filter['slice'] = slices[0]
  70     slivers = _get_slivers(filter)
  71     return slivers
  72
  73
  74