build.tests.unit.test_main

Complexity

Total Complexity

84

Size/Duplication

Total Lines	2406
Duplicated Lines	8.73 %

Importance

Changes

0

73 Methods

Rating	Name	Duplication	Size	Complexity
A	TestMain.test_get_metadata()	0	13	1
B	TestMain.test_update_circuit_invalid_json()	68	68	1
B	TestMain._add_mongodb_schedule_data()	0	52	1
A	TestMain.test_list_no_circuits_stored()	0	11	1
B	TestMain.test_create_schedule()	0	66	1
A	TestMain.test_circuit_with_invalid_id()	0	9	1
A	TestMain._uni_from_dict_side_effect()	0	5	1
A	TestMain.test_uni_from_dict()	0	27	2
B	TestMain.test_handle_link_down()	0	133	1
B	TestMain.test_update_schedule()	0	68	1
A	TestMain.test_circuit_with_valid_id()	0	10	1
A	TestMain.test_execute_consistency_wait_for()	0	33	1
A	TestMain.test_update_no_schedule()	0	14	1
A	TestMain.test_add_metadata_malformed_json()	0	14	1
A	TestMain.test_get_specific_schedules_from_mongodb_not_found()	0	14	1
A	TestMain.test_create_a_circuit_case_4()	0	41	1
B	TestMain.test_delete_archived_evc()	0	69	1
B	TestMain.test_delete_schedule()	0	56	1
B	TestMain.test_update_circuit()	0	161	1
A	TestMain.test_list_schedules_from_mongodb()	0	53	1
A	TestMain.test_add_bulk_metadata_no_circuits()	0	15	1
A	TestMain.test_evc_from_dict_paths()	0	49	1
A	TestMain.test_delete_metadata()	0	12	1
B	TestMain.test_create_circuit_already_enabled()	0	61	1
A	TestMain.get_app_test_client()	0	5	1
A	TestMain.test_uni_from_dict_non_existent_intf()	0	8	2
B	TestMain.test_create_a_circuit_case_1()	0	92	1
A	TestMain.test_create_a_circuit_case_3()	0	16	1
A	TestMain.get_napp_urls()	0	24	4
A	TestMain.test_link_from_dict_non_existent_intf()	0	9	2
A	TestMain.test_list_with_archived_circuits_all()	0	16	1
B	TestMain.test_execute_consistency()	0	44	1
B	TestMain.test_verify_api_urls()	0	69	1
A	TestMain.test_list_without_circuits()	0	9	1
A	TestMain.test_delete_schedule_archived()	0	41	1
A	TestMain.test_add_bulk_metadata_no_id()	0	15	1
A	TestMain.test_list_schedules__no_data_stored()	0	12	1
B	TestMain.test_update_circuit_invalid_path()	0	79	1
A	TestMain.test_add_metadata_no_body()	0	10	1
A	TestMain.test_create_circuit_case_5()	0	34	1
A	TestMain.test_handle_link_up()	0	14	1
A	TestMain.test_redeploy_evc_deleted()	0	9	1
A	TestMain.test_add_bulk_metadata()	25	25	1
A	TestMain.test_get_event_listeners()	0	12	2
A	TestMain.test_execute()	0	19	1
A	TestMain.test_create_a_circuit_invalid_queue_id()	0	27	1
A	TestMain.test_get_specific_schedule_from_mongodb()	0	25	1
A	TestMain.test_add_metadata()	0	17	1
A	TestMain.test_add_metadata_no_evc()	0	13	1
A	TestMain.test_delete_schedule_not_found()	0	8	1
A	TestMain.test_handle_evc_deployed()	0	13	1
A	TestMain.test_delete_no_evc()	0	8	1
A	TestMain.test_list_with_circuits_stored()	16	16	1
A	TestMain.test_update_schedule_archived()	0	49	1
A	TestMain.test_add_metadata_wrong_content_type()	0	13	1
A	TestMain.test_evc_from_dict()	0	33	1
A	TestMain.test_list_with_archived_circuits_archived()	19	19	1
A	TestMain.test_get_evcs_by_svc_level()	0	19	3
A	TestMain.test_redeploy_evc_disabled()	0	9	1
A	TestMain.test_evc_from_dict_links()	0	53	1
B	TestMain.test_update_evc_no_json_mime()	60	60	1
A	TestMain.test_create_a_circuit_case_2()	0	11	1
A	TestMain.test_get_circuit_not_found()	0	7	1
A	TestMain.test_delete_bulk_metadata()	22	22	1
A	TestMain.test_load_all_evcs()	0	15	1
A	TestMain.setUp()	0	17	2
A	TestMain.test_redeploy_evc()	0	9	1
A	TestMain.test_handle_flow_mod_error()	0	11	1
B	TestMain.test_create_schedule_invalid_request()	0	76	1
A	TestMain.test_load_evc()	0	27	1
A	TestMain.test_delete_metadata_no_evc()	0	10	1
B	TestMain.test_handle_evc_affected_by_link_down()	0	57	1
A	TestMain.test_handle_flow_delete()	0	11	1

"""Module to test the main napp file."""
import json
from unittest import TestCase
from unittest.mock import (
    AsyncMock,
    MagicMock,
    PropertyMock,
    call,
    create_autospec,
    patch
)

from kytos.core.events import KytosEvent
from kytos.core.interface import UNI, Interface
from kytos.lib.helpers import get_controller_mock
from napps.kytos.mef_eline.exceptions import InvalidPath
from napps.kytos.mef_eline.models import EVC
from napps.kytos.mef_eline.tests.helpers import get_uni_mocked


async def test_on_table_enabled():
    """Test on_table_enabled"""
    # pylint: disable=import-outside-toplevel
    from napps.kytos.mef_eline.main import Main
    controller = get_controller_mock()
    controller.buffers.app.aput = AsyncMock()
    Main.get_eline_controller = MagicMock()
    napp = Main(controller)

    # Succesfully setting table groups
    content = {"mef_eline": {"epl": 2}}
    event = KytosEvent(name="kytos/of_multi_table.enable_table",
                       content=content)
    await napp.on_table_enabled(event)
    assert napp.table_group["epl"] == 2
    assert napp.table_group["evpl"] == 0
    assert controller.buffers.app.aput.call_count == 1

    # Failure at setting table groups
    content = {"mef_eline": {"unknown": 123}}
    event = KytosEvent(name="kytos/of_multi_table.enable_table",
                       content=content)
    await napp.on_table_enabled(event)
    assert controller.buffers.app.aput.call_count == 1


# pylint: disable=too-many-public-methods, too-many-lines
class TestMain(TestCase):
    """Test the Main class."""

    def setUp(self):
        """Execute steps before each tests.

        Set the server_name_url_url from kytos/mef_eline
        """
        self.server_name_url = "http://localhost:8181/api/kytos/mef_eline"

        # The decorator run_on_thread is patched, so methods that listen
        # for events do not run on threads while tested.
        # Decorators have to be patched before the methods that are
        # decorated with them are imported.
        patch("kytos.core.helpers.run_on_thread", lambda x: x).start()
        # pylint: disable=import-outside-toplevel
        from napps.kytos.mef_eline.main import Main
        Main.get_eline_controller = MagicMock()
        self.addCleanup(patch.stopall)
        self.napp = Main(get_controller_mock())

    def test_get_event_listeners(self):
        """Verify all event listeners registered."""
        expected_events = [
            "kytos/core.shutdown",
            "kytos/core.shutdown.kytos/mef_eline",
            "kytos/topology.link_up",
            "kytos/topology.link_down",
        ]
        actual_events = self.napp.listeners()

        for _event in expected_events:
            self.assertIn(_event, actual_events, _event)

    def test_verify_api_urls(self):
        """Verify all APIs registered."""
        expected_urls = [
            ({}, {"POST", "OPTIONS"}, "/api/kytos/mef_eline/v2/evc/"),
            ({}, {"OPTIONS", "HEAD", "GET"}, "/api/kytos/mef_eline/v2/evc/"),
            (
                {"circuit_id": "[circuit_id]"},
                {"OPTIONS", "DELETE"},
                "/api/kytos/mef_eline/v2/evc/<circuit_id>",
            ),
            (
                {"circuit_id": "[circuit_id]"},
                {"OPTIONS", "HEAD", "GET"},
                "/api/kytos/mef_eline/v2/evc/<circuit_id>",
            ),
            (
                {"circuit_id": "[circuit_id]"},
                {"OPTIONS", "PATCH"},
                "/api/kytos/mef_eline/v2/evc/<circuit_id>",
            ),
            (
                {"circuit_id": "[circuit_id]"},
                {"OPTIONS", "HEAD", "GET"},
                "/api/kytos/mef_eline/v2/evc/<circuit_id>/metadata",
            ),
            (
                {"circuit_id": "[circuit_id]"},
                {"OPTIONS", "POST"},
                "/api/kytos/mef_eline/v2/evc/<circuit_id>/metadata",
            ),
            (
                {"circuit_id": "[circuit_id]", "key": "[key]"},
                {"OPTIONS", "DELETE"},
                "/api/kytos/mef_eline/v2/evc/<circuit_id>/metadata/<key>",
            ),
            (
                {"circuit_id": "[circuit_id]"},
                {"OPTIONS", "PATCH"},
                "/api/kytos/mef_eline/v2/evc/<circuit_id>/redeploy",
            ),
            (
                {},
                {"OPTIONS", "DELETE"},
                "/api/kytos/mef_eline/v2/evc/metadata",
            ),
            (
                {},
                {"OPTIONS", "POST"},
                "/api/kytos/mef_eline/v2/evc/metadata",
            ),
            (
                {},
                {"OPTIONS", "GET", "HEAD"},
                "/api/kytos/mef_eline/v2/evc/schedule",
            ),
            ({}, {"POST", "OPTIONS"}, "/api/kytos/mef_eline/v2/evc/schedule/"),
            (
                {"schedule_id": "[schedule_id]"},
                {"OPTIONS", "DELETE"},
                "/api/kytos/mef_eline/v2/evc/schedule/<schedule_id>",
            ),
            (
                {"schedule_id": "[schedule_id]"},
                {"OPTIONS", "PATCH"},
                "/api/kytos/mef_eline/v2/evc/schedule/<schedule_id>",
            ),
        ]
        urls = self.get_napp_urls(self.napp)
        self.assertEqual(len(expected_urls), len(urls))

    @patch('napps.kytos.mef_eline.main.log')
    @patch('napps.kytos.mef_eline.main.Main.execute_consistency')
    def test_execute(self, mock_execute_consistency, mock_log):
        """Test execute."""
        self.napp.execution_rounds = 0
        self.napp.execute()
        mock_execute_consistency.assert_called()
        self.assertEqual(mock_log.debug.call_count, 2)

        # Test locked should return
        mock_execute_consistency.call_count = 0
        mock_log.info.call_count = 0
        # pylint: disable=protected-access
        self.napp._lock = MagicMock()
        self.napp._lock.locked.return_value = True
        # pylint: enable=protected-access
        self.napp.execute()
        mock_execute_consistency.assert_not_called()
        mock_log.info.assert_not_called()

    @patch('napps.kytos.mef_eline.main.settings')
    @patch('napps.kytos.mef_eline.main.Main._load_evc')
    @patch("napps.kytos.mef_eline.controllers.ELineController.upsert_evc")
    @patch("napps.kytos.mef_eline.models.evc.EVCDeploy.check_list_traces")
    def test_execute_consistency(self, mock_check_list_traces, *args):
        """Test execute_consistency."""
        (mongo_controller_upsert_mock, mock_load_evc, mock_settings) = args

        stored_circuits = {'1': {'name': 'circuit_1'},
                           '2': {'name': 'circuit_2'},
                           '3': {'name': 'circuit_3'}}
        mongo_controller_upsert_mock.return_value = True
        self.napp.mongo_controller.get_circuits.return_value = {
            "circuits": stored_circuits
        }

        mock_settings.WAIT_FOR_OLD_PATH = -1
        evc1 = MagicMock(id=1, service_level=0, creation_time=1)
        evc1.is_enabled.return_value = True
        evc1.is_active.return_value = False
        evc1.lock.locked.return_value = False
        evc1.has_recent_removed_flow.return_value = False
        evc1.is_recent_updated.return_value = False
        evc1.execution_rounds = 0
        evc2 = MagicMock(id=2, service_level=7, creation_time=1)
        evc2.is_enabled.return_value = True
        evc2.is_active.return_value = False
        evc2.lock.locked.return_value = False
        evc2.has_recent_removed_flow.return_value = False
        evc2.is_recent_updated.return_value = False
        evc2.execution_rounds = 0
        self.napp.circuits = {'1': evc1, '2': evc2}
        assert self.napp.get_evcs_by_svc_level() == [evc2, evc1]

        mock_check_list_traces.return_value = {
                                                1: True,
                                                2: False
                                            }

        self.napp.execute_consistency()
        self.assertEqual(evc1.activate.call_count, 1)
        self.assertEqual(evc1.sync.call_count, 1)
        self.assertEqual(evc2.deploy.call_count, 1)
        mock_load_evc.assert_called_with(stored_circuits['3'])

    @patch('napps.kytos.mef_eline.main.settings')
    @patch('napps.kytos.mef_eline.main.Main._load_evc')
    @patch("napps.kytos.mef_eline.controllers.ELineController.upsert_evc")
    @patch("napps.kytos.mef_eline.models.evc.EVCDeploy.check_list_traces")
    def test_execute_consistency_wait_for(self, mock_check_list_traces, *args):
        """Test execute and wait for setting."""
        (mongo_controller_upsert_mock, _, mock_settings) = args

        stored_circuits = {'1': {'name': 'circuit_1'}}
        mongo_controller_upsert_mock.return_value = True
        self.napp.mongo_controller.get_circuits.return_value = {
            "circuits": stored_circuits
        }

        mock_settings.WAIT_FOR_OLD_PATH = -1
        evc1 = MagicMock(id=1, service_level=0, creation_time=1)
        evc1.is_enabled.return_value = True
        evc1.is_active.return_value = False
        evc1.lock.locked.return_value = False
        evc1.has_recent_removed_flow.return_value = False
        evc1.is_recent_updated.return_value = False
        evc1.execution_rounds = 0
        evc1.deploy.call_count = 0
        self.napp.circuits = {'1': evc1}
        assert self.napp.get_evcs_by_svc_level() == [evc1]
        mock_settings.WAIT_FOR_OLD_PATH = 1

        mock_check_list_traces.return_value = {1: False}

        self.napp.execute_consistency()
        self.assertEqual(evc1.deploy.call_count, 0)
        self.napp.execute_consistency()
        self.assertEqual(evc1.deploy.call_count, 1)

    @patch('napps.kytos.mef_eline.main.Main._uni_from_dict')
    @patch('napps.kytos.mef_eline.models.evc.EVCBase._validate')
    def test_evc_from_dict(self, _validate_mock, uni_from_dict_mock):
        """
        Test the helper method that create an EVN from dict.

        Verify object creation with circuit data and schedule data.
        """
        _validate_mock.return_value = True
        uni_from_dict_mock.side_effect = ["uni_a", "uni_z"]
        payload = {
            "name": "my evc1",
            "uni_a": {
                "interface_id": "00:00:00:00:00:00:00:01:1",
                "tag": {"tag_type": 1, "value": 80},
            },
            "uni_z": {
                "interface_id": "00:00:00:00:00:00:00:02:2",
                "tag": {"tag_type": 1, "value": 1},
            },
            "circuit_scheduler": [
                {"frequency": "* * * * *", "action": "create"}
            ],
            "queue_id": 5,
        }
        # pylint: disable=protected-access
        evc_response = self.napp._evc_from_dict(payload)
        self.assertIsNotNone(evc_response)
        self.assertIsNotNone(evc_response.uni_a)
        self.assertIsNotNone(evc_response.uni_z)
        self.assertIsNotNone(evc_response.circuit_scheduler)
        self.assertIsNotNone(evc_response.name)
        self.assertIsNotNone(evc_response.queue_id)

    @patch("napps.kytos.mef_eline.main.Main._uni_from_dict")
    @patch("napps.kytos.mef_eline.models.evc.EVCBase._validate")
    @patch("kytos.core.Controller.get_interface_by_id")
    def test_evc_from_dict_paths(
        self, _get_interface_by_id_mock, _validate_mock, uni_from_dict_mock
    ):
        """
        Test the helper method that create an EVN from dict.

        Verify object creation with circuit data and schedule data.
        """

        _get_interface_by_id_mock.return_value = get_uni_mocked().interface
        _validate_mock.return_value = True
        uni_from_dict_mock.side_effect = ["uni_a", "uni_z"]
        payload = {
            "name": "my evc1",
            "uni_a": {
                "interface_id": "00:00:00:00:00:00:00:01:1",
                "tag": {"tag_type": 1, "value": 80},
            },
            "uni_z": {
                "interface_id": "00:00:00:00:00:00:00:02:2",
                "tag": {"tag_type": 1, "value": 1},
            },
            "current_path": [],
            "primary_path": [
                {
                    "endpoint_a": {
                        "interface_id": "00:00:00:00:00:00:00:01:1"
                    },
                    "endpoint_b": {
                        "interface_id": "00:00:00:00:00:00:00:02:2"
                    },
                }
            ],
            "backup_path": [],
        }

        # pylint: disable=protected-access
        evc_response = self.napp._evc_from_dict(payload)
        self.assertIsNotNone(evc_response)
        self.assertIsNotNone(evc_response.uni_a)
        self.assertIsNotNone(evc_response.uni_z)
        self.assertIsNotNone(evc_response.circuit_scheduler)
        self.assertIsNotNone(evc_response.name)
        self.assertEqual(len(evc_response.current_path), 0)
        self.assertEqual(len(evc_response.backup_path), 0)
        self.assertEqual(len(evc_response.primary_path), 1)

    @patch("napps.kytos.mef_eline.main.Main._uni_from_dict")
    @patch("napps.kytos.mef_eline.models.evc.EVCBase._validate")
    @patch("kytos.core.Controller.get_interface_by_id")
    def test_evc_from_dict_links(
        self, _get_interface_by_id_mock, _validate_mock, uni_from_dict_mock
    ):
        """
        Test the helper method that create an EVN from dict.

        Verify object creation with circuit data and schedule data.
        """
        _get_interface_by_id_mock.return_value = get_uni_mocked().interface
        _validate_mock.return_value = True
        uni_from_dict_mock.side_effect = ["uni_a", "uni_z"]
        payload = {
            "name": "my evc1",
            "uni_a": {
                "interface_id": "00:00:00:00:00:00:00:01:1",
                "tag": {"tag_type": 1, "value": 80},
            },
            "uni_z": {
                "interface_id": "00:00:00:00:00:00:00:02:2",
                "tag": {"tag_type": 1, "value": 1},
            },
            "primary_links": [
                {
                    "endpoint_a": {
                        "interface_id": "00:00:00:00:00:00:00:01:1"
                    },
                    "endpoint_b": {
                        "interface_id": "00:00:00:00:00:00:00:02:2"
                    },
                    "metadata": {
                        "s_vlan": {
                            "tag_type": 1,
                            "value": 100
                        }
                    },
                }
            ],
            "backup_links": [],
        }

        # pylint: disable=protected-access
        evc_response = self.napp._evc_from_dict(payload)
        self.assertIsNotNone(evc_response)
        self.assertIsNotNone(evc_response.uni_a)
        self.assertIsNotNone(evc_response.uni_z)
        self.assertIsNotNone(evc_response.circuit_scheduler)
        self.assertIsNotNone(evc_response.name)
        self.assertEqual(len(evc_response.current_links_cache), 0)
        self.assertEqual(len(evc_response.backup_links), 0)
        self.assertEqual(len(evc_response.primary_links), 1)

    def test_list_without_circuits(self):
        """Test if list circuits return 'no circuit stored.'."""
        circuits = {"circuits": {}}
        self.napp.mongo_controller.get_circuits.return_value = circuits
        api = self.get_app_test_client(self.napp)
        url = f"{self.server_name_url}/v2/evc/"
        response = api.get(url)
        self.assertEqual(response.status_code, 200, response.data)
        self.assertEqual(json.loads(response.data.decode()), {})

    def test_list_no_circuits_stored(self):
        """Test if list circuits return all circuits stored."""
        circuits = {"circuits": {}}
        self.napp.mongo_controller.get_circuits.return_value = circuits

        api = self.get_app_test_client(self.napp)
        url = f"{self.server_name_url}/v2/evc/"

        response = api.get(url)
        expected_result = circuits["circuits"]
        self.assertEqual(json.loads(response.data), expected_result)

    def test_list_with_circuits_stored(self):

This code seems to be duplicated in your project.

        """Test if list circuits return all circuits stored."""
        circuits = {
            'circuits':
            {"1": {"name": "circuit_1"}, "2": {"name": "circuit_2"}}
        }
        get_circuits = self.napp.mongo_controller.get_circuits
        get_circuits.return_value = circuits

        api = self.get_app_test_client(self.napp)
        url = f"{self.server_name_url}/v2/evc/"

        response = api.get(url)
        expected_result = circuits["circuits"]
        get_circuits.assert_called_with(archived="false", metadata={})
        self.assertEqual(json.loads(response.data), expected_result)

    def test_list_with_archived_circuits_archived(self):

This code seems to be duplicated in your project.

        """Test if list circuits only archived circuits."""
        circuits = {
            'circuits':
            {
                "1": {"name": "circuit_1", "archived": True},
            }
        }
        get_circuits = self.napp.mongo_controller.get_circuits
        get_circuits.return_value = circuits

        api = self.get_app_test_client(self.napp)
        url = f"{self.server_name_url}/v2/evc/?archived=true&metadata.a=1"

        response = api.get(url)
        get_circuits.assert_called_with(archived="true",
                                        metadata={"metadata.a": "1"})
        expected_result = {"1": circuits["circuits"]["1"]}
        self.assertEqual(json.loads(response.data), expected_result)

    def test_list_with_archived_circuits_all(self):
        """Test if list circuits return all circuits."""
        circuits = {
            'circuits': {
                "1": {"name": "circuit_1"},
                "2": {"name": "circuit_2", "archived": True},
            }
        }
        self.napp.mongo_controller.get_circuits.return_value = circuits

        api = self.get_app_test_client(self.napp)
        url = f"{self.server_name_url}/v2/evc/?archived=null"

        response = api.get(url)
        expected_result = circuits["circuits"]
        self.assertEqual(json.loads(response.data), expected_result)

    def test_circuit_with_valid_id(self):
        """Test if get_circuit return the circuit attributes."""
        circuit = {"name": "circuit_1"}
        self.napp.mongo_controller.get_circuit.return_value = circuit

        api = self.get_app_test_client(self.napp)
        url = f"{self.server_name_url}/v2/evc/1"
        response = api.get(url)
        expected_result = circuit
        self.assertEqual(json.loads(response.data), expected_result)

    def test_circuit_with_invalid_id(self):
        """Test if get_circuit return invalid circuit_id."""
        self.napp.mongo_controller.get_circuit.return_value = None
        api = self.get_app_test_client(self.napp)
        url = f"{self.server_name_url}/v2/evc/3"
        response = api.get(url)
        expected_result = "circuit_id 3 not found"
        self.assertEqual(
            json.loads(response.data)["description"], expected_result
        )

    @patch("napps.kytos.mef_eline.models.evc.EVC.deploy")
    @patch("napps.kytos.mef_eline.scheduler.Scheduler.add")
    @patch("napps.kytos.mef_eline.main.Main._uni_from_dict")
    @patch("napps.kytos.mef_eline.controllers.ELineController.upsert_evc")
    @patch("napps.kytos.mef_eline.main.EVC.as_dict")
    @patch("napps.kytos.mef_eline.models.evc.EVC._validate")
    def test_create_a_circuit_case_1(self, *args):
        """Test create a new circuit."""
        # pylint: disable=too-many-locals
        (
            validate_mock,
            evc_as_dict_mock,
            mongo_controller_upsert_mock,
            uni_from_dict_mock,
            sched_add_mock,
            evc_deploy_mock,
        ) = args

        validate_mock.return_value = True
        mongo_controller_upsert_mock.return_value = True
        evc_deploy_mock.return_value = True
        uni1 = create_autospec(UNI)
        uni2 = create_autospec(UNI)
        uni1.interface = create_autospec(Interface)
        uni2.interface = create_autospec(Interface)
        uni1.interface.switch = "00:00:00:00:00:00:00:01"
        uni2.interface.switch = "00:00:00:00:00:00:00:02"
        uni_from_dict_mock.side_effect = [uni1, uni2]
        evc_as_dict_mock.return_value = {}
        sched_add_mock.return_value = True
        self.napp.mongo_controller.get_circuits.return_value = {}

        api = self.get_app_test_client(self.napp)
        url = f"{self.server_name_url}/v2/evc/"
        payload = {
            "name": "my evc1",
            "frequency": "* * * * *",
            "uni_a": {
                "interface_id": "00:00:00:00:00:00:00:01:1",
                "tag": {"tag_type": 1, "value": 80},
            },
            "uni_z": {
                "interface_id": "00:00:00:00:00:00:00:02:2",
                "tag": {"tag_type": 1, "value": 1},
            },
            "dynamic_backup_path": True,
            "primary_constraints": {
                "spf_max_path_cost": 8,
                "mandatory_metrics": {
                    "ownership": "red"
                }
            },
            "secondary_constraints": {
                "mandatory_metrics": {
                    "ownership": "blue"
                }
            }
        }

        response = api.post(
            url, data=json.dumps(payload), content_type="application/json"
        )
        current_data = json.loads(response.data)

        # verify expected result from request
        self.assertEqual(201, response.status_code, response.data)
        self.assertIn("circuit_id", current_data)

        # verify uni called
        uni_from_dict_mock.called_twice()
        uni_from_dict_mock.assert_any_call(payload["uni_z"])
        uni_from_dict_mock.assert_any_call(payload["uni_a"])

        # verify validation called
        validate_mock.assert_called_once()
        validate_mock.assert_called_with(
            table_group={'evpl': 0, 'epl': 0},
            frequency="* * * * *",
            name="my evc1",
            uni_a=uni1,
            uni_z=uni2,
            dynamic_backup_path=True,
            primary_constraints=payload["primary_constraints"],
            secondary_constraints=payload["secondary_constraints"],
        )
        # verify save method is called
        mongo_controller_upsert_mock.assert_called_once()

        # verify evc as dict is called to save in the box
        evc_as_dict_mock.assert_called()
        # verify add circuit in sched
        sched_add_mock.assert_called_once()

    @staticmethod
    def get_napp_urls(napp):
        """Return the kytos/mef_eline urls.

        The urls will be like:

        urls = [
            (options, methods, url)
        ]

        """
        controller = napp.controller
        controller.api_server.register_napp_endpoints(napp)

        urls = []
        for rule in controller.api_server.app.url_map.iter_rules():
            options = {}
            for arg in rule.arguments:
                options[arg] = f"[{0}]".format(arg)

            if f"{napp.username}/{napp.name}" in str(rule):
                urls.append((options, rule.methods, f"{str(rule)}"))

        return urls

    @staticmethod
    def get_app_test_client(napp):
        """Return a flask api test client."""
        napp.controller.api_server.register_napp_endpoints(napp)
        return napp.controller.api_server.app.test_client()

    def test_create_a_circuit_case_2(self):
        """Test create a new circuit trying to send request without a json."""
        api = self.get_app_test_client(self.napp)
        url = f"{self.server_name_url}/v2/evc/"

        response = api.post(url)
        current_data = json.loads(response.data)
        expected_message = "The request body mimetype is not application/json."
        expected_data = expected_message
        self.assertEqual(415, response.status_code, response.data)
        self.assertEqual(current_data["description"], expected_data)

    def test_create_a_circuit_case_3(self):
        """Test create a new circuit trying to send request with an
        invalid json."""
        api = self.get_app_test_client(self.napp)
        url = f"{self.server_name_url}/v2/evc/"

        response = api.post(
            url,
            data="This is an {Invalid:} JSON",
            content_type="application/json",
        )
        current_data = json.loads(response.data)
        expected_data = "The request body is not a well-formed JSON."

        self.assertEqual(400, response.status_code, response.data)
        self.assertEqual(current_data["description"], expected_data)

    @patch("napps.kytos.mef_eline.main.Main._uni_from_dict")
    @patch("napps.kytos.mef_eline.controllers.ELineController.upsert_evc")
    def test_create_a_circuit_case_4(
        self,
        mongo_controller_upsert_mock,
        uni_from_dict_mock
    ):
        """Test create a new circuit trying to send request with an
        invalid value."""
        # pylint: disable=too-many-locals
        uni_from_dict_mock.side_effect = ValueError("Could not instantiate")
        mongo_controller_upsert_mock.return_value = True
        api = self.get_app_test_client(self.napp)
        url = f"{self.server_name_url}/v2/evc/"

        payload = {
            "name": "my evc1",
            "frequency": "* * * * *",
            "uni_a": {
                "interface_id": "00:00:00:00:00:00:00:01:76",
                "tag": {"tag_type": 1, "value": 80},
            },
            "uni_z": {
                "interface_id": "00:00:00:00:00:00:00:02:2",
                "tag": {"tag_type": 1, "value": 1},
            },
        }

        response = api.post(
            url, data=json.dumps(payload), content_type="application/json"
        )
        current_data = json.loads(response.data)
        expected_data = "Error creating UNI: Invalid value"
        self.assertEqual(400, response.status_code, response.data)
        self.assertEqual(current_data["description"], expected_data)

        payload["name"] = 1
        response = api.post(
            url, data=json.dumps(payload), content_type="application/json"
        )
        self.assertEqual(400, response.status_code, response.data)

    def test_create_a_circuit_invalid_queue_id(self):
        """Test create a new circuit with invalid queue_id."""
        api = self.get_app_test_client(self.napp)
        url = f"{self.server_name_url}/v2/evc/"

        payload = {
            "name": "my evc1",
            "queue_id": 8,
            "uni_a": {
                "interface_id": "00:00:00:00:00:00:00:01:76",
                "tag": {"tag_type": 1, "value": 80},
            },
            "uni_z": {
                "interface_id": "00:00:00:00:00:00:00:02:2",
                "tag": {"tag_type": 1, "value": 1},
            },
        }
        response = api.post(
            url,
            data=json.dumps(payload),
            content_type="application/json",
        )
        current_data = json.loads(response.data)
        expected_data = "8 is greater than the maximum of 7"

        assert response.status_code == 400
        assert expected_data in current_data["description"], expected_data

    @patch("napps.kytos.mef_eline.models.evc.EVC.deploy")
    @patch("napps.kytos.mef_eline.scheduler.Scheduler.add")
    @patch("napps.kytos.mef_eline.main.Main._uni_from_dict")
    @patch("napps.kytos.mef_eline.controllers.ELineController.upsert_evc")
    @patch("napps.kytos.mef_eline.models.evc.EVC._validate")
    @patch("napps.kytos.mef_eline.main.EVC.as_dict")
    def test_create_circuit_already_enabled(self, *args):
        """Test create an already created circuit."""
        # pylint: disable=too-many-locals
        (
            evc_as_dict_mock,
            validate_mock,
            mongo_controller_upsert_mock,
            uni_from_dict_mock,
            sched_add_mock,
            evc_deploy_mock,
        ) = args

        validate_mock.return_value = True
        mongo_controller_upsert_mock.return_value = True
        sched_add_mock.return_value = True
        evc_deploy_mock.return_value = True
        uni1 = create_autospec(UNI)
        uni2 = create_autospec(UNI)
        uni1.interface = create_autospec(Interface)
        uni2.interface = create_autospec(Interface)
        uni1.interface.switch = "00:00:00:00:00:00:00:01"
        uni2.interface.switch = "00:00:00:00:00:00:00:02"
        uni_from_dict_mock.side_effect = [uni1, uni2, uni1, uni2]

        api = self.get_app_test_client(self.napp)
        payload = {
            "name": "my evc1",
            "uni_a": {
                "interface_id": "00:00:00:00:00:00:00:01:1",
                "tag": {"tag_type": 1, "value": 80},
            },
            "uni_z": {
                "interface_id": "00:00:00:00:00:00:00:02:2",
                "tag": {"tag_type": 1, "value": 1},
            },
            "dynamic_backup_path": True,
        }

        evc_as_dict_mock.return_value = payload
        response = api.post(
            f"{self.server_name_url}/v2/evc/",
            data=json.dumps(payload),
            content_type="application/json",
        )
        self.assertEqual(201, response.status_code)

        response = api.post(
            f"{self.server_name_url}/v2/evc/",
            data=json.dumps(payload),
            content_type="application/json",
        )
        current_data = json.loads(response.data)
        expected_data = "The EVC already exists."
        self.assertEqual(current_data["description"], expected_data)
        self.assertEqual(409, response.status_code)

    @patch("napps.kytos.mef_eline.main.Main._uni_from_dict")
    def test_create_circuit_case_5(self, uni_from_dict_mock):
        """Test when neither primary path nor dynamic_backup_path is set."""
        api = self.get_app_test_client(self.napp)
        url = f"{self.server_name_url}/v2/evc/"
        uni1 = create_autospec(UNI)
        uni2 = create_autospec(UNI)
        uni1.interface = create_autospec(Interface)
        uni2.interface = create_autospec(Interface)
        uni1.interface.switch = "00:00:00:00:00:00:00:01"
        uni2.interface.switch = "00:00:00:00:00:00:00:02"
        uni_from_dict_mock.side_effect = [uni1, uni2, uni1, uni2]

        payload = {
            "name": "my evc1",
            "frequency": "* * * * *",
            "uni_a": {
                "interface_id": "00:00:00:00:00:00:00:01:1",
                "tag": {"tag_type": 1, "value": 80},
            },
            "uni_z": {
                "interface_id": "00:00:00:00:00:00:00:02:2",
                "tag": {"tag_type": 1, "value": 1},
            },
        }

        response = api.post(
            url, data=json.dumps(payload), content_type="application/json"
        )
        current_data = json.loads(response.data)
        expected_data = "The EVC must have a primary path "
        expected_data += "or allow dynamic paths."
        self.assertEqual(400, response.status_code, response.data)
        self.assertEqual(current_data["description"], expected_data)

    def test_redeploy_evc(self):
        """Test endpoint to redeploy an EVC."""
        evc1 = MagicMock()
        evc1.is_enabled.return_value = True
        self.napp.circuits = {"1": evc1, "2": MagicMock()}
        api = self.get_app_test_client(self.napp)
        url = f"{self.server_name_url}/v2/evc/1/redeploy"
        response = api.patch(url)
        self.assertEqual(response.status_code, 202, response.data)

    def test_redeploy_evc_disabled(self):
        """Test endpoint to redeploy an EVC."""
        evc1 = MagicMock()
        evc1.is_enabled.return_value = False
        self.napp.circuits = {"1": evc1, "2": MagicMock()}
        api = self.get_app_test_client(self.napp)
        url = f"{self.server_name_url}/v2/evc/1/redeploy"
        response = api.patch(url)
        self.assertEqual(response.status_code, 409, response.data)

    def test_redeploy_evc_deleted(self):
        """Test endpoint to redeploy an EVC."""
        evc1 = MagicMock()
        evc1.is_enabled.return_value = True
        self.napp.circuits = {"1": evc1, "2": MagicMock()}
        api = self.get_app_test_client(self.napp)
        url = f"{self.server_name_url}/v2/evc/3/redeploy"
        response = api.patch(url)
        self.assertEqual(response.status_code, 404, response.data)

    def test_list_schedules__no_data_stored(self):
        """Test if list circuits return all circuits stored."""
        self.napp.mongo_controller.get_circuits.return_value = {"circuits": {}}

        api = self.get_app_test_client(self.napp)
        url = f"{self.server_name_url}/v2/evc/schedule"

        response = api.get(url)
        expected_result = {}

        self.assertEqual(response.status_code, 200, response.data)
        self.assertEqual(json.loads(response.data), expected_result)

    def _add_mongodb_schedule_data(self, data_mock):
        """Add schedule data to mongodb mock object."""
        circuits = {"circuits": {}}
        payload_1 = {
            "id": "aa:aa:aa",
            "name": "my evc1",
            "uni_a": {
                "interface_id": "00:00:00:00:00:00:00:01:1",
                "tag": {"tag_type": 1, "value": 80},
            },
            "uni_z": {
                "interface_id": "00:00:00:00:00:00:00:02:2",
                "tag": {"tag_type": 1, "value": 1},
            },
            "circuit_scheduler": [
                {"id": "1", "frequency": "* * * * *", "action": "create"},
                {"id": "2", "frequency": "1 * * * *", "action": "remove"},
            ],
        }
        circuits["circuits"].update({"aa:aa:aa": payload_1})
        payload_2 = {
            "id": "bb:bb:bb",
            "name": "my second evc2",
            "uni_a": {
                "interface_id": "00:00:00:00:00:00:00:01:2",
                "tag": {"tag_type": 1, "value": 90},
            },
            "uni_z": {
                "interface_id": "00:00:00:00:00:00:00:03:2",
                "tag": {"tag_type": 1, "value": 100},
            },
            "circuit_scheduler": [
                {"id": "3", "frequency": "1 * * * *", "action": "create"},
                {"id": "4", "frequency": "2 * * * *", "action": "remove"},
            ],
        }
        circuits["circuits"].update({"bb:bb:bb": payload_2})
        payload_3 = {
            "id": "cc:cc:cc",
            "name": "my third evc3",
            "uni_a": {
                "interface_id": "00:00:00:00:00:00:00:03:1",
                "tag": {"tag_type": 1, "value": 90},
            },
            "uni_z": {
                "interface_id": "00:00:00:00:00:00:00:04:2",
                "tag": {"tag_type": 1, "value": 100},
            },
        }
        circuits["circuits"].update({"cc:cc:cc": payload_3})
        # Add one circuit to the mongodb.
        data_mock.return_value = circuits

    def test_list_schedules_from_mongodb(self):
        """Test if list circuits return specific circuits stored."""
        self._add_mongodb_schedule_data(
            self.napp.mongo_controller.get_circuits
        )

        api = self.get_app_test_client(self.napp)
        url = f"{self.server_name_url}/v2/evc/schedule"

        # Call URL
        response = api.get(url)
        # Expected JSON data from response
        expected = [
            {
                "circuit_id": "aa:aa:aa",
                "schedule": {
                    "action": "create",
                    "frequency": "* * * * *",
                    "id": "1",
                },
                "schedule_id": "1",
            },
            {
                "circuit_id": "aa:aa:aa",
                "schedule": {
                    "action": "remove",
                    "frequency": "1 * * * *",
                    "id": "2",
                },
                "schedule_id": "2",
            },
            {
                "circuit_id": "bb:bb:bb",
                "schedule": {
                    "action": "create",
                    "frequency": "1 * * * *",
                    "id": "3",
                },
                "schedule_id": "3",
            },
            {
                "circuit_id": "bb:bb:bb",
                "schedule": {
                    "action": "remove",
                    "frequency": "2 * * * *",
                    "id": "4",
                },
                "schedule_id": "4",
            },
        ]

        self.assertEqual(response.status_code, 200, response.data)
        self.assertEqual(expected, json.loads(response.data))

    def test_get_specific_schedule_from_mongodb(self):
        """Test get schedules from a circuit."""
        self._add_mongodb_schedule_data(
            self.napp.mongo_controller.get_circuits
        )

        requested_circuit_id = "bb:bb:bb"
        evc = self.napp.mongo_controller.get_circuits()
        evc = evc["circuits"][requested_circuit_id]
        self.napp.mongo_controller.get_circuit.return_value = evc
        api = self.get_app_test_client(self.napp)
        url = f"{self.server_name_url}/v2/evc/{requested_circuit_id}"

        # Call URL
        response = api.get(url)

        # Expected JSON data from response
        expected = [
            {"action": "create", "frequency": "1 * * * *", "id": "3"},
            {"action": "remove", "frequency": "2 * * * *", "id": "4"},
        ]

        self.assertEqual(response.status_code, 200)
        self.assertEqual(
            expected, json.loads(response.data)["circuit_scheduler"]
        )

    def test_get_specific_schedules_from_mongodb_not_found(self):
        """Test get specific schedule ID that does not exist."""
        requested_id = "blah"
        api = self.get_app_test_client(self.napp)
        self.napp.mongo_controller.get_circuit.return_value = None
        url = f"{self.server_name_url}/v2/evc/{requested_id}"

        # Call URL
        response = api.get(url)

        expected = "circuit_id blah not found"
        # Assert response not found
        self.assertEqual(response.status_code, 404, response.data)
        self.assertEqual(expected, json.loads(response.data)["description"])

    def _uni_from_dict_side_effect(self, uni_dict):
        interface_id = uni_dict.get("interface_id")
        tag_dict = uni_dict.get("tag")
        interface = Interface(interface_id, "0", MagicMock(id="1"))
        return UNI(interface, tag_dict)

    @patch("apscheduler.schedulers.background.BackgroundScheduler.add_job")
    @patch("napps.kytos.mef_eline.scheduler.Scheduler.add")
    @patch("napps.kytos.mef_eline.main.Main._uni_from_dict")
    @patch("napps.kytos.mef_eline.controllers.ELineController.upsert_evc")
    @patch("napps.kytos.mef_eline.main.EVC.as_dict")
    @patch("napps.kytos.mef_eline.models.evc.EVC._validate")
    def test_create_schedule(self, *args):  # pylint: disable=too-many-locals
        """Test create a circuit schedule."""
        (
            validate_mock,
            evc_as_dict_mock,
            mongo_controller_upsert_mock,
            uni_from_dict_mock,
            sched_add_mock,
            scheduler_add_job_mock,
        ) = args

        validate_mock.return_value = True
        mongo_controller_upsert_mock.return_value = True
        uni_from_dict_mock.side_effect = self._uni_from_dict_side_effect
        evc_as_dict_mock.return_value = {}
        sched_add_mock.return_value = True

        self._add_mongodb_schedule_data(
            self.napp.mongo_controller.get_circuits
        )

        requested_id = "bb:bb:bb"
        api = self.get_app_test_client(self.napp)
        url = f"{self.server_name_url}/v2/evc/schedule/"

        payload = {
            "circuit_id": requested_id,
            "schedule": {"frequency": "1 * * * *", "action": "create"},
            "metadata": {"metadata1": "test_data"},
        }

        # Call URL
        response = api.post(
            url, data=json.dumps(payload), content_type="application/json"
        )

        response_json = json.loads(response.data)

        self.assertEqual(response.status_code, 201, response.data)
        scheduler_add_job_mock.assert_called_once()
        mongo_controller_upsert_mock.assert_called_once()
        self.assertEqual(
            payload["schedule"]["frequency"], response_json["frequency"]
        )
        self.assertEqual(
            payload["schedule"]["action"], response_json["action"]
        )
        self.assertIsNotNone(response_json["id"])

        # Case 2: there is no schedule
        payload = {
              "circuit_id": "cc:cc:cc",
              "schedule": {
                "frequency": "1 * * * *",
                "action": "create"
              }
            }
        response = api.post(url, data=json.dumps(payload),
                            content_type='application/json')
        self.assertEqual(response.status_code, 201)

    def test_create_schedule_invalid_request(self):
        """Test create schedule API with invalid request."""
        evc1 = MagicMock()
        self.napp.circuits = {'bb:bb:bb': evc1}
        api = self.get_app_test_client(self.napp)
        url = f'{self.server_name_url}/v2/evc/schedule/'

        # case 1: empty post
        response = api.post(url, data="")
        self.assertEqual(response.status_code, 415)

        # case 2: content-type not specified
        payload = {
            "circuit_id": "bb:bb:bb",
            "schedule": {
                "frequency": "1 * * * *",
                "action": "create"
            }
        }
        response = api.post(url, data=json.dumps(payload))
        self.assertEqual(response.status_code, 415)

        # case 3: not a dictionary
        payload = []
        response = api.post(url, data=json.dumps(payload),
                            content_type='application/json')
        self.assertEqual(response.status_code, 400)

        # case 4: missing circuit id
        payload = {
            "schedule": {
                "frequency": "1 * * * *",
                "action": "create"
            }
        }
        response = api.post(url, data=json.dumps(payload),
                            content_type='application/json')
        self.assertEqual(response.status_code, 400)

        # case 5: missing schedule
        payload = {
            "circuit_id": "bb:bb:bb"
        }
        response = api.post(url, data=json.dumps(payload),
                            content_type='application/json')
        self.assertEqual(response.status_code, 400)

        # case 6: invalid circuit
        payload = {
            "circuit_id": "xx:xx:xx",
            "schedule": {
                "frequency": "1 * * * *",
                "action": "create"
            }
        }
        response = api.post(url, data=json.dumps(payload),
                            content_type='application/json')
        self.assertEqual(response.status_code, 404)

        # case 7: archived or deleted evc
        evc1.archived.return_value = True
        payload = {
            "circuit_id": "bb:bb:bb",
            "schedule": {
                "frequency": "1 * * * *",
                "action": "create"
            }
        }
        response = api.post(url, data=json.dumps(payload),
                            content_type='application/json')
        self.assertEqual(response.status_code, 403)

        # case 8: invalid json
        response = api.post(url, data='{"test"}',
                            content_type='application/json')
        self.assertEqual(response.status_code, 400)

    @patch('apscheduler.schedulers.background.BackgroundScheduler.remove_job')
    @patch('napps.kytos.mef_eline.scheduler.Scheduler.add')
    @patch('napps.kytos.mef_eline.main.Main._uni_from_dict')
    @patch("napps.kytos.mef_eline.controllers.ELineController.upsert_evc")
    @patch('napps.kytos.mef_eline.main.EVC.as_dict')
    @patch('napps.kytos.mef_eline.models.evc.EVC._validate')
    def test_update_schedule(self, *args):  # pylint: disable=too-many-locals
        """Test create a circuit schedule."""
        (
            validate_mock,
            evc_as_dict_mock,
            mongo_controller_upsert_mock,
            uni_from_dict_mock,
            sched_add_mock,
            scheduler_remove_job_mock,
        ) = args

        mongo_payload_1 = {
            "circuits": {
                "aa:aa:aa": {
                    "id": "aa:aa:aa",
                    "name": "my evc1",
                    "uni_a": {
                        "interface_id": "00:00:00:00:00:00:00:01:1",
                        "tag": {"tag_type": 1, "value": 80},
                    },
                    "uni_z": {
                        "interface_id": "00:00:00:00:00:00:00:02:2",
                        "tag": {"tag_type": 1, "value": 1},
                    },
                    "circuit_scheduler": [
                        {
                            "id": "1",
                            "frequency": "* * * * *",
                            "action": "create"
                        }
                    ],
                }
            }
        }

        validate_mock.return_value = True
        mongo_controller_upsert_mock.return_value = True
        sched_add_mock.return_value = True
        uni_from_dict_mock.side_effect = ["uni_a", "uni_z"]
        evc_as_dict_mock.return_value = {}
        self.napp.mongo_controller.get_circuits.return_value = mongo_payload_1
        scheduler_remove_job_mock.return_value = True

        requested_schedule_id = "1"
        api = self.get_app_test_client(self.napp)
        url = f"{self.server_name_url}/v2/evc/schedule/{requested_schedule_id}"

        payload = {"frequency": "*/1 * * * *", "action": "create"}

        # Call URL
        response = api.patch(
            url, data=json.dumps(payload), content_type="application/json"
        )

        response_json = json.loads(response.data)

        self.assertEqual(response.status_code, 200, response.data)
        scheduler_remove_job_mock.assert_called_once()
        mongo_controller_upsert_mock.assert_called_once()
        self.assertEqual(payload["frequency"], response_json["frequency"])
        self.assertEqual(payload["action"], response_json["action"])
        self.assertIsNotNone(response_json["id"])

    @patch('napps.kytos.mef_eline.main.Main._find_evc_by_schedule_id')
    def test_update_no_schedule(self, find_evc_by_schedule_id_mock):
        """Test update a circuit schedule."""
        api = self.get_app_test_client(self.napp)
        url = f"{self.server_name_url}/v2/evc/schedule/1"
        payload = {"frequency": "*/1 * * * *", "action": "create"}

        find_evc_by_schedule_id_mock.return_value = None, None

        response = api.patch(
            url, data=json.dumps(payload), content_type="application/json"
        )

        self.assertEqual(response.status_code, 404)

    @patch("napps.kytos.mef_eline.scheduler.Scheduler.add")
    @patch("napps.kytos.mef_eline.main.Main._uni_from_dict")
    @patch("napps.kytos.mef_eline.main.EVC.as_dict")
    @patch("napps.kytos.mef_eline.models.evc.EVC._validate")
    def test_update_schedule_archived(self, *args):
        """Test create a circuit schedule."""
        # pylint: disable=too-many-locals
        (
            validate_mock,
            evc_as_dict_mock,
            uni_from_dict_mock,
            sched_add_mock,
        ) = args

        mongo_payload_1 = {
            "circuits": {
                "aa:aa:aa": {
                    "id": "aa:aa:aa",
                    "name": "my evc1",
                    "archived": True,
                    "circuit_scheduler": [
                        {
                            "id": "1",
                            "frequency": "* * * * *",
                            "action": "create"
                        }
                    ],
                }
            }
        }

        validate_mock.return_value = True
        sched_add_mock.return_value = True
        uni_from_dict_mock.side_effect = ["uni_a", "uni_z"]
        evc_as_dict_mock.return_value = {}
        self.napp.mongo_controller.get_circuits.return_value = mongo_payload_1

        requested_schedule_id = "1"
        api = self.get_app_test_client(self.napp)
        url = f"{self.server_name_url}/v2/evc/schedule/{requested_schedule_id}"

        payload = {"frequency": "*/1 * * * *", "action": "create"}

        # Call URL
        response = api.patch(
            url, data=json.dumps(payload), content_type="application/json"
        )

        self.assertEqual(response.status_code, 403, response.data)

    @patch("apscheduler.schedulers.background.BackgroundScheduler.remove_job")
    @patch("napps.kytos.mef_eline.main.Main._uni_from_dict")
    @patch("napps.kytos.mef_eline.controllers.ELineController.upsert_evc")
    @patch("napps.kytos.mef_eline.main.EVC.as_dict")
    @patch("napps.kytos.mef_eline.models.evc.EVC._validate")
    def test_delete_schedule(self, *args):
        """Test create a circuit schedule."""
        (
            validate_mock,
            evc_as_dict_mock,
            mongo_controller_upsert_mock,
            uni_from_dict_mock,
            scheduler_remove_job_mock,
        ) = args

        mongo_payload_1 = {
            "circuits": {
                "2": {
                    "id": "2",
                    "name": "my evc1",
                    "uni_a": {
                        "interface_id": "00:00:00:00:00:00:00:01:1",
                        "tag": {"tag_type": 1, "value": 80},
                    },
                    "uni_z": {
                        "interface_id": "00:00:00:00:00:00:00:02:2",
                        "tag": {"tag_type": 1, "value": 1},
                    },
                    "circuit_scheduler": [
                        {
                            "id": "1",
                            "frequency": "* * * * *",
                            "action": "create"
                        }
                    ],
                }
            }
        }
        validate_mock.return_value = True
        mongo_controller_upsert_mock.return_value = True
        uni_from_dict_mock.side_effect = ["uni_a", "uni_z"]
        evc_as_dict_mock.return_value = {}
        self.napp.mongo_controller.get_circuits.return_value = mongo_payload_1
        scheduler_remove_job_mock.return_value = True

        requested_schedule_id = "1"
        api = self.get_app_test_client(self.napp)
        url = f"{self.server_name_url}/v2/evc/schedule/{requested_schedule_id}"

        # Call URL
        response = api.delete(url)

        self.assertEqual(response.status_code, 200, response.data)
        scheduler_remove_job_mock.assert_called_once()
        mongo_controller_upsert_mock.assert_called_once()
        self.assertIn("Schedule removed", f"{response.data}")

    @patch("napps.kytos.mef_eline.main.Main._uni_from_dict")
    @patch("napps.kytos.mef_eline.main.EVC.as_dict")
    @patch("napps.kytos.mef_eline.models.evc.EVC._validate")
    def test_delete_schedule_archived(self, *args):
        """Test create a circuit schedule."""
        (
            validate_mock,
            evc_as_dict_mock,
            uni_from_dict_mock,
        ) = args

        mongo_payload_1 = {
            "circuits": {
                "2": {
                    "id": "2",
                    "name": "my evc1",
                    "archived": True,
                    "circuit_scheduler": [
                        {
                            "id": "1",
                            "frequency": "* * * * *",
                            "action": "create"
                        }
                    ],
                }
            }
        }

        validate_mock.return_value = True
        uni_from_dict_mock.side_effect = ["uni_a", "uni_z"]
        evc_as_dict_mock.return_value = {}
        self.napp.mongo_controller.get_circuits.return_value = mongo_payload_1

        requested_schedule_id = "1"
        api = self.get_app_test_client(self.napp)
        url = f"{self.server_name_url}/v2/evc/schedule/{requested_schedule_id}"

        # Call URL
        response = api.delete(url)

        self.assertEqual(response.status_code, 403, response.data)

    @patch('napps.kytos.mef_eline.main.Main._find_evc_by_schedule_id')
    def test_delete_schedule_not_found(self, mock_find_evc_by_sched):
        """Test delete a circuit schedule - unexisting."""
        mock_find_evc_by_sched.return_value = (None, False)
        api = self.get_app_test_client(self.napp)
        url = f'{self.server_name_url}/v2/evc/schedule/1'
        response = api.delete(url)
        self.assertEqual(response.status_code, 404)

    def test_get_evcs_by_svc_level(self) -> None:
        """Test get_evcs_by_svc_level."""
        levels = [1, 2, 4, 2, 7]
        evcs = {i: MagicMock(service_level=v, creation_time=1)
                for i, v in enumerate(levels)}
        self.napp.circuits = evcs
        expected_levels = sorted(levels, reverse=True)
        evcs_by_level = self.napp.get_evcs_by_svc_level()
        assert evcs_by_level

        for evc, exp_level in zip(evcs_by_level, expected_levels):
            assert evc.service_level == exp_level

        evcs = {i: MagicMock(service_level=1, creation_time=i)
                for i in reversed(range(2))}
        self.napp.circuits = evcs
        evcs_by_level = self.napp.get_evcs_by_svc_level()
        for i in range(2):
            assert evcs_by_level[i].creation_time == i

    def test_get_circuit_not_found(self):
        """Test /v2/evc/<circuit_id> 404."""
        self.napp.mongo_controller.get_circuit.return_value = None
        api = self.get_app_test_client(self.napp)
        url = f'{self.server_name_url}/v2/evc/1234'
        response = api.get(url)
        self.assertEqual(response.status_code, 404)

    @patch('requests.post')
    @patch('napps.kytos.mef_eline.scheduler.Scheduler.add')
    @patch("napps.kytos.mef_eline.controllers.ELineController.upsert_evc")
    @patch('napps.kytos.mef_eline.models.evc.EVC._validate')
    @patch('kytos.core.Controller.get_interface_by_id')
    @patch('napps.kytos.mef_eline.models.path.Path.is_valid')
    @patch('napps.kytos.mef_eline.models.evc.EVCDeploy.deploy')
    @patch('napps.kytos.mef_eline.main.Main._uni_from_dict')
    @patch('napps.kytos.mef_eline.main.EVC.as_dict')
    def test_update_circuit(self, *args):
        """Test update a circuit circuit."""
        # pylint: disable=too-many-locals,duplicate-code
        (
            evc_as_dict_mock,
            uni_from_dict_mock,
            evc_deploy,
            _,
            interface_by_id_mock,
            _,
            _,
            _,
            requests_mock,
        ) = args

        interface_by_id_mock.return_value = get_uni_mocked().interface
        unis = [
            get_uni_mocked(switch_dpid="00:00:00:00:00:00:00:01"),
            get_uni_mocked(switch_dpid="00:00:00:00:00:00:00:02"),
        ]
        uni_from_dict_mock.side_effect = 2 * unis

        response = MagicMock()
        response.status_code = 201
        requests_mock.return_value = response

        api = self.get_app_test_client(self.napp)
        payloads = [
            {
                "name": "my evc1",
                "uni_a": {
                    "interface_id": "00:00:00:00:00:00:00:01:1",
                    "tag": {"tag_type": 1, "value": 80},
                },
                "uni_z": {
                    "interface_id": "00:00:00:00:00:00:00:02:2",
                    "tag": {"tag_type": 1, "value": 1},
                },
                "dynamic_backup_path": True,
            },
            {
                "primary_path": [
                    {
                        "endpoint_a": {"id": "00:00:00:00:00:00:00:01:1"},
                        "endpoint_b": {"id": "00:00:00:00:00:00:00:02:2"},
                    }
                ]
            },
            {
                "sb_priority": 3
            },
            {
                # It works only with 'enable' and not with 'enabled'
                "enable": True
            },
            {
                "name": "my evc1",
                "active": True,
                "enable": True,
                "uni_a": {
                    "interface_id": "00:00:00:00:00:00:00:01:1",
                    "tag": {
                        "tag_type": 1,
                        "value": 80
                    }
                },
                "uni_z": {
                    "interface_id": "00:00:00:00:00:00:00:02:2",
                    "tag": {
                        "tag_type": 1,
                        "value": 1
                    }
                },
                "priority": 3,
                "bandwidth": 1000,
                "dynamic_backup_path": True
            }
        ]

        evc_as_dict_mock.return_value = payloads[0]
        response = api.post(
            f"{self.server_name_url}/v2/evc/",
            data=json.dumps(payloads[0]),
            content_type="application/json",
        )
        self.assertEqual(201, response.status_code)

        evc_deploy.reset_mock()
        evc_as_dict_mock.return_value = payloads[1]
        current_data = json.loads(response.data)
        circuit_id = current_data["circuit_id"]
        response = api.patch(
            f"{self.server_name_url}/v2/evc/{circuit_id}",
            data=json.dumps(payloads[1]),
            content_type="application/json",
        )
        # evc_deploy.assert_called_once()
        self.assertEqual(200, response.status_code)

        evc_deploy.reset_mock()
        evc_as_dict_mock.return_value = payloads[2]
        response = api.patch(
            f"{self.server_name_url}/v2/evc/{circuit_id}",
            data=json.dumps(payloads[2]),
            content_type="application/json",
        )
        evc_deploy.assert_not_called()
        self.assertEqual(200, response.status_code)

        evc_deploy.reset_mock()
        evc_as_dict_mock.return_value = payloads[3]
        response = api.patch(f'{self.server_name_url}/v2/evc/{circuit_id}',
                             data=json.dumps(payloads[3]),
                             content_type='application/json')
        evc_deploy.assert_called_once()
        self.assertEqual(200, response.status_code)

        evc_deploy.reset_mock()
        response = api.patch(f'{self.server_name_url}/v2/evc/{circuit_id}',
                             data='{"priority":5,}',
                             content_type='application/json')
        evc_deploy.assert_not_called()
        self.assertEqual(400, response.status_code)

        evc_deploy.reset_mock()
        response = api.patch(
            f"{self.server_name_url}/v2/evc/{circuit_id}",
            data=json.dumps(payloads[3]),
            content_type="application/json",
        )
        evc_deploy.assert_called_once()
        self.assertEqual(200, response.status_code)

        response = api.patch(
            f"{self.server_name_url}/v2/evc/1234",
            data=json.dumps(payloads[1]),
            content_type="application/json",
        )
        current_data = json.loads(response.data)
        expected_data = "circuit_id 1234 not found"
        self.assertEqual(current_data["description"], expected_data)
        self.assertEqual(404, response.status_code)

        api.delete(f"{self.server_name_url}/v2/evc/{circuit_id}")
        evc_deploy.reset_mock()
        response = api.patch(
            f"{self.server_name_url}/v2/evc/{circuit_id}",
            data=json.dumps(payloads[1]),
            content_type="application/json",
        )
        evc_deploy.assert_not_called()
        self.assertEqual(405, response.status_code)

    @patch("napps.kytos.mef_eline.models.evc.EVC.deploy")

This code seems to be duplicated in your project.

    @patch("napps.kytos.mef_eline.scheduler.Scheduler.add")
    @patch("napps.kytos.mef_eline.main.Main._uni_from_dict")
    @patch("napps.kytos.mef_eline.controllers.ELineController.upsert_evc")
    @patch("napps.kytos.mef_eline.models.evc.EVC._validate")
    @patch("napps.kytos.mef_eline.main.EVC.as_dict")
    def test_update_circuit_invalid_json(self, *args):
        """Test update a circuit circuit."""
        # pylint: disable=too-many-locals
        (
            evc_as_dict_mock,
            validate_mock,
            mongo_controller_upsert_mock,
            uni_from_dict_mock,
            sched_add_mock,
            evc_deploy_mock,
        ) = args

        validate_mock.return_value = True
        mongo_controller_upsert_mock.return_value = True
        sched_add_mock.return_value = True
        evc_deploy_mock.return_value = True
        uni1 = create_autospec(UNI)
        uni2 = create_autospec(UNI)
        uni1.interface = create_autospec(Interface)
        uni2.interface = create_autospec(Interface)
        uni1.interface.switch = "00:00:00:00:00:00:00:01"
        uni2.interface.switch = "00:00:00:00:00:00:00:02"
        uni_from_dict_mock.side_effect = [uni1, uni2, uni1, uni2]

        api = self.get_app_test_client(self.napp)
        payload1 = {
            "name": "my evc1",
            "uni_a": {
                "interface_id": "00:00:00:00:00:00:00:01:1",
                "tag": {"tag_type": 1, "value": 80},
            },
            "uni_z": {
                "interface_id": "00:00:00:00:00:00:00:02:2",
                "tag": {"tag_type": 1, "value": 1},
            },
            "dynamic_backup_path": True,
        }

        payload2 = {
            "dynamic_backup_path": False,
        }

        evc_as_dict_mock.return_value = payload1
        response = api.post(
            f"{self.server_name_url}/v2/evc/",
            data=json.dumps(payload1),
            content_type="application/json",
        )
        self.assertEqual(201, response.status_code)

        evc_as_dict_mock.return_value = payload2
        current_data = json.loads(response.data)
        circuit_id = current_data["circuit_id"]
        response = api.patch(
            f"{self.server_name_url}/v2/evc/{circuit_id}",
            data=payload2,
            content_type="application/json",
        )
        current_data = json.loads(response.data)
        expected_data = "The request body is not a well-formed JSON."
        self.assertEqual(current_data["description"], expected_data)
        self.assertEqual(400, response.status_code)

    @patch("napps.kytos.mef_eline.models.evc.EVC.deploy")
    @patch("napps.kytos.mef_eline.scheduler.Scheduler.add")
    @patch("napps.kytos.mef_eline.main.Main._uni_from_dict")
    @patch("napps.kytos.mef_eline.main.Main._link_from_dict")
    @patch("napps.kytos.mef_eline.controllers.ELineController.upsert_evc")
    @patch("napps.kytos.mef_eline.models.evc.EVC._validate")
    @patch("napps.kytos.mef_eline.main.EVC.as_dict")
    @patch("napps.kytos.mef_eline.models.path.Path.is_valid")
    def test_update_circuit_invalid_path(self, *args):
        """Test update a circuit circuit."""
        # pylint: disable=too-many-locals
        (
            is_valid_mock,
            evc_as_dict_mock,
            validate_mock,
            mongo_controller_upsert_mock,
            link_from_dict_mock,
            uni_from_dict_mock,
            sched_add_mock,
            evc_deploy_mock,
        ) = args

        is_valid_mock.side_effect = InvalidPath("error")
        validate_mock.return_value = True
        mongo_controller_upsert_mock.return_value = True
        sched_add_mock.return_value = True
        evc_deploy_mock.return_value = True
        link_from_dict_mock.return_value = 1
        uni1 = create_autospec(UNI)
        uni2 = create_autospec(UNI)
        uni1.interface = create_autospec(Interface)
        uni2.interface = create_autospec(Interface)
        uni1.interface.switch = "00:00:00:00:00:00:00:01"
        uni2.interface.switch = "00:00:00:00:00:00:00:02"
        uni_from_dict_mock.side_effect = [uni1, uni2, uni1, uni2]

        api = self.get_app_test_client(self.napp)
        payload1 = {
            "name": "my evc1",
            "uni_a": {
                "interface_id": "00:00:00:00:00:00:00:01:1",
                "tag": {"tag_type": 1, "value": 80},
            },
            "uni_z": {
                "interface_id": "00:00:00:00:00:00:00:02:2",
                "tag": {"tag_type": 1, "value": 1},
            },
            "dynamic_backup_path": True,
        }

        payload2 = {
            "primary_path": [
                {
                    "endpoint_a": {"id": "00:00:00:00:00:00:00:01:1"},
                    "endpoint_b": {"id": "00:00:00:00:00:00:00:02:2"},
                }
            ]
        }

        evc_as_dict_mock.return_value = payload1
        response = api.post(
            f"{self.server_name_url}/v2/evc/",
            data=json.dumps(payload1),
            content_type="application/json",
        )
        self.assertEqual(201, response.status_code)

        evc_as_dict_mock.return_value = payload2
        current_data = json.loads(response.data)
        circuit_id = current_data["circuit_id"]
        response = api.patch(
            f"{self.server_name_url}/v2/evc/{circuit_id}",
            data=json.dumps(payload2),
            content_type="application/json",
        )
        current_data = json.loads(response.data)
        expected_data = "primary_path is not a valid path: error"
        self.assertEqual(400, response.status_code)
        self.assertEqual(current_data["description"], expected_data)

    def test_link_from_dict_non_existent_intf(self):
        """Test _link_from_dict non existent intf."""
        self.napp.controller.get_interface_by_id = MagicMock(return_value=None)
        link_dict = {
            "endpoint_a": {"id": "a"},
            "endpoint_b": {"id": "b"}
        }
        with self.assertRaises(ValueError):
            self.napp._link_from_dict(link_dict)

    def test_uni_from_dict_non_existent_intf(self):
        """Test _link_from_dict non existent intf."""
        self.napp.controller.get_interface_by_id = MagicMock(return_value=None)
        uni_dict = {
            "interface_id": "aaa",
        }
        with self.assertRaises(ValueError):
            self.napp._uni_from_dict(uni_dict)

    @patch("napps.kytos.mef_eline.models.evc.EVC.deploy")

This code seems to be duplicated in your project.

    @patch("napps.kytos.mef_eline.scheduler.Scheduler.add")
    @patch("napps.kytos.mef_eline.main.Main._uni_from_dict")
    @patch("napps.kytos.mef_eline.models.evc.EVC._validate")
    @patch("napps.kytos.mef_eline.controllers.ELineController.upsert_evc")
    def test_update_evc_no_json_mime(self, *args):
        """Test update a circuit with wrong mimetype."""
        # pylint: disable=too-many-locals
        (
            mongo_controller_upsert_mock,
            validate_mock,
            uni_from_dict_mock,
            sched_add_mock,
            evc_deploy_mock,
        ) = args

        validate_mock.return_value = True
        sched_add_mock.return_value = True
        evc_deploy_mock.return_value = True
        uni1 = create_autospec(UNI)
        uni2 = create_autospec(UNI)
        uni1.interface = create_autospec(Interface)
        uni2.interface = create_autospec(Interface)
        uni1.interface.switch = "00:00:00:00:00:00:00:01"
        uni2.interface.switch = "00:00:00:00:00:00:00:02"
        uni_from_dict_mock.side_effect = [uni1, uni2, uni1, uni2]
        mongo_controller_upsert_mock.return_value = True

        api = self.get_app_test_client(self.napp)
        payload1 = {
            "name": "my evc1",
            "uni_a": {
                "interface_id": "00:00:00:00:00:00:00:01:1",
                "tag": {"tag_type": 1, "value": 80},
            },
            "uni_z": {
                "interface_id": "00:00:00:00:00:00:00:02:2",
                "tag": {"tag_type": 1, "value": 1},
            },
            "dynamic_backup_path": True,
        }

        payload2 = {"dynamic_backup_path": False}

        response = api.post(
            f"{self.server_name_url}/v2/evc/",
            data=json.dumps(payload1),
            content_type="application/json",
        )
        self.assertEqual(201, response.status_code)

        current_data = json.loads(response.data)
        circuit_id = current_data["circuit_id"]
        response = api.patch(
            f"{self.server_name_url}/v2/evc/{circuit_id}", data=payload2
        )
        current_data = json.loads(response.data)
        expected_data = "The request body mimetype is not application/json."
        self.assertEqual(current_data["description"], expected_data)
        self.assertEqual(415, response.status_code)

    def test_delete_no_evc(self):
        """Test delete when EVC does not exist."""
        api = self.get_app_test_client(self.napp)
        response = api.delete(f"{self.server_name_url}/v2/evc/123")
        current_data = json.loads(response.data)
        expected_data = "circuit_id 123 not found"
        self.assertEqual(current_data["description"], expected_data)
        self.assertEqual(404, response.status_code)

    @patch("napps.kytos.mef_eline.models.evc.EVC.remove_current_flows")
    @patch("napps.kytos.mef_eline.models.evc.EVC.deploy")
    @patch("napps.kytos.mef_eline.scheduler.Scheduler.add")
    @patch("napps.kytos.mef_eline.main.Main._uni_from_dict")
    @patch("napps.kytos.mef_eline.controllers.ELineController.upsert_evc")
    @patch("napps.kytos.mef_eline.models.evc.EVC._validate")
    @patch("napps.kytos.mef_eline.main.EVC.as_dict")
    def test_delete_archived_evc(self, *args):
        """Try to delete an archived EVC"""
        # pylint: disable=too-many-locals
        (
            evc_as_dict_mock,
            validate_mock,
            mongo_controller_upsert_mock,
            uni_from_dict_mock,
            sched_add_mock,
            evc_deploy_mock,
            remove_current_flows_mock
        ) = args

        validate_mock.return_value = True
        mongo_controller_upsert_mock.return_value = True
        sched_add_mock.return_value = True
        evc_deploy_mock.return_value = True
        remove_current_flows_mock.return_value = True
        uni1 = create_autospec(UNI)
        uni2 = create_autospec(UNI)
        uni1.interface = create_autospec(Interface)
        uni2.interface = create_autospec(Interface)
        uni1.interface.switch = "00:00:00:00:00:00:00:01"
        uni2.interface.switch = "00:00:00:00:00:00:00:02"
        uni_from_dict_mock.side_effect = [uni1, uni2, uni1, uni2]

        api = self.get_app_test_client(self.napp)
        payload1 = {
            "name": "my evc1",
            "uni_a": {
                "interface_id": "00:00:00:00:00:00:00:01:1",
                "tag": {"tag_type": 1, "value": 80},
            },
            "uni_z": {
                "interface_id": "00:00:00:00:00:00:00:02:2",
                "tag": {"tag_type": 1, "value": 1},
            },
            "dynamic_backup_path": True,
        }

        evc_as_dict_mock.return_value = payload1
        response = api.post(
            f"{self.server_name_url}/v2/evc/",
            data=json.dumps(payload1),
            content_type="application/json",
        )
        self.assertEqual(201, response.status_code)

        current_data = json.loads(response.data)
        circuit_id = current_data["circuit_id"]
        response = api.delete(
            f"{self.server_name_url}/v2/evc/{circuit_id}"
        )
        self.assertEqual(200, response.status_code)

        response = api.delete(
            f"{self.server_name_url}/v2/evc/{circuit_id}"
        )
        current_data = json.loads(response.data)
        expected_data = f"Circuit {circuit_id} already removed"
        self.assertEqual(current_data["description"], expected_data)
        self.assertEqual(404, response.status_code)

    def test_handle_link_up(self):
        """Test handle_link_up method."""
        evc_mock = create_autospec(EVC)
        evc_mock.service_level, evc_mock.creation_time = 0, 1
        evc_mock.is_enabled = MagicMock(side_effect=[True, False, True])
        evc_mock.lock = MagicMock()
        type(evc_mock).archived = PropertyMock(
            side_effect=[True, False, False]
        )
        evcs = [evc_mock, evc_mock, evc_mock]
        event = KytosEvent(name="test", content={"link": "abc"})
        self.napp.circuits = dict(zip(["1", "2", "3"], evcs))
        self.napp.handle_link_up(event)
        evc_mock.handle_link_up.assert_called_once_with("abc")

    @patch("time.sleep", return_value=None)
    @patch("napps.kytos.mef_eline.main.settings")
    @patch("napps.kytos.mef_eline.main.emit_event")
    def test_handle_link_down(self, emit_event_mock, settings_mock, _):
        """Test handle_link_down method."""
        uni = create_autospec(UNI)
        evc1 = MagicMock(id="1", service_level=0, creation_time=1,
                         metadata="mock", _active="true", _enabled="true",
                         uni_a=uni, uni_z=uni)
        evc1.name = "name"
        evc1.is_affected_by_link.return_value = True
        evc1.handle_link_down.return_value = True
        evc1.failover_path = None
        evc2 = MagicMock(id="2", service_level=6, creation_time=1)
        evc2.is_affected_by_link.return_value = False
        evc3 = MagicMock(id="3", service_level=5, creation_time=1,
                         metadata="mock", _active="true", _enabled="true",
                         uni_a=uni, uni_z=uni)
        evc3.name = "name"
        evc3.is_affected_by_link.return_value = True
        evc3.handle_link_down.return_value = True
        evc3.failover_path = None
        evc4 = MagicMock(id="4", service_level=4, creation_time=1,
                         metadata="mock", _active="true", _enabled="true",
                         uni_a=uni, uni_z=uni)
        evc4.name = "name"
        evc4.is_affected_by_link.return_value = True
        evc4.is_failover_path_affected_by_link.return_value = False
        evc4.failover_path = ["2"]
        evc4.get_failover_flows.return_value = {
            "2": ["flow1", "flow2"],
            "3": ["flow3", "flow4", "flow5", "flow6"],
        }
        evc5 = MagicMock(id="5", service_level=7, creation_time=1)
        evc5.is_affected_by_link.return_value = True
        evc5.is_failover_path_affected_by_link.return_value = False
        evc5.failover_path = ["3"]
        evc5.get_failover_flows.return_value = {
            "4": ["flow7", "flow8"],
            "5": ["flow9", "flow10"],
        }
        link = MagicMock(id="123")
        event = KytosEvent(name="test", content={"link": link})
        self.napp.circuits = {"1": evc1, "2": evc2, "3": evc3, "4": evc4,
                              "5": evc5}
        settings_mock.BATCH_SIZE = 2
        self.napp.handle_link_down(event)

        assert evc5.service_level > evc4.service_level
        # evc5 batched flows should be sent first
        emit_event_mock.assert_has_calls([
            call(
                self.napp.controller,
                context="kytos.flow_manager",
                name="flows.install",
                content={
                    "dpid": "4",
                    "flow_dict": {"flows": ["flow7", "flow8"]},
                }
            ),
            call(
                self.napp.controller,
                context="kytos.flow_manager",
                name="flows.install",
                content={
                    "dpid": "5",
                    "flow_dict": {"flows": ["flow9", "flow10"]},
                }
            ),
            call(
                self.napp.controller,
                context="kytos.flow_manager",
                name="flows.install",
                content={
                    "dpid": "2",
                    "flow_dict": {"flows": ["flow1", "flow2"]},
                }
            ),
            call(
                self.napp.controller,
                context="kytos.flow_manager",
                name="flows.install",
                content={
                    "dpid": "3",
                    "flow_dict": {"flows": ["flow3", "flow4"]},
                }
            ),
            call(
                self.napp.controller,
                context="kytos.flow_manager",
                name="flows.install",
                content={
                    "dpid": "3",
                    "flow_dict": {"flows": ["flow5", "flow6"]},
                }
            ),
        ])
        event_name = "evc_affected_by_link_down"
        assert evc3.service_level > evc1.service_level
        # evc3 should be handled before evc1
        emit_event_mock.assert_has_calls([
            call(self.napp.controller, event_name, content={
                "link_id": "123",
                "evc_id": "3",
                "name": "name",
                "metadata": "mock",
                "active": "true",
                "enabled": "true",
                "uni_a": uni.as_dict(),
                "uni_z": uni.as_dict(),
            }),
            call(self.napp.controller, event_name, content={
                "link_id": "123",
                "evc_id": "1",
                "name": "name",
                "metadata": "mock",
                "active": "true",
                "enabled": "true",
                "uni_a": uni.as_dict(),
                "uni_z": uni.as_dict(),
            }),
        ])
        evc4.sync.assert_called_once()
        event_name = "redeployed_link_down"
        emit_event_mock.assert_has_calls([
            call(self.napp.controller, event_name, content={
                "evc_id": "4",
                "name": "name",
                "metadata": "mock",
                "active": "true",
                "enabled": "true",
                "uni_a": uni.as_dict(),
                "uni_z": uni.as_dict(),
            }),
        ])

    @patch("napps.kytos.mef_eline.main.emit_event")
    def test_handle_evc_affected_by_link_down(self, emit_event_mock):
        """Test handle_evc_affected_by_link_down method."""
        uni = create_autospec(UNI)
        evc1 = MagicMock(
            id="1",
            metadata="data_mocked",
            _active="true",
            _enabled="false",
            uni_a=uni,
            uni_z=uni,
        )
        evc1.name = "name_mocked"
        evc1.handle_link_down.return_value = True
        evc2 = MagicMock(
            id="2",
            metadata="mocked_data",
            _active="false",
            _enabled="true",
            uni_a=uni,
            uni_z=uni,
        )
        evc2.name = "mocked_name"
        evc2.handle_link_down.return_value = False
        self.napp.circuits = {"1": evc1, "2": evc2}

        event = KytosEvent(name="e1", content={
            "evc_id": "3",
            "link_id": "1",
        })
        self.napp.handle_evc_affected_by_link_down(event)
        emit_event_mock.assert_not_called()
        event.content["evc_id"] = "1"
        self.napp.handle_evc_affected_by_link_down(event)
        emit_event_mock.assert_called_with(
            self.napp.controller, "redeployed_link_down", content={
                "evc_id": "1",
                "name": "name_mocked",
                "metadata": "data_mocked",
                "active": "true",
                "enabled": "false",
                "uni_a": uni.as_dict(),
                "uni_z": uni.as_dict(),
            }
        )

        event.content["evc_id"] = "2"
        self.napp.handle_evc_affected_by_link_down(event)
        emit_event_mock.assert_called_with(
            self.napp.controller, "error_redeploy_link_down", content={
                "evc_id": "2",
                "name": "mocked_name",
                "metadata": "mocked_data",
                "active": "false",
                "enabled": "true",
                "uni_a": uni.as_dict(),
                "uni_z": uni.as_dict(),
            }
        )

    def test_handle_evc_deployed(self):
        """Test handle_evc_deployed method."""
        evc = create_autospec(EVC, id="1")
        evc.lock = MagicMock()
        self.napp.circuits = {"1": evc}

        event = KytosEvent(name="e1", content={"evc_id": "2"})
        self.napp.handle_evc_deployed(event)
        evc.setup_failover_path.assert_not_called()

        event.content["evc_id"] = "1"
        self.napp.handle_evc_deployed(event)
        evc.setup_failover_path.assert_called()

    def test_add_metadata(self):
        """Test method to add metadata"""
        evc_mock = create_autospec(EVC)
        evc_mock.metadata = {}
        evc_mock.id = 1234
        self.napp.circuits = {"1234": evc_mock}

        api = self.get_app_test_client(self.napp)
        payload = {"metadata1": 1, "metadata2": 2}
        response = api.post(
            f"{self.server_name_url}/v2/evc/1234/metadata",
            data=json.dumps(payload),
            content_type="application/json",
        )

        self.assertEqual(response.status_code, 201)
        evc_mock.extend_metadata.assert_called_with(payload)

    def test_add_metadata_malformed_json(self):
        """Test method to add metadata with a malformed json"""
        api = self.get_app_test_client(self.napp)
        payload = '{"metadata1": 1, "metadata2": 2,}'
        response = api.post(
            f"{self.server_name_url}/v2/evc/1234/metadata",
            data=payload,
            content_type="application/json"
        )

        self.assertEqual(response.status_code, 400)
        self.assertEqual(
            response.json["description"],
            "The request body is not a well-formed JSON."
        )

    def test_add_metadata_no_body(self):
        """Test method to add metadata with no body"""
        api = self.get_app_test_client(self.napp)
        response = api.post(
            f"{self.server_name_url}/v2/evc/1234/metadata"
        )
        self.assertEqual(response.status_code, 400)
        self.assertEqual(
            response.json["description"],
            "The request body is empty."
        )

    def test_add_metadata_no_evc(self):
        """Test method to add metadata with no evc"""
        api = self.get_app_test_client(self.napp)
        payload = {"metadata1": 1, "metadata2": 2}
        response = api.post(
            f"{self.server_name_url}/v2/evc/1234/metadata",
            data=json.dumps(payload),
            content_type="application/json",
        )
        self.assertEqual(response.status_code, 404)
        self.assertEqual(
            response.json["description"],
            "circuit_id 1234 not found."
        )

    def test_add_metadata_wrong_content_type(self):
        """Test method to add metadata with wrong content type"""
        api = self.get_app_test_client(self.napp)
        payload = {"metadata1": 1, "metadata2": 2}
        response = api.post(
            f"{self.server_name_url}/v2/evc/1234/metadata",
            data=json.dumps(payload),
            content_type="application/xml",
        )
        self.assertEqual(response.status_code, 415)
        self.assertEqual(
            response.json["description"],
            "The content type must be application/json "
            "(received application/xml)."
        )

    def test_get_metadata(self):
        """Test method to get metadata"""
        evc_mock = create_autospec(EVC)
        evc_mock.metadata = {'metadata1': 1, 'metadata2': 2}
        evc_mock.id = 1234
        self.napp.circuits = {"1234": evc_mock}

        api = self.get_app_test_client(self.napp)
        response = api.get(
            f"{self.server_name_url}/v2/evc/1234/metadata",
        )
        self.assertEqual(response.status_code, 200)
        self.assertEqual(response.json, {"metadata": evc_mock.metadata})

    def test_delete_metadata(self):
        """Test method to delete metadata"""
        evc_mock = create_autospec(EVC)
        evc_mock.metadata = {'metadata1': 1, 'metadata2': 2}
        evc_mock.id = 1234
        self.napp.circuits = {"1234": evc_mock}

        api = self.get_app_test_client(self.napp)
        response = api.delete(
            f"{self.server_name_url}/v2/evc/1234/metadata/metadata1",
        )
        self.assertEqual(response.status_code, 200)

    def test_delete_metadata_no_evc(self):
        """Test method to delete metadata with no evc"""
        api = self.get_app_test_client(self.napp)
        response = api.delete(
            f"{self.server_name_url}/v2/evc/1234/metadata/metadata1",
        )
        self.assertEqual(response.status_code, 404)
        self.assertEqual(
            response.json["description"],
            "circuit_id 1234 not found."
        )

    @patch('napps.kytos.mef_eline.main.Main._load_evc')
    def test_load_all_evcs(self, load_evc_mock):
        """Test load_evcs method"""
        mock_circuits = {
            'circuits': {
                1: 'circuit_1',
                2: 'circuit_2',
                3: 'circuit_3',
                4: 'circuit_4'
            }
        }
        self.napp.mongo_controller.get_circuits.return_value = mock_circuits
        self.napp.circuits = {2: 'circuit_2', 3: 'circuit_3'}
        self.napp.load_all_evcs()
        load_evc_mock.assert_has_calls([call('circuit_1'), call('circuit_4')])

    @patch('napps.kytos.mef_eline.main.Main._evc_from_dict')
    def test_load_evc(self, evc_from_dict_mock):
        """Test _load_evc method"""
        # pylint: disable=protected-access
        # case 1: early return with ValueError exception
        evc_from_dict_mock.side_effect = ValueError("err")
        evc_dict = MagicMock()
        self.assertEqual(self.napp._load_evc(evc_dict), None)

        # case2: archived evc
        evc = MagicMock()
        evc.archived = True
        evc_from_dict_mock.side_effect = None
        evc_from_dict_mock.return_value = evc
        self.assertEqual(self.napp._load_evc(evc_dict), None)

        # case3: success creating
        evc.archived = False
        evc.id = 1
        self.napp.sched = MagicMock()

        result = self.napp._load_evc(evc_dict)
        self.assertEqual(result, evc)
        evc.deactivate.assert_called()
        evc.sync.assert_called()
        self.napp.sched.add.assert_called_with(evc)
        self.assertEqual(self.napp.circuits[1], evc)

    def test_handle_flow_mod_error(self):
        """Test handle_flow_mod_error method"""
        flow = MagicMock()
        flow.cookie = 0xaa00000000000011
        event = MagicMock()
        event.content = {'flow': flow, 'error_command': 'add'}
        evc = create_autospec(EVC)
        evc.remove_current_flows = MagicMock()
        self.napp.circuits = {"00000000000011": evc}
        self.napp.handle_flow_mod_error(event)
        evc.remove_current_flows.assert_called_once()

    @patch("kytos.core.Controller.get_interface_by_id")
    def test_uni_from_dict(self, _get_interface_by_id_mock):
        """Test _uni_from_dict method."""
        # pylint: disable=protected-access
        # case1: early return on empty dict
        self.assertEqual(self.napp._uni_from_dict(None), False)

        # case2: invalid interface raises ValueError
        _get_interface_by_id_mock.return_value = None
        uni_dict = {
            "interface_id": "00:01:1",
            "tag": {"tag_type": 1, "value": 81},
        }
        with self.assertRaises(ValueError):
            self.napp._uni_from_dict(uni_dict)

        # case3: success creation
        uni_mock = get_uni_mocked(switch_id="00:01")
        _get_interface_by_id_mock.return_value = uni_mock.interface
        uni = self.napp._uni_from_dict(uni_dict)
        self.assertEqual(uni, uni_mock)

        # case4: success creation without tag
        uni_mock.user_tag = None
        del uni_dict["tag"]
        uni = self.napp._uni_from_dict(uni_dict)
        self.assertEqual(uni, uni_mock)

    def test_handle_flow_delete(self):
        """Test handle_flow_delete method"""
        flow = MagicMock()
        flow.cookie = 0xaa00000000000011
        event = MagicMock()
        event.content = {'flow': flow}
        evc = create_autospec(EVC)
        evc.set_flow_removed_at = MagicMock()
        self.napp.circuits = {"00000000000011": evc}
        self.napp.handle_flow_delete(event)
        evc.set_flow_removed_at.assert_called_once()

    def test_add_bulk_metadata(self):

This code seems to be duplicated in your project.

        """Test add_bulk_metadata method"""
        evc_mock = create_autospec(EVC)
        evc_mock.id = 1234
        self.napp.circuits = {"1234": evc_mock}
        api = self.get_app_test_client(self.napp)
        payload = {
            "circuit_ids": ["1234"],
            "metadata1": 1,
            "metadata2": 2
        }
        response = api.post(
            f"{self.server_name_url}/v2/evc/metadata",
            data=json.dumps(payload),
            content_type="application/json",
        )
        self.assertEqual(response.status_code, 201)
        args = self.napp.mongo_controller.update_evcs.call_args[0]
        ids = payload.pop("circuit_ids")
        self.assertEqual(args[0], ids)
        self.assertEqual(args[1], payload)
        self.assertEqual(args[2], "add")
        calls = self.napp.mongo_controller.update_evcs.call_count
        self.assertEqual(calls, 1)
        evc_mock.extend_metadata.assert_called_with(payload)

    def test_add_bulk_metadata_no_id(self):
        """Test add_bulk_metadata with unknown evc id"""
        evc_mock = create_autospec(EVC)
        evc_mock.id = 1234
        self.napp.circuits = {"1234": evc_mock}
        api = self.get_app_test_client(self.napp)
        payload = {
            "circuit_ids": ["1234", "4567"]
        }
        response = api.post(
            f"{self.server_name_url}/v2/evc/metadata",
            data=json.dumps(payload),
            content_type="application/json",
        )
        self.assertEqual(response.status_code, 404)

    def test_add_bulk_metadata_no_circuits(self):
        """Test add_bulk_metadata without circuit_ids"""
        evc_mock = create_autospec(EVC)
        evc_mock.id = 1234
        self.napp.circuits = {"1234": evc_mock}
        api = self.get_app_test_client(self.napp)
        payload = {
            "metadata": "data"
        }
        response = api.post(
            f"{self.server_name_url}/v2/evc/metadata",
            data=json.dumps(payload),
            content_type="application/json",
        )
        self.assertEqual(response.status_code, 400)

    def test_delete_bulk_metadata(self):

This code seems to be duplicated in your project.

        """Test delete_metadata method"""
        evc_mock = create_autospec(EVC)
        evc_mock.id = 1234
        self.napp.circuits = {"1234": evc_mock}
        api = self.get_app_test_client(self.napp)
        payload = {
            "circuit_ids": ["1234"]
        }
        response = api.delete(
            f"{self.server_name_url}/v2/evc/metadata/metadata1",
            data=json.dumps(payload),
            content_type="application/json",
        )
        self.assertEqual(response.status_code, 200)
        args = self.napp.mongo_controller.update_evcs.call_args[0]
        self.assertEqual(args[0], payload["circuit_ids"])
        self.assertEqual(args[1], {"metadata1": ""})
        self.assertEqual(args[2], "del")
        calls = self.napp.mongo_controller.update_evcs.call_count
        self.assertEqual(calls, 1)
        self.assertEqual(evc_mock.remove_metadata.call_count, 1)