kytos-ng / flow_stats

        json_response = json.loads(response.data)

        assert len(json_response) == 0

    @patch("napps.amlight.flow_stats.main.Main.flow_stats_by_dpid_flow_id")

    def test_bytes_count_per_flow(self, mock_from_flow):

        """Test bytes_count_per_flow rest call."""

        flow_stats = {

            'byte_count': 10,

            'duration_sec': 20,

            'duration_nsec': 30,

            'packet_count': 40

            }

        flow_id = '6055f13593fad45e0b4699f49d56b105'

        flow_stats_dict_mock = {flow_id: flow_stats}

        dpid_id = "00:00:00:00:00:00:00:01"

        flow_by_sw = {dpid_id: flow_stats_dict_mock}

        mock_from_flow.return_value = flow_by_sw

        rest_name = "bytes_count/per_flow"

        self._patch_switch_flow(flow_id)

        response = self._get_rest_response(rest_name, dpid_id)

        json_response = json.loads(response.data)

        assert json_response[0]["flow_id"] == flow_id

        assert json_response[0]["bytes_counter"] == 10

        assert json_response[0]["bits_per_second"] == 4.0

    @patch("napps.amlight.flow_stats.main.Main.flow_stats_by_dpid_flow_id")

    def test_flows_counters_packet(self, mock_from_flow):

        json_response = json.loads(response.data)

        assert len(json_response) == 0

    @patch("napps.amlight.flow_stats.main.Main.flow_stats_by_dpid_flow_id")

    def test_packet_count_per_flow(self, mock_from_flow):

        """Test packet_count_per_flow rest call."""

        flow_stats = {

            'byte_count': 10,

            'duration_sec': 20,

            'duration_nsec': 30,

            'packet_count': 40

            }

        flow_id = '6055f13593fad45e0b4699f49d56b105'

        flow_stats_dict_mock = {flow_id: flow_stats}

        dpid_id = "00:00:00:00:00:00:00:01"

        flow_by_sw = {dpid_id: flow_stats_dict_mock}

        mock_from_flow.return_value = flow_by_sw

        rest_name = "packet_count/per_flow"

        self._patch_switch_flow(flow_id)

        response = self._get_rest_response(rest_name, dpid_id)

        json_response = json.loads(response.data)

        assert json_response[0]["flow_id"] == flow_id

        assert json_response[0]["packet_counter"] == 40

        assert json_response[0]["packet_per_second"] == 2.0

    def test_bytes_count_per_flow__empty(self):

        """Test bytes_count rest call with a flow that does not exist ."""