X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=src%2Femuvim%2Fapi%2Fopenstack%2Fopenstack_dummies%2Fheat_dummy_api.py;h=86fb6c164689d5dd3a5f530fc9aa831356c374cc;hb=refs%2Fchanges%2F49%2F6149%2F3;hp=f696442b74cddc19a7a0b3f32d4113ef022fbc14;hpb=6dcec5542d668c188ffcf491a8abaac4c5735040;p=osm%2Fvim-emu.git diff --git a/src/emuvim/api/openstack/openstack_dummies/heat_dummy_api.py b/src/emuvim/api/openstack/openstack_dummies/heat_dummy_api.py index f696442..86fb6c1 100755 --- a/src/emuvim/api/openstack/openstack_dummies/heat_dummy_api.py +++ b/src/emuvim/api/openstack/openstack_dummies/heat_dummy_api.py @@ -1,19 +1,47 @@ +# Copyright (c) 2015 SONATA-NFV and Paderborn University +# ALL RIGHTS RESERVED. +# +# 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. +# +# Neither the name of the SONATA-NFV, Paderborn University +# nor the names of its contributors may be used to endorse or promote +# products derived from this software without specific prior written +# permission. +# +# This work has been performed in the framework of the SONATA project, +# funded by the European Commission under Grant number 671517 through +# the Horizon 2020 and 5G-PPP programmes. The authors would like to +# acknowledge the contributions of their colleagues of the SONATA +# partner consortium (www.sonata-nfv.eu). from flask import request, Response from flask_restful import Resource -from emuvim.api.openstack.resources import Stack +from emuvim.api.openstack.resources.stack import Stack from emuvim.api.openstack.openstack_dummies.base_openstack_dummy import BaseOpenstackDummy +from emuvim.api.openstack.helper import get_host from datetime import datetime from emuvim.api.openstack.heat_parser import HeatParser import logging import json +LOG = logging.getLogger("api.openstack.heat") + + class HeatDummyApi(BaseOpenstackDummy): def __init__(self, in_ip, in_port, compute): super(HeatDummyApi, self).__init__(in_ip, in_port) self.compute = compute - self.api.add_resource(Shutdown, "/shutdown") self.api.add_resource(HeatListAPIVersions, "/", resource_class_kwargs={'api': self}) self.api.add_resource(HeatCreateStack, "/v1//stacks", @@ -21,6 +49,10 @@ class HeatDummyApi(BaseOpenstackDummy): self.api.add_resource(HeatShowStack, "/v1//stacks/", "/v1//stacks//", resource_class_kwargs={'api': self}) + self.api.add_resource(HeatShowStackTemplate, "/v1//stacks///template", + resource_class_kwargs={'api': self}) + self.api.add_resource(HeatShowStackResources, "/v1//stacks///resources", + resource_class_kwargs={'api': self}) self.api.add_resource(HeatUpdateStack, "/v1//stacks/", "/v1//stacks//", resource_class_kwargs={'api': self}) @@ -34,32 +66,12 @@ class HeatDummyApi(BaseOpenstackDummy): return response - def _start_flask(self): - logging.info("Starting %s endpoint @ http://%s:%d" % (__name__, self.ip, self.port)) - if self.app is not None: - self.app.before_request(self.dump_playbook) - self.app.run(self.ip, self.port, debug=True, use_reloader=False) - - -class Shutdown(Resource): - """ - A get request to /shutdown will shut down this endpoint. - """ - - def get(self): - logging.debug(("%s is beeing shut down") % (__name__)) - func = request.environ.get('werkzeug.server.shutdown') - if func is None: - raise RuntimeError('Not running with the Werkzeug Server') - func() - - class HeatListAPIVersions(Resource): def __init__(self, api): self.api = api def get(self): - logging.debug("API CALL: %s GET" % str(self.__class__.__name__)) + LOG.debug("API CALL: %s GET" % str(self.__class__.__name__)) resp = dict() resp['versions'] = dict() @@ -68,13 +80,14 @@ class HeatListAPIVersions(Resource): "id": "v1.0", "links": [ { - "href": "http://%s:%d/v2.0" % (self.api.ip, self.api.port), + "href": "http://%s:%d/v2.0" % (get_host(request), self.api.port), "rel": "self" } ] }] - return Response(json.dumps(resp), status=200, mimetype="application/json") + return Response(json.dumps(resp), status=200, + mimetype="application/json") class HeatCreateStack(Resource): @@ -91,7 +104,7 @@ class HeatCreateStack(Resource): 500, if any exception occurred while creation. 201, if everything worked out. """ - logging.debug("API CALL: %s POST" % str(self.__class__.__name__)) + LOG.debug("API CALL: %s POST" % str(self.__class__.__name__)) try: stack_dict = json.loads(request.data) @@ -100,14 +113,17 @@ class HeatCreateStack(Resource): return [], 409 stack = Stack() stack.stack_name = stack_dict['stack_name'] - reader = HeatParser(self.api.compute) - if isinstance(stack_dict['template'], str) or isinstance(stack_dict['template'], unicode): + reader = HeatParser(self.api.compute) + if isinstance(stack_dict['template'], str) or isinstance( + stack_dict['template'], unicode): stack_dict['template'] = json.loads(stack_dict['template']) - if not reader.parse_input(stack_dict['template'], stack, self.api.compute.dc.label): + if not reader.parse_input( + stack_dict['template'], stack, self.api.compute.dc.label): self.api.compute.clean_broken_stack(stack) return 'Could not create stack.', 400 + stack.template = stack_dict['template'] stack.creation_time = str(datetime.now()) stack.status = "CREATE_COMPLETE" @@ -115,16 +131,17 @@ class HeatCreateStack(Resource): "links": [ { "href": "http://%s:%s/v1/%s/stacks/%s" - % (self.api.ip, self.api.port, tenant_id, stack.id), + % (get_host(request), self.api.port, tenant_id, stack.id), "rel": "self" }]}} self.api.compute.add_stack(stack) self.api.compute.deploy_stack(stack.id) - return Response(json.dumps(return_dict), status=201, mimetype="application/json") + return Response(json.dumps(return_dict), status=201, + mimetype="application/json") except Exception as ex: - logging.exception("Heat: Create Stack exception.") + LOG.exception("Heat: Create Stack exception.") return ex.message, 500 def get(self, tenant_id): @@ -136,7 +153,7 @@ class HeatCreateStack(Resource): 500, if any exception occurred. 200, if everything worked out. """ - logging.debug("API CALL: %s GET" % str(self.__class__.__name__)) + LOG.debug("API CALL: %s GET" % str(self.__class__.__name__)) try: return_stacks = dict() return_stacks['stacks'] = list() @@ -153,9 +170,10 @@ class HeatCreateStack(Resource): "tags": "" }) - return Response(json.dumps(return_stacks), status=200, mimetype="application/json") + return Response(json.dumps(return_stacks), + status=200, mimetype="application/json") except Exception as ex: - logging.exception("Heat: List Stack exception.") + LOG.exception("Heat: List Stack exception.") return ex.message, 500 @@ -174,7 +192,7 @@ class HeatShowStack(Resource): 500, if any exception occurred. 200, if everything worked out. """ - logging.debug("API CALL: %s GET" % str(self.__class__.__name__)) + LOG.debug("API CALL: %s GET" % str(self.__class__.__name__)) try: stack = None if stack_name_or_id in self.api.compute.stacks: @@ -196,7 +214,7 @@ class HeatShowStack(Resource): "links": [ { "href": "http://%s:%s/v1/%s/stacks/%s" - % (self.api.ip, self.api.port, tenant_id, stack.id), + % (get_host(request), self.api.port, tenant_id, stack.id), "rel": "self" } ], @@ -210,7 +228,8 @@ class HeatShowStack(Resource): "stack_name": stack.stack_name, "stack_owner": "The owner of the stack.", # add stack owner "stack_status": stack.status, - "stack_status_reason": "The reason for the current status of the stack.", # add status reason + # add status reason + "stack_status_reason": "The reason for the current status of the stack.", "template_description": "The description of the stack template.", "stack_user_project_id": "The project UUID of the stack user.", "timeout_mins": "", @@ -220,10 +239,80 @@ class HeatShowStack(Resource): } } - return Response(json.dumps(return_stack), status=200, mimetype="application/json") + return Response(json.dumps(return_stack), + status=200, mimetype="application/json") + + except Exception as ex: + LOG.exception("Heat: Show stack exception.") + return ex.message, 500 + + +class HeatShowStackTemplate(Resource): + def __init__(self, api): + self.api = api + + def get(self, tenant_id, stack_name_or_id, stack_id=None): + """ + Returns template of given stack. + + :param tenant_id: + :param stack_name_or_id: + :param stack_id: + :return: Returns a json response which contains the stack's template. + """ + LOG.debug("API CALL: %s GET" % str(self.__class__.__name__)) + try: + stack = None + if stack_name_or_id in self.api.compute.stacks: + stack = self.api.compute.stacks[stack_name_or_id] + else: + for tmp_stack in self.api.compute.stacks.values(): + if tmp_stack.stack_name == stack_name_or_id: + stack = tmp_stack + if stack is None: + return 'Could not resolve Stack - ID', 404 + # LOG.debug("STACK: {}".format(stack)) + # LOG.debug("TEMPLATE: {}".format(stack.template)) + return Response(json.dumps(stack.template), + status=200, mimetype="application/json") + + except Exception as ex: + LOG.exception("Heat: Show stack template exception.") + return ex.message, 500 + + +class HeatShowStackResources(Resource): + def __init__(self, api): + self.api = api + + def get(self, tenant_id, stack_name_or_id, stack_id=None): + """ + Returns template of given stack. + + :param tenant_id: + :param stack_name_or_id: + :param stack_id: + :return: Returns a json response which contains the stack's template. + """ + LOG.debug("API CALL: %s GET" % str(self.__class__.__name__)) + try: + stack = None + if stack_name_or_id in self.api.compute.stacks: + stack = self.api.compute.stacks[stack_name_or_id] + else: + for tmp_stack in self.api.compute.stacks.values(): + if tmp_stack.stack_name == stack_name_or_id: + stack = tmp_stack + if stack is None: + return 'Could not resolve Stack - ID', 404 + + response = {"resources": []} + + return Response(json.dumps(response), status=200, + mimetype="application/json") except Exception as ex: - logging.exception("Heat: Show stack exception.") + LOG.exception("Heat: Show stack template exception.") return ex.message, 500 @@ -232,6 +321,14 @@ class HeatUpdateStack(Resource): self.api = api def put(self, tenant_id, stack_name_or_id, stack_id=None): + LOG.debug("API CALL: %s PUT" % str(self.__class__.__name__)) + return self.update_stack(tenant_id, stack_name_or_id, stack_id) + + def patch(self, tenant_id, stack_name_or_id, stack_id=None): + LOG.debug("API CALL: %s PATCH" % str(self.__class__.__name__)) + return self.update_stack(tenant_id, stack_name_or_id, stack_id) + + def update_stack(self, tenant_id, stack_name_or_id, stack_id=None): """ Updates an existing stack with a new heat template. @@ -243,7 +340,6 @@ class HeatUpdateStack(Resource): 500, if any exception occurred while updating. 202, if everything worked out. """ - logging.debug("API CALL: %s PUT" % str(self.__class__.__name__)) try: old_stack = None if stack_name_or_id in self.api.compute.stacks: @@ -265,10 +361,13 @@ class HeatUpdateStack(Resource): stack.status = "UPDATE_COMPLETE" reader = HeatParser(self.api.compute) - if isinstance(stack_dict['template'], str) or isinstance(stack_dict['template'], unicode): + if isinstance(stack_dict['template'], str) or isinstance( + stack_dict['template'], unicode): stack_dict['template'] = json.loads(stack_dict['template']) - if not reader.parse_input(stack_dict['template'], stack, self.api.compute.dc.label, stack_update=True): + if not reader.parse_input( + stack_dict['template'], stack, self.api.compute.dc.label, stack_update=True): return 'Could not create stack.', 400 + stack.template = stack_dict['template'] if not self.api.compute.update_stack(old_stack.id, stack): return 'Could not update stack.', 400 @@ -276,7 +375,7 @@ class HeatUpdateStack(Resource): return Response(status=202, mimetype="application/json") except Exception as ex: - logging.exception("Heat: Update Stack exception") + LOG.exception("Heat: Update Stack exception") return ex.message, 500 @@ -294,17 +393,19 @@ class HeatDeleteStack(Resource): :return: 500, if any exception occurred while deletion. 204, if everything worked out. """ - logging.debug("API CALL: %s DELETE" % str(self.__class__.__name__)) + LOG.debug("API CALL: %s DELETE" % str(self.__class__.__name__)) try: if stack_name_or_id in self.api.compute.stacks: self.api.compute.delete_stack(stack_name_or_id) - return Response('Deleted Stack: ' + stack_name_or_id, 204) + return Response("", 204, + mimetype='application/json') for stack in self.api.compute.stacks.values(): if stack.stack_name == stack_name_or_id: self.api.compute.delete_stack(stack.id) - return Response('Deleted Stack: ' + stack_name_or_id, 204) + return Response("", 204, + mimetype='application/json') except Exception as ex: - logging.exception("Heat: Delete Stack exception") + LOG.exception("Heat: Delete Stack exception") return ex.message, 500