import json
import logging
import os

import avro
import pytest

from pbcommand.models import PipelinePreset, PipelineDataStoreViewRules
from pbcommand.models.report import Report, ReportSpec
from pbcommand.pb_io import (load_pipeline_presets_from,
                             load_pipeline_datastore_view_rules_from_json,
                             load_report_spec_from_json)
from pbcommand.schemas import (validate_presets,
                               validate_datastore_view_rules,
                               validate_report_spec)
from pbcommand.utils import walker
from base_utils import DATA_DIR_PRESETS, DATA_DIR_DSVIEW, DATA_DIR_REPORT_SPECS

log = logging.getLogger(__name__)


def _to_json(path):
    with open(path, 'r') as f:
        d = json.loads(f.read())
    return d


def json_filter(path):
    return path.endswith(".json")


def _to_assertion(path, schema_validate_func):
    def test_is_validate(self):
        d = _to_json(path)
        # log.debug(d)
        log.info("Attempting to validate '{}'".format(path))
        is_valid = schema_validate_func(d)
        log.info(" is-valid? {i} {p}".format(i=is_valid, p=path))
        if not is_valid:
            print("{p} is not valid with the avro schema".format(p=path))
        assert is_valid
    return test_is_validate


class ValidatePipelinePreset:
    def test_validate_pipeline_presets(self):
        for path in walker(DATA_DIR_PRESETS, json_filter):
            f = _to_assertion(path, validate_presets)
            f(self)
            assert isinstance(load_pipeline_presets_from(path), PipelinePreset)


class ValidateDataStoreViewRules:
    def test_validate_pipeline_datastore_view_rules(self):
        for path in walker(DATA_DIR_DSVIEW, json_filter):
            f = _to_assertion(path, validate_datastore_view_rules)
            f(self)
            assert isinstance(
                load_pipeline_datastore_view_rules_from_json(path),
                PipelineDataStoreViewRules)


class ValidateReportSpec:
    def test_validate_report_spec(self):
        for path in walker(DATA_DIR_REPORT_SPECS, json_filter):
            if os.path.basename(path).startswith("report-specs"):
                f = _to_assertion(path, validate_report_spec)
                f(self)
                assert isinstance(load_report_spec_from_json(path),
                                  ReportSpec)