-# Copyright (c) 2016 Cable Television Laboratories, Inc. ("CableLabs")
+# Copyright (c) 2017 Cable Television Laboratories, Inc. ("CableLabs")
# and others. All rights reserved.
#
# Licensed under the Apache License, Version 2.0 (the "License");
import logging
from keystoneclient.exceptions import NotFound
+
+from snaps.config.user import UserConfig
+from snaps.openstack.openstack_creator import OpenStackIdentityObject
from snaps.openstack.os_credentials import OSCreds
from snaps.openstack.utils import keystone_utils
logger = logging.getLogger('create_user')
-class OpenStackUser:
+class OpenStackUser(OpenStackIdentityObject):
"""
- Class responsible for creating a user in OpenStack
+ Class responsible for managing a user in OpenStack
"""
def __init__(self, os_creds, user_settings):
:param user_settings: The user settings
:return:
"""
- self.__os_creds = os_creds
+ super(self.__class__, self).__init__(os_creds)
+
self.user_settings = user_settings
self.__user = None
- self.__keystone = None
- def create(self, cleanup=False):
+ def initialize(self):
"""
Creates the user in OpenStack if it does not already exist
- :param cleanup: Denotes whether or not this is being called for cleanup
- :return: The OpenStack user object
+ :return: The User domain object
"""
- self.__keystone = keystone_utils.keystone_client(self.__os_creds)
- self.__user = keystone_utils.get_user(self.__keystone,
+ super(self.__class__, self).initialize()
+
+ self.__user = keystone_utils.get_user(self._keystone,
self.user_settings.name)
- if not self.__user and not cleanup:
- self.__user = keystone_utils.create_user(self.__keystone,
- self.user_settings)
+ return self.__user
+ def create(self, cleanup=False):
+ """
+ Creates a User if one does not already exist
+ :return: The User domain object
+ """
+ self.initialize()
+ if not self.__user:
+ self.__user = keystone_utils.create_user(self._keystone,
+ self.user_settings)
return self.__user
def clean(self):
"""
if self.__user:
try:
- keystone_utils.delete_user(self.__keystone, self.__user)
+ keystone_utils.delete_user(self._keystone, self.__user)
except NotFound:
pass
self.__user = None
+ super(self.__class__, self).clean()
+
def get_user(self):
"""
Returns the OpenStack user object populated in create()
credentials
:return:
"""
+ if not project_name:
+ project_name = self._os_creds.project_name
+
return OSCreds(
username=self.user_settings.name,
password=self.user_settings.password,
- auth_url=self.__os_creds.auth_url,
+ auth_url=self._os_creds.auth_url,
project_name=project_name,
- identity_api_version=self.__os_creds.identity_api_version,
- user_domain_id=self.__os_creds.user_domain_id,
- project_domain_id=self.__os_creds.project_domain_id,
- interface=self.__os_creds.interface,
- proxy_settings=self.__os_creds.proxy_settings,
- cacert=self.__os_creds.cacert)
-
-
-class UserSettings:
- def __init__(self, **kwargs):
-
- """
- Constructor
- :param name: the user's name (required)
- :param password: the user's password (required)
- :param project_name: the user's primary project name (optional)
- :param domain_name: the user's domain name (default='default'). For v3
- APIs
- :param email: the user's email address (optional)
- :param enabled: denotes whether or not the user is enabled
- (default True)
- :param roles: dict where key is the role name and value is a list of
- project names
- """
-
- self.name = kwargs.get('name')
- self.password = kwargs.get('password')
- self.project_name = kwargs.get('project_name')
- self.email = kwargs.get('email')
- self.domain_name = kwargs.get('domain_name', 'default')
- self.enabled = kwargs.get('enabled', True)
- self.roles = kwargs.get('roles', dict())
-
- if not self.name or not self.password:
- raise UserSettingsException(
- 'The attributes name and password are required for '
- 'UserSettings')
-
- if not isinstance(self.enabled, bool):
- raise UserSettingsException('The attribute enabled must be of type'
- ' boolean')
-
-
-class UserSettingsException(Exception):
+ identity_api_version=self._os_creds.identity_api_version,
+ image_api_version=self._os_creds.image_api_version,
+ network_api_version=self._os_creds.network_api_version,
+ compute_api_version=self._os_creds.compute_api_version,
+ heat_api_version=self._os_creds.heat_api_version,
+ volume_api_version=self._os_creds.volume_api_version,
+ region_name=self._os_creds.region_name,
+ user_domain_name=self._os_creds.user_domain_name,
+ user_domain_id=self._os_creds.user_domain_id,
+ project_domain_name=self._os_creds.project_domain_name,
+ project_domain_id=self._os_creds.project_domain_id,
+ interface=self._os_creds.interface,
+ proxy_settings=self._os_creds.proxy_settings,
+ cacert=self._os_creds.cacert)
+
+
+class UserSettings(UserConfig):
"""
- Raised when there is a problem with the values set in the UserSettings
- class
+ Class to hold the configuration settings required for creating OpenStack
+ user objects
+ deprecated
"""
+
+ def __init__(self, **kwargs):
+ from warnings import warn
+ warn('Use snaps.config.user.UserConfig instead',
+ DeprecationWarning)
+ super(self.__class__, self).__init__(**kwargs)