import pytest

from frictionless import platform
from frictionless.resources import TableResource

# Read


def test_stream_loader():
    with open("data/table.csv", mode="rb") as file:
        with TableResource(data=file, format="csv") as resource:
            assert resource.header == ["id", "name"]
            assert resource.read_rows() == [
                {"id": 1, "name": "english"},
                {"id": 2, "name": "中国人"},
            ]


def test_stream_loader_text_stream():
    with open("data/table.csv") as file:
        with TableResource(data=file, format="csv") as resource:
            assert resource.header == ["id", "name"]
            assert resource.read_rows() == [
                {"id": 1, "name": "english"},
                {"id": 2, "name": "中国人"},
            ]


def test_stream_loader_without_open():
    with open("data/table.csv", mode="rb") as file:
        resource = TableResource(data=file, format="csv")
        assert resource.read_rows() == [
            {"id": 1, "name": "english"},
            {"id": 2, "name": "中国人"},
        ]


# Write


@pytest.mark.skipif(platform.type == "windows", reason="Fix on Windows")
def test_stream_loader_write():
    source = TableResource(path="data/table.csv")
    target = source.write(scheme="stream", format="csv")
    with target:
        assert target.read_rows() == [
            {"id": 1, "name": "english"},
            {"id": 2, "name": "中国人"},
        ]


# Bugs


def test_stream_loader_validate_issue_740():
    with open("data/table.csv", mode="rb") as file:
        resource = TableResource(data=file, format="csv")
        report = resource.validate()
        assert report.valid


def test_stream_loader_validate_text_stream_issue_740():
    with open("data/table.csv") as file:
        resource = TableResource(data=file, format="csv")
        report = resource.validate()
        assert report.valid