248 lines
9.8 KiB
Python
248 lines
9.8 KiB
Python
# Licensed under the Apache License, Version 2.0 (the "License"); you may
|
|
# not use this file except in compliance with the License. You may obtain
|
|
# a copy of the License at
|
|
#
|
|
# http://www.apache.org/licenses/LICENSE-2.0
|
|
#
|
|
# Unless required by applicable law or agreed to in writing, software
|
|
# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
|
|
# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
|
|
# License for the specific language governing permissions and limitations
|
|
# under the License.
|
|
|
|
import pecan
|
|
from pecan import expose
|
|
from pecan import rest
|
|
|
|
from oslo_log import log as logging
|
|
|
|
from tricircle.common import constants
|
|
import tricircle.common.context as t_context
|
|
import tricircle.common.exceptions as t_exc
|
|
from tricircle.common.i18n import _
|
|
from tricircle.common.i18n import _LE
|
|
from tricircle.common import policy
|
|
from tricircle.common import utils
|
|
|
|
from tricircle.db import api as db_api
|
|
|
|
LOG = logging.getLogger(__name__)
|
|
|
|
|
|
SUPPORTED_FILTERS = ['id', 'top_id', 'bottom_id', 'pod_id', 'project_id',
|
|
'resource_type', 'created_at', 'updated_at']
|
|
|
|
|
|
class RoutingController(rest.RestController):
|
|
|
|
def __init__(self):
|
|
pass
|
|
|
|
@expose(generic=True, template='json')
|
|
def post(self, **kw):
|
|
context = t_context.extract_context_from_environ()
|
|
|
|
if not policy.enforce(context, policy.ADMIN_API_ROUTINGS_CREATE):
|
|
return utils.format_api_error(
|
|
403, _("Unauthorized to create resource routing"))
|
|
|
|
if 'routing' not in kw:
|
|
return utils.format_api_error(
|
|
400, _("Request body not found"))
|
|
|
|
routing = kw['routing']
|
|
|
|
for field in ('top_id', 'bottom_id', 'pod_id',
|
|
'project_id', 'resource_type'):
|
|
value = routing.get(field)
|
|
if value is None or len(value.strip()) == 0:
|
|
return utils.format_api_error(
|
|
400, _("Field %(field)s can not be empty") % {
|
|
'field': field})
|
|
|
|
# verify the integrity: the pod_id and the project_id should be bound
|
|
pod_id = routing.get('pod_id').strip()
|
|
project_id = routing.get('project_id').strip()
|
|
bindings = db_api.list_pod_bindings(context,
|
|
[{'key': 'pod_id',
|
|
'comparator': 'eq',
|
|
'value': pod_id
|
|
},
|
|
{'key': 'tenant_id',
|
|
'comparator': 'eq',
|
|
'value': project_id}
|
|
], [])
|
|
if len(bindings) == 0:
|
|
return utils.format_api_error(
|
|
400, _('The pod_id and project_id have not been bound'))
|
|
|
|
# the resource type should be properly provisioned.
|
|
resource_type = routing.get('resource_type').strip()
|
|
if not constants.is_valid_resource_type(resource_type):
|
|
return utils.format_api_error(
|
|
400, _('There is no such resource type'))
|
|
|
|
try:
|
|
top_id = routing.get('top_id').strip()
|
|
bottom_id = routing.get('bottom_id').strip()
|
|
|
|
routing = db_api.create_resource_mapping(context, top_id,
|
|
bottom_id, pod_id,
|
|
project_id,
|
|
resource_type)
|
|
if not routing:
|
|
return utils.format_api_error(
|
|
409, _('Resource routing already exists'))
|
|
except Exception as e:
|
|
LOG.exception(_LE('Failed to create resource routing: '
|
|
'%(exception)s '), {'exception': e})
|
|
return utils.format_api_error(
|
|
500, _('Failed to create resource routing'))
|
|
|
|
return {'routing': routing}
|
|
|
|
def _get_filters(self, params):
|
|
"""Return a dictionary of query param filters from the request.
|
|
|
|
:param params: the URI params coming from the wsgi layer
|
|
:return a dict of key/value filters
|
|
"""
|
|
filters = {}
|
|
for param in params:
|
|
if param in SUPPORTED_FILTERS:
|
|
# map filter name
|
|
filter_name = param
|
|
filters[filter_name] = params.get(param)
|
|
|
|
return filters
|
|
|
|
@expose(generic=True, template='json')
|
|
def get_all(self, **kwargs):
|
|
context = t_context.extract_context_from_environ()
|
|
|
|
if not policy.enforce(context, policy.ADMIN_API_ROUTINGS_LIST):
|
|
return utils.format_api_error(
|
|
403, _('Unauthorized to show all resource routings'))
|
|
|
|
filters = self._get_filters(kwargs)
|
|
filters = [{'key': key,
|
|
'comparator': 'eq',
|
|
'value': value} for key, value in filters.iteritems()]
|
|
|
|
try:
|
|
return {'routings': db_api.list_resource_routings(context,
|
|
filters)}
|
|
except Exception as e:
|
|
LOG.exception(_LE('Failed to show all resource routings: '
|
|
'%(exception)s '), {'exception': e})
|
|
return utils.format_api_error(
|
|
500, _('Failed to show all resource routings'))
|
|
|
|
@expose(generic=True, template='json')
|
|
def get_one(self, _id):
|
|
context = t_context.extract_context_from_environ()
|
|
|
|
if not policy.enforce(context, policy.ADMIN_API_ROUTINGS_SHOW):
|
|
return utils.format_api_error(
|
|
403, _('Unauthorized to show the resource routing'))
|
|
|
|
try:
|
|
return {'routing': db_api.get_resource_routing(context, _id)}
|
|
except t_exc.ResourceNotFound:
|
|
return utils.format_api_error(
|
|
404, _('Resource routing not found'))
|
|
|
|
@expose(generic=True, template='json')
|
|
def delete(self, _id):
|
|
context = t_context.extract_context_from_environ()
|
|
|
|
if not policy.enforce(context, policy.ADMIN_API_ROUTINGS_DELETE):
|
|
return utils.format_api_error(
|
|
403, _('Unauthorized to delete the resource routing'))
|
|
|
|
try:
|
|
db_api.get_resource_routing(context, _id)
|
|
except t_exc.ResourceNotFound:
|
|
return utils.format_api_error(404,
|
|
_('Resource routing not found'))
|
|
try:
|
|
db_api.delete_resource_routing(context, _id)
|
|
pecan.response.status = 200
|
|
return pecan.response
|
|
except Exception as e:
|
|
LOG.exception(_LE('Failed to delete the resource routing: '
|
|
'%(exception)s '), {'exception': e})
|
|
return utils.format_api_error(
|
|
500, _('Failed to delete the resource routing'))
|
|
|
|
@expose(generic=True, template='json')
|
|
def put(self, _id, **kw):
|
|
context = t_context.extract_context_from_environ()
|
|
|
|
if not policy.enforce(context, policy.ADMIN_API_ROUTINGS_PUT):
|
|
return utils.format_api_error(
|
|
403, _('Unauthorized to update resource routing'))
|
|
|
|
try:
|
|
routing = db_api.get_resource_routing(context, _id)
|
|
except t_exc.ResourceNotFound:
|
|
return utils.format_api_error(404,
|
|
_('Resource routing not found'))
|
|
|
|
if 'routing' not in kw:
|
|
return utils.format_api_error(
|
|
400, _('Request body not found'))
|
|
|
|
update_dict = kw['routing']
|
|
|
|
# values to be updated should not be empty
|
|
for field in update_dict:
|
|
value = update_dict.get(field)
|
|
if value is None or len(value.strip()) == 0:
|
|
return utils.format_api_error(
|
|
400, _("Field %(field)s can not be empty") % {
|
|
'field': field})
|
|
|
|
# the resource type should be properly provisioned.
|
|
if 'resource_type' in update_dict:
|
|
if not constants.is_valid_resource_type(
|
|
update_dict['resource_type']):
|
|
return utils.format_api_error(
|
|
400, _('There is no such resource type'))
|
|
|
|
# verify the integrity: the pod_id and project_id should be bound
|
|
if 'pod_id' in update_dict or 'project_id' in update_dict:
|
|
if 'pod_id' in update_dict:
|
|
pod_id = update_dict['pod_id']
|
|
else:
|
|
pod_id = routing['pod_id']
|
|
|
|
if 'project_id' in update_dict:
|
|
project_id = update_dict['project_id']
|
|
else:
|
|
project_id = routing['project_id']
|
|
|
|
bindings = db_api.list_pod_bindings(context,
|
|
[{'key': 'pod_id',
|
|
'comparator': 'eq',
|
|
'value': pod_id
|
|
},
|
|
{'key': 'tenant_id',
|
|
'comparator': 'eq',
|
|
'value': project_id}
|
|
], [])
|
|
if len(bindings) == 0:
|
|
return utils.format_api_error(
|
|
400, _('The pod_id and project_id have not been '
|
|
'bound'))
|
|
|
|
try:
|
|
routing_updated = db_api.update_resource_routing(
|
|
context, _id, update_dict)
|
|
return {'routing': routing_updated}
|
|
except Exception as e:
|
|
LOG.exception(_LE('Failed to update resource routing: '
|
|
'%(exception)s '), {'exception': e})
|
|
return utils.format_api_error(
|
|
500, _('Failed to update resource routing'))
|