X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=planetstack%2Fopenstack%2Fdriver.py;h=4f1c17784c2747d364b6f9be1a1bcf2df50a6e33;hb=23925ac2ccb24c8fccd9525dc9c0389b00bdb824;hp=8ebea6897937d7a3620543848d8bebac99893962;hpb=9c7a1e1391145d425227dd6da7dabd429bb53844;p=plstackapi.git diff --git a/planetstack/openstack/driver.py b/planetstack/openstack/driver.py index 8ebea68..4f1c177 100644 --- a/planetstack/openstack/driver.py +++ b/planetstack/openstack/driver.py @@ -1,6 +1,7 @@ import commands import hashlib from planetstack.config import Config +from core.models import Deployment try: from openstack.client import OpenStackClient @@ -12,38 +13,41 @@ manager_enabled = Config().api_nova_enabled class OpenStackDriver: - def __init__(self, config = None, client=None, deployment=None): + def __init__(self, config = None, client=None): if config: self.config = Config(config) else: self.config = Config() - self.admin_client = OpenStackClient(deployment=deployment) - self.admin_user = self.admin_client.keystone.users.find(name=self.admin_client.keystone.username) - if client: self.shell = client - else: - self.shell = OpenStackClient(deployment=deployment) self.enabled = manager_enabled self.has_openstack = has_openstack + self.deployment = None + self.admin_user = None def client_driver(self, caller=None, tenant=None, deployment=None): + admin_driver = self.admin_driver(tenant=tenant, deployment=deployment) if caller: auth = {'username': caller.email, 'password': hashlib.md5(caller.password).hexdigest()[:6], 'tenant': tenant} - client = OpenStackClient(deployment=deployment, **auth) + client = OpenStackClient(deployment=admin_driver.deployment, **auth) else: - client = OpenStackClient(tenant=tenant, deployment=deployment) + client = OpenStackClient(tenant=tenant, deployment=admin_driver.deployment) - driver = OpenStackDriver(client=client, deployment=deployment) + driver = OpenStackDriver(client=client) + driver.admin_user = admin_driver.admin_user + driver.deployment = admin_driver.deployment return driver def admin_driver(self, tenant=None, deployment=None): + deployment = Deployment.objects.get(name=deployment) client = OpenStackClient(tenant=tenant, deployment=deployment) - driver = OpenStackDriver(client=client, deployment=deployment) + driver = OpenStackDriver(client=client) + driver.admin_user = client.keystone.users.find(name=deployment.admin_user) + driver.deployment = deployment return driver def create_role(self, name): @@ -413,11 +417,12 @@ class OpenStackDriver: return (subnet_id, subnet) - def spawn_instance(self, name, key_name=None, hostname=None, image_id=None, security_group=None, pubkeys=[], nics=None, metadata=None, userdata=None): - flavor_name = self.config.nova_default_flavor + def spawn_instance(self, name, key_name=None, hostname=None, image_id=None, security_group=None, pubkeys=[], nics=None, metadata=None, userdata=None, flavor_name=None): + if not flavor_name: + flavor_name = self.config.nova_default_flavor + flavor = self.shell.nova.flavors.find(name=flavor_name) - #if not image: - # image = self.config.nova_default_imave + if not security_group: security_group = self.config.nova_default_security_group