kytos-ng / mef_eline

        self.napp.handle_flow_delete(event)

        evc.set_flow_removed_at.assert_called_once()

    async def test_add_bulk_metadata(self, event_loop):

        """Test add_bulk_metadata method"""

        self.napp.controller.loop = event_loop

        evc_mock = create_autospec(EVC)

        evc_mock.id = 1234

        self.napp.circuits = {"1234": evc_mock}

        payload = {

            "circuit_ids": ["1234"],

            "metadata1": 1,

            "metadata2": 2

        }

        response = await self.api_client.post(

            f"{self.base_endpoint}/v2/evc/metadata",

            json=payload

        )

        assert response.status_code == 201

        args = self.napp.mongo_controller.update_evcs.call_args[0]

        ids = payload.pop("circuit_ids")

        assert args[0] == ids

        assert args[1] == payload

        assert args[2] == "add"

        calls = self.napp.mongo_controller.update_evcs.call_count

        assert calls == 1

        evc_mock.extend_metadata.assert_called_with(payload)

    async def test_add_bulk_metadata_no_id(self, event_loop):

        """Test add_bulk_metadata with unknown evc id"""

        )

        assert response.status_code == 400

    async def test_delete_bulk_metadata(self, event_loop):

        """Test delete_metadata method"""

        self.napp.controller.loop = event_loop

        evc_mock = create_autospec(EVC)

        evc_mock.id = 1234

        self.napp.circuits = {"1234": evc_mock}

        payload = {

            "circuit_ids": ["1234"]

        }

        response = await self.api_client.request(

            "DELETE",

            f"{self.base_endpoint}/v2/evc/metadata/metadata1",

            json=payload

        )

        assert response.status_code == 200

        args = self.napp.mongo_controller.update_evcs.call_args[0]

        assert args[0] == payload["circuit_ids"]

        assert args[1] == {"metadata1": ""}

        assert args[2] == "del"

        calls = self.napp.mongo_controller.update_evcs.call_count

        assert calls == 1

        assert evc_mock.remove_metadata.call_count == 1

    async def test_handle_topology_update(self):

        """Test handle_topology_update"""