implements https://github.com/DrorHarari/csvjson

csvjson.py

import io
import json
from typing import Any, Dict, Iterator, List, Union


def _parse_row(row: str) -> List[Any]:
    return json.loads(f"[{row}]")


def parse(file_io: io.TextIOWrapper, header: bool = True) -> Iterator[Union[Dict[str, Any], Any]]:
    """implements https://github.com/DrorHarari/csvjson"""
    if header:
        field_names = _parse_row(file_io.readline())
        if all(isinstance(field_name, dict) for field_name in field_names):
            field_names = [field["field"] for field in field_names]
        elif not all(isinstance(field_name, str) for field_name in field_names):
            raise ValueError()

    while True:
        line = file_io.readline().strip()
        if not line:
            break

        field_values = _parse_row(line)

        if header:
            assert len(field_values) == len(field_names)
            yield dict(zip(field_names, field_values))
        else:
            yield field_values