Coverage for osm_pla/test/test_nsPlacementDataFactory.py: 99%

1# Copyright 2020 ArctosLabs Scandinavia AB 

2# 

3# Licensed under the Apache License, Version 2.0 (the "License"); 

4# you may not use this file except in compliance with the License. 

5# You may obtain a copy of the License at 

6# 

7# http://www.apache.org/licenses/LICENSE-2.0 

8# 

9# Unless required by applicable law or agreed to in writing, software 

10# distributed under the License is distributed on an "AS IS" BASIS, 

11# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or 

12# implied. 

13# See the License for the specific language governing permissions and 

14# limitations under the License. 

15import os 

16import unittest 

17from collections import Counter 

18from pathlib import Path 

19from unittest import TestCase, mock 

20from unittest.mock import call 

21 

22import yaml 

23 

24from osm_pla.placement.mznplacement import NsPlacementDataFactory 

25 

26 

27class TestNsPlacementDataFactory(TestCase): 

28 vim_accounts = [ 

29 { 

30 "vim_password": "FxtnynxBCnouzAT4Hkerhg==", 

31 "config": {}, 

32 "_admin": { 

33 "modified": 1564579854.0480285, 

34 "created": 1564579854.0480285, 

35 "operationalState": "ENABLED", 

36 "projects_read": ["69915588-e5e2-46d3-96b0-a29bedef6f73"], 

37 "deployed": { 

38 "RO-account": "6beb4e2e-b397-11e9-a7a3-02420aff0008", 

39 "RO": "6bcfc3fc-b397-11e9-a7a3-02420aff0008", 

40 }, 

41 "projects_write": ["69915588-e5e2-46d3-96b0-a29bedef6f73"], 

42 "detailed-status": "Done", 

43 }, 

44 "name": "OpenStack1", 

45 "vim_type": "openstack", 

46 "_id": "92b056a7-38f5-438d-b8ee-3f93b3531f87", 

47 "schema_version": "1.1", 

48 "vim_user": "admin", 

49 "vim_url": "http://10.234.12.47:5000/v3", 

50 "vim_tenant_name": "admin", 

51 }, 

52 { 

53 "config": {}, 

54 "vim_tenant_name": "osm_demo", 

55 "schema_version": "1.1", 

56 "name": "OpenStack2", 

57 "vim_password": "gK5v4Gh2Pl41o6Skwp6RCw==", 

58 "vim_type": "openstack", 

59 "_admin": { 

60 "modified": 1567148372.2490237, 

61 "created": 1567148372.2490237, 

62 "operationalState": "ENABLED", 

63 "projects_read": ["69915588-e5e2-46d3-96b0-a29bedef6f73"], 

64 "deployed": { 

65 "RO-account": "b7fb0034-caf3-11e9-9388-02420aff000a", 

66 "RO": "b7f129ce-caf3-11e9-9388-02420aff000a", 

67 }, 

68 "projects_write": ["69915588-e5e2-46d3-96b0-a29bedef6f73"], 

69 "detailed-status": "Done", 

70 }, 

71 "vim_user": "admin", 

72 "vim_url": "http://10.234.12.44:5000/v3", 

73 "_id": "6618d412-d7fc-4eb0-a6f8-d2c258e0e900", 

74 }, 

75 { 

76 "config": {}, 

77 "schema_version": "1.1", 

78 "name": "OpenStack3", 

79 "vim_password": "1R2FoMQnaL6rNSosoRP2hw==", 

80 "vim_type": "openstack", 

81 "vim_tenant_name": "osm_demo", 

82 "_admin": { 

83 "modified": 1567599746.689582, 

84 "created": 1567599746.689582, 

85 "operationalState": "ENABLED", 

86 "projects_read": ["69915588-e5e2-46d3-96b0-a29bedef6f73"], 

87 "deployed": { 

88 "RO-account": "a8161f54-cf0e-11e9-9388-02420aff000a", 

89 "RO": "a80b6280-cf0e-11e9-9388-02420aff000a", 

90 }, 

91 "projects_write": ["69915588-e5e2-46d3-96b0-a29bedef6f73"], 

92 "detailed-status": "Done", 

93 }, 

94 "vim_user": "admin", 

95 "vim_url": "http://10.234.12.46:5000/v3", 

96 "_id": "331ffdec-44a8-4707-94a1-af7a292d9735", 

97 }, 

98 { 

99 "config": {}, 

100 "schema_version": "1.1", 

101 "name": "OpenStack4", 

102 "vim_password": "6LScyPeMq3QFh3GRb/xwZw==", 

103 "vim_type": "openstack", 

104 "vim_tenant_name": "osm_demo", 

105 "_admin": { 

106 "modified": 1567599911.5108898, 

107 "created": 1567599911.5108898, 

108 "operationalState": "ENABLED", 

109 "projects_read": ["69915588-e5e2-46d3-96b0-a29bedef6f73"], 

110 "deployed": { 

111 "RO-account": "0a651200-cf0f-11e9-9388-02420aff000a", 

112 "RO": "0a4defc6-cf0f-11e9-9388-02420aff000a", 

113 }, 

114 "projects_write": ["69915588-e5e2-46d3-96b0-a29bedef6f73"], 

115 "detailed-status": "Done", 

116 }, 

117 "vim_user": "admin", 

118 "vim_url": "http://10.234.12.43:5000/v3", 

119 "_id": "eda92f47-29b9-4007-9709-c1833dbfbe31", 

120 }, 

121 ] 

122 

123 vim_accounts_fewer_vims = [ 

124 { 

125 "vim_password": "FxtnynxBCnouzAT4Hkerhg==", 

126 "config": {}, 

127 "_admin": { 

128 "modified": 1564579854.0480285, 

129 "created": 1564579854.0480285, 

130 "operationalState": "ENABLED", 

131 "projects_read": ["69915588-e5e2-46d3-96b0-a29bedef6f73"], 

132 "deployed": { 

133 "RO-account": "6beb4e2e-b397-11e9-a7a3-02420aff0008", 

134 "RO": "6bcfc3fc-b397-11e9-a7a3-02420aff0008", 

135 }, 

136 "projects_write": ["69915588-e5e2-46d3-96b0-a29bedef6f73"], 

137 "detailed-status": "Done", 

138 }, 

139 "name": "OpenStack1", 

140 "vim_type": "openstack", 

141 "_id": "92b056a7-38f5-438d-b8ee-3f93b3531f87", 

142 "schema_version": "1.1", 

143 "vim_user": "admin", 

144 "vim_url": "http://10.234.12.47:5000/v3", 

145 "vim_tenant_name": "admin", 

146 }, 

147 { 

148 "config": {}, 

149 "vim_tenant_name": "osm_demo", 

150 "schema_version": "1.1", 

151 "name": "OpenStack2", 

152 "vim_password": "gK5v4Gh2Pl41o6Skwp6RCw==", 

153 "vim_type": "openstack", 

154 "_admin": { 

155 "modified": 1567148372.2490237, 

156 "created": 1567148372.2490237, 

157 "operationalState": "ENABLED", 

158 "projects_read": ["69915588-e5e2-46d3-96b0-a29bedef6f73"], 

159 "deployed": { 

160 "RO-account": "b7fb0034-caf3-11e9-9388-02420aff000a", 

161 "RO": "b7f129ce-caf3-11e9-9388-02420aff000a", 

162 }, 

163 "projects_write": ["69915588-e5e2-46d3-96b0-a29bedef6f73"], 

164 "detailed-status": "Done", 

165 }, 

166 "vim_user": "admin", 

167 "vim_url": "http://10.234.12.44:5000/v3", 

168 "_id": "6618d412-d7fc-4eb0-a6f8-d2c258e0e900", 

169 }, 

170 { 

171 "config": {}, 

172 "schema_version": "1.1", 

173 "name": "OpenStack4", 

174 "vim_password": "6LScyPeMq3QFh3GRb/xwZw==", 

175 "vim_type": "openstack", 

176 "vim_tenant_name": "osm_demo", 

177 "_admin": { 

178 "modified": 1567599911.5108898, 

179 "created": 1567599911.5108898, 

180 "operationalState": "ENABLED", 

181 "projects_read": ["69915588-e5e2-46d3-96b0-a29bedef6f73"], 

182 "deployed": { 

183 "RO-account": "0a651200-cf0f-11e9-9388-02420aff000a", 

184 "RO": "0a4defc6-cf0f-11e9-9388-02420aff000a", 

185 }, 

186 "projects_write": ["69915588-e5e2-46d3-96b0-a29bedef6f73"], 

187 "detailed-status": "Done", 

188 }, 

189 "vim_user": "admin", 

190 "vim_url": "http://10.234.12.43:5000/v3", 

191 "_id": "eda92f47-29b9-4007-9709-c1833dbfbe31", 

192 }, 

193 ] 

194 

195 vim_accounts_more_vims = [ 

196 { 

197 "vim_password": "FxtnynxBCnouzAT4Hkerhg==", 

198 "config": {}, 

199 "_admin": { 

200 "modified": 1564579854.0480285, 

201 "created": 1564579854.0480285, 

202 "operationalState": "ENABLED", 

203 "projects_read": ["69915588-e5e2-46d3-96b0-a29bedef6f73"], 

204 "deployed": { 

205 "RO-account": "6beb4e2e-b397-11e9-a7a3-02420aff0008", 

206 "RO": "6bcfc3fc-b397-11e9-a7a3-02420aff0008", 

207 }, 

208 "projects_write": ["69915588-e5e2-46d3-96b0-a29bedef6f73"], 

209 "detailed-status": "Done", 

210 }, 

211 "name": "OpenStack1", 

212 "vim_type": "openstack", 

213 "_id": "92b056a7-38f5-438d-b8ee-3f93b3531f87", 

214 "schema_version": "1.1", 

215 "vim_user": "admin", 

216 "vim_url": "http://10.234.12.47:5000/v3", 

217 "vim_tenant_name": "admin", 

218 }, 

219 { 

220 "config": {}, 

221 "vim_tenant_name": "osm_demo", 

222 "schema_version": "1.1", 

223 "name": "OpenStack2", 

224 "vim_password": "gK5v4Gh2Pl41o6Skwp6RCw==", 

225 "vim_type": "openstack", 

226 "_admin": { 

227 "modified": 1567148372.2490237, 

228 "created": 1567148372.2490237, 

229 "operationalState": "ENABLED", 

230 "projects_read": ["69915588-e5e2-46d3-96b0-a29bedef6f73"], 

231 "deployed": { 

232 "RO-account": "b7fb0034-caf3-11e9-9388-02420aff000a", 

233 "RO": "b7f129ce-caf3-11e9-9388-02420aff000a", 

234 }, 

235 "projects_write": ["69915588-e5e2-46d3-96b0-a29bedef6f73"], 

236 "detailed-status": "Done", 

237 }, 

238 "vim_user": "admin", 

239 "vim_url": "http://10.234.12.44:5000/v3", 

240 "_id": "6618d412-d7fc-4eb0-a6f8-d2c258e0e900", 

241 }, 

242 { 

243 "config": {}, 

244 "schema_version": "1.1", 

245 "name": "OpenStack4", 

246 "vim_password": "6LScyPeMq3QFh3GRb/xwZw==", 

247 "vim_type": "openstack", 

248 "vim_tenant_name": "osm_demo", 

249 "_admin": { 

250 "modified": 1567599911.5108898, 

251 "created": 1567599911.5108898, 

252 "operationalState": "ENABLED", 

253 "projects_read": ["69915588-e5e2-46d3-96b0-a29bedef6f73"], 

254 "deployed": { 

255 "RO-account": "0a651200-cf0f-11e9-9388-02420aff000a", 

256 "RO": "0a4defc6-cf0f-11e9-9388-02420aff000a", 

257 }, 

258 "projects_write": ["69915588-e5e2-46d3-96b0-a29bedef6f73"], 

259 "detailed-status": "Done", 

260 }, 

261 "vim_user": "admin", 

262 "vim_url": "http://10.234.12.43:5000/v3", 

263 "_id": "eda92f47-29b9-4007-9709-c1833dbfbe31", 

264 }, 

265 { 

266 "config": {}, 

267 "schema_version": "1.1", 

268 "name": "OpenStack3", 

269 "vim_password": "6LScyPeMq3QFh3GRb/xwZw==", 

270 "vim_type": "openstack", 

271 "vim_tenant_name": "osm_demo", 

272 "_admin": { 

273 "modified": 1567599911.5108898, 

274 "created": 1567599911.5108898, 

275 "operationalState": "ENABLED", 

276 "projects_read": ["69915588-e5e2-46d3-96b0-a29bedef6f73"], 

277 "deployed": { 

278 "RO-account": "0a651200-cf0f-11e9-9388-02420aff000a", 

279 "RO": "0a4defc6-cf0f-11e9-9388-02420aff000a", 

280 }, 

281 "projects_write": ["69915588-e5e2-46d3-96b0-a29bedef6f73"], 

282 "detailed-status": "Done", 

283 }, 

284 "vim_user": "admin", 

285 "vim_url": "http://10.234.12.46:5000/v3", 

286 "_id": "eda92f47-29b9-4007-9709-c1833dbfbe31", 

287 }, 

288 { 

289 "config": {}, 

290 "schema_version": "1.1", 

291 "name": "OpenStack5", 

292 "vim_password": "6LScyPeMq3QFh3GRb/xwZw==", 

293 "vim_type": "openstack", 

294 "vim_tenant_name": "osm_demo", 

295 "_admin": { 

296 "modified": 1567599911.5108898, 

297 "created": 1567599911.5108898, 

298 "operationalState": "ENABLED", 

299 "projects_read": ["69915588-e5e2-46d3-96b0-a29bedef6f73"], 

300 "deployed": { 

301 "RO-account": "0a651200-cf0f-11e9-9388-02420aff000a", 

302 "RO": "0a4defc6-cf0f-11e9-9388-02420aff000a", 

303 }, 

304 "projects_write": ["69915588-e5e2-46d3-96b0-a29bedef6f73"], 

305 "detailed-status": "Done", 

306 }, 

307 "vim_user": "admin", 

308 "vim_url": "http://1.1.1.1:5000/v3", 

309 "_id": "ffffffff-29b9-4007-9709-c1833dbfbe31", 

310 }, 

311 ] 

312 

313 def _produce_ut_vim_accounts_info(self, vim_accounts): 

314 """ 

315 FIXME temporary, we will need more control over vim_urls and _id for test purpose - make a generator 

316 :return: vim_url and _id as dict, i.e. extract these from vim_accounts data 

317 """ 

318 return {_["name"]: _["_id"] for _ in vim_accounts} 

319 

320 def _adjust_path(self, file): 

321 """In case we are not running from test directory, 

322 then assume we are in top level directory (e.g. running from tox) and adjust file path accordingly 

323 """ 

324 path_component = "/osm_pla/test/" 

325 real_path = os.path.realpath(file) 

326 if path_component not in real_path: 

327 return ( 

328 os.path.dirname(real_path) 

329 + path_component 

330 + os.path.basename(real_path) 

331 ) 

332 else: 

333 return real_path 

334 

335 def _populate_pil_info(self, file): 

336 """ 

337 Note str(Path()) is a 3.5 thing 

338 """ 

339 with open(str(Path(self._adjust_path(file)))) as pp_fd: 

340 test_data = yaml.safe_load_all(pp_fd) 

341 return next(test_data) 

342 

343 def _get_ut_nsd_from_file(self, nsd_file_name): 

344 """ 

345 creates the structure representing the nsd. 

346 

347 IMPORTANT NOTE: If using .yaml files from the NS packages for the unit tests (which we do), 

348 then the files must be modified with respect to the way booleans are processed at on-boarding in OSM. 

349 The following construct in the NS package yaml file: 

350 mgmt-network: 'false' 

351 will become a boolean in the MongoDB, and therefore the yaml used in these unit test must use yaml 

352 tag as follows: 

353 mgmt-network: !!bool False 

354 The modification also applies to 'true' => !!bool True 

355 This will ensure that the object returned from this function is as expected by PLA. 

356 """ 

357 with open(str(Path(self._adjust_path(nsd_file_name)))) as nsd_fd: 

358 test_data = yaml.safe_load_all(nsd_fd) 

359 return next(test_data) 

360 

361 def _produce_ut_vnf_price_list(self): 

362 price_list_file = "vnf_price_list.yaml" 

363 with open(str(Path(self._adjust_path(price_list_file)))) as pl_fd: 

364 price_list_data = yaml.safe_load_all(pl_fd) 

365 return { 

366 i["vnfd"]: {i1["vim_name"]: i1["price"] for i1 in i["prices"]} 

367 for i in next(price_list_data) 

368 } 

369 

370 def _produce_ut_vnf_test_price_list(self, price_list): 

371 price_list_file = price_list 

372 with open(str(Path(self._adjust_path(price_list_file)))) as pl_fd: 

373 price_list_data = yaml.safe_load_all(pl_fd) 

374 return { 

375 i["vnfd"]: {i1["vim_name"]: i1["price"] for i1 in i["prices"]} 

376 for i in next(price_list_data) 

377 } 

378 

379 def test__produce_trp_link_characteristics_link_latency_with_more_vims(self): 

380 """ 

381 -test with more(other) vims compared to pil 

382 """ 

383 content_expected = [ 

384 0, 

385 0, 

386 0, 

387 0, 

388 0, 

389 120, 

390 120, 

391 130, 

392 130, 

393 140, 

394 140, 

395 230, 

396 230, 

397 240, 

398 240, 

399 340, 

400 340, 

401 32767, 

402 32767, 

403 32767, 

404 32767, 

405 32767, 

406 32767, 

407 32767, 

408 32767, 

409 ] 

410 nspdf = NsPlacementDataFactory( 

411 self._produce_ut_vim_accounts_info( 

412 TestNsPlacementDataFactory.vim_accounts_more_vims 

413 ), 

414 self._produce_ut_vnf_price_list(), 

415 nsd=None, 

416 pil_info=self._populate_pil_info("pil_unittest1_keys.yaml"), 

417 pinning=None, 

418 ) 

419 pil_latencies = nspdf._produce_trp_link_characteristics_data("pil_latency") 

420 content_produced = [i for row in pil_latencies for i in row] 

421 self.assertEqual( 

422 Counter(content_expected), 

423 Counter(content_produced), 

424 "trp_link_latency incorrect", 

425 ) 

426 

427 def test__produce_trp_link_characteristics_link_latency_with_fewer_vims(self): 

428 """ 

429 -test with fewer vims compared to pil 

430 :return: 

431 """ 

432 content_expected = [0, 0, 0, 120, 120, 140, 140, 240, 240] 

433 nspdf = NsPlacementDataFactory( 

434 self._produce_ut_vim_accounts_info( 

435 TestNsPlacementDataFactory.vim_accounts_fewer_vims 

436 ), 

437 self._produce_ut_vnf_price_list(), 

438 nsd=None, 

439 pil_info=self._populate_pil_info("pil_unittest1_keys.yaml"), 

440 pinning=None, 

441 ) 

442 pil_latencies = nspdf._produce_trp_link_characteristics_data("pil_latency") 

443 content_produced = [i for row in pil_latencies for i in row] 

444 self.assertEqual( 

445 Counter(content_expected), 

446 Counter(content_produced), 

447 "trp_link_latency incorrect", 

448 ) 

449 

450 def test__produce_trp_link_characteristic_not_supported(self): 

451 """ 

452 - test with non-supported characteristic 

453 """ 

454 nspdf = NsPlacementDataFactory( 

455 self._produce_ut_vim_accounts_info(TestNsPlacementDataFactory.vim_accounts), 

456 self._produce_ut_vnf_price_list(), 

457 nsd=None, 

458 pil_info=self._populate_pil_info("pil_unittest1.yaml"), 

459 pinning=None, 

460 ) 

461 

462 with self.assertRaises(Exception) as e: 

463 nspdf._produce_trp_link_characteristics_data("test_no_support") 

464 self.assertRegex( 

465 str(e.exception), 

466 r"characteristic.*not supported", 

467 "invalid exception content", 

468 ) 

469 

470 def test__produce_trp_link_characteristics_link_latency(self): 

471 """ 

472 -test with full set of vims as in pil 

473 -test with fewer vims compared to pil 

474 -test with more(other) vims compared to pil 

475 -test with invalid/corrupt pil configuration file (e.g. missing endpoint), empty file, not yaml conformant 

476 - test with non-supported characteristic 

477 

478 :return: 

479 """ 

480 content_expected = [ 

481 0, 

482 0, 

483 0, 

484 0, 

485 120, 

486 120, 

487 130, 

488 130, 

489 140, 

490 140, 

491 230, 

492 230, 

493 240, 

494 240, 

495 340, 

496 340, 

497 ] 

498 

499 nspdf = NsPlacementDataFactory( 

500 self._produce_ut_vim_accounts_info(TestNsPlacementDataFactory.vim_accounts), 

501 self._produce_ut_vnf_price_list(), 

502 nsd=None, 

503 pil_info=self._populate_pil_info("pil_unittest1_keys.yaml"), 

504 pinning=None, 

505 ) 

506 pil_latencies = nspdf._produce_trp_link_characteristics_data("pil_latency") 

507 content_produced = [i for row in pil_latencies for i in row] 

508 self.assertEqual( 

509 Counter(content_expected), 

510 Counter(content_produced), 

511 "trp_link_latency incorrect", 

512 ) 

513 

514 def test__produce_trp_link_characteristics_link_jitter(self): 

515 """ 

516 -test with full set of vims as in pil 

517 """ 

518 content_expected = [ 

519 0, 

520 0, 

521 0, 

522 0, 

523 1200, 

524 1200, 

525 1300, 

526 1300, 

527 1400, 

528 1400, 

529 2300, 

530 2300, 

531 2400, 

532 2400, 

533 3400, 

534 3400, 

535 ] 

536 

537 nspdf = NsPlacementDataFactory( 

538 self._produce_ut_vim_accounts_info(TestNsPlacementDataFactory.vim_accounts), 

539 self._produce_ut_vnf_price_list(), 

540 nsd=None, 

541 pil_info=self._populate_pil_info("pil_unittest1_keys.yaml"), 

542 pinning=None, 

543 ) 

544 pil_jitter = nspdf._produce_trp_link_characteristics_data("pil_jitter") 

545 content_produced = [i for row in pil_jitter for i in row] 

546 self.assertEqual( 

547 Counter(content_expected), 

548 Counter(content_produced), 

549 "trp_link_jitter incorrect", 

550 ) 

551 

552 def test__produce_trp_link_characteristics_link_jitter_with_fewer_vims(self): 

553 """ 

554 -test with fewer vims compared to pil, link jitter 

555 """ 

556 content_expected = [0, 0, 0, 1200, 1200, 1400, 1400, 2400, 2400] 

557 nspdf = NsPlacementDataFactory( 

558 self._produce_ut_vim_accounts_info(self.vim_accounts_fewer_vims), 

559 self._produce_ut_vnf_price_list(), 

560 nsd=None, 

561 pil_info=self._populate_pil_info("pil_unittest1_keys.yaml"), 

562 pinning=None, 

563 ) 

564 pil_latencies = nspdf._produce_trp_link_characteristics_data("pil_jitter") 

565 content_produced = [i for row in pil_latencies for i in row] 

566 self.assertEqual( 

567 Counter(content_expected), 

568 Counter(content_produced), 

569 "trp_link_jitter incorrect", 

570 ) 

571 

572 def test__produce_trp_link_characteristics_link_jitter_with_more_vims(self): 

573 """ 

574 -test with more vims compared to pil, link jitter 

575 """ 

576 content_expected = [ 

577 0, 

578 0, 

579 0, 

580 0, 

581 0, 

582 1200, 

583 1200, 

584 1300, 

585 1300, 

586 1400, 

587 1400, 

588 2300, 

589 2300, 

590 2400, 

591 2400, 

592 3400, 

593 3400, 

594 32767, 

595 32767, 

596 32767, 

597 32767, 

598 32767, 

599 32767, 

600 32767, 

601 32767, 

602 ] 

603 nspdf = NsPlacementDataFactory( 

604 self._produce_ut_vim_accounts_info(self.vim_accounts_more_vims), 

605 self._produce_ut_vnf_price_list(), 

606 nsd=None, 

607 pil_info=self._populate_pil_info("pil_unittest1_keys.yaml"), 

608 pinning=None, 

609 ) 

610 pil_latencies = nspdf._produce_trp_link_characteristics_data("pil_jitter") 

611 content_produced = [i for row in pil_latencies for i in row] 

612 self.assertEqual( 

613 Counter(content_expected), 

614 Counter(content_produced), 

615 "trp_link_jitter incorrect", 

616 ) 

617 

618 def test__produce_trp_link_characteristics_link_price(self): 

619 """ 

620 -test with full set of vims as in pil 

621 """ 

622 content_expected = [0, 0, 0, 0, 12, 12, 13, 13, 14, 14, 23, 23, 24, 24, 34, 34] 

623 nspdf = NsPlacementDataFactory( 

624 self._produce_ut_vim_accounts_info(TestNsPlacementDataFactory.vim_accounts), 

625 self._produce_ut_vnf_price_list(), 

626 nsd=None, 

627 pil_info=self._populate_pil_info("pil_unittest1_keys.yaml"), 

628 pinning=None, 

629 ) 

630 pil_prices = nspdf._produce_trp_link_characteristics_data("pil_price") 

631 content_produced = [i for row in pil_prices for i in row] 

632 self.assertEqual( 

633 Counter(content_expected), 

634 Counter(content_produced), 

635 "invalid trp link prices", 

636 ) 

637 

638 def test__produce_trp_link_characteristics_link_price_with_fewer_vims(self): 

639 """ 

640 -test with fewer vims compared to pil 

641 """ 

642 content_expected = [0, 0, 0, 12, 12, 14, 14, 24, 24] 

643 nspdf = NsPlacementDataFactory( 

644 self._produce_ut_vim_accounts_info(self.vim_accounts_fewer_vims), 

645 self._produce_ut_vnf_price_list(), 

646 nsd=None, 

647 pil_info=self._populate_pil_info("pil_unittest1_keys.yaml"), 

648 pinning=None, 

649 ) 

650 pil_prices = nspdf._produce_trp_link_characteristics_data("pil_price") 

651 content_produced = [i for row in pil_prices for i in row] 

652 self.assertEqual( 

653 Counter(content_expected), 

654 Counter(content_produced), 

655 "invalid trp link prices", 

656 ) 

657 

658 def test__produce_trp_link_characteristics_partly_constrained(self): 

659 content_expected = [ 

660 0, 

661 0, 

662 0, 

663 0, 

664 32767, 

665 32767, 

666 32767, 

667 32767, 

668 1200, 

669 1200, 

670 1400, 

671 1400, 

672 2400, 

673 2400, 

674 3400, 

675 3400, 

676 ] 

677 nspdf = NsPlacementDataFactory( 

678 self._produce_ut_vim_accounts_info(TestNsPlacementDataFactory.vim_accounts), 

679 self._produce_ut_vnf_price_list(), 

680 nsd=None, 

681 pil_info=self._populate_pil_info("pil_unittest2_keys.yaml"), 

682 pinning=None, 

683 ) 

684 pil_jitter = nspdf._produce_trp_link_characteristics_data("pil_jitter") 

685 content_produced = [i for row in pil_jitter for i in row] 

686 self.assertEqual( 

687 Counter(content_expected), 

688 Counter(content_produced), 

689 "invalid trp link jitter, partly constrained", 

690 ) 

691 

692 def test__produce_vld_desc_partly_constrained(self): 

693 vld_desc_expected = [ 

694 {"cp_refs": ["one", "two"], "jitter": 30}, 

695 {"cp_refs": ["two", "three"], "latency": 120}, 

696 ] 

697 

698 nsd = self._get_ut_nsd_from_file("nsd_unittest2.yaml") 

699 nsd = nsd["nsd"]["nsd"][0] 

700 nspdf = NsPlacementDataFactory( 

701 self._produce_ut_vim_accounts_info(TestNsPlacementDataFactory.vim_accounts), 

702 self._produce_ut_vnf_price_list(), 

703 nsd=nsd, 

704 pil_info=None, 

705 pinning=None, 

706 ) 

707 self.assertEqual( 

708 vld_desc_expected, nspdf._produce_vld_desc(), "vld_desc incorrect" 

709 ) 

710 

711 def test__produce_trp_link_characteristics_link_latency_not_yaml_conformant(self): 

712 """ 

713 -test with invalid/corrupt pil configuration file (not yaml conformant) 

714 """ 

715 with self.assertRaises(Exception) as e: 

716 _ = NsPlacementDataFactory( 

717 self._produce_ut_vim_accounts_info( 

718 TestNsPlacementDataFactory.vim_accounts 

719 ), 

720 self._produce_ut_vnf_price_list(), 

721 nsd=None, 

722 pil_info=self._populate_pil_info("not_yaml_conformant.yaml"), 

723 pinning=None, 

724 ) 

725 self.assertRegex( 

726 str(e.exception), 

727 r"mapping values are not allowed here.*", 

728 "invalid exception content", 

729 ) 

730 

731 def test__produce_trp_link_characteristics_with_invalid_pil_config(self): 

732 """ 

733 -test with invalid/corrupt pil configuration file (missing endpoint) 

734 """ 

735 nspdf = NsPlacementDataFactory( 

736 self._produce_ut_vim_accounts_info(TestNsPlacementDataFactory.vim_accounts), 

737 self._produce_ut_vnf_price_list(), 

738 nsd=None, 

739 pil_info=self._populate_pil_info( 

740 "corrupt_pil_endpoints_config_unittest1.yaml" 

741 ), 

742 pinning=None, 

743 ) 

744 with self.assertRaises(Exception) as e: 

745 _ = nspdf._produce_trp_link_characteristics_data("pil_latency") 

746 self.assertEqual( 

747 "list index out of range", str(e.exception), "unexpected exception" 

748 ) 

749 

750 def test__produce_vld_desc_w_instantiate_override(self): 

751 vld_desc_expected = [ 

752 {"cp_refs": ["one", "two"], "latency": 150, "jitter": 30}, 

753 {"cp_refs": ["two", "three"], "latency": 90, "jitter": 30}, 

754 ] 

755 

756 nsd = self._get_ut_nsd_from_file("nsd_unittest_no_vld_constraints.yaml") 

757 nsd = nsd["nsd"]["nsd"][0] 

758 nspdf = NsPlacementDataFactory( 

759 self._produce_ut_vim_accounts_info(TestNsPlacementDataFactory.vim_accounts), 

760 self._produce_ut_vnf_price_list(), 

761 nsd=nsd, 

762 pil_info=None, 

763 pinning=None, 

764 order_constraints=None, 

765 ) 

766 

767 self.assertNotEqual( 

768 nspdf._produce_vld_desc(), vld_desc_expected, "vld_desc incorrect" 

769 ) 

770 

771 def test__produce_vld_desc_nsd_w_instantiate_wo(self): 

772 """ 

773 nsd w/ constraints, instantiate w/o constraints 

774 :return: 

775 """ 

776 vld_desc_expected = [ 

777 {"cp_refs": ["one", "two"], "latency": 150, "jitter": 30}, 

778 {"cp_refs": ["two", "three"], "latency": 90, "jitter": 30}, 

779 ] 

780 

781 nsd = self._get_ut_nsd_from_file("nsd_unittest3.yaml") 

782 nsd = nsd["nsd"]["nsd"][0] 

783 nspdf = NsPlacementDataFactory( 

784 self._produce_ut_vim_accounts_info(TestNsPlacementDataFactory.vim_accounts), 

785 self._produce_ut_vnf_price_list(), 

786 nsd=nsd, 

787 pil_info=None, 

788 pinning=None, 

789 order_constraints=None, 

790 ) 

791 

792 self.assertEqual( 

793 vld_desc_expected, nspdf._produce_vld_desc(), "vld_desc incorrect" 

794 ) 

795 

796 def test__produce_vld_desc_nsd_w_instantiate_w(self): 

797 """ 

798 nsd w/ constraints, instantiate w/ constraints => override 

799 :return: 

800 """ 

801 vld_desc_expected = [ 

802 {"cp_refs": ["one", "two"], "latency": 120, "jitter": 21}, 

803 {"cp_refs": ["two", "three"], "latency": 121, "jitter": 22}, 

804 ] 

805 

806 nsd = self._get_ut_nsd_from_file("nsd_unittest3.yaml") 

807 nsd = nsd["nsd"]["nsd"][0] 

808 nspdf = NsPlacementDataFactory( 

809 self._produce_ut_vim_accounts_info(TestNsPlacementDataFactory.vim_accounts), 

810 self._produce_ut_vnf_price_list(), 

811 nsd=nsd, 

812 pil_info=None, 

813 pinning=None, 

814 order_constraints={ 

815 "vld-constraints": [ 

816 { 

817 "id": "three_vnf_constrained_nsd_vld1", 

818 "link-constraints": {"latency": 120, "jitter": 21}, 

819 }, 

820 { 

821 "id": "three_vnf_constrained_nsd_vld2", 

822 "link-constraints": {"latency": 121, "jitter": 22}, 

823 }, 

824 ] 

825 }, 

826 ) 

827 

828 self.assertEqual( 

829 vld_desc_expected, nspdf._produce_vld_desc(), "vld_desc incorrect" 

830 ) 

831 

832 def test__produce_vld_desc_nsd_wo_instantiate_wo(self): 

833 """ 

834 nsd w/o constraints, instantiate w/o constraints = no constraints in model 

835 :return: 

836 """ 

837 vld_desc_expected = [{"cp_refs": ["one", "two"]}, {"cp_refs": ["two", "three"]}] 

838 

839 nsd = self._get_ut_nsd_from_file("nsd_unittest_no_vld_constraints.yaml") 

840 nsd = nsd["nsd"]["nsd"][0] 

841 nspdf = NsPlacementDataFactory( 

842 self._produce_ut_vim_accounts_info(TestNsPlacementDataFactory.vim_accounts), 

843 self._produce_ut_vnf_price_list(), 

844 nsd=nsd, 

845 pil_info=None, 

846 pinning=None, 

847 order_constraints=None, 

848 ) 

849 

850 self.assertEqual( 

851 vld_desc_expected, nspdf._produce_vld_desc(), "vld_desc incorrect" 

852 ) 

853 

854 def test__produce_vld_desc_nsd_wo_instantiate_w(self): 

855 """ 

856 nsd w/o constraints, instantiate w/ constraints => add constraints 

857 :return: 

858 """ 

859 vld_desc_expected = [ 

860 {"cp_refs": ["one", "two"], "latency": 140, "jitter": 41}, 

861 {"cp_refs": ["two", "three"], "latency": 141, "jitter": 42}, 

862 ] 

863 

864 nsd = self._get_ut_nsd_from_file("nsd_unittest_no_vld_constraints.yaml") 

865 nsd = nsd["nsd"]["nsd"][0] 

866 nspdf = NsPlacementDataFactory( 

867 self._produce_ut_vim_accounts_info(TestNsPlacementDataFactory.vim_accounts), 

868 self._produce_ut_vnf_price_list(), 

869 nsd=nsd, 

870 pil_info=None, 

871 pinning=None, 

872 order_constraints={ 

873 "vld-constraints": [ 

874 { 

875 "id": "three_vnf_constrained_nsd_vld1", 

876 "link-constraints": {"latency": 140, "jitter": 41}, 

877 }, 

878 { 

879 "id": "three_vnf_constrained_nsd_vld2", 

880 "link-constraints": {"latency": 141, "jitter": 42}, 

881 }, 

882 ] 

883 }, 

884 ) 

885 

886 self.assertEqual( 

887 vld_desc_expected, nspdf._produce_vld_desc(), "vld_desc incorrect" 

888 ) 

889 

890 def test__produce_vld_desc_nsd_wo_instantiate_w_faulty_input(self): 

891 """ 

892 nsd w/o constraints, instantiate w/ constraints => add constraints that can be parsed 

893 :return: 

894 """ 

895 vld_desc_expected = [ 

896 {"cp_refs": ["one", "two"]}, 

897 {"cp_refs": ["two", "three"], "latency": 151},