X-Git-Url: https://osm.etsi.org/gitweb/?p=osm%2Fvim-emu.git;a=blobdiff_plain;f=src%2Femuvim%2Fapi%2Fopenstack%2Fopenstack_dummies%2Fnova_dummy_api.py;h=e12fb059c9fcdd704a14757409c16e0d6f74098d;hp=3c525f64f14a19236be578916205664ec4a03778;hb=72f09885db3935e77901c3dee132cb176b927c7b;hpb=5b428742f78d79c2c465957b01d911a3513c3d30 diff --git a/src/emuvim/api/openstack/openstack_dummies/nova_dummy_api.py b/src/emuvim/api/openstack/openstack_dummies/nova_dummy_api.py index 3c525f6..e12fb05 100755 --- a/src/emuvim/api/openstack/openstack_dummies/nova_dummy_api.py +++ b/src/emuvim/api/openstack/openstack_dummies/nova_dummy_api.py @@ -1,6 +1,32 @@ +# 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_restful import Resource from flask import Response, request from emuvim.api.openstack.openstack_dummies.base_openstack_dummy import BaseOpenstackDummy +from emuvim.api.openstack.helper import get_host import logging import json import uuid @@ -14,10 +40,13 @@ class NovaDummyApi(BaseOpenstackDummy): def __init__(self, in_ip, in_port, compute): super(NovaDummyApi, self).__init__(in_ip, in_port) self.compute = compute + self.compute.add_flavor('m1.tiny', 1, 512, "MB", 1, "GB") + self.compute.add_flavor('m1.nano', 1, 64, "MB", 0, "GB") + self.compute.add_flavor('m1.micro', 1, 128, "MB", 0, "GB") + self.compute.add_flavor('m1.small', 1, 1024, "MB", 2, "GB") self.api.add_resource(NovaVersionsList, "/", resource_class_kwargs={'api': self}) - self.api.add_resource(Shutdown, "/shutdown") self.api.add_resource(NovaVersionShow, "/v2.1/", resource_class_kwargs={'api': self}) self.api.add_resource(NovaListServersApi, "/v2.1//servers", @@ -44,30 +73,8 @@ class NovaDummyApi(BaseOpenstackDummy): resource_class_kwargs={'api': self}) self.api.add_resource(NovaListImageById, "/v2.1//images/", resource_class_kwargs={'api': self}) - - def _start_flask(self): - LOG.info("Starting %s endpoint @ http://%s:%d" % ("NovaDummyApi", self.ip, self.port)) - # add some flavors for good measure - self.compute.add_flavor('m1.tiny', 1, 512, "MB", 1, "GB") - self.compute.add_flavor('m1.nano', 1, 64, "MB", 0, "GB") - self.compute.add_flavor('m1.micro', 1, 128, "MB", 0, "GB") - self.compute.add_flavor('m1.small', 1, 1024, "MB", 2, "GB") - 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): - LOG.debug(("%s is beeing shut doen") % (__name__)) - func = request.environ.get('werkzeug.server.shutdown') - if func is None: - raise RuntimeError('Not running with the Werkzeug Server') - func() + self.api.add_resource(NovaLimits, "/v2.1//limits", + resource_class_kwargs={'api': self}) class NovaVersionsList(Resource): @@ -101,7 +108,7 @@ class NovaVersionsList(Resource): } ] } - """ % (self.api.ip, self.api.port) + """ % (get_host(request), self.api.port) response = Response(resp, status=200, mimetype="application/json") response.headers['Access-Control-Allow-Origin'] = '*' @@ -155,7 +162,7 @@ class NovaVersionShow(Resource): "updated": "2013-07-23T11:33:21Z" } } - """ % (self.api.ip, self.api.port) + """ % (get_host(request), self.api.port) response = Response(resp, status=200, mimetype="application/json") response.headers['Access-Control-Allow-Origin'] = '*' @@ -186,19 +193,21 @@ class NovaListServersApi(Resource): resp['servers'] = list() for server in self.api.compute.computeUnits.values(): s = server.create_server_dict(self.api.compute) - s['links'] = [{'href': "http://%s:%d/v2.1/%s/servers/%s" % (self.api.ip, + s['links'] = [{'href': "http://%s:%d/v2.1/%s/servers/%s" % (get_host(request), self.api.port, id, server.id)}] resp['servers'].append(s) - response = Response(json.dumps(resp), status=200, mimetype="application/json") + response = Response(json.dumps(resp), status=200, + mimetype="application/json") response.headers['Access-Control-Allow-Origin'] = '*' return response except Exception as ex: - LOG.exception(u"%s: Could not retrieve the list of servers." % __name__) + LOG.exception( + u"%s: Could not retrieve the list of servers." % __name__) return ex.message, 500 def post(self, id): @@ -214,16 +223,19 @@ class NovaListServersApi(Resource): try: server_dict = json.loads(request.data)['server'] networks = server_dict.get('networks', None) - name = str(self.api.compute.dc.label) + "_man_" + server_dict["name"][0:12] + name = str(self.api.compute.dc.label) + "_" + server_dict["name"] if self.api.compute.find_server_by_name_or_id(name) is not None: - return Response("Server with name %s already exists." % name, status=409) + LOG.error("Server with name %s already exists. 409" % name) + return Response( + "Server with name %s already exists." % name, status=409) # TODO: not finished! - resp = dict() - server = self.api.compute.create_server(name) - server.full_name = str(self.api.compute.dc.label) + "_man_" + server_dict["name"] + server.full_name = str( + self.api.compute.dc.label) + "_" + server_dict["name"] server.template_name = server_dict["name"] + if "metadata" in server_dict: + server.properties = server_dict["metadata"] for flavor in self.api.compute.flavors.values(): if flavor.id == server_dict.get('flavorRef', ''): @@ -234,11 +246,13 @@ class NovaListServersApi(Resource): if networks is not None: for net in networks: - port = self.api.compute.find_port_by_name_or_id(net.get('port', "")) + port = self.api.compute.find_port_by_name_or_id( + net.get('port', "")) if port is not None: server.port_names.append(port.name) else: - return Response("Currently only networking by port is supported.", status=400) + return Response( + "Currently only networking by port is supported.", status=400) self.api.compute._start_compute(server) @@ -272,7 +286,7 @@ class NovaListServersAndPortsApi(Resource): resp['servers'] = list() for server in self.api.compute.computeUnits.values(): s = server.create_server_dict(self.api.compute) - s['links'] = [{'href': "http://%s:%d/v2.1/%s/servers/%s" % (self.api.ip, + s['links'] = [{'href': "http://%s:%d/v2.1/%s/servers/%s" % (get_host(request), self.api.port, id, server.id)}] @@ -289,12 +303,14 @@ class NovaListServersAndPortsApi(Resource): resp['servers'].append(s) - response = Response(json.dumps(resp), status=200, mimetype="application/json") + response = Response(json.dumps(resp), status=200, + mimetype="application/json") response.headers['Access-Control-Allow-Origin'] = '*' return response except Exception as ex: - LOG.exception(u"%s: Could not retrieve the list of servers." % __name__) + LOG.exception( + u"%s: Could not retrieve the list of servers." % __name__) return ex.message, 500 @@ -318,7 +334,7 @@ class NovaListServersDetailed(Resource): resp = {"servers": list()} for server in self.api.compute.computeUnits.values(): s = server.create_server_dict(self.api.compute) - s['links'] = [{'href': "http://%s:%d/v2.1/%s/servers/%s" % (self.api.ip, + s['links'] = [{'href': "http://%s:%d/v2.1/%s/servers/%s" % (get_host(request), self.api.port, id, server.id)}] @@ -327,7 +343,7 @@ class NovaListServersDetailed(Resource): "id": flavor.id, "links": [ { - "href": "http://%s:%d/v2.1/%s/flavors/%s" % (self.api.ip, + "href": "http://%s:%d/v2.1/%s/flavors/%s" % (get_host(request), self.api.port, id, flavor.id), @@ -340,7 +356,7 @@ class NovaListServersDetailed(Resource): "id": image.id, "links": [ { - "href": "http://%s:%d/v2.1/%s/images/%s" % (self.api.ip, + "href": "http://%s:%d/v2.1/%s/images/%s" % (get_host(request), self.api.port, id, image.id), @@ -351,12 +367,14 @@ class NovaListServersDetailed(Resource): resp['servers'].append(s) - response = Response(json.dumps(resp), status=200, mimetype="application/json") + response = Response(json.dumps(resp), status=200, + mimetype="application/json") response.headers['Access-Control-Allow-Origin'] = '*' return response except Exception as ex: - LOG.exception(u"%s: Could not retrieve the list of servers." % __name__) + LOG.exception( + u"%s: Could not retrieve the list of servers." % __name__) return ex.message, 500 @@ -381,18 +399,20 @@ class NovaListFlavors(Resource): f = flavor.__dict__.copy() f['id'] = flavor.id f['name'] = flavor.name - f['links'] = [{'href': "http://%s:%d/v2.1/%s/flavors/%s" % (self.api.ip, + f['links'] = [{'href': "http://%s:%d/v2.1/%s/flavors/%s" % (get_host(request), self.api.port, id, flavor.id)}] resp['flavors'].append(f) - response = Response(json.dumps(resp), status=200, mimetype="application/json") + response = Response(json.dumps(resp), status=200, + mimetype="application/json") response.headers['Access-Control-Allow-Origin'] = '*' return response except Exception as ex: - LOG.exception(u"%s: Could not retrieve the list of servers." % __name__) + LOG.exception( + u"%s: Could not retrieve the list of servers." % __name__) return ex.message, 500 def post(self, id): @@ -407,12 +427,13 @@ class NovaListFlavors(Resource): data.get("disk"), "GB") # create response based on incoming data data["id"] = f.id - data["links"] = [{'href': "http://%s:%d/v2.1/%s/flavors/%s" % (self.api.ip, + data["links"] = [{'href': "http://%s:%d/v2.1/%s/flavors/%s" % (get_host(request), self.api.port, id, f.id)}] resp = {"flavor": data} - return Response(json.dumps(resp), status=200, mimetype="application/json") + return Response(json.dumps(resp), status=200, + mimetype="application/json") class NovaListFlavorsDetails(Resource): @@ -437,7 +458,7 @@ class NovaListFlavorsDetails(Resource): # but use a copy so we don't modifiy the original f = flavor.__dict__.copy() # add additional expected stuff stay openstack compatible - f['links'] = [{'href': "http://%s:%d/v2.1/%s/flavors/%s" % (self.api.ip, + f['links'] = [{'href': "http://%s:%d/v2.1/%s/flavors/%s" % (get_host(request), self.api.port, id, flavor.id)}] @@ -451,12 +472,14 @@ class NovaListFlavorsDetails(Resource): f['rxtx_factor'] = 1.0 resp['flavors'].append(f) - response = Response(json.dumps(resp), status=200, mimetype="application/json") + response = Response(json.dumps(resp), status=200, + mimetype="application/json") response.headers['Access-Control-Allow-Origin'] = '*' return response except Exception as ex: - LOG.exception(u"%s: Could not retrieve the list of servers." % __name__) + LOG.exception( + u"%s: Could not retrieve the list of servers." % __name__) return ex.message, 500 def post(self, id): @@ -471,12 +494,13 @@ class NovaListFlavorsDetails(Resource): data.get("disk"), "GB") # create response based on incoming data data["id"] = f.id - data["links"] = [{'href': "http://%s:%d/v2.1/%s/flavors/%s" % (self.api.ip, + data["links"] = [{'href': "http://%s:%d/v2.1/%s/flavors/%s" % (get_host(request), self.api.port, id, f.id)}] resp = {"flavor": data} - return Response(json.dumps(resp), status=200, mimetype="application/json") + return Response(json.dumps(resp), status=200, + mimetype="application/json") class NovaListFlavorById(Resource): @@ -506,18 +530,28 @@ class NovaListFlavorById(Resource): break resp['flavor']['id'] = flavor.id resp['flavor']['name'] = flavor.name - resp['flavor']['links'] = [{'href': "http://%s:%d/v2.1/%s/flavors/%s" % (self.api.ip, + resp['flavor']['links'] = [{'href': "http://%s:%d/v2.1/%s/flavors/%s" % (get_host(request), self.api.port, id, flavor.id)}] - response = Response(json.dumps(resp), status=200, mimetype="application/json") + response = Response(json.dumps(resp), status=200, + mimetype="application/json") response.headers['Access-Control-Allow-Origin'] = '*' return response except Exception as ex: - LOG.exception(u"%s: Could not retrieve flavor with id %s" % (__name__, flavorid)) + LOG.exception(u"%s: Could not retrieve flavor with id %s" % + (__name__, flavorid)) return ex.message, 500 + def delete(self, id, flavorid): + """ + Removes the given flavor. + Does not really remove anything from the machine, just fakes an OK. + """ + LOG.debug("API CALL: %s GET" % str(self.__class__.__name__)) + return Response("", status=204, mimetype="application/json") + class NovaListImages(Resource): def __init__(self, api): @@ -540,17 +574,19 @@ class NovaListImages(Resource): f = dict() f['id'] = image.id f['name'] = str(image.name).replace(":latest", "") - f['links'] = [{'href': "http://%s:%d/v2.1/%s/images/%s" % (self.api.ip, + f['links'] = [{'href': "http://%s:%d/v2.1/%s/images/%s" % (get_host(request), self.api.port, id, image.id)}] resp['images'].append(f) - response = Response(json.dumps(resp), status=200, mimetype="application/json") + response = Response(json.dumps(resp), status=200, + mimetype="application/json") response.headers['Access-Control-Allow-Origin'] = '*' return response except Exception as ex: - LOG.exception(u"%s: Could not retrieve the list of images." % __name__) + LOG.exception( + u"%s: Could not retrieve the list of images." % __name__) return ex.message, 500 @@ -577,7 +613,7 @@ class NovaListImagesDetails(Resource): f = image.__dict__.copy() # add additional expected stuff stay openstack compatible f['name'] = str(image.name).replace(":latest", "") - f['links'] = [{'href': "http://%s:%d/v2.1/%s/images/%s" % (self.api.ip, + f['links'] = [{'href': "http://%s:%d/v2.1/%s/images/%s" % (get_host(request), self.api.port, id, image.id)}] @@ -589,12 +625,14 @@ class NovaListImagesDetails(Resource): } resp['images'].append(f) - response = Response(json.dumps(resp), status=200, mimetype="application/json") + response = Response(json.dumps(resp), status=200, + mimetype="application/json") response.headers['Access-Control-Allow-Origin'] = '*' return response except Exception as ex: - LOG.exception(u"%s: Could not retrieve the list of images." % __name__) + LOG.exception( + u"%s: Could not retrieve the list of images." % __name__) return ex.message, 500 @@ -622,16 +660,27 @@ class NovaListImageById(Resource): i['id'] = image.id i['name'] = image.name - return Response(json.dumps(resp), status=200, mimetype="application/json") + return Response(json.dumps(resp), status=200, + mimetype="application/json") - response = Response("Image with id or name %s does not exists." % imageid, status=404) + response = Response( + "Image with id or name %s does not exists." % imageid, status=404) response.headers['Access-Control-Allow-Origin'] = '*' return response except Exception as ex: - LOG.exception(u"%s: Could not retrieve image with id %s." % (__name__, imageid)) + LOG.exception(u"%s: Could not retrieve image with id %s." % + (__name__, imageid)) return ex.message, 500 + def delete(self, id, imageid): + """ + Removes the given image. + Does not really remove anything from the machine, just fakes an OK. + """ + LOG.debug("API CALL: %s GET" % str(self.__class__.__name__)) + return Response("", status=204, mimetype="application/json") + class NovaShowServerDetails(Resource): def __init__(self, api): @@ -652,9 +701,10 @@ class NovaShowServerDetails(Resource): try: server = self.api.compute.find_server_by_name_or_id(serverid) if server is None: - return Response("Server with id or name %s does not exists." % serverid, status=404) + return Response( + "Server with id or name %s does not exists." % serverid, status=404) s = server.create_server_dict() - s['links'] = [{'href': "http://%s:%d/v2.1/%s/servers/%s" % (self.api.ip, + s['links'] = [{'href': "http://%s:%d/v2.1/%s/servers/%s" % (get_host(request), self.api.port, id, server.id)}] @@ -664,7 +714,7 @@ class NovaShowServerDetails(Resource): "id": flavor.id, "links": [ { - "href": "http://%s:%d/v2.1/%s/flavors/%s" % (self.api.ip, + "href": "http://%s:%d/v2.1/%s/flavors/%s" % (get_host(request), self.api.port, id, flavor.id), @@ -677,7 +727,7 @@ class NovaShowServerDetails(Resource): "id": image.id, "links": [ { - "href": "http://%s:%d/v2.1/%s/images/%s" % (self.api.ip, + "href": "http://%s:%d/v2.1/%s/images/%s" % (get_host(request), self.api.port, id, image.id), @@ -686,12 +736,14 @@ class NovaShowServerDetails(Resource): ] } - response = Response(json.dumps({'server': s}), status=200, mimetype="application/json") + response = Response(json.dumps( + {'server': s}), status=200, mimetype="application/json") response.headers['Access-Control-Allow-Origin'] = '*' return response except Exception as ex: - LOG.exception(u"%s: Could not retrieve the server details." % __name__) + LOG.exception( + u"%s: Could not retrieve the server details." % __name__) return ex.message, 500 def delete(self, id, serverid): @@ -702,18 +754,19 @@ class NovaShowServerDetails(Resource): :type id: ``str`` :param serverid: The UUID of the server :type serverid: ``str`` - :return: Returns 200 if everything is fine. + :return: Returns 204 if everything is fine. :rtype: :class:`flask.response` """ - LOG.debug("API CALL: %s POST" % str(self.__class__.__name__)) + LOG.debug("API CALL: %s DELETE" % str(self.__class__.__name__)) try: server = self.api.compute.find_server_by_name_or_id(serverid) if server is None: - return Response('Could not find server.', status=404, mimetype="application/json") + return Response('Could not find server.', + status=404, mimetype="application/json") self.api.compute.stop_compute(server) - response = Response('Server deleted.', status=204, mimetype="application/json") + response = Response('', status=204, mimetype="application/json") response.headers['Access-Control-Allow-Origin'] = '*' return response @@ -741,11 +794,13 @@ class NovaInterfaceToServer(Resource): try: server = self.api.compute.find_server_by_name_or_id(serverid) if server is None: - return Response("Server with id or name %s does not exists." % serverid, status=404) + return Response( + "Server with id or name %s does not exists." % serverid, status=404) if server.emulator_compute is None: LOG.error("The targeted container does not exist.") - return Response("The targeted container of %s does not exist." % serverid, status=404) + return Response( + "The targeted container of %s does not exist." % serverid, status=404) data = json.loads(request.data).get("interfaceAttachment") resp = dict() port = data.get("port_id", None) @@ -763,7 +818,8 @@ class NovaInterfaceToServer(Resource): elif net is not None: network = self.api.compute.find_network_by_name_or_id(net) if network is None: - return Response("Network with id or name %s does not exists." % net, status=404) + return Response( + "Network with id or name %s does not exists." % net, status=404) port = self.api.compute.create_port("port:cp%s:fl:%s" % (len(self.api.compute.ports), str(uuid.uuid4()))) @@ -776,10 +832,12 @@ class NovaInterfaceToServer(Resource): port = self.api.compute.find_port_by_name_or_id(port) network_dict['id'] = port.intf_name network_dict['ip'] = port.ip_address - network = self.api.compute.find_network_by_name_or_id(port.net_name) + network = self.api.compute.find_network_by_name_or_id( + port.net_name) network_dict[network_dict['id']] = network.name else: - raise Exception("You can only attach interfaces by port or network at the moment") + raise Exception( + "You can only attach interfaces by port or network at the moment") if network == self.api.manage.floating_network: dc.net.addLink(server.emulator_compute, self.api.manage.floating_switch, @@ -789,19 +847,22 @@ class NovaInterfaceToServer(Resource): params1=network_dict, cls=Link, intfName1=port.intf_name) resp["port_state"] = "ACTIVE" resp["port_id"] = port.id - resp["net_id"] = self.api.compute.find_network_by_name_or_id(port.net_name).id + resp["net_id"] = self.api.compute.find_network_by_name_or_id( + port.net_name).id resp["mac_addr"] = port.mac_address resp["fixed_ips"] = list() fixed_ips = dict() fixed_ips["ip_address"] = port.ip_address fixed_ips["subnet_id"] = network.subnet_name resp["fixed_ips"].append(fixed_ips) - response = Response(json.dumps({"interfaceAttachment": resp}), status=202, mimetype="application/json") + response = Response(json.dumps( + {"interfaceAttachment": resp}), status=202, mimetype="application/json") response.headers['Access-Control-Allow-Origin'] = '*' return response except Exception as ex: - LOG.exception(u"%s: Could not add interface to the server." % __name__) + LOG.exception( + u"%s: Could not add interface to the server." % __name__) return ex.message, 500 @@ -827,14 +888,16 @@ class NovaShowAndDeleteInterfaceAtServer(Resource): try: server = self.api.compute.find_server_by_name_or_id(serverid) if server is None: - return Response("Server with id or name %s does not exists." % serverid, status=404) + return Response( + "Server with id or name %s does not exists." % serverid, status=404) port = self.api.compute.find_port_by_name_or_id(port_id) if port is None: - return Response("Port with id or name %s does not exists." % port_id, status=404) + return Response( + "Port with id or name %s does not exists." % port_id, status=404) for link in self.api.compute.dc.net.links: if str(link.intf1) == port.intf_name and \ - str(link.intf1.ip) == port.ip_address.split('/')[0]: + str(link.intf1.ip) == port.ip_address.split('/')[0]: self.api.compute.dc.net.removeLink(link) break @@ -843,5 +906,61 @@ class NovaShowAndDeleteInterfaceAtServer(Resource): return response except Exception as ex: - LOG.exception(u"%s: Could not detach interface from the server." % __name__) + LOG.exception( + u"%s: Could not detach interface from the server." % __name__) + return ex.message, 500 + + +class NovaLimits(Resource): + def __init__(self, api): + self.api = api + + def get(self, id): + """ + Returns the resource limits of the emulated cloud. + https://developer.openstack.org/api-ref/compute/?expanded=show-rate-and-absolute-limits-detail#limits-limits + + TODO: For now we only return fixed limits, not based on the real deployment. + + :param id: tenant id, used for the 'href' link + :type id: ``str`` + :return: Returns the resource limits. + :rtype: :class:`flask.response` + """ + LOG.debug("API CALL: %s GET" % str(self.__class__.__name__)) + try: + resp = { + "limits": { + "absolute": { + "maxImageMeta": 12800, + "maxPersonality": 500, + "maxPersonalitySize": 1024000, + "maxSecurityGroupRules": 2000, + "maxSecurityGroups": 1000, + "maxServerMeta": 12800, + "maxTotalCores": 2000, + "maxTotalFloatingIps": 1000, + "maxTotalInstances": 1000, + "maxTotalKeypairs": 1000, + "maxTotalRAMSize": 5120000, + "maxServerGroups": 1000, + "maxServerGroupMembers": 1000, + "totalCoresUsed": 0, + "totalInstancesUsed": 0, + "totalRAMUsed": 0, + "totalSecurityGroupsUsed": 0, + "totalFloatingIpsUsed": 0, + "totalServerGroupsUsed": 0 + }, + "rate": [] + } + } + response = Response(json.dumps(resp), status=200, + mimetype="application/json") + response.headers['Access-Control-Allow-Origin'] = '*' + return response + + except Exception as ex: + LOG.exception( + u"%s: Could not retrieve the list of images." % __name__) return ex.message, 500