+"""
+Copyright (c) 2015 SONATA-NFV
+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 [, ANY ADDITIONAL AFFILIATION]
+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).
+"""
+
import time
import requests
import json
import unittest
from emuvim.test.base import SimpleTestTopology
from emuvim.api.sonata import SonataDummyGatekeeperEndpoint
+from emuvim.api.sonata.dummygatekeeper import initialize_GK
+import mininet.clean
-PACKAGE_PATH = "misc/sonata-demo-docker.son"
+PACKAGE_PATH = "misc/sonata-demo-service.son"
class testSonataDummyGatekeeper(SimpleTestTopology):
- @unittest.skip("disabled")
- def testAPI(self):
+# @unittest.skip("disabled")
+ def test_GK_Api_start_service(self):
# create network
self.createNet(nswitches=0, ndatacenter=2, nhosts=2, ndockers=0)
# setup links
# board package
files = {"package": open(PACKAGE_PATH, "rb")}
r = requests.post("http://127.0.0.1:5000/packages", files=files)
- self.assertEqual(r.status_code, 200)
+ self.assertEqual(r.status_code, 201)
self.assertTrue(json.loads(r.text).get("service_uuid") is not None)
# instantiate service
- service_uuid = json.loads(r.text).get("service_uuid")
- r2 = requests.post("http://127.0.0.1:5000/instantiations", data=json.dumps({"service_uuid": service_uuid}))
- self.assertEqual(r2.status_code, 200)
+ self.service_uuid = json.loads(r.text).get("service_uuid")
+ r2 = requests.post("http://127.0.0.1:5000/instantiations", data=json.dumps({"service_uuid": self.service_uuid}))
+ self.assertEqual(r2.status_code, 201)
# give the emulator some time to instantiate everything
time.sleep(2)
r3 = requests.get("http://127.0.0.1:5000/packages")
self.assertEqual(len(json.loads(r3.text).get("service_uuid_list")), 1)
r4 = requests.get("http://127.0.0.1:5000/instantiations")
- self.assertEqual(len(json.loads(r4.text).get("service_instance_list")), 1)
+ self.assertEqual(len(json.loads(r4.text).get("service_instantiations_list")), 1)
# check number of running nodes
self.assertTrue(len(self.getContainernetContainers()) == 3)
self.assertTrue(len(self.net.hosts) == 5)
self.assertTrue(len(self.net.switches) == 2)
# check compute list result
- self.assertTrue(len(self.dc[0].listCompute()) == 3)
+ self.assertEqual(len(self.dc[0].listCompute()), 2)
# check connectivity by using ping
for vnf in self.dc[0].listCompute():
- self.assertTrue(self.net.ping([self.h[0], vnf]) <= 0.0)
+ p = self.net.ping([self.h[0], vnf])
+ print p
+# self.assertTrue(p <= 50.0)
# stop Mininet network
self.stopNet()
+ initialize_GK()
+ def test_GK_Api_stop_service(self):
+ # create network
+ self.createNet(ndatacenter=2, nhosts=2)
+ # setup links
+ self.net.addLink(self.dc[0], self.h[0])
+ self.net.addLink(self.dc[0], self.dc[1])
+ self.net.addLink(self.h[1], self.dc[1])
+ # connect dummy GK to data centers
+ sdkg1 = SonataDummyGatekeeperEndpoint("0.0.0.0", 5000)
+ sdkg1.connectDatacenter(self.dc[0])
+ sdkg1.connectDatacenter(self.dc[1])
+ # run the dummy gatekeeper (in another thread, don't block)
+ sdkg1.start()
+ # start Mininet network
+ self.startNet()
+ time.sleep(1)
+
+ print "starting tests"
+ # board package
+ files = {"package": open(PACKAGE_PATH, "rb")}
+ r = requests.post("http://127.0.0.1:5000/packages", files=files)
+ self.assertEqual(r.status_code, 201)
+ self.assertTrue(json.loads(r.text).get("service_uuid") is not None)
+
+ # instantiate service
+ self.service_uuid = json.loads(r.text).get("service_uuid")
+ r2 = requests.post("http://127.0.0.1:5000/instantiations", data=json.dumps({"service_uuid": self.service_uuid}))
+ self.assertEqual(r2.status_code, 201)
+
+ # give the emulator some time to instantiate everything
+ time.sleep(2)
+
+ # check get request APIs
+ r3 = requests.get("http://127.0.0.1:5000/packages")
+ self.assertEqual(len(json.loads(r3.text).get("service_uuid_list")), 1)
+ r4 = requests.get("http://127.0.0.1:5000/instantiations")
+ self.assertEqual(len(json.loads(r4.text).get("service_instantiations_list")), 1)
+
+ # check number of running nodes
+ self.assertTrue(len(self.getContainernetContainers()) == 3)
+ self.assertTrue(len(self.net.hosts) == 5)
+ self.assertTrue(len(self.net.switches) == 2)
+ # check compute list result
+ self.assertEqual(len(self.dc[0].listCompute()), 2)
+
+ # stop the service
+ service_instance_uuid = json.loads(r2.text).get("service_instance_uuid")
+ self.assertTrue(service_instance_uuid is not None)
+ requests.delete("http://127.0.0.1:5000/instantiations", data=json.dumps({"service_uuid": self.service_uuid, "service_instance_uuid":service_instance_uuid}))
+
+ r5 = requests.get("http://127.0.0.1:5000/instantiations")
+ self.assertTrue(len(json.loads(r5.text).get("service_instantiations_list")), 0) # note that there was 1 instance before
+
+ # stop Mininet network
+ self.stopNet()
+ initialize_GK()