kytos / flow_manager

        self.napp.consistency_of_flows_in_switch(switch)

        mock_install_flows.assert_called()

    @patch('napps.kytos.flow_manager.main.Main')

    @patch('napps.kytos.flow_manager.main.Main._install_flows')

    @patch('napps.kytos.flow_manager.main.FlowFactory.get_class')

    def test_consistency_flow_is_missing_in_storehouse(self, *args):

        """Test consistency_of_flows_in_switch method.

        This test checks the case when a flow is missing in storehouse.

        """

        (mock_flow_factory, mock_install_flows, mock_main) = args

        dpid = "00:00:00:00:00:00:00:01"

        switch = get_switch_mock(dpid, 0x04)

        flow_1 = MagicMock()

        flow_1.as_dict.return_value = {'flow_1': 'data'}

        switch.flows = [flow_1]

        flow_list = [{"command": "add",

                      "flow": {'flow_2': 'data'}

                      }]

        serializer = MagicMock()

        mock_flow_factory.return_value = serializer

        self.napp.stored_flows = {dpid: {"flow_list": flow_list}}

        mock_main._is_flow_in_list.return_value = False

        self.napp.consistency_of_flows_in_storehouse(switch)

        mock_install_flows.assert_called()

        self.napp.consistency_of_flows_in_switch(switch)

        mock_install_flows.assert_called()

    @patch('napps.kytos.flow_manager.main.Main._is_flow_in_list')

    @patch('napps.kytos.flow_manager.main.Main._install_flows')

    @patch('napps.kytos.flow_manager.main.FlowFactory.get_class')

    def test_consistency_flow_is_missing_in_switch_delete(self, *args):

        """Test consistency_of_flows_in_switch method.

        This test checks the case when a flow is missing in switch and have the

        DELETE command.

        """

        (mock_flow_factory, mock_install_flows, mock_is_flow_in_list) = args

        dpid = "00:00:00:00:00:00:00:01"

        switch = get_switch_mock(dpid, 0x04)

        switch.flows = []

        flow_1 = MagicMock()

        flow_1.as_dict.return_value = {'flow_1': 'data'}

        flow_list = [{"command": "delete",

                      "flow": {'flow_1': 'data'}

                      }]

        serializer = MagicMock()

        mock_flow_factory.return_value = serializer

        self.napp.stored_flows = {dpid: {"flow_list": flow_list}}

        mock_is_flow_in_list.return_value = True

        self.napp.consistency_of_flows_in_switch(switch)

        mock_install_flows.assert_called()

    @patch('napps.kytos.flow_manager.main.Main')

    @patch('napps.kytos.flow_manager.main.Main._install_flows')

        self.napp._store_changed_flows(command, flows, switch)

        mock_save_flow.assert_called()

    @patch('napps.kytos.flow_manager.main.Main._is_flow_in_list')

    @patch('napps.kytos.flow_manager.main.Main._install_flows')

    @patch('napps.kytos.flow_manager.main.FlowFactory.get_class')

    def test_consistency_flow_is_missing_in_switch_add(self, *args):

        """Test consistency_of_flows_in_switch method.

        This test checks the case when a flow is missing in switch and have the

        ADD command.

        """

        (mock_flow_factory, mock_install_flows, mock_is_flow_in_list) = args

        dpid = "00:00:00:00:00:00:00:01"

        switch = get_switch_mock(dpid, 0x04)

        switch.flows = []

        flow_1 = MagicMock()

        flow_1.as_dict.return_value = {'flow_1': 'data'}

        flow_list = [{"command": "add",

                      "flow": {'flow_1': 'data'}

                      }]

        serializer = MagicMock()

        mock_flow_factory.return_value = serializer

        self.napp.stored_flows = {dpid: {"flow_list": flow_list}}

        mock_is_flow_in_list.return_value = False

        self.napp.consistency_of_flows_in_switch(switch)

        mock_install_flows.assert_called()

    @patch('napps.kytos.flow_manager.main.Main._is_flow_in_list')

    @patch('napps.kytos.flow_manager.main.Main._install_flows')