Allow multiple ports to exist with the same name
[osm/vim-emu.git] / src / emuvim / test / unittests / test_openstack.py
1 # Copyright (c) 2015 SONATA-NFV and Paderborn University
2 # ALL RIGHTS RESERVED.
3 #
4 # Licensed under the Apache License, Version 2.0 (the "License");
5 # you may not use this file except in compliance with the License.
6 # You may obtain a copy of the License at
7 #
8 # http://www.apache.org/licenses/LICENSE-2.0
9 #
10 # Unless required by applicable law or agreed to in writing, software
11 # distributed under the License is distributed on an "AS IS" BASIS,
12 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 # See the License for the specific language governing permissions and
14 # limitations under the License.
15 #
16 # Neither the name of the SONATA-NFV, Paderborn University
17 # nor the names of its contributors may be used to endorse or promote
18 # products derived from this software without specific prior written
19 # permission.
20 #
21 # This work has been performed in the framework of the SONATA project,
22 # funded by the European Commission under Grant number 671517 through
23 # the Horizon 2020 and 5G-PPP programmes. The authors would like to
24 # acknowledge the contributions of their colleagues of the SONATA
25 # partner consortium (www.sonata-nfv.eu).
26 import os
27 import unittest
28 import requests
29 import simplejson as json
30 import yaml
31
32 from emuvim.test.api_base_openstack import ApiBaseOpenStack
33
34
35 class testRestApi(ApiBaseOpenStack):
36 """
37 Tests to check the REST API endpoints of the emulator.
38 """
39
40 def setUp(self):
41 # create network
42 self.createNet(nswitches=3, ndatacenter=2, nhosts=2,
43 ndockers=0, autolinkswitches=True)
44
45 # setup links
46 self.net.addLink(self.dc[0], self.h[0])
47 self.net.addLink(self.h[1], self.dc[1])
48 self.net.addLink(self.dc[0], self.dc[1])
49
50 # start api
51 self.startApi()
52
53 # start Mininet network
54 self.startNet()
55
56 def testNovaDummy(self):
57 print('->>>>>>> test Nova Dummy Class->>>>>>>>>>>>>>>')
58 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
59 print(" ")
60
61 headers = {'Content-type': 'application/json'}
62 test_heatapi_template_create_stack = open(os.path.join(os.path.dirname(
63 __file__), "templates/test_heatapi_template_create_stack.yml")).read()
64 url = "http://0.0.0.0:18004/v1/tenantabc123/stacks"
65 requests.post(url, data=json.dumps(yaml.load(test_heatapi_template_create_stack)),
66 headers=headers)
67
68 print('->>>>>>> test Nova List Versions ->>>>>>>>>>>>>>>')
69 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
70 url = "http://0.0.0.0:18774/"
71 listapiversionnovaresponse = requests.get(url, headers=headers)
72 self.assertEqual(listapiversionnovaresponse.status_code, 200)
73 self.assertEqual(json.loads(listapiversionnovaresponse.content)[
74 "versions"][0]["id"], "v2.1")
75 self.assertEqual(json.loads(listapiversionnovaresponse.content)[
76 "versions"][0]["status"], "CURRENT")
77 self.assertEqual(json.loads(listapiversionnovaresponse.content)[
78 "versions"][0]["version"], "2.38")
79 self.assertEqual(json.loads(listapiversionnovaresponse.content)[
80 "versions"][0]["min_version"], "2.1")
81 self.assertEqual(json.loads(listapiversionnovaresponse.content)[
82 "versions"][0]["updated"], "2013-07-23T11:33:21Z")
83 print(" ")
84
85 print('->>>>>>> test Nova Version Show ->>>>>>>>>>>>>>>')
86 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
87 url = "http://0.0.0.0:18774/v2.1/id_bla"
88 listapiversion21novaresponse = requests.get(url, headers=headers)
89 self.assertEqual(listapiversion21novaresponse.status_code, 200)
90 self.assertEqual(json.loads(listapiversion21novaresponse.content)[
91 "version"]["id"], "v2.1")
92 self.assertEqual(json.loads(listapiversion21novaresponse.content)[
93 "version"]["status"], "CURRENT")
94 self.assertEqual(json.loads(listapiversion21novaresponse.content)[
95 "version"]["version"], "2.38")
96 self.assertEqual(json.loads(listapiversion21novaresponse.content)[
97 "version"]["min_version"], "2.1")
98 self.assertEqual(json.loads(listapiversion21novaresponse.content)[
99 "version"]["updated"], "2013-07-23T11:33:21Z")
100 print(" ")
101
102 print('->>>>>>> test Nova Version List Server APIs ->>>>>>>>>>>>>>>')
103 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
104 url = "http://0.0.0.0:18774/v2.1/id_bla/servers"
105 listserverapisnovaresponse = requests.get(url, headers=headers)
106 self.assertEqual(listserverapisnovaresponse.status_code, 200)
107 self.assertNotEqual(json.loads(listserverapisnovaresponse.content)[
108 "servers"][0]["name"], "")
109 print(" ")
110
111 print('->>>>>>> test Nova Delete Server APIs ->>>>>>>>>>>>>>>')
112 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
113 url = "http://0.0.0.0:18774/v2.1/id_bla/servers/%s" % (
114 json.loads(listserverapisnovaresponse.content)["servers"][0]["id"])
115 deleteserverapisnovaresponse = requests.delete(url, headers=headers)
116 self.assertEqual(deleteserverapisnovaresponse.status_code, 204)
117 print(" ")
118
119 print('->>>>>>> test Nova Delete Non-Existing Server APIs ->>>>>>>>>>>>>>>')
120 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
121 url = "http://0.0.0.0:18774/v2.1/id_bla/servers/non-existing-ix"
122 deleteserverapisnovaresponse = requests.delete(url, headers=headers)
123 self.assertEqual(deleteserverapisnovaresponse.status_code, 404)
124 print(" ")
125
126 print('->>>>>>> testNovaVersionListServerAPIs_withPortInformation ->>>>>>>>>>>>>>>')
127 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
128 url = "http://0.0.0.0:18774/v2.1/id_bla/servers/andPorts"
129 listserverapisnovaresponse = requests.get(url, headers=headers)
130 self.assertEqual(listserverapisnovaresponse.status_code, 200)
131 self.assertNotEqual(json.loads(listserverapisnovaresponse.content)[
132 "servers"][0]["name"], "")
133 print(" ")
134
135 print('->>>>>>> test Nova List Flavors ->>>>>>>>>>>>>>>')
136 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
137 url = "http://0.0.0.0:18774/v2.1/id_bla/flavors"
138 listflavorsresponse = requests.get(url, headers=headers)
139 self.assertEqual(listflavorsresponse.status_code, 200)
140 self.assertIn(json.loads(listflavorsresponse.content)["flavors"][0]["name"], [
141 "m1.nano", "m1.tiny", "m1.micro", "m1.small"])
142 self.assertIn(json.loads(listflavorsresponse.content)["flavors"][1]["name"], [
143 "m1.nano", "m1.tiny", "m1.micro", "m1.small"])
144 self.assertIn(json.loads(listflavorsresponse.content)["flavors"][2]["name"], [
145 "m1.nano", "m1.tiny", "m1.micro", "m1.small"])
146 print(" ")
147
148 print('->>>>>>> testNovaAddFlavors ->>>>>>>>>>>>>>>')
149 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
150 url = "http://0.0.0.0:18774/v2.1/id_bla/flavors"
151 addflavorsresponse = requests.post(url,
152 data='{"flavor":{"name": "testFlavor", "vcpus": "test_vcpus", "ram": 1024, "disk": 10}}',
153 headers=headers)
154 self.assertEqual(addflavorsresponse.status_code, 200)
155 self.assertIsNotNone(json.loads(
156 addflavorsresponse.content)["flavor"]["id"])
157 self.assertIsNotNone(json.loads(addflavorsresponse.content)[
158 "flavor"]["links"][0]['href'])
159 print(" ")
160
161 print('->>>>>>> test Nova List Flavors Detail ->>>>>>>>>>>>>>>')
162 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
163 url = "http://0.0.0.0:18774/v2.1/id_bla/flavors/detail"
164 listflavorsdetailresponse = requests.get(url, headers=headers)
165 self.assertEqual(listflavorsdetailresponse.status_code, 200)
166 self.assertIn(json.loads(listflavorsdetailresponse.content)[
167 "flavors"][0]["name"], ["m1.nano", "m1.tiny", "m1.micro", "m1.small"])
168 self.assertIn(json.loads(listflavorsdetailresponse.content)[
169 "flavors"][1]["name"], ["m1.nano", "m1.tiny", "m1.micro", "m1.small"])
170 self.assertIn(json.loads(listflavorsdetailresponse.content)[
171 "flavors"][2]["name"], ["m1.nano", "m1.tiny", "m1.micro", "m1.small"])
172 print(" ")
173
174 print('->>>>>>> testNovaAddFlavors ->>>>>>>>>>>>>>>')
175 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
176 url = "http://0.0.0.0:18774/v2.1/id_bla/flavors/detail"
177 addflavorsresponse = requests.post(url,
178 data='{"flavor":{"name": "testFlavor", "vcpus": "test_vcpus", "ram": 1024, "disk": 10}}',
179 headers=headers)
180 self.assertEqual(addflavorsresponse.status_code, 200)
181 self.assertIsNotNone(json.loads(
182 addflavorsresponse.content)["flavor"]["id"])
183 self.assertIsNotNone(json.loads(addflavorsresponse.content)[
184 "flavor"]["links"][0]['href'])
185 print(" ")
186
187 print('->>>>>>> test Nova List Flavor By Id ->>>>>>>>>>>>>>>')
188
189 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
190 url = "http://0.0.0.0:18774/v2.1/id_bla/flavors/%s" % (
191 json.loads(listflavorsdetailresponse.content)["flavors"][0]["name"])
192 listflavorsbyidresponse = requests.get(url, headers=headers)
193 self.assertEqual(listflavorsbyidresponse.status_code, 200)
194 self.assertEqual(json.loads(listflavorsbyidresponse.content)[
195 "flavor"]["id"], json.loads(listflavorsdetailresponse.content)["flavors"][0]["id"])
196 print(" ")
197
198 print('->>>>>>> test Nova List Images ->>>>>>>>>>>>>>>')
199 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
200 url = "http://0.0.0.0:18774/v2.1/id_bla/images"
201 listimagesresponse = requests.get(url, headers=headers)
202 self.assertEqual(listimagesresponse.status_code, 200)
203 print(listimagesresponse.content)
204 print(" ")
205
206 print('->>>>>>> test Nova List Images Details ->>>>>>>>>>>>>>>')
207 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
208 url = "http://0.0.0.0:18774/v2.1/id_bla/images/detail"
209 listimagesdetailsresponse = requests.get(url, headers=headers)
210 self.assertEqual(listimagesdetailsresponse.status_code, 200)
211 self.assertEqual(json.loads(listimagesdetailsresponse.content)[
212 "images"][0]["metadata"]["architecture"], "x86_64")
213 print(" ")
214
215 print('->>>>>>> test Nova List Image By Id ->>>>>>>>>>>>>>>')
216 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
217 url = "http://0.0.0.0:18774/v2.1/id_bla/images/%s" % (
218 json.loads(listimagesdetailsresponse.content)["images"][0]["id"])
219 listimagebyidresponse = requests.get(url, headers=headers)
220 self.assertEqual(listimagebyidresponse.status_code, 200)
221 self.assertEqual(json.loads(listimagebyidresponse.content)[
222 "image"]["id"], json.loads(listimagesdetailsresponse.content)["images"][0]["id"])
223 print(" ")
224
225 print('->>>>>>> test Nova List Image By Non-Existend Id ->>>>>>>>>>>>>>>')
226 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
227 url = "http://0.0.0.0:18774/v2.1/id_bla/images/non_existing_id"
228 listimagebynonexistingidresponse = requests.get(url, headers=headers)
229 self.assertEqual(listimagebynonexistingidresponse.status_code, 404)
230 print(" ")
231
232 # find ubuntu id
233 for image in json.loads(listimagesresponse.content)["images"]:
234 if image["name"] == "ubuntu:trusty":
235 ubuntu_image_id = image["id"]
236
237 print('->>>>>>> test Nova Create Server Instance ->>>>>>>>>>>>>>>')
238 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
239 url = "http://0.0.0.0:18774/v2.1/id_bla/servers"
240 data = '{"server": {"name": "X", "flavorRef": "%s", "imageRef":"%s"}}' % (
241 json.loads(listflavorsresponse.content)["flavors"][0]["id"], ubuntu_image_id)
242 createserverinstance = requests.post(url, data=data, headers=headers)
243 self.assertEqual(createserverinstance.status_code, 200)
244 self.assertEqual(json.loads(createserverinstance.content)[
245 "server"]["image"]["id"], ubuntu_image_id)
246 print(" ")
247
248 print('->>>>>>> test Nova Create Server Instance With Already Existing Name ->>>>>>>>>>>>>>>')
249 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
250 url = "http://0.0.0.0:18774/v2.1/id_bla/servers"
251 data = '{"server": {"name": "X", "flavorRef": "%s", "imageRef":"%s"}}' % (
252 json.loads(listflavorsresponse.content)["flavors"][0]["id"], ubuntu_image_id)
253 createserverinstance = requests.post(url, data=data, headers=headers)
254 self.assertEqual(createserverinstance.status_code, 409)
255 print(" ")
256
257 print('->>>>>>> test Nova Version List Server APIs Detailed ->>>>>>>>>>>>>>>')
258 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
259 url = "http://0.0.0.0:18774/v2.1/id_bla/servers/detail"
260 listserverapisdetailedresponse = requests.get(url, headers=headers)
261 self.assertEqual(listserverapisdetailedresponse.status_code, 200)
262 self.assertEqual(json.loads(listserverapisdetailedresponse.content)[
263 "servers"][0]["status"], "ACTIVE")
264 print(" ")
265
266 print('->>>>>>> test Nova Show Server Details ->>>>>>>>>>>>>>>')
267 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
268 url = "http://0.0.0.0:18774/v2.1/id_bla/servers/%s" % (
269 json.loads(listserverapisdetailedresponse.content)["servers"][0]["id"])
270 listserverdetailsresponse = requests.get(url, headers=headers)
271 self.assertEqual(listserverdetailsresponse.status_code, 200)
272 self.assertEqual(json.loads(listserverdetailsresponse.content)[
273 "server"]["flavor"]["links"][0]["rel"], "bookmark")
274 print(" ")
275
276 print('->>>>>>> test Nova Show Non-Existing Server Details ->>>>>>>>>>>>>>>')
277 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
278 url = "http://0.0.0.0:18774/v2.1/id_bla/servers/non_existing_server_id"
279 listnonexistingserverdetailsresponse = requests.get(
280 url, headers=headers)
281 self.assertEqual(listnonexistingserverdetailsresponse.status_code, 404)
282 print(" ")
283
284 def testNeutronDummy(self):
285 print('->>>>>>> test Neutron Dummy Class->>>>>>>>>>>>>>>')
286 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
287 print(" ")
288
289 headers = {'Content-type': 'application/json'}
290 test_heatapi_template_create_stack = open(os.path.join(os.path.dirname(
291 __file__), "templates/test_heatapi_template_create_stack.yml")).read()
292 url = "http://0.0.0.0:18004/v1/tenantabc123/stacks"
293 requests.post(url, data=json.dumps(
294 yaml.load(test_heatapi_template_create_stack)), headers=headers)
295 # test_heatapi_keystone_get_token = open("test_heatapi_keystone_get_token.json").read()
296
297 print('->>>>>>> test Neutron List Versions ->>>>>>>>>>>>>>>')
298 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
299 url = "http://0.0.0.0:19696/"
300 listapiversionstackresponse = requests.get(url, headers=headers)
301 self.assertEqual(listapiversionstackresponse.status_code, 200)
302 self.assertEqual(json.loads(listapiversionstackresponse.content)[
303 "versions"][0]["id"], "v2.0")
304 print(" ")
305
306 print('->>>>>>> test Neutron Show API v2.0 ->>>>>>>>>>>>>>>')
307 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
308 url = "http://0.0.0.0:19696/v2.0"
309 listapiversionv20response = requests.get(url, headers=headers)
310 self.assertEqual(listapiversionv20response.status_code, 200)
311 self.assertEqual(json.loads(listapiversionv20response.content)[
312 "resources"][0]["name"], "subnet")
313 self.assertEqual(json.loads(listapiversionv20response.content)[
314 "resources"][1]["name"], "network")
315 self.assertEqual(json.loads(listapiversionv20response.content)[
316 "resources"][2]["name"], "ports")
317 print(" ")
318
319 print('->>>>>>> test Neutron List Networks ->>>>>>>>>>>>>>>')
320 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
321 url = "http://0.0.0.0:19696/v2.0/networks"
322 listnetworksesponse1 = requests.get(url, headers=headers)
323 self.assertEqual(listnetworksesponse1.status_code, 200)
324 self.assertEqual(json.loads(listnetworksesponse1.content)[
325 "networks"][0]["status"], "ACTIVE")
326 listNetworksId = json.loads(listnetworksesponse1.content)[
327 "networks"][0]["id"]
328 listNetworksName = json.loads(listnetworksesponse1.content)[
329 "networks"][0]["name"]
330 listNetworksId2 = json.loads(listnetworksesponse1.content)[
331 "networks"][1]["id"]
332 print(" ")
333
334 print('->>>>>>> test Neutron List Non-Existing Networks ->>>>>>>>>>>>>>>')
335 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
336 url = "http://0.0.0.0:19696/v2.0/networks?name=non_existent_network_name"
337 listnetworksesponse2 = requests.get(url, headers=headers)
338 self.assertEqual(listnetworksesponse2.status_code, 404)
339 print(" ")
340
341 print('->>>>>>> test Neutron List Networks By Name ->>>>>>>>>>>>>>>')
342 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
343 # tcpdump-vnf:input:net:9df6a98f-9e11-4cb7-b3c0-InAdUnitTest
344 url = "http://0.0.0.0:19696/v2.0/networks?name=" + listNetworksName
345 listnetworksesponse3 = requests.get(url, headers=headers)
346 self.assertEqual(listnetworksesponse3.status_code, 200)
347 self.assertEqual(json.loads(listnetworksesponse3.content)[
348 "networks"][0]["name"], listNetworksName)
349 print(" ")
350
351 print('->>>>>>> test Neutron List Networks By Id ->>>>>>>>>>>>>>>')
352 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
353 # tcpdump-vnf:input:net:9df6a98f-9e11-4cb7-b3c0-InAdUnitTest
354 url = "http://0.0.0.0:19696/v2.0/networks?id=" + listNetworksId
355 listnetworksesponse4 = requests.get(url, headers=headers)
356 self.assertEqual(listnetworksesponse4.status_code, 200)
357 self.assertEqual(json.loads(listnetworksesponse4.content)[
358 "networks"][0]["id"], listNetworksId)
359 print(" ")
360
361 print('->>>>>>> test Neutron List Networks By Multiple Ids ->>>>>>>>>>>>>>>')
362 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
363 url = "http://0.0.0.0:19696/v2.0/networks?id=" + listNetworksId + "&id=" + \
364 listNetworksId2 # tcpdump-vnf:input:net:9df6a98f-9e11-4cb7-b3c0-InAdUnitTest
365 listnetworksesponse5 = requests.get(url, headers=headers)
366 self.assertEqual(listnetworksesponse5.status_code, 200)
367 self.assertEqual(json.loads(listnetworksesponse5.content)[
368 "networks"][0]["id"], listNetworksId)
369 self.assertEqual(json.loads(listnetworksesponse5.content)[
370 "networks"][1]["id"], listNetworksId2)
371 print(" ")
372
373 print('->>>>>>> test Neutron Show Network ->>>>>>>>>>>>>>>')
374 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
375 url = "http://0.0.0.0:19696/v2.0/networks/" + listNetworksId
376 shownetworksesponse = requests.get(url, headers=headers)
377 self.assertEqual(shownetworksesponse.status_code, 200)
378 self.assertEqual(json.loads(shownetworksesponse.content)[
379 "network"]["status"], "ACTIVE")
380 print(" ")
381
382 print('->>>>>>> test Neutron Show Network Non-ExistendNetwork ->>>>>>>>>>>>>>>')
383 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
384 url = "http://0.0.0.0:19696/v2.0/networks/non_existent_network_id"
385 shownetworksesponse2 = requests.get(url, headers=headers)
386 self.assertEqual(shownetworksesponse2.status_code, 404)
387 print(" ")
388
389 print('->>>>>>> test Neutron Create Network ->>>>>>>>>>>>>>>')
390 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
391 url = "http://0.0.0.0:19696/v2.0/networks"
392 createnetworkresponse = requests.post(
393 url, data='{"network": {"name": "sample_network","admin_state_up": true}}', headers=headers)
394 self.assertEqual(createnetworkresponse.status_code, 201)
395 self.assertEqual(json.loads(createnetworkresponse.content)[
396 "network"]["status"], "ACTIVE")
397 print(" ")
398
399 print('->>>>>>> test Neutron Create Network With Existing Name ->>>>>>>>>>>>>>>')
400 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
401 url = "http://0.0.0.0:19696/v2.0/networks"
402 createnetworkresponsefailure = requests.post(
403 url, data='{"network": {"name": "sample_network","admin_state_up": true}}', headers=headers)
404 self.assertEqual(createnetworkresponsefailure.status_code, 400)
405 print(" ")
406
407 print('->>>>>>> test Neutron Update Network ->>>>>>>>>>>>>>>')
408 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
409 url = "http://0.0.0.0:19696/v2.0/networks/%s" % (
410 json.loads(createnetworkresponse.content)["network"]["id"])
411 updatenetworkresponse = requests.put(
412 url, data='{"network": {"status": "ACTIVE", "admin_state_up":true, "tenant_id":"abcd123", "name": "sample_network_new_name", "shared":false}}', headers=headers)
413 self.assertEqual(updatenetworkresponse.status_code, 200)
414 self.assertEqual(json.loads(updatenetworkresponse.content)[
415 "network"]["name"], "sample_network_new_name")
416 self.assertEqual(json.loads(updatenetworkresponse.content)[
417 "network"]["tenant_id"], "abcd123")
418 print(" ")
419
420 print('->>>>>>> test Neutron Update Non-Existing Network ->>>>>>>>>>>>>>>')
421 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
422 url = "http://0.0.0.0:19696/v2.0/networks/non-existing-name123"
423 updatenetworkresponse = requests.put(
424 url, data='{"network": {"name": "sample_network_new_name"}}', headers=headers)
425 self.assertEqual(updatenetworkresponse.status_code, 404)
426 print(" ")
427
428 print('->>>>>>> test Neutron List Subnets ->>>>>>>>>>>>>>>')
429 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
430 url = "http://0.0.0.0:19696/v2.0/subnets"
431 listsubnetsresponse = requests.get(url, headers=headers)
432 listSubnetName = json.loads(listsubnetsresponse.content)[
433 "subnets"][0]["name"]
434 listSubnetId = json.loads(listsubnetsresponse.content)[
435 "subnets"][0]["id"]
436 listSubnetId2 = json.loads(listsubnetsresponse.content)[
437 "subnets"][1]["id"]
438 self.assertEqual(listsubnetsresponse.status_code, 200)
439 self.assertNotIn('None', listSubnetName)
440 print(" ")
441
442 print('->>>>>>> test Neutron List Subnets By Name ->>>>>>>>>>>>>>>')
443 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
444 url = "http://0.0.0.0:19696/v2.0/subnets?name=" + listSubnetName
445 listsubnetByNameresponse = requests.get(url, headers=headers)
446 self.assertEqual(listsubnetByNameresponse.status_code, 200)
447 self.assertNotIn('None', json.loads(
448 listsubnetByNameresponse.content)["subnets"][0]["name"])
449 print(" ")
450
451 print('->>>>>>> test Neutron List Subnets By Id ->>>>>>>>>>>>>>>')
452 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
453 url = "http://0.0.0.0:19696/v2.0/subnets?id=" + listSubnetId
454 listsubnetsbyidresponse = requests.get(url, headers=headers)
455 self.assertEqual(listsubnetsbyidresponse.status_code, 200)
456 self.assertNotIn("None", json.loads(
457 listsubnetsbyidresponse.content)["subnets"][0]["name"])
458 print(" ")
459
460 print('->>>>>>> test Neutron List Subnets By Multiple Id ->>>>>>>>>>>>>>>')
461 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
462 url = "http://0.0.0.0:19696/v2.0/subnets?id=" + \
463 listSubnetId + "&id=" + listSubnetId2
464 listsubnetsbymultipleidsresponse = requests.get(url, headers=headers)
465 self.assertEqual(listsubnetsbymultipleidsresponse.status_code, 200)
466 self.assertNotIn("None", json.loads(
467 listsubnetsbymultipleidsresponse.content)["subnets"][0]["name"])
468 print(" ")
469
470 print('->>>>>>> test Neutron Show Subnet->>>>>>>>>>>>>>>')
471 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
472 url = "http://0.0.0.0:19696/v2.0/subnets/%s" % (
473 json.loads(listsubnetsresponse.content)["subnets"][0]["id"])
474 showsubnetsresponse = requests.get(url, headers=headers)
475 self.assertEqual(showsubnetsresponse.status_code, 200)
476 self.assertNotIn("None", json.loads(
477 showsubnetsresponse.content)["subnet"]["name"])
478 print(" ")
479
480 print('->>>>>>> test Neutron Show Non-Existing Subnet->>>>>>>>>>>>>>>')
481 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
482 url = "http://0.0.0.0:19696/v2.0/subnets/non-existing-id123"
483 showsubnetsresponse = requests.get(url, headers=headers)
484 self.assertEqual(showsubnetsresponse.status_code, 404)
485 print(" ")
486
487 print('->>>>>>> test Neutron Create Subnet ->>>>>>>>>>>>>>>')
488 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
489 url = "http://0.0.0.0:19696/v2.0/subnets"
490 createsubnetdata = '{"subnet": {"name": "new_subnet", "network_id": "%s","ip_version": 4,"cidr": "10.0.0.1/24"} }' % (
491 json.loads(createnetworkresponse.content)["network"]["id"])
492 createsubnetresponse = requests.post(
493 url, data=createsubnetdata, headers=headers)
494 self.assertEqual(createsubnetresponse.status_code, 201)
495 self.assertEqual(json.loads(createsubnetresponse.content)[
496 "subnet"]["name"], "new_subnet")
497 print(" ")
498
499 print('->>>>>>> test Neutron Create Second Subnet ->>>>>>>>>>>>>>>')
500 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
501 url = "http://0.0.0.0:19696/v2.0/subnets"
502 createsubnetdata = '{"subnet": {"name": "new_subnet", "network_id": "%s","ip_version": 4,"cidr": "10.0.0.1/24"} }' % (
503 json.loads(createnetworkresponse.content)["network"]["id"])
504 createsubnetfailureresponse = requests.post(
505 url, data=createsubnetdata, headers=headers)
506 self.assertEqual(createsubnetfailureresponse.status_code, 409)
507 print(" ")
508
509 print('->>>>>>> test Neutron Update Subnet ->>>>>>>>>>>>>>>')
510 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
511 url = "http://0.0.0.0:19696/v2.0/subnets/%s" % (
512 json.loads(createsubnetresponse.content)["subnet"]["id"])
513 updatesubnetdata = '{"subnet": {"name": "new_subnet_new_name", "network_id":"some_id", "tenant_id":"new_tenant_id", "allocation_pools":"change_me", "gateway_ip":"192.168.1.120", "ip_version":4, "cidr":"10.0.0.1/24", "id":"some_new_id", "enable_dhcp":true} }'
514 updatesubnetresponse = requests.put(
515 url, data=updatesubnetdata, headers=headers)
516 self.assertEqual(updatesubnetresponse.status_code, 200)
517 self.assertEqual(json.loads(updatesubnetresponse.content)[
518 "subnet"]["name"], "new_subnet_new_name")
519 print(" ")
520
521 print('->>>>>>> test Neutron Update Non-Existing Subnet ->>>>>>>>>>>>>>>')
522 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
523 url = "http://0.0.0.0:19696/v2.0/subnets/non-existing-subnet-12345"
524 updatenonexistingsubnetdata = '{"subnet": {"name": "new_subnet_new_name"} }'
525 updatenonexistingsubnetresponse = requests.put(
526 url, data=updatenonexistingsubnetdata, headers=headers)
527 self.assertEqual(updatenonexistingsubnetresponse.status_code, 404)
528 print(" ")
529
530 print('->>>>>>> test Neutron List Ports ->>>>>>>>>>>>>>>')
531 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
532 url = "http://0.0.0.0:19696/v2.0/ports"
533 listportsesponse = requests.get(url, headers=headers)
534 self.assertEqual(listportsesponse.status_code, 200)
535 self.assertEqual(json.loads(listportsesponse.content)
536 ["ports"][0]["status"], "ACTIVE")
537 listPortsName = json.loads(listportsesponse.content)[
538 "ports"][0]["name"]
539 listPortsId1 = json.loads(listportsesponse.content)["ports"][0]["id"]
540 listPortsId2 = json.loads(listportsesponse.content)["ports"][1]["id"]
541 print(" ")
542
543 print('->>>>>>> test Neutron List Ports By Name ->>>>>>>>>>>>>>>')
544 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
545 url = "http://0.0.0.0:19696/v2.0/ports?name=" + listPortsName
546 listportsbynameesponse = requests.get(url, headers=headers)
547 self.assertEqual(listportsbynameesponse.status_code, 200)
548 self.assertEqual(json.loads(listportsbynameesponse.content)[
549 "ports"][0]["name"], listPortsName)
550 print(" ")
551
552 print('->>>>>>> test Neutron List Ports By Id ->>>>>>>>>>>>>>>')
553 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
554 url = "http://0.0.0.0:19696/v2.0/ports?id=" + listPortsId1
555 listportsbyidesponse = requests.get(url, headers=headers)
556 self.assertEqual(listportsbyidesponse.status_code, 200)
557 self.assertEqual(json.loads(listportsbyidesponse.content)[
558 "ports"][0]["id"], listPortsId1)
559 print(" ")
560
561 print('->>>>>>> test Neutron List Ports By Multiple Ids ->>>>>>>>>>>>>>>')
562 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
563 url = "http://0.0.0.0:19696/v2.0/ports?id=" + \
564 listPortsId1 + "&id=" + listPortsId2
565 listportsbymultipleidsesponse = requests.get(url, headers=headers)
566 self.assertEqual(listportsbymultipleidsesponse.status_code, 200)
567 self.assertEqual(json.loads(listportsbymultipleidsesponse.content)[
568 "ports"][0]["id"], listPortsId1)
569 print(" ")
570
571 print('->>>>>>> test Neutron List Non-Existing Ports ->>>>>>>>>>>>>>>')
572 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
573 url = "http://0.0.0.0:19696/v2.0/ports?id=non-existing-port-id"
574 listportsbynonexistingidsesponse = requests.get(url, headers=headers)
575 self.assertEqual(listportsbynonexistingidsesponse.status_code, 404)
576 print(" ")
577
578 print('->>>>>>> test Neutron Show Port ->>>>>>>>>>>>>>>')
579 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
580 url = "http://0.0.0.0:19696/v2.0/ports/%s" % (
581 json.loads(listportsesponse.content)["ports"][0]["id"])
582 showportresponse = requests.get(url, headers=headers)
583 self.assertEqual(showportresponse.status_code, 200)
584 self.assertEqual(json.loads(showportresponse.content)
585 ["port"]["status"], "ACTIVE")
586 print(" ")
587
588 print('->>>>>>> test Neutron Show Non-Existing Port ->>>>>>>>>>>>>>>')
589 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
590 url = "http://0.0.0.0:19696/v2.0/ports/non-existing-portid123"
591 shownonexistingportresponse = requests.get(url, headers=headers)
592 self.assertEqual(shownonexistingportresponse.status_code, 404)
593 print(" ")
594
595 print('->>>>>>> test Neutron Create Port In Non-Existing Network ->>>>>>>>>>>>>>>')
596 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
597 url = "http://0.0.0.0:19696/v2.0/ports"
598 createnonexistingportdata = '{"port": {"name": "new_port", "network_id": "non-existing-id"} }'
599 createnonexistingnetworkportresponse = requests.post(
600 url, data=createnonexistingportdata, headers=headers)
601 self.assertEqual(createnonexistingnetworkportresponse.status_code, 404)
602 print(" ")
603
604 print('->>>>>>> test Neutron Create Port ->>>>>>>>>>>>>>>')
605 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
606 url = "http://0.0.0.0:19696/v2.0/ports"
607 createportdata = '{"port": {"name": "new_port", "network_id": "%s", "admin_state_up":true, "device_id":"device_id123", "device_owner":"device_owner123", "fixed_ips":"change_me","id":"new_id1234", "mac_address":"12:34:56:78:90", "status":"change_me", "tenant_id":"tenant_id123"} }' % (json.loads(createnetworkresponse.content)[
608 "network"]["id"])
609 createportresponse = requests.post(
610 url, data=createportdata, headers=headers)
611 self.assertEqual(createportresponse.status_code, 201)
612 print(createportresponse.content)
613 createport = json.loads(createportresponse.content)["port"]
614 self.assertEqual(createport["name"], "new_port")
615 print(" ")
616
617 print('->>>>>>> test Neutron Create Port With Existing Name ->>>>>>>>>>>>>>>')
618 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
619 url = "http://0.0.0.0:19696/v2.0/ports"
620 network_id = json.loads(createnetworkresponse.content)["network"]["id"]
621 createportwithexistingnamedata = '{"port": {"name": "duplicate_port_name", "network_id": "%s"} }' % network_id
622 createportwithexistingnameresponse1 = requests.post(
623 url, data=createportwithexistingnamedata, headers=headers)
624 createportwithexistingnameresponse2 = requests.post(
625 url, data=createportwithexistingnamedata, headers=headers)
626 createportwithexistingname1 = json.loads(createportwithexistingnameresponse1.content)["port"]
627 createportwithexistingname2 = json.loads(createportwithexistingnameresponse2.content)["port"]
628 self.assertEqual(createportwithexistingnameresponse1.status_code, 201)
629 self.assertEqual(createportwithexistingnameresponse2.status_code, 201)
630 self.assertEqual(createportwithexistingname1["name"], "duplicate_port_name")
631 self.assertEqual(createportwithexistingname2["name"], "duplicate_port_name")
632 self.assertNotEqual(createportwithexistingname1["id"], createportwithexistingname2["id"], "Duplicate port should have different id")
633 print(" ")
634
635 print('->>>>>>> test Neutron Create Port Without Name ->>>>>>>>>>>>>>>')
636 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
637 url = "http://0.0.0.0:19696/v2.0/ports"
638 createportdatawithoutname = '{"port": {"network_id": "%s"} }' % (
639 json.loads(createnetworkresponse.content)["network"]["id"])
640 createportwithoutnameresponse = requests.post(
641 url, data=createportdatawithoutname, headers=headers)
642 self.assertEqual(createportwithoutnameresponse.status_code, 201)
643 self.assertIn("port:cp", json.loads(
644 createportwithoutnameresponse.content)["port"]["name"])
645 print(" ")
646
647 print('->>>>>>> test Neutron Update Port ->>>>>>>>>>>>>>>')
648 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
649 print(json.loads(createportresponse.content)["port"]["name"])
650 url = "http://0.0.0.0:19696/v2.0/ports/%s" % (
651 json.loads(createportresponse.content)["port"]["name"])
652 updateportdata = '{"port": {"name": "new_port_new_name", "admin_state_up":true, "device_id":"device_id123", "device_owner":"device_owner123", "fixed_ips":"change_me","mac_address":"12:34:56:78:90", "status":"change_me", "tenant_id":"tenant_id123", "network_id":"network_id123"} }'
653 updateportresponse = requests.put(
654 url, data=updateportdata, headers=headers)
655 self.assertEqual(updateportresponse.status_code, 200)
656 self.assertEqual(json.loads(updateportresponse.content)[
657 "port"]["name"], "new_port_new_name")
658 print(" ")
659
660 print('->>>>>>> test Neutron Update Non-Existing Port ->>>>>>>>>>>>>>>')
661 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
662 url = "http://0.0.0.0:19696/v2.0/ports/non-existing-port-ip"
663 updatenonexistingportdata = '{"port": {"name": "new_port_new_name"} }'
664 updatenonexistingportresponse = requests.put(
665 url, data=updatenonexistingportdata, headers=headers)
666 self.assertEqual(updatenonexistingportresponse.status_code, 404)
667 print(" ")
668
669 print('->>>>>>> test Neutron Delete Port ->>>>>>>>>>>>>>>')
670 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
671 righturl = "http://0.0.0.0:19696/v2.0/ports/%s" % (
672 json.loads(createportresponse.content)["port"]["id"])
673 deleterightportresponse = requests.delete(righturl, headers=headers)
674 self.assertEqual(deleterightportresponse.status_code, 204)
675 print(" ")
676
677 print('->>>>>>> test Neutron Delete Non-Existing Port ->>>>>>>>>>>>>>>')
678 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
679 wrongurl = "http://0.0.0.0:19696/v2.0/ports/unknownid"
680 deletewrongportresponse = requests.delete(wrongurl, headers=headers)
681 self.assertEqual(deletewrongportresponse.status_code, 404)
682 print(" ")
683
684 print('->>>>>>> test Neutron Delete Subnet ->>>>>>>>>>>>>>>')
685 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
686 wrongurl = "http://0.0.0.0:19696/v2.0/subnets/unknownid"
687 righturl = "http://0.0.0.0:19696/v2.0/subnets/%s" % (
688 json.loads(updatesubnetresponse.content)["subnet"]["id"])
689 deletewrongsubnetresponse = requests.delete(wrongurl, headers=headers)
690 deleterightsubnetresponse = requests.delete(righturl, headers=headers)
691 self.assertEqual(deletewrongsubnetresponse.status_code, 404)
692 self.assertEqual(deleterightsubnetresponse.status_code, 204)
693 print(" ")
694
695 print('->>>>>>> test Neutron Delete Network ->>>>>>>>>>>>>>>')
696 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
697 righturl = "http://0.0.0.0:19696/v2.0/networks/%s" % (
698 json.loads(createnetworkresponse.content)["network"]["id"])
699 deleterightnetworkresponse = requests.delete(righturl, headers=headers)
700 self.assertEqual(deleterightnetworkresponse.status_code, 204)
701 print(" ")
702
703 print('->>>>>>> test Neutron Delete Non-Existing Network ->>>>>>>>>>>>>>>')
704 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
705 wrongurl = "http://0.0.0.0:19696/v2.0/networks/unknownid"
706 deletewrongnetworkresponse = requests.delete(wrongurl, headers=headers)
707 self.assertEqual(deletewrongnetworkresponse.status_code, 404)
708 print(" ")
709
710 def testKeystomeDummy(self):
711 print('->>>>>>> test Keystone Dummy Class->>>>>>>>>>>>>>>')
712 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
713 print(" ")
714
715 headers = {'Content-type': 'application/json'}
716 test_heatapi_keystone_get_token = open(os.path.join(os.path.dirname(
717 __file__), "templates/test_heatapi_keystone_get_token.yml")).read()
718
719 print('->>>>>>> test Keystone List Versions ->>>>>>>>>>>>>>>')
720 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
721 url = "http://0.0.0.0:15000/"
722 listapiversionstackresponse = requests.get(url, headers=headers)
723 self.assertEqual(listapiversionstackresponse.status_code, 200)
724 self.assertEqual(json.loads(listapiversionstackresponse.content)[
725 "versions"]["values"][0]["id"], "v2.0")
726 print(" ")
727
728 print('->>>>>>> test Keystone Show ApiV2 ->>>>>>>>>>>>>>>')
729 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
730 url = "http://0.0.0.0:15000/v2.0"
731 showapiversionstackresponse = requests.get(url, headers=headers)
732 self.assertEqual(showapiversionstackresponse.status_code, 200)
733 self.assertEqual(json.loads(showapiversionstackresponse.content)[
734 "version"]["id"], "v2.0")
735 print(" ")
736
737 print('->>>>>>> test Keystone Get Token ->>>>>>>>>>>>>>>')
738 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
739 url = "http://0.0.0.0:15000/v2.0/tokens"
740 gettokenstackresponse = requests.post(url, data=json.dumps(
741 yaml.load(test_heatapi_keystone_get_token)), headers=headers)
742 self.assertEqual(gettokenstackresponse.status_code, 200)
743 self.assertEqual(json.loads(gettokenstackresponse.content)[
744 "access"]["user"]["name"], "tenantName")
745 print(" ")
746
747 def testHeatDummy(self):
748 print('->>>>>>> test Heat Dummy Class->>>>>>>>>>>>>>>')
749 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
750 print(" ")
751
752 headers = {'Content-type': 'application/json'}
753 test_heatapi_template_create_stack = open(os.path.join(os.path.dirname(
754 __file__), "templates/test_heatapi_template_create_stack.yml")).read()
755 test_heatapi_template_update_stack = open(os.path.join(os.path.dirname(
756 __file__), "templates/test_heatapi_template_update_stack.yml")).read()
757
758 print('->>>>>>> test Heat List API Versions Stack ->>>>>>>>>>>>>>>')
759 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
760 url = "http://0.0.0.0:18004/"
761 listapiversionstackresponse = requests.get(url, headers=headers)
762 self.assertEqual(listapiversionstackresponse.status_code, 200)
763 self.assertEqual(json.loads(listapiversionstackresponse.content)[
764 "versions"][0]["id"], "v1.0")
765 print(" ")
766
767 print('->>>>>>> test Create Stack ->>>>>>>>>>>>>>>')
768 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
769 url = "http://0.0.0.0:18004/v1/tenantabc123/stacks"
770 createstackresponse = requests.post(url, data=json.dumps(
771 yaml.load(test_heatapi_template_create_stack)), headers=headers)
772 self.assertEqual(createstackresponse.status_code, 201)
773 self.assertNotEqual(json.loads(
774 createstackresponse.content)["stack"]["id"], "")
775 print(" ")
776
777 print('->>>>>>> test Create Stack With Existing Name ->>>>>>>>>>>>>>>')
778 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
779 url = "http://0.0.0.0:18004/v1/tenantabc123/stacks"
780 createstackwithexistingnameresponse = requests.post(
781 url, data='{"stack_name" : "s1"}', headers=headers)
782 self.assertEqual(createstackwithexistingnameresponse.status_code, 409)
783 print(" ")
784
785 print('->>>>>>> test Create Stack With Unsupported Version ->>>>>>>>>>>>>>>')
786 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
787 url = "http://0.0.0.0:18004/v1/tenantabc123/stacks"
788 createstackwitheunsupportedversionresponse = requests.post(
789 url, data='{"stack_name" : "stackname123", "template" : {"heat_template_version": "2015-04-29"}}', headers=headers)
790 self.assertEqual(
791 createstackwitheunsupportedversionresponse.status_code, 400)
792 print(" ")
793
794 print('->>>>>>> test List Stack ->>>>>>>>>>>>>>>')
795 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
796 url = "http://0.0.0.0:18004/v1/tenantabc123/stacks"
797 liststackresponse = requests.get(url, headers=headers)
798 self.assertEqual(liststackresponse.status_code, 200)
799 self.assertEqual(json.loads(liststackresponse.content)[
800 "stacks"][0]["stack_status"], "CREATE_COMPLETE")
801 print(" ")
802
803 print('->>>>>>> test Show Stack ->>>>>>>>>>>>>>>')
804 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
805 url = "http://0.0.0.0:18004/v1/tenantabc123showStack/stacks/%s" % json.loads(
806 createstackresponse.content)['stack']['id']
807 liststackdetailsresponse = requests.get(url, headers=headers)
808 self.assertEqual(liststackdetailsresponse.status_code, 200)
809 self.assertEqual(json.loads(liststackdetailsresponse.content)[
810 "stack"]["stack_status"], "CREATE_COMPLETE")
811 print(" ")
812
813 print('->>>>>>> test Show Non-Exisitng Stack ->>>>>>>>>>>>>>>')
814 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
815 url = "http://0.0.0.0:18004/v1/tenantabc123showStack/stacks/non_exisitng_id123"
816 listnonexistingstackdetailsresponse = requests.get(
817 url, headers=headers)
818 self.assertEqual(listnonexistingstackdetailsresponse.status_code, 404)
819 print(" ")
820
821 print('->>>>>>> test Update Stack ->>>>>>>>>>>>>>>')
822 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
823 url = "http://0.0.0.0:18004/v1/tenantabc123updateStack/stacks/%s" % json.loads(
824 createstackresponse.content)['stack']['id']
825 updatestackresponse = requests.put(url, data=json.dumps(yaml.load(test_heatapi_template_update_stack)),
826 headers=headers)
827 self.assertEqual(updatestackresponse.status_code, 202)
828 liststackdetailsresponse = requests.get(url, headers=headers)
829 self.assertEqual(json.loads(liststackdetailsresponse.content)[
830 "stack"]["stack_status"], "UPDATE_COMPLETE")
831 print(" ")
832
833 print('->>>>>>> test Update Non-Existing Stack ->>>>>>>>>>>>>>>')
834 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
835 url = "http://0.0.0.0:18004/v1/tenantabc123updateStack/stacks/non_existing_id_1234"
836 updatenonexistingstackresponse = requests.put(
837 url, data={"non": "sense"}, headers=headers)
838 self.assertEqual(updatenonexistingstackresponse.status_code, 404)
839 print(" ")
840
841 print('->>>>>>> test Delete Stack ->>>>>>>>>>>>>>>')
842 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
843 url = "http://0.0.0.0:18004/v1/tenantabc123showStack/stacks/%s" % \
844 json.loads(createstackresponse.content)['stack']['id']
845 deletestackdetailsresponse = requests.delete(url, headers=headers)
846 self.assertEqual(deletestackdetailsresponse.status_code, 204)
847 print(" ")
848
849 def testNeutronSFC(self):
850 """
851 Tests the Neutron Service Function Chaining implementation. As Some functions build up on others, a
852 complete environment is created here:
853
854 Ports: p1, p2, p3, p4
855 Port Pairs: pp1(p1, p2), pp2(p3, p4)
856 Port Pair Groups: ppg1(pp1, pp2)
857 Flow Classifiers: fc1
858 Port Chain: pc1(ppg1, fc1)
859 """
860
861 headers = {'Content-type': 'application/json'}
862
863 print('->>>>>>> Create ports p1 - p4 ->>>>>>>>>>>>>>>')
864 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
865 # Get network id
866 network_resp = requests.get(
867 "http://0.0.0.0:19696/v2.0/networks?name=default", headers=headers)
868 self.assertEqual(network_resp.status_code, 200)
869 network_id = json.loads(network_resp.content)["networks"][0]["id"]
870
871 url = "http://0.0.0.0:19696/v2.0/ports"
872 port_request = '{"port": {"name": "%s", "network_id": "%s"}}'
873 p1_resp = requests.post(url, data=port_request %
874 ("p1", network_id), headers=headers)
875 self.assertEqual(p1_resp.status_code, 201)
876 p2_resp = requests.post(url, data=port_request %
877 ("p2", network_id), headers=headers)
878 self.assertEqual(p2_resp.status_code, 201)
879 p3_resp = requests.post(url, data=port_request %
880 ("p3", network_id), headers=headers)
881 self.assertEqual(p3_resp.status_code, 201)
882 p4_resp = requests.post(url, data=port_request %
883 ("p4", network_id), headers=headers)
884 self.assertEqual(p4_resp.status_code, 201)
885
886 p1_id = json.loads(p1_resp.content)["port"]["id"]
887 p2_id = json.loads(p2_resp.content)["port"]["id"]
888 p3_id = json.loads(p3_resp.content)["port"]["id"]
889 p4_id = json.loads(p4_resp.content)["port"]["id"]
890
891 print('->>>>>>> test Neutron SFC Port Pair Create ->>>>>>>>>>>>>>>')
892 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
893 url = "http://0.0.0.0:19696/v2.0/sfc/port_pairs"
894 pp1_resp = requests.post(url, data='{"port_pair": {"name": "pp1", "ingress": "%s", "egress": "%s"}}' % (
895 p1_id, p2_id), headers=headers)
896 self.assertEqual(pp1_resp.status_code, 201)
897 pp2_resp = requests.post(url, data='{"port_pair": {"name": "pp2", "ingress": "%s", "egress": "%s"}}' % (
898 p3_id, p4_id), headers=headers)
899 self.assertEqual(pp2_resp.status_code, 201)
900 pp3_resp = requests.post(url, data='{"port_pair": {"name": "pp3", "ingress": "%s", "egress": "%s"}}' % (
901 p3_id, p4_id), headers=headers)
902 self.assertEqual(pp3_resp.status_code, 201)
903
904 pp1_id = json.loads(pp1_resp.content)["port_pair"]["id"]
905 pp2_id = json.loads(pp2_resp.content)["port_pair"]["id"]
906 pp3_id = json.loads(pp3_resp.content)["port_pair"]["id"]
907
908 print('->>>>>>> test Neutron SFC Port Pair Update ->>>>>>>>>>>>>>>')
909 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
910 url = "http://0.0.0.0:19696/v2.0/sfc/port_pairs/%s" % pp3_id
911 pp3_update_resp = requests.put(
912 url, data='{"port_pair": {"description": "port_pair_update"}}', headers=headers)
913 self.assertEqual(pp3_update_resp.status_code, 200)
914 self.assertEqual(json.loads(pp3_update_resp.content)[
915 "port_pair"]["description"], "port_pair_update")
916
917 print('->>>>>>> test Neutron SFC Port Pair Delete ->>>>>>>>>>>>>>>')
918 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
919 url = "http://0.0.0.0:19696/v2.0/sfc/port_pairs/%s" % pp3_id
920 pp3_delete_resp = requests.delete(url, headers=headers)
921 self.assertEqual(pp3_delete_resp.status_code, 204)
922
923 print('->>>>>>> test Neutron SFC Port Pair List ->>>>>>>>>>>>>>>')
924 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
925 url = "http://0.0.0.0:19696/v2.0/sfc/port_pairs"
926 pp_list_resp = requests.get(url, headers=headers)
927 self.assertEqual(pp_list_resp.status_code, 200)
928 pp_list = json.loads(pp_list_resp.content)["port_pairs"]
929 # only pp1 and pp2 should be left
930 self.assertEqual(len(pp_list), 2)
931
932 print('->>>>>>> test Neutron SFC Port Pair List filtered by id ->>>>>>>>>>>>>>>')
933 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
934 url = "http://0.0.0.0:19696/v2.0/sfc/port_pairs?id=%s" % pp_list[0]["id"]
935 pp_list_filtered_by_id_resp = requests.get(url, headers=headers)
936 pp_list_filtered_by_id = json.loads(pp_list_filtered_by_id_resp.content)["port_pairs"]
937 self.assertEqual(pp_list_filtered_by_id_resp.status_code, 200)
938 self.assertEqual(len(pp_list_filtered_by_id), 1)
939 self.assertEqual(pp_list_filtered_by_id[0], pp_list[0])
940
941 print('->>>>>>> test Neutron SFC Port Pair Show ->>>>>>>>>>>>>>>')
942 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
943 url = "http://0.0.0.0:19696/v2.0/sfc/port_pairs/%s" % pp2_id
944 pp2_show_resp = requests.get(url, headers=headers)
945 self.assertEqual(pp2_show_resp.status_code, 200)
946 self.assertEqual(json.loads(pp2_show_resp.content)
947 ["port_pair"]["name"], "pp2")
948
949 print('->>>>>>> test Neutron SFC Port Pair Group Create ->>>>>>>>>>>>>>>')
950 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
951 url = "http://0.0.0.0:19696/v2.0/sfc/port_pair_groups"
952 ppg1_resp = requests.post(
953 url, data='{"port_pair_group": {"name": "ppg1", "port_pairs": ["%s"]}}' % (pp1_id), headers=headers)
954 self.assertEqual(ppg1_resp.status_code, 201)
955 ppg2_resp = requests.post(
956 url, data='{"port_pair_group": {"name": "ppg2", "port_pairs": ["%s"]}}' % (pp2_id), headers=headers)
957 self.assertEqual(ppg2_resp.status_code, 201)
958 ppg3_resp = requests.post(
959 url, data='{"port_pair_group": {"name": "ppg3", "port_pairs": ["%s"]}}' % (pp2_id), headers=headers)
960 self.assertEqual(ppg3_resp.status_code, 201)
961
962 ppg1_id = json.loads(ppg1_resp.content)["port_pair_group"]["id"]
963 ppg2_id = json.loads(ppg2_resp.content)["port_pair_group"]["id"]
964 ppg3_id = json.loads(ppg3_resp.content)["port_pair_group"]["id"]
965
966 print('->>>>>>> test Neutron SFC Port Pair Group Update ->>>>>>>>>>>>>>>')
967 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
968 url = "http://0.0.0.0:19696/v2.0/sfc/port_pair_groups/%s" % ppg3_id
969 ppg3_update_resp = requests.put(
970 url, data='{"port_pair_group": {"description": "port_pair_group_update"}}', headers=headers)
971 self.assertEqual(ppg3_update_resp.status_code, 200)
972 self.assertEqual(json.loads(ppg3_update_resp.content)[
973 "port_pair_group"]["description"], "port_pair_group_update")
974
975 print('->>>>>>> test Neutron SFC Port Pair Group Delete ->>>>>>>>>>>>>>>')
976 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
977 url = "http://0.0.0.0:19696/v2.0/sfc/port_pair_groups/%s" % ppg3_id
978 ppg3_delete_resp = requests.delete(url, headers=headers)
979 self.assertEqual(ppg3_delete_resp.status_code, 204)
980
981 print('->>>>>>> test Neutron SFC Port Pair Group List ->>>>>>>>>>>>>>>')
982 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
983 url = "http://0.0.0.0:19696/v2.0/sfc/port_pair_groups"
984 ppg_list_resp = requests.get(url, headers=headers)
985 self.assertEqual(ppg_list_resp.status_code, 200)
986 # only ppg1 and ppg2 should be left
987 self.assertEqual(
988 len(json.loads(ppg_list_resp.content)["port_pair_groups"]), 2)
989
990 print('->>>>>>> test Neutron SFC Port Pair Group Show ->>>>>>>>>>>>>>>')
991 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
992 url = "http://0.0.0.0:19696/v2.0/sfc/port_pair_groups/%s" % ppg2_id
993 ppg2_show_resp = requests.get(url, headers=headers)
994 self.assertEqual(ppg2_show_resp.status_code, 200)
995 self.assertEqual(json.loads(ppg2_show_resp.content)[
996 "port_pair_group"]["name"], "ppg2")
997
998 print('->>>>>>> test Neutron SFC Flow Classifier Create ->>>>>>>>>>>>>>>')
999 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
1000 url = "http://0.0.0.0:19696/v2.0/sfc/flow_classifiers"
1001 fc1_resp = requests.post(
1002 url, data='{"flow_classifier": {"name": "fc1", "source_port_range_min": 22, "source_port_range_max": 4000}}', headers=headers)
1003 self.assertEqual(fc1_resp.status_code, 201)
1004 fc2_resp = requests.post(
1005 url, data='{"flow_classifier": {"name": "fc2", "source_port_range_min": 22, "source_port_range_max": 4000}}', headers=headers)
1006 self.assertEqual(fc2_resp.status_code, 201)
1007
1008 fc1_id = json.loads(fc1_resp.content)["flow_classifier"]["id"]
1009 fc2_id = json.loads(fc2_resp.content)["flow_classifier"]["id"]
1010
1011 print('->>>>>>> test Neutron SFC Flow Classifier Update ->>>>>>>>>>>>>>>')
1012 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
1013 url = "http://0.0.0.0:19696/v2.0/sfc/flow_classifiers/%s" % fc2_id
1014 fc2_update_resp = requests.put(
1015 url, data='{"flow_classifier": {"description": "flow_classifier_update"}}', headers=headers)
1016 self.assertEqual(fc2_update_resp.status_code, 200)
1017 self.assertEqual(json.loads(fc2_update_resp.content)[
1018 "flow_classifier"]["description"], "flow_classifier_update")
1019
1020 print('->>>>>>> test Neutron SFC Flow Classifier Delete ->>>>>>>>>>>>>>>')
1021 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
1022 url = "http://0.0.0.0:19696/v2.0/sfc/flow_classifiers/%s" % fc2_id
1023 fc2_delete_resp = requests.delete(url, headers=headers)
1024 self.assertEqual(fc2_delete_resp.status_code, 204)
1025
1026 print('->>>>>>> test Neutron SFC Flow Classifier List ->>>>>>>>>>>>>>>')
1027 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
1028 url = "http://0.0.0.0:19696/v2.0/sfc/flow_classifiers"
1029 fc_list_resp = requests.get(url, headers=headers)
1030 self.assertEqual(fc_list_resp.status_code, 200)
1031 self.assertEqual(len(json.loads(fc_list_resp.content)
1032 ["flow_classifiers"]), 1) # only fc1
1033
1034 print('->>>>>>> test Neutron SFC Flow Classifier Show ->>>>>>>>>>>>>>>')
1035 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
1036 url = "http://0.0.0.0:19696/v2.0/sfc/flow_classifiers/%s" % fc1_id
1037 fc1_show_resp = requests.get(url, headers=headers)
1038 self.assertEqual(fc1_show_resp.status_code, 200)
1039 self.assertEqual(json.loads(fc1_show_resp.content)[
1040 "flow_classifier"]["name"], "fc1")
1041
1042 print('->>>>>>> test Neutron SFC Port Chain Create ->>>>>>>>>>>>>>>')
1043 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
1044 url = "http://0.0.0.0:19696/v2.0/sfc/port_chains"
1045 pc1_resp = requests.post(url, data='{"port_chain": {"name": "pc1", "port_pair_groups": ["%s"], "flow_classifiers": ["%s"]}}' % (
1046 ppg1_id, fc1_id), headers=headers)
1047 self.assertEqual(pc1_resp.status_code, 201)
1048 pc2_resp = requests.post(url, data='{"port_chain": {"name": "pc2", "port_pair_groups": ["%s"], "flow_classifiers": ["%s"]}}' % (
1049 ppg1_id, fc1_id), headers=headers)
1050 self.assertEqual(pc2_resp.status_code, 201)
1051
1052 pc1_id = json.loads(pc1_resp.content)["port_chain"]["id"]
1053 pc2_id = json.loads(pc2_resp.content)["port_chain"]["id"]
1054
1055 print('->>>>>>> test Neutron SFC Port Chain Update ->>>>>>>>>>>>>>>')
1056 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
1057 url = "http://0.0.0.0:19696/v2.0/sfc/port_chains/%s" % pc2_id
1058 pc2_update_resp = requests.put(
1059 url, data='{"port_chain": {"description": "port_chain_update"}}', headers=headers)
1060 self.assertEqual(pc2_update_resp.status_code, 200)
1061 self.assertEqual(json.loads(pc2_update_resp.content)[
1062 "port_chain"]["description"], "port_chain_update")
1063
1064 print('->>>>>>> test Neutron SFC Port Chain Delete ->>>>>>>>>>>>>>>')
1065 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
1066 url = "http://0.0.0.0:19696/v2.0/sfc/port_chains/%s" % pc2_id
1067 pc2_delete_resp = requests.delete(url, headers=headers)
1068 self.assertEqual(pc2_delete_resp.status_code, 204)
1069
1070 print('->>>>>>> test Neutron SFC Port Chain List ->>>>>>>>>>>>>>>')
1071 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
1072 url = "http://0.0.0.0:19696/v2.0/sfc/port_chains"
1073 pc_list_resp = requests.get(url, headers=headers)
1074 self.assertEqual(pc_list_resp.status_code, 200)
1075 self.assertEqual(len(json.loads(pc_list_resp.content)
1076 ["port_chains"]), 1) # only pc1
1077
1078 print('->>>>>>> test Neutron SFC Port Chain Show ->>>>>>>>>>>>>>>')
1079 print('->>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
1080 url = "http://0.0.0.0:19696/v2.0/sfc/port_chains/%s" % pc1_id
1081 pc1_show_resp = requests.get(url, headers=headers)
1082 self.assertEqual(pc1_show_resp.status_code, 200)
1083 self.assertEqual(json.loads(pc1_show_resp.content)
1084 ["port_chain"]["name"], "pc1")
1085
1086
1087 if __name__ == '__main__':
1088 unittest.main()