Coverage for cms_rest/__init__.py : - 100% -
- -
-
-
-
-
-
-
-
-
-
- 
- Hot-keys on this page
-- r - m - x - p toggle line displays -
-- j - k next/prev highlighted chunk -
-- 0 (zero) top of page -
-- 1 (one) first highlighted chunk -
-| - - | -- - | -
-
-
- Hot-keys on this page
-- r - m - x - p toggle line displays -
-- j - k next/prev highlighted chunk -
-- 0 (zero) top of page -
-- 1 (one) first highlighted chunk -
-| - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - | -
-
-
-
-
-
-
-
- - - - - - - - - - - # setting configurations for utils to be used from now and on - -- - app_conf.pop('root'), -logging=getattr(config, 'logging', {}), -**app_conf -) - - -- - - runner = CommandRunner() -runner.run(['serve', '../config.py']) -- - main() - - |
-
-
-
- Hot-keys on this page
-- r - m - x - p toggle line displays -
-- j - k next/prev highlighted chunk -
-- 0 (zero) top of page -
-- 1 (one) first highlighted chunk -
-| - - | -- - | -
-
-
- Hot-keys on this page
-- r - m - x - p toggle line displays -
-- j - k next/prev highlighted chunk -
-- 0 (zero) top of page -
-- 1 (one) first highlighted chunk -
-| - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - | -
-
-
-
-
-
-
- - - - # url/v1/ - -- - def _default(self): -""" -Method to handle GET / -parameters: None -return: dict describing cms rest version information -""" -return { -"versions": { -"values": [ -{ -"status": "stable", -"id": "v1", -"links": [ -{ -"href": "http://localhost:7080/" -} -] -} -] -} -} - - |
-
-
-
- Hot-keys on this page
-- r - m - x - p toggle line displays -
-- j - k next/prev highlighted chunk -
-- 0 (zero) top of page -
-- 1 (one) first highlighted chunk -
-| - - | -- - | -
-
-
- Hot-keys on this page
-- r - m - x - p toggle line displays -
-- j - k next/prev highlighted chunk -
-- 0 (zero) top of page -
-- 1 (one) first highlighted chunk -
-| - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - | -
-
-
-
-
- - - - - response.translatable_error = error -super(ClientSideError, self).__init__(error, status_code) -- - - - super(InputValueError, self).__init__("Invalid value for input {} : {}".format(name, value), status_code) -- - - - super(EntityNotFoundError, self).__init__("Entity not found for {}".format(id), status_code=404) -- - - pass -- - @classmethod -def from_model(cls, m): -return cls(**(m.as_dict())) -- def as_dict(self, model): -valid_keys = inspect.getargspec(model.__init__)[0] -if 'self' in valid_keys: -valid_keys.remove('self') -return self.as_dict_from_keys(valid_keys) -- - def as_dict_from_keys(self, keys): -return dict((k, getattr(self, k)) -for k in keys -if hasattr(self, k) and -getattr(self, k) != wsme.Unset) -- @classmethod -def from_db_and_links(cls, m, links): -return cls(links=links, **(m.as_dict())) -- ''' - - |
-
-
-
- Hot-keys on this page
-- r - m - x - p toggle line displays -
-- j - k next/prev highlighted chunk -
-- 0 (zero) top of page -
-- 1 (one) first highlighted chunk -
-| - - | -- - | -
-
-
- Hot-keys on this page
-- r - m - x - p toggle line displays -
-- j - k next/prev highlighted chunk -
-- 0 (zero) top of page -
-- 1 (one) first highlighted chunk -
-| - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - | -
- """Configuration rest API input module.""" -- - - - - - - - - - - - """Configuration controller.""" -- - - """get method. -- :param dump_to_log: A boolean string that says whether the -configuration should be written to log -:return: A pretty string that contains the service's configuration -""" - -- - - - - - |
-
-
-
- Hot-keys on this page
-- r - m - x - p toggle line displays -
-- j - k next/prev highlighted chunk -
-- 0 (zero) top of page -
-- 1 (one) first highlighted chunk -
-| - - | -- - | -
-
-
- Hot-keys on this page
-- r - m - x - p toggle line displays -
-- j - k next/prev highlighted chunk -
-- 0 (zero) top of page -
-- 1 (one) first highlighted chunk -
-| - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - | -
-
-
- - - - - - - - - - - - - - - def put(self, customer_uuid, enable): - - - - - - -- - 'enabled' if enable.enabled else 'disabled') - -request.headers, customer_uuid, -event_details=event_details) -- - - - message=exception.message, -status_code=exception.status_code) -- - - - status_code=500, -error_details=str(exception)) -- - - - def post(self, customer_id): -raise err_utils.get_error(request.transaction_id, status_code=405) -- - def get(self, customer_id): -raise err_utils.get_error(request.transaction_id, status_code=405) -- - def delete(self, customer_id): -raise err_utils.get_error(request.transaction_id, status_code=405) - - |
-
-
-
- Hot-keys on this page
-- r - m - x - p toggle line displays -
-- j - k next/prev highlighted chunk -
-- 0 (zero) top of page -
-- 1 (one) first highlighted chunk -
-| - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - | -
-
-
-
-
-
- - - - - - - - - - - - - def post(self, customer_uuid, metadata): - - - -- - - request.headers, customer_uuid, -event_details=event_details) - - - -message=ex.message, status_code=409) - - -message=ex.message, status_code=404) - - - -status_code=ex.status_code) - - - -message=ex.message, status_code=400) - - - -status_code=500, error_details=str(ex)) -- - def put(self, customer_uuid, metadata): - - - -- - - request.transaction_id, request.headers, -customer_uuid, event_details=event_details) - - - -message=ex.message, status_code=400) - - -message=ex.message, status_code=404) - - - -status_code=ex.status_code) - - - -message=ex.message, status_code=400) - - - -status_code=500, error_details=str(ex)) - - |
-
-
-
- Hot-keys on this page
-- r - m - x - p toggle line displays -
-- j - k next/prev highlighted chunk -
-- 0 (zero) top of page -
-- 1 (one) first highlighted chunk -
-| - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - | -
-
-
-
- - - - - - - - - - - - - - - - - - - - def get(self, customer_id, region_id): - -- - def post(self, customer_id, regions): - - - - - - -- - customer_id, [r.name for r in regions]) - -request.headers, customer_id, -event_details=event_details) -- - LOG.log_exception("RegionController - Add Regions (post) - region already exists", exception) -raise err_utils.get_error(request.transaction_id, -status_code=409, -message='Region already exists', -error_details=exception.message) -- - - - message=exception.message, -status_code=exception.status_code) -- - - - status_code=500, -error_details=str(exception)) -- - - - def put(self, customer_id, regions): - - - - - - - -- - customer_id, [r.name for r in regions]) - -request.headers, customer_id, -event_details=event_details) -- - - - message=exception.message, -status_code=exception.status_code) -- - - - status_code=500, -error_details=str(exception)) -- - - - def delete(self, customer_id, region_id): - - - - - - -- - customer_id, region_id) - -request.headers, customer_id, -event_details=event_details) -- - raise err_utils.get_error(request.transaction_id, -message=exception.message, -status_code=404) - - - -message=exception.message, -status_code=exception.status_code) -- - - - status_code=500, -error_details=str(exception)) -- - def validate_put_url(): - - -# If there's an element after 'regions', it is a region ID -# which is currently unsupported - - - -message='Method not allowed for a specific region', -status_code=405) - - |
-
-
-
- Hot-keys on this page
-- r - m - x - p toggle line displays -
-- j - k next/prev highlighted chunk -
-- 0 (zero) top of page -
-- 1 (one) first highlighted chunk -
-| - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - | -
-
-
-
- - - - - - - - - - - - - - - - - - - - - - - - - - def get(self, customer_uuid): - - - - - - -- - - - message=exception.message, -status_code=exception.status_code) -- - - - status_code=500, -error_details=exception.message) -- - - - def post(self, customer): - - - - - - -else: - -utils.audit_trail('create customer', request.transaction_id, request.headers, customer.custId) -raise ErrorStatus('400', None) - - - - -- - - - - raise ErrorStatus(409.2, 'Customer field {0} already exists'.format(exception.columns)) -- - - uuid, customer.name, [r.name for r in customer.regions], -[u.id for u in customer.users]) - -request.headers, uuid, -event_details=event_details) - -- - - - message=exception.message, -status_code=exception.status_code) -- - - - status_code=500, -error_details=exception.message) -- - def put(self, customer_id, customer): - - - - - - - -- - customer_id, customer.name, [r.name for r in customer.regions], -[u.id for u in customer.users]) - -request.headers, customer_id, -event_details=event_details) -- - - - message=exception.message, -status_code=exception.status_code) -- - - - status_code=500, -error_details=exception.message) -- - - - rest_content_types='json') - -contains=None, metadata=None): - - - - - -starts_with, -contains, -metadata) -- - - - - status_code=exception.status_code) -- - - - status_code=500, -error_details=exception.message) -- - def delete(self, customer_id): - - -- - - - - - - - request.headers, customer_id, -event_details=event_details) -- - - exception) - -message=exception.message, -status_code=exception.status_code) -- - - exception) - -status_code=500, -error_details=exception.message) -- - def validate_cust_id(cust_id): -# regex = re.compile('[a-zA-Z]') -# return regex.match(cust_id[0]) - - - |
-
-
-
- Hot-keys on this page
-- r - m - x - p toggle line displays -
-- j - k next/prev highlighted chunk -
-- 0 (zero) top of page -
-- 1 (one) first highlighted chunk -
-| - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - | -
-
-
- - - - - - - - - - - - - - - - - def get(self, customer_id): - -"customer id: " + customer_id, -"user " + "default user"] -- - def put(self, customer_id, users): # replace default users to customer - - - - - - -- - - - message=exception.message, -status_code=exception.status_code) -- - LOG.log_exception("DefaultUserController - {0}".format(exception.message), exception) -raise err_utils.get_error(request.transaction_id, -message=exception.message, -status_code=404) -- - - - - status_code=500, -error_details=str(exception)) -- - - - def post(self, customer_id, users): # add default users to customer - - - - - - -customer_id, str(users))) -- - - - message=exception.message, -status_code=exception.status_code) -- - LOG.log_exception("DefaultUserController - {0}".format(exception.message), exception) -raise err_utils.get_error(request.transaction_id, -message=exception.message, -status_code=404) -- - - - - status_code=500, -error_details=str(exception)) -- - - - def delete(self, customer_id, user_id): - - - - - - - -- - - - status_code=exception.status_code) -- - LOG.log_exception("DefaultUserController - {0}".format(exception.message), exception) -raise err_utils.get_error(request.transaction_id, -message=exception.message, -status_code=404) -- - raise err_utils.get_error(request.transaction_id, -message=e.message, -status_code=404) -- - - - status_code=500, -error_details=str(exception)) -- - - - - def _validate(args): -# validate if user didnt provide input json for users -# to prevent wsme to take the input from url params - -raise err_utils.get_error(request.transaction_id, -message="bad request, no json body", -status_code=400) -- - def get(self, customer_id, region_id): - -"customer id: " + customer_id, -"region id: " + region_id] -- - def post(self, customer_id, region_id, users): - - - - - - - - -- - customer_id, [u.id for u in users], region_id) - -request.headers, customer_id, -event_details=event_details) -- - - - message=exception.message, -status_code=exception.status_code) -- - LOG.log_exception("DefaultUserController - {0}".format(exception.message), exception) -raise err_utils.get_error(request.transaction_id, -message=exception.message, -status_code=404) -- - - - - status_code=500, -error_details=str(exception)) -- - - - def put(self, customer_id, region_id, users): - - - - - - - - -- - customer_id, [u.id for u in users], region_id) - -request.headers, customer_id, -event_details=event_details) -- - - - message=exception.message, -status_code=exception.status_code) -- - LOG.log_exception("DefaultUserController - {0}".format(exception.message), exception) -raise err_utils.get_error(request.transaction_id, -message=exception.message, -status_code=404) -- - - - - status_code=500, -error_details=str(exception)) -- - - - def delete(self, customer_id, region_id, user_id): - - - - - - -- - customer_id, user_id, region_id) - -request.headers, customer_id, -event_details=event_details) -- - - - status_code=exception.status_code) -- - LOG.log_exception("DefaultUserController - {0}".format(exception.message), exception) -raise err_utils.get_error(request.transaction_id, -message=exception.message, -status_code=404) -- - raise err_utils.get_error(request.transaction_id, -message=e.message, -status_code=404) -- - - - status_code=500, -error_details=str(exception)) - - |
-
-
-
- Hot-keys on this page
-- r - m - x - p toggle line displays -
-- j - k next/prev highlighted chunk -
-- 0 (zero) top of page -
-- 1 (one) first highlighted chunk -
-| - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - | -
-
- - - - - - - - - - """log change result wsme type.""" -- - - - """"init method.""" -super(LogChangeResult, self).__init__(**kwargs) -- - - """log change result type.""" -- - """"init method.""" -self.result = result -- - - """Logs Audit controller.""" -- - rest_content_types='json') -def put(self, level): -"""update log level. -- :param level: the log level text name -:return: -""" -- logger.info("Changing log level to [{}]".format(level)) -try: -log_level = logging._levelNames.get(level.upper()) -if log_level is not None: -self._change_log_level(log_level) -result = "Log level changed to {}.".format(level) -logger.info(result) -else: -raise Exception( -"The given log level [{}] doesn't exist.".format(level)) -except Exception as e: -result = "Fail to change log_level. Reason: {}".format( -e.message) -logger.error(result) -return LogChangeResult(result) -- - def _change_log_level(log_level): -path = __name__.split('.') -if len(path) > 0: -root = path[0] -root_logger = logging.getLogger(root) -root_logger.setLevel(log_level) -else: -logger.info("Fail to change log_level to [{}]. " -"the given log level doesn't exist.".format(log_level)) - - |
-
-
-
- Hot-keys on this page
-- r - m - x - p toggle line displays -
-- j - k next/prev highlighted chunk -
-- 0 (zero) top of page -
-- 1 (one) first highlighted chunk -
-
-
-
- Hot-keys on this page
-- r - m - x - p toggle line displays -
-- j - k next/prev highlighted chunk -
-- 0 (zero) top of page -
-- 1 (one) first highlighted chunk -
-
-
-
- Hot-keys on this page
-- r - m - x - p toggle line displays -
-- j - k next/prev highlighted chunk -
-- 0 (zero) top of page -
-- 1 (one) first highlighted chunk -
-
-
-
- Hot-keys on this page
-- r - m - x - p toggle line displays -
-- j - k next/prev highlighted chunk -
-- 0 (zero) top of page -
-- 1 (one) first highlighted chunk -
-| - - | -- - | -
-
-
- Hot-keys on this page
-- r - m - x - p toggle line displays -
-- j - k next/prev highlighted chunk -
-- 0 (zero) top of page -
-- 1 (one) first highlighted chunk -
-| - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - | -
-
-
-
-
-
-
-
-
-
-
-
- - - - - - - - - - - - - - - - - metadata = CustomerMetadata(field_key=key, field_value=value) -sql_customer.customer_metadata.append(metadata) -- - - - - - - - - - - - - - - - - - - datamanager.add_user_role(sql_user.id, sql_role.id, -sql_customer.id, -1) -- - - - - - - datamanager) -- # NOTE: if region has no users there is no need to update the -# default users in that region -# if len(region.users) == 0: -# users_roles.extend(self.add_user_and_roles_to_db( -# customer.users, datamanager)) -# else: -# users_roles.extend(self.add_user_and_roles_to_db( -# region.users, datamanager)) -- - - - except Exception as ex: -if hasattr(ex, 'orig') and ex.orig[0] == 1062: -raise DuplicateEntryError( -'Error, duplicate entry, region ' + region.name + ' already associated with customer') -raise ex -- - - sql_customer_id, sql_region.id) -- - datamanager.add_quota(sql_customer_id, sql_region.id, quota) -- # NOTE: if region has no quotas there is no need to update -# the default quotas in that region -# if len(region.quotas) == 0: -# for quota in customer.defaultQuotas: -# datamanager.add_quota(sql_customer_id, -# sql_region.id, quota) -# else: -# for quota in region.quotas: -# datamanager.add_quota(sql_customer_id, -# sql_region.id, quota) -- - - - - - - - - - - - - - - - - - - - - - - - - customer_dict = sql_customer.get_proxy_dict() -for region in customer_dict["regions"]: -region["action"] = "create" -- datamanager.flush() # i want to get any exception created by this insert -RdsProxy.send_customer_dict(customer_dict, transaction_id, "POST") -else: - -- - - - - - - - - - - - - - - - customer_uuid) -- - - raise ErrorStatus(404, 'customer {0} was not found'.format(customer_uuid)) - - - -- - datamanager) - - - -new_customer_dict["regions"]) -- - - - RdsProxy.send_customer_dict(new_customer_dict, transaction_id, "PUT") - -- - - - - - - - - - old_region = next((r for r in old_regions_dict if r["name"] == region["name"]), None) -if old_region: -region["action"] = "modify" -else: -region["action"] = "create" -- - new_region = next((r for r in new_regions_dict if r["name"] == region["name"]), None) -if not new_region: -region["action"] = "delete" -new_regions_dict.append(region) -- - - - - - - - - else: - -- - - - - raise ErrorStatus(404, "customer {} does not exist".format(customer_uuid)) -- - raise ErrorStatus(404, "region {} not found".format(region_name)) -- - - - - - - - - - - - - pecan.request.path) -- - 'links': {'self': base_link + user.id}} for user in -users] - -transaction_id=transaction_id, users=result_users) -- - - - raise ErrorStatus(409, exception.message) - - - -- - - - - - - - - raise ErrorStatus(404, "customer {} does not exist".format(customer_uuid)) -- - - raise ErrorStatus(404, "region {} not found".format(region_name)) -- # delete older default user - - - - - -- - - - - - - - - - - - - - - # TODO: change add_use_role to receive sqlalchemy model (UserRole) - -customer_id, region_id, adding) - - - - -- - - - - - - - raise ErrorStatus(404, "customer {} does not exist".format(customer_uuid)) -- - region_id, -user_id) - - -- - - - - user_id, region_id, customer_uuid) - - - -e.message) - -e.message) - - - - -- - - - - - - else: - -- - - - raise ErrorStatus(404, "customer {} does not exist".format(customer_uuid)) -- - - - - - - - - RdsProxy.send_customer(customer, transaction_id, "PUT") -- - - - - pecan.request.path) -- - 'links': {'self': base_link + user.id}} for user in -users] - -transaction_id=transaction_id, users=result_users) -- - - - - - raise ErrorStatus(409, exception.message) - - -- - - - - - - - - raise ErrorStatus(404, "customer {} does not exist".format(customer_uuid)) -- # delete older default user - - - - - -- - - - - - - - - - - raise ErrorStatus(404, "customer {} does not exist".format(customer_uuid)) -- - - 'DEFAULT', -user_id) -- - - - - - - user_id, 'DEFAULT', customer_uuid) -- - - - e.message) - -e.message) -- - - - - - - - - # TODO DataBase action - - -raise ErrorStatus(404, -"customer with id {} does not exist".format( -customer_uuid)) - -- - - - - - - new_region = next((r for r in regions if r.name == region["name"]), None) -if new_region: -region["action"] = "create" -else: -region["action"] = "modify" -- - - - - - - pecan.request.path) -- - 'links': {'self': base_link + region.name}} for -region in regions] - -transaction_id=transaction_id, regions=result_regions) -- - - - - - - - - - - - - raise ErrorStatus(404, -"customer with id {} does not exist".format( -customer_uuid)) -- - - raise ErrorStatus(404, -"customer with id {} does not exist".format( -customer_id)) - - -- - - - - - - - - - - - - - new_customer_dict["regions"]) -- - - - - pecan.request.path) -- - 'links': {'self': base_link + region.name}} for -region in regions] - -transaction_id=transaction_id, regions=result_regions) -- - - - - - - - - - - - - raise ErrorStatus(404, -"customer with id {} does not exist".format( -customer_id)) - -- - - - # i want to get any exception created by this insert - -- - - if region.type == 'group': -set_utils_conf(conf) -regions = get_regions_of_group(region.name) -else: -regions = [region_id] - -if region['name'] in regions: -region['action'] = 'delete' -- - - - - customer_id)) - - - -- - - - - - - - - - - - # if we have regions in sql_customer -- - conf.api.rds_server.status + -sql_customer.uuid, verify=conf.verify).json() -- - - - - - item.error_message = status['error_msg'] - -else: -ret_customer.status = 'no regions' -- - - - metadata): - - - -user=user, -starts_with=starts_with, -contains=contains, -metadata=metadata) -- - - # get aggregate status for each customer - - - - - -- - - - - - - - - - - raise ErrorStatus(404, 'customer: {0} not found'.format(customer_uuid)) -- - - - - - - - - - - - - - - - - - - - - - u = UserRole() -u.customer_id = region.customer_id -u.region_id = region.region_id -u.user_id = user.user_id -u.role_id = user.role_id -new_users.append(u) - -- - - - - - - - - - - - # The customer does not exist, so the delete operation is -# considered successful - -- - - # Do not delete a customer that still has some regions - -"Cannot delete a customer that has regions. " -"Please delete the regions first and then " -"delete the customer.") -else: - - -# Get status from RDS - - - - - -'RDS returned status: {}'.format( -status_resp['status'])) - -else: -# Invalid response from RDS - - - -# Customer not found in RDS, that means it never had any regions -# So it is OK to delete it - -'Resource not found in RDS, so it is OK to delete') - -else: -# Invalid status code from RDS - -resp.status_code) - -'_') - - -- - - - - "The customer has not been deleted " -"successfully from all of its regions " -"(either the deletion failed on one of the " -"regions or it is still in progress)") -- # OK to delete - -- - - - - - - - - - """ -this function generate th customer action response JSON -:param customer_uuid: -:param transaction_id: -:param context: create or update -:return: -""" -# The link should point to the customer itself (/v1/orm/customers/{id}) -link_elements = request.url.split('/') -base_link = '/'.join(link_elements) -if context == 'create': -base_link += customer_uuid -- timestamp = utils.get_time_human() -customer_result_wrapper = CustomerResultWrapper( -transaction_id=transaction_id, -id=customer_uuid, -updated=None, -created=timestamp, -links={'self': base_link}) -return customer_result_wrapper - - |
-
-
-
- Hot-keys on this page
-- r - m - x - p toggle line displays -
-- j - k next/prev highlighted chunk -
-- 0 (zero) top of page -
-- 1 (one) first highlighted chunk -
-| - - - - - - - - - - - - - - - - - - - - - - | -
-
-
- - - - - - - - - - - - - - - - - self.status_code = status_code -self.message = message - - |
-
-
-
- Hot-keys on this page
-- r - m - x - p toggle line displays -
-- j - k next/prev highlighted chunk -
-- 0 (zero) top of page -
-- 1 (one) first highlighted chunk -
-| - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - | -
-
-
-
-
-
-
-
-
-
- - - - - - sql_metadata_collection = map_metadata(customer_uuid, metadata_wrapper) -- datamanager = DataManager() -- try: -customer_record = datamanager.get_record('customer') -sql_customer = customer_record.read_customer_by_uuid(customer_uuid) -if not sql_customer: -logger.error('customer not found, customer uuid: {0}'.format(customer_uuid)) -raise ValueError('customer not found, customer uuid: {0}'.format(customer_uuid)) -- for metadata in sql_metadata_collection: -metadata_match = [m for m in sql_customer.customer_metadata if m.field_key == metadata.field_key] -if len(metadata_match) > 0: -logger.error('Duplicate metadata key, key already exits: {0}'.format(metadata.field_key)) -raise AttributeError('Duplicate metadata key, key already exits: {0}'.format(metadata.field_key)) -- for metadata in sql_metadata_collection: -sql_customer.customer_metadata.append(metadata) -logger.debug('updating metadata {0}'.format(json.dumps(metadata.get_proxy_dict()))) -- logger.debug('finished appending metadata to customer') -if len(sql_customer.customer_customer_regions) > 1: -RdsProxy.send_customer(sql_customer, transaction_id, "PUT") -datamanager.commit() -- customer_result_wrapper = build_response(customer_uuid, transaction_id) -- return customer_result_wrapper -- except Exception as exp: -datamanager.rollback() -raise exp -- - - sql_metadata_collection = map_metadata(customer_uuid, metadata_wrapper) -- datamanager = DataManager() -- try: -customer_record = datamanager.get_record('customer') -sql_customer = customer_record.read_customer_by_uuid(customer_uuid) -- if not sql_customer: -logger.error('customer not found, customer uuid: {0}'.format(customer_uuid)) -raise ValueError('customer not found, customer uuid: {0}'.format(customer_uuid)) -- while len(sql_customer.customer_metadata) > 0: -sql_customer.customer_metadata.remove(sql_customer.customer_metadata[0]) -- for metadata in sql_metadata_collection: -sql_customer.customer_metadata.append(metadata) -logger.debug('updating metadata {0}'.format(json.dumps(metadata.get_proxy_dict()))) -- if len(sql_customer.customer_customer_regions) > 1: -RdsProxy.send_customer(sql_customer, transaction_id, "PUT") -datamanager.commit() -- customer_result_wrapper = build_response(customer_uuid, transaction_id) -- return customer_result_wrapper -- except Exception as exp: -datamanager.rollback() -raise exp -- - - sql_metadata_collection = [] -for key, value in metadata_wrapper.metadata.iteritems(): -sql_metadata = CustomerMetadata() -sql_metadata.customer_id = customer_id -sql_metadata.field_key = key -sql_metadata.field_value = value -- sql_metadata_collection.append(sql_metadata) -return sql_metadata_collection -- - - # The link should point to the customer itself (/v1/orm/customers/{id}), -# so the 'metadata' element should be removed. -link_elements = request.url.split('/') -link_elements.remove('metadata') -base_link = '/'.join(link_elements) -- timestamp = utils.get_time_human() -customer_result_wrapper = CustomerResultWrapper( -transaction_id=transaction_id, -id=customer_uuid, -updated=None, -created=timestamp, -links={'self': base_link}) -return customer_result_wrapper - - |
-
-
-
- Hot-keys on this page
-- r - m - x - p toggle line displays -
-- j - k next/prev highlighted chunk -
-- 0 (zero) top of page -
-- 1 (one) first highlighted chunk -
-| - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - | -
-
-
-
- - - - """Base class for CMS models. -""" -- - return tojson(type(self), self) -- - def __init__(self, **kwds): -self.fields = list(kwds) -for k, v in kwds.iteritems(): -setattr(self, k, v) -- def as_dict(self): -d = {} -for f in self.fields: -v = getattr(self, f) -if isinstance(v, Model): -v = v.as_dict() -elif isinstance(v, list) and v and isinstance(v[0], Model): -v = [sub.as_dict() for sub in v] -d[f] = v -return d -- def __eq__(self, other): -return self.as_dict() == other.as_dict() -- @classmethod -def get_field_names(cls): -fields = inspect.getargspec(cls.__init__)[0] -return set(fields) - set(["self"]) -- """ - - |
-
-
-
- Hot-keys on this page
-- r - m - x - p toggle line displays -
-- j - k next/prev highlighted chunk -
-- 0 (zero) top of page -
-- 1 (one) first highlighted chunk -
-| - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - | -
-
-
-
-
-
-
- - - - """enable model the customer -- """ - -- - """Create a new enables class. -- :param enabled: customer status -""" - -- - - """compute model the customer -- """ - - - - - - - - - - - - -- - vcpus=None, metadata_items=None, injected_file_content_bytes=None, -floating_ips='', fixed_ips='', injected_file_path_bytes='', -server_groups='', server_group_members=''): -""" -Create a new compute instance. -:param instances: -:param injected_files: -:param key_pairs: -:param ram: -:param vcpus: -:param metadata_items: -:param injected_file_content_bytes: -:param floating_ips: -:param fixed_ips: -:param injected_file_path_bytes: -:param server_groups: -:param server_group_members: -""" - - - - - - -else: - - - -conf.quotas_default_values.compute.metadata_items -else: - - - -conf.quotas_default_values.compute.injected_file_content_bytes -else: - -- - - - - - - - - """storage info model for customer -- """ - - - -- - """ -create a new Storage instance. -:param gigabytes: -:param snapshots: -:param volumes: -""" - - - -- - - """network model the customer -- """ - - - - - - - - - - - - - -- - subnets='', security_groups=None, security_group_rules=None, -health_monitor='', member='', nat_instance='', -pool='', route_table='', vip=''): -- """ -Create a new Network instance. -:param floating_ips: num of floating_ips -:param networks: num of networks -:param ports: num of ports -:param routers: num of routers -:param subnets: num of subnets -:param security_groups: security groups -:param security_group_rules: security group rules -:param health_monitor: -:param member: -:param nat_instance: -:param pool: -:param route_table: -:param vip: -""" - - - - - - - -else: - - - -else: - -- - - - - - - - - - """network model the customer -- """ - - - -- - """Create a new compute. -- :param compute: compute quota -:param storage: storage quota -:param network: network quota -""" - - - -- - - """user model the customer -- """ - - -- - """Create a new compute. -- :param id: user id -:param role: roles this use belong to -""" - - -- - - """network model the customer -- """ - - - - - - -- - error_message=""): -"""Create a new compute. -- :param name: region name -:param type: region type -:param quotas: quotas ( array of Quota) -:param users: array of users of specific region -:param status: status of creation -:param error_message: error message if status is error -""" -- - - - - - - self.error_message = error_message -- - - """customer entity with all it's related data -- """ - - - - - - - - - - -- - defaultQuotas=[], status="", custId="", uuid=None): -"""Create a new Customer. -- :param description: Server name -:param enabled: I don't know -:param status: status of creation -""" - - - - - - - - - - -self.uuid = uuid -- - """ -this function check if the customer model meet the demands -:param context: i.e. 'create 'update' -:return: none -""" - - -if region.type == "group": -raise ErrorStatus(400, "region type is invalid for update, \'group\' can be only in create") -- - - - - - - - - - type='single', -quotas=region.quotas, -users=region.users)) - -- - - - - - - - - """ Customer Result Handler """ -- - - - - - - - - - - self.updated = updated - - - -- - - - - - - - - - - - """ ****************************************************************** """ -- """ User Result Handler """ -- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - """ ****************************************************************** """ -- """ Region Result Handler """ -- - - - - - - - - - - - - - - - - - - - - - - - """ ****************************************************************** """ -- """ CustomerSummary is a DataObject and contains all the fields defined in CustomerSummary structure. """ -- - - - - - - - - - - - enabled=True, status="", regions=[], num_regions=0): - -- - - - - - - - - - def from_db_model(sql_customer): - -sql_customer.customer_customer_regions if -region.region_id != -1] -# default region is -1 , check if -1 in customer list if yes it will return (true, flase) equal to (0, 1) - - - - - - - - -- - - - - - - - - - - - - - |
-
-
-
- Hot-keys on this page
-- r - m - x - p toggle line displays -
-- j - k next/prev highlighted chunk -
-- 0 (zero) top of page -
-- 1 (one) first highlighted chunk -
-| - - - - - - - - - - - - - - - - - | -
-
- - - - """ -This is a stub method which is called at application startup time. -- If you need to bind to a parsed database configuration, set up tables or -ORM classes, or perform any database initialization, this is the -recommended place to do it. -- For more information working with databases, and some common recipes, -see http://pecan.readthedocs.org/en/latest/databases.html -""" - - - |
-
-
-
- Hot-keys on this page
-- r - m - x - p toggle line displays -
-- j - k next/prev highlighted chunk -
-- 0 (zero) top of page -
-- 1 (one) first highlighted chunk -
-| - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - | -
-
-
-
-
-
-
-
- - - - - - - - - def get_status(resource_id): -try: -LOG.debug( -"Sending to RDS Server to get status: " + conf.api.rds_server.base + conf.api.rds_server.status + resource_id) -resp = requests.get( -conf.api.rds_server.base + conf.api.rds_server.status + resource_id, -verify=conf.verify) -LOG.debug( -"Sending to RDS Server to get status: " + conf.api.rds_server.base + conf.api.rds_server.status + resource_id) -pp = pprint.PrettyPrinter(width=30) -pretty_text = pp.pformat(resp.json()) -LOG.debug("Response from RDS Server:\n" + pretty_text) -return resp -except Exception as exp: -LOG.log_exception( -"CustomerLogic - Failed to Get status for customer : " + resource_id, -exp) -raise -- - def send_customer(customer, transaction_id, method): # method is "POST" or "PUT" - -- - def send_customer_dict(customer_dict, transaction_id, method): # method is "POST" or "PUT" - -"service_template": -{ -"resource": { -"resource_type": "customer" -}, -"model": str(json.dumps(customer_dict)), -"tracking": { -"external_id": "", -"tracking_id": transaction_id -} -} -} -- - "service_template": -{ -"resource": { -"resource_type": "customer" -}, -"model": customer_dict, -"tracking": { -"external_id": "", -"tracking_id": transaction_id -} -} -} -- - - - - - 'X-RANGER-Client'] if 'X-RANGER-Client' in request.headers else \ -'NA' - -'X-RANGER-Requester'] if 'X-RANGER-Requester' in request.headers else \ -'' -- - - - - - - - data=wrapper_json, -headers=headers, -verify=conf.verify) -else: -resp = requests.put(conf.api.rds_server.base + conf.api.rds_server.resources, -data=wrapper_json, -headers=headers, -verify=conf.verify) - - -- - - - - - - - - - - |
-
-
-
- Hot-keys on this page
-- r - m - x - p toggle line displays -
-- j - k next/prev highlighted chunk -
-- 0 (zero) top of page -
-- 1 (one) first highlighted chunk -
-| - - | -- - | -
-
-
- Hot-keys on this page
-- r - m - x - p toggle line displays -
-- j - k next/prev highlighted chunk -
-- 0 (zero) top of page -
-- 1 (one) first highlighted chunk -
-| - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - | -
-
-
-
-
- - - - - - - if not _is_authorization_enabled(conf): -return -- auth_region = request.headers.get('X-Auth-Region') -if not auth_region: -raise err_utils.get_error('N/A', message='X-Auth-Region is missing', -status_code=401) -policy.authorize(action, request, conf) -- - - - - - - - - - - - - keystone_version) - -- - - - - - - - - - - - .format(token_to_validate, lcp_id, "valid" if is_permitted else "invalid")) -else: -raise Exception("Token=[{}] and/or Region=[{}] are empty/none.".format(token_to_validate, lcp_id)) -else: - - - - - - - - - - - |
-
-
-
-
- Hot-keys on this page
-- n - s - m - x - - b - p - - c change column sorting -
-| Module | -statements | -missing | -excluded | - -branches | -partial | - -coverage | -
|---|---|---|---|---|---|---|
| Total | -1417 | -203 | -0 | - -312 | -55 | - -82% | -
| cms_rest/__init__.py | -0 | -0 | -0 | - -0 | -0 | - -100% | -
| cms_rest/app.py | -22 | -3 | -0 | - -2 | -1 | - -83% | -
| cms_rest/controllers/__init__.py | -0 | -0 | -0 | - -0 | -0 | - -100% | -
| cms_rest/controllers/root.py | -10 | -1 | -0 | - -0 | -0 | - -90% | -
| cms_rest/controllers/v1/__init__.py | -0 | -0 | -0 | - -0 | -0 | - -100% | -
| cms_rest/controllers/v1/base.py | -16 | -4 | -0 | - -0 | -0 | - -75% | -
| cms_rest/controllers/v1/orm/__init__.py | -0 | -0 | -0 | - -0 | -0 | - -100% | -
| cms_rest/controllers/v1/orm/configuration.py | -14 | -0 | -0 | - -0 | -0 | - -100% | -
| cms_rest/controllers/v1/orm/customer/__init__.py | -0 | -0 | -0 | - -0 | -0 | - -100% | -
| cms_rest/controllers/v1/orm/customer/enabled.py | -33 | -3 | -0 | - -2 | -0 | - -91% | -
| cms_rest/controllers/v1/orm/customer/metadata.py | -52 | -0 | -0 | - -16 | -0 | - -100% | -
| cms_rest/controllers/v1/orm/customer/regions.py | -75 | -3 | -0 | - -12 | -2 | - -94% | -
| cms_rest/controllers/v1/orm/customer/root.py | -111 | -3 | -0 | - -14 | -1 | - -97% | -
| cms_rest/controllers/v1/orm/customer/users.py | -138 | -15 | -0 | - -30 | -9 | - -86% | -
| cms_rest/controllers/v1/orm/logs.py | -33 | -20 | -0 | - -4 | -0 | - -35% | -
| cms_rest/controllers/v1/orm/root.py | -8 | -0 | -0 | - -0 | -0 | - -100% | -
| cms_rest/controllers/v1/root.py | -4 | -0 | -0 | - -0 | -0 | - -100% | -
| cms_rest/logger/__init__.py | -6 | -0 | -0 | - -2 | -0 | - -100% | -
| cms_rest/logic/__init__.py | -0 | -0 | -0 | - -0 | -0 | - -100% | -
| cms_rest/logic/customer_logic.py | -466 | -64 | -0 | - -162 | -34 | - -81% | -
| cms_rest/logic/error_base.py | -14 | -2 | -0 | - -0 | -0 | - -86% | -
| cms_rest/logic/metadata_logic.py | -74 | -60 | -0 | - -20 | -0 | - -15% | -
| cms_rest/model/Model.py | -7 | -1 | -0 | - -0 | -0 | - -86% | -
| cms_rest/model/Models.py | -241 | -5 | -0 | - -32 | -6 | - -95% | -
| cms_rest/model/__init__.py | -3 | -0 | -0 | - -0 | -0 | - -100% | -
| cms_rest/rds_proxy.py | -47 | -12 | -0 | - -8 | -1 | - -76% | -
| cms_rest/utils/__init__.py | -0 | -0 | -0 | - -0 | -0 | - -100% | -
| cms_rest/utils/authentication.py | -43 | -7 | -0 | - -8 | -1 | - -76% | -
- No items found using the specified filter. -
-| t |
-
-
-
- Hot-keys on this page
-- n - s - m - x - - c change column sorting -
-- No items found using the specified filter. -
-