+"""
+Copyright (c) 2017 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 request, Response
from emuvim.api.openstack.openstack_dummies.base_openstack_dummy import BaseOpenstackDummy
+from emuvim.api.openstack.helper import get_host
from datetime import datetime
import neutron_sfc_dummy_api as SFC
import logging
super(NeutronDummyApi, self).__init__(ip, port)
self.compute = compute
+ # create default networks (OSM usually assumes to have these pre-configured)
+ self.compute.create_network("mgmt")
+ self.compute.create_network("mgmtnet")
+
self.api.add_resource(NeutronListAPIVersions, "/")
- self.api.add_resource(Shutdown, "/shutdown")
self.api.add_resource(NeutronShowAPIv2Details, "/v2.0")
self.api.add_resource(NeutronListNetworks, "/v2.0/networks.json", "/v2.0/networks",
resource_class_kwargs={'api': self})
"/v2.0/sfc/port_chains/<chain_id>",
resource_class_kwargs={'api': self})
- def _start_flask(self):
- LOG.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):
- def get(self):
- LOG.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 NeutronListAPIVersions(Resource):
def get(self):
:rtype: :class:`flask.response`
"""
LOG.debug("API CALL: %s GET" % str(self.__class__.__name__))
+ # LOG.debug("ARGS: {}".format(request.args))
try:
if request.args.get('name'):
tmp_network = NeutronShowNetwork(self.api)
- return tmp_network.get_network(request.args.get('name'), True)
+ response = tmp_network.get_network(request.args.get('name'), True)
+ LOG.debug("{} RESPONSE (1): {}".format(self.__class__.__name__, response))
+ return response
id_list = request.args.getlist('id')
if len(id_list) == 1:
tmp_network = NeutronShowNetwork(self.api)
- return tmp_network.get_network(request.args.get('id'), True)
+ response = tmp_network.get_network(request.args.get('id'), True)
+ LOG.debug("{} RESPONSE (2): {}".format(self.__class__.__name__, response))
+ return response
network_list = list()
network_dict = dict()
network_list.append(tmp_network_dict)
network_dict["networks"] = network_list
-
+ LOG.debug("{} RESPONSE (3): {}".format(self.__class__.__name__, network_dict))
return Response(json.dumps(network_dict), status=200, mimetype='application/json')
except Exception as ex:
self.api.compute.delete_network(network_id)
- return Response('Network ' + str(network_id) + ' deleted.\n', status=204, mimetype='application/json')
+ return Response('', status=204, mimetype='application/json')
except Exception as ex:
LOG.exception("Neutron: Delete network exception.")
return Response(ex.message, status=500, mimetype='application/json')
net.subnet_name = subnet_dict["subnet"].get('name', str(net.name) + '-sub')
if net.subnet_id is not None:
+ LOG.error("Only one subnet per network is supported: {}".format(net.subnet_id))
return Response('Only one subnet per network is supported\n', status=409, mimetype='application/json')
if "id" in subnet_dict["subnet"]:
for server in self.api.compute.computeUnits.values():
for port_name in server.port_names:
port = self.api.compute.find_port_by_name_or_id(port_name)
+ if port is None:
+ LOG.warning("Port search for {} returned None.".format(port_name))
+ continue
if port.net_name == net.name:
port.ip_address = None
self.api.compute.dc.net.removeLink(
net.delete_subnet()
- return Response('Subnet ' + str(subnet_id) + ' deleted.\n',
- status=204, mimetype='application/json')
+ return Response('', status=204, mimetype='application/json')
return Response('Could not find subnet.', status=404, mimetype='application/json')
except Exception as ex:
# delete the port
self.api.compute.delete_port(port.id)
- return Response('Port ' + port_id + ' deleted.\n', status=204, mimetype='application/json')
+ return Response('', status=204, mimetype='application/json')
except Exception as ex:
LOG.exception("Neutron: Delete port exception.")
projects / osm / vim-emu.git / blobdiff