|
@@ 2264-2287 (lines=24) @@
|
| 2261 |
|
self.napp.handle_flow_delete(event) |
| 2262 |
|
evc.set_flow_removed_at.assert_called_once() |
| 2263 |
|
|
| 2264 |
|
async def test_add_bulk_metadata(self, event_loop): |
| 2265 |
|
"""Test add_bulk_metadata method""" |
| 2266 |
|
self.napp.controller.loop = event_loop |
| 2267 |
|
evc_mock = create_autospec(EVC) |
| 2268 |
|
evc_mock.id = 1234 |
| 2269 |
|
self.napp.circuits = {"1234": evc_mock} |
| 2270 |
|
payload = { |
| 2271 |
|
"circuit_ids": ["1234"], |
| 2272 |
|
"metadata1": 1, |
| 2273 |
|
"metadata2": 2 |
| 2274 |
|
} |
| 2275 |
|
response = await self.api_client.post( |
| 2276 |
|
f"{self.base_endpoint}/v2/evc/metadata", |
| 2277 |
|
json=payload |
| 2278 |
|
) |
| 2279 |
|
assert response.status_code == 201 |
| 2280 |
|
args = self.napp.mongo_controller.update_evcs.call_args[0] |
| 2281 |
|
ids = payload.pop("circuit_ids") |
| 2282 |
|
assert args[0] == ids |
| 2283 |
|
assert args[1] == payload |
| 2284 |
|
assert args[2] == "add" |
| 2285 |
|
calls = self.napp.mongo_controller.update_evcs.call_count |
| 2286 |
|
assert calls == 1 |
| 2287 |
|
evc_mock.extend_metadata.assert_called_with(payload) |
| 2288 |
|
|
| 2289 |
|
async def test_add_bulk_metadata_no_id(self, event_loop): |
| 2290 |
|
"""Test add_bulk_metadata with unknown evc id""" |
|
@@ 2319-2340 (lines=22) @@
|
| 2316 |
|
) |
| 2317 |
|
assert response.status_code == 400 |
| 2318 |
|
|
| 2319 |
|
async def test_delete_bulk_metadata(self, event_loop): |
| 2320 |
|
"""Test delete_metadata method""" |
| 2321 |
|
self.napp.controller.loop = event_loop |
| 2322 |
|
evc_mock = create_autospec(EVC) |
| 2323 |
|
evc_mock.id = 1234 |
| 2324 |
|
self.napp.circuits = {"1234": evc_mock} |
| 2325 |
|
payload = { |
| 2326 |
|
"circuit_ids": ["1234"] |
| 2327 |
|
} |
| 2328 |
|
response = await self.api_client.request( |
| 2329 |
|
"DELETE", |
| 2330 |
|
f"{self.base_endpoint}/v2/evc/metadata/metadata1", |
| 2331 |
|
json=payload |
| 2332 |
|
) |
| 2333 |
|
assert response.status_code == 200 |
| 2334 |
|
args = self.napp.mongo_controller.update_evcs.call_args[0] |
| 2335 |
|
assert args[0] == payload["circuit_ids"] |
| 2336 |
|
assert args[1] == {"metadata1": ""} |
| 2337 |
|
assert args[2] == "del" |
| 2338 |
|
calls = self.napp.mongo_controller.update_evcs.call_count |
| 2339 |
|
assert calls == 1 |
| 2340 |
|
assert evc_mock.remove_metadata.call_count == 1 |
| 2341 |
|
|
| 2342 |
|
async def test_use_uni_tags(self, event_loop): |
| 2343 |
|
"""Test _use_uni_tags""" |
kytos-ng /
mef_eline
