kytos / flow_manager

                                                  flow, 'add')

        mock_send_napp_event.assert_called_with(self.switch_01, flow, 'add')

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

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

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

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

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

    def test_install_flows_with_delete_strict(self, *args):

        """Test _install_flows method with strict delete command."""

        (mock_flow_factory, mock_send_flow_mod, mock_add_flow_mod_sent,

         mock_send_napp_event, _) = args

        serializer = MagicMock()

        flow = MagicMock()

        flow_mod = MagicMock()

        flow.as_of_strict_delete_flow_mod.return_value = flow_mod

        serializer.from_dict.return_value = flow

        mock_flow_factory.return_value = serializer

        flows_dict = {'flows': [MagicMock()]}

        switches = [self.switch_01]

        self.napp._install_flows('delete_strict', flows_dict, switches)

        mock_send_flow_mod.assert_called_with(flow.switch, flow_mod)

        mock_add_flow_mod_sent.assert_called_with(flow_mod.header.xid,

                                                  flow, 'delete_strict')

        mock_send_napp_event.assert_called_with(self.switch_01, flow,

                                                'delete_strict')

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

    def test_event_add_flow(self, mock_install_flows):

        self.assertEqual(switches, [self.switch_01])

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

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

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

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

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

    def test_install_flows(self, *args):

        """Test _install_flows method."""

        (mock_flow_factory, mock_send_flow_mod, mock_add_flow_mod_sent,

         mock_send_napp_event, _) = args

        serializer = MagicMock()

        flow = MagicMock()

        flow_mod = MagicMock()

        flow.as_of_add_flow_mod.return_value = flow_mod

        serializer.from_dict.return_value = flow

        mock_flow_factory.return_value = serializer

        flows_dict = {'flows': [MagicMock()]}

        switches = [self.switch_01]

        self.napp._install_flows('add', flows_dict, switches)

        mock_send_flow_mod.assert_called_with(flow.switch, flow_mod)

        mock_add_flow_mod_sent.assert_called_with(flow_mod.header.xid,

                                                  flow, 'add')

        mock_send_napp_event.assert_called_with(self.switch_01, flow, 'add')

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

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