import logging
import operator
import platform
import re
from collections.abc import Iterable
from typing import Any, Callable

import _pytest.logging
import pytest
from pytest_container import Container

from tmt.utils import remove_color


class PatternMatching:
    def __init__(self, pattern: str, method: str) -> None:
        self.pattern = pattern
        self._compiled_pattern = re.compile(pattern)
        self.method = getattr(self._compiled_pattern, method)

    def __repr__(self) -> str:
        return f'<{self.__class__.__name__}: "{self.pattern}">'


class MATCH(PatternMatching):
    """
    Wrap a string with this class, to use it as a regular expression when matching log records.

    :py:class:`SEARCH` applies to any place within the string, while ``MATCH`` must match from the
    beginning of the string.

    .. code-block:: python

       assert_log(message=MATCH('an exception .+ was raised'))
    """

    def __init__(self, pattern: str) -> None:
        super().__init__(pattern, 'match')


class SEARCH(PatternMatching):
    """
    Wrap a string with this class, to use it as a regular expression when searching for log
    records.

    ``SEARCH`` applies to any place within the string, while :py:class:`MATCH` must match from the
    beginning of the string.

    .. code-block:: python

       assert_log(message=SEARCH('an exception .+ was raised'))
    """

    def __init__(self, pattern: str) -> None:
        super().__init__(pattern, 'search')


def _assert_log(
    caplog: _pytest.logging.LogCaptureFixture,
    evaluator: Callable[[Iterable[Any]], bool] = any,
    remove_colors: bool = False,
    not_present: bool = False,
    **tests: Any,
) -> None:
    """
    Assert log contains a record - logged message - with given properties. Those are specified as
    keyword parameters: :py:class:`logging.LogRecords` properties are allowed names, parameter
    values are the expected values.

    .. code-block:: python

       assert_log(message='everything went well', levelno=logging.INFO)
       assert_log(message='things broke down', levelno=logging.ERROR)
       assert_log(message=MATCH('user .+ logged in'), levelno=logging.INFO)

    :param caplog: Pytest's `caplog` fixture.
    :param evaluator: a callable reducing a given list of booleans into a single boolean. It is
        used to evaluate whether the search for matching record was successful: each record is
        tested, and results of these per-record tests are passed to `evaluator` for the final
        decision.
    """

    # We are given field_name=expected_value pairs, but we also want to be open to other binary
    # operators, like "field_name matches pattern". To protect the actual matching from aspects of
    # different possible operators, we will convert the "tests" into basic building blocks: a
    # field name, a callable accepting two parameters, and the given (expected) value. With these,
    # we can reduce the matching into functions calls without worrying what functions we work with.

    operators: list[tuple[Callable[[Any], Any], str, Callable[[Any, Any], bool], Any]] = []

    for field_name, expected_value in tests.items():
        if field_name == 'message' and remove_colors:

            def field_getter(record, name):
                return remove_color(getattr(record, name))

        elif field_name.startswith('details_'):
            field_name = field_name.replace('details_', '')

            def field_getter(record, name):
                return getattr(record.details, name, None)

        elif field_name == 'message':

            def field_getter(record, name):
                return remove_color(getattr(record, name))

        else:

            def field_getter(record, name):
                return getattr(record, name)

        # Special case: if the expected value is a pattern matching instance, it represents a
        # regular expression. We don't modify the field name and "expected" value, but the
        # function will be a custom lambda calling proper `re` method.
        if isinstance(expected_value, PatternMatching):
            operators.append(
                (field_getter, field_name, lambda a, b: a.method(b) is not None, expected_value)
            )

            continue

        # Python's `operator` package offers operators - `==` or `!=` - in a form of functions,
        # which is exactly what we need here, so we don't have to build our own
        # `lambda a, b: a == b`. We might use more than just `eq` in the future, so let's start
        # with `operator` right away.

        operators.append((field_getter, field_name, operator.eq, expected_value))

    # Given a logging record, apply all field/operator/value triplets, and make sure all match the
    # actual record properties.
    def _cmp(record: logging.LogRecord) -> bool:
        return all(
            op(expected_value, field_getter(record, field_name))
            for field_getter, field_name, op, expected_value in operators
        )

    # Final step: apply our "make sure field/operator/value triplets match given record" to each
    # and every record, and reduce per-record results into a single answer. By default, `any` is
    # used which means that any record matching all field/operator/value triples yield the final
    # "yes, such a record exists".
    outcome = evaluator([_cmp(record) for record in caplog.records])

    def _report(message: str) -> None:
        formatted_fields = [f'    {field} == {value}' for field, value in tests.items()]

        for record in caplog.records:
            for field_getter, field_name, op, expected_value in operators:
                print(
                    f'field={field_name}',
                    f'current=>>>{field_getter(record, field_name)}<<<',
                    f'expected=>>>{expected_value}<<<',
                    f'comparison={op(expected_value, field_getter(record, field_name))}',
                )

        pytest.fail(f"""
{message}:

{chr(10).join(formatted_fields)}
""")

    # Cannot find log record with these properties

    if not_present is False and not outcome:
        _report('Could not find log record with these properties when it should exist')

    elif not_present is True and outcome:
        _report('Found log record with these properties when it should not exist')


def assert_log(
    caplog: _pytest.logging.LogCaptureFixture,
    evaluator: Callable[[Iterable[Any]], bool] = any,
    remove_colors: bool = False,
    **tests: Any,
) -> None:
    _assert_log(
        caplog, evaluator=evaluator, remove_colors=remove_colors, not_present=False, **tests
    )


def assert_not_log(
    caplog: _pytest.logging.LogCaptureFixture,
    evaluator: Callable[[Iterable[Any]], bool] = any,
    remove_colors: bool = False,
    **tests: Any,
) -> None:
    _assert_log(
        caplog, evaluator=evaluator, remove_colors=remove_colors, not_present=True, **tests
    )


# Local images created via `make images/test`, reference to local registry
CONTAINER_FEDORA_RAWHIDE = Container(
    url='containers-storage:localhost/tmt/container/test/fedora/rawhide/upstream:latest'
)
CONTAINER_FEDORA_43 = Container(
    url='containers-storage:localhost/tmt/container/test/fedora/43/upstream:latest'
)
CONTAINER_FEDORA_42 = Container(
    url='containers-storage:localhost/tmt/container/test/fedora/42/upstream:latest'
)
CONTAINER_FEDORA_ELN = Container(
    url='containers-storage:localhost/tmt/container/test/fedora/eln/upstream:latest'
)
CONTAINER_CENTOS_STREAM_10 = Container(
    url='containers-storage:localhost/tmt/container/test/centos/stream10/upstream:latest'
)
CONTAINER_CENTOS_STREAM_9 = Container(
    url='containers-storage:localhost/tmt/container/test/centos/stream9/upstream:latest'
)
# CentOS 7 is not available for aarch64 architecture.
CONTAINER_CENTOS_7 = (
    Container(url='containers-storage:localhost/tmt/container/test/centos/7/upstream:latest')
    if platform.machine() != 'aarch64'
    else None
)
CONTAINER_UBI_8 = Container(
    url='containers-storage:localhost/tmt/container/test/ubi/8/upstream:latest'
)
CONTAINER_UBUNTU_2204 = Container(
    url='containers-storage:localhost/tmt/container/test/ubuntu/22.04/upstream:latest'
)
CONTAINER_DEBIAN_127 = Container(
    url='containers-storage:localhost/tmt/container/test/debian/12.7/upstream:latest'
)
# CONTAINER_FEDORA_COREOS = Container(
#     url='containers-storage:localhost/tmt/container/test/fedora/coreos:stable'
# )
# CONTAINER_FEDORA_COREOS_OSTREE = Container(
#     url='containers-storage:localhost/tmt/container/test/fedora/coreos/ostree:stable'
# )
CONTAINER_ALPINE = Container(url='containers-storage:localhost/tmt/container/test/alpine:latest')


TEST_CONTAINERS: dict[str, Container] = {
    _container_attribute: _container
    for _container_attribute, _container in locals().items()
    if _container_attribute.startswith('CONTAINER_') and _container
}