#!/usr/bin/env python3


# Libervia: an XMPP client
# Copyright (C) 2009-2021 Jérôme Poisson (goffi@goffi.org)

# This program is free software: you can redistribute it and/or modify
# it under the terms of the GNU Affero General Public License as published by
# the Free Software Foundation, either version 3 of the License, or
# (at your option) any later version.

# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
# GNU Affero General Public License for more details.

# You should have received a copy of the GNU Affero General Public License
# along with this program.  If not, see <http://www.gnu.org/licenses/>.

"""High level logging functions"""
# XXX: this module use standard logging module when possible, but as SàT can work in different cases where logging is not the best choice (twisted, pyjamas, etc), it is necessary to have a dedicated module. Additional feature like environment variables and colors are also managed.
# TODO: change formatting from "%s" style to "{}" when moved to Python 3

from typing import TYPE_CHECKING, Any, Optional, Dict

if TYPE_CHECKING:
    from logging import _ExcInfoType
else:
    _ExcInfoType = Any

from libervia.backend.core.constants import Const as C
from libervia.backend.tools.common.ansi import ANSI as A
from libervia.backend.core import exceptions
import traceback

backend = None
_loggers: Dict[str, "Logger"] = {}
handlers = {}
COLOR_START = "%(color_start)s"
COLOR_END = "%(color_end)s"


class Filtered(Exception):
    pass


class Logger:
    """High level logging class"""

    fmt = None  # format option as given by user (e.g. SAT_LOG_LOGGER)
    filter_name = None  # filter to call
    post_treat = None

    def __init__(self, name):
        if isinstance(name, Logger):
            self.copy(name)
        else:
            self._name = name

    def copy(self, other):
        """Copy values from other Logger"""
        self.fmt = other.fmt
        self.Filter_name = other.fmt
        self.post_treat = other.post_treat
        self._name = other._name

    def add_traceback(self, message):
        tb = traceback.format_exc()
        return message + "\n==== traceback ====\n" + tb

    def out(
        self,
        message: object,
        level: Optional[str] = None,
        exc_info: _ExcInfoType = False,
        **kwargs,
    ) -> None:
        """Actually log the message

        @param message: formatted message
        """
        if exc_info:
            message = self.add_traceback(message)
        print(message)

    def log(
        self, level: str, message: object, exc_info: _ExcInfoType = False, **kwargs
    ) -> None:
        """Print message

        @param level: one of C.LOG_LEVELS
        @param message: message to format and print
        """
        if exc_info:
            message = self.add_traceback(message)
        try:
            formatted = self.format(level, message)
            if self.post_treat is None:
                self.out(formatted, level, **kwargs)
            else:
                self.out(self.post_treat(level, formatted), level, **kwargs)
        except Filtered:
            pass

    def format(self, level: str, message: object) -> object:
        """Format message according to Logger.fmt

        @param level: one of C.LOG_LEVELS
        @param message: message to format
        @return: formatted message

        @raise: Filtered when the message must not be logged
        """
        if self.fmt is None and self.filter_name is None:
            return message
        record = {
            "name": self._name,
            "message": message,
            "levelname": level,
        }
        try:
            if not self.filter_name.dict_filter(record):
                raise Filtered
        except (
            AttributeError,
            TypeError,
        ):  # XXX: TypeError is here because of a pyjamas bug which need to be fixed (TypeError is raised instead of AttributeError)
            if self.filter_name is not None:
                raise ValueError("Bad filter: filters must have a .filter method")
        try:
            return self.fmt % record
        except TypeError:
            return message
        except KeyError as e:
            if e.args[0] == "profile":
                # XXX: %(profile)s use some magic with introspection, for debugging purpose only *DO NOT* use in production
                record["profile"] = configure_cls[backend].get_profile()
                return self.fmt % record
            else:
                raise e

    def debug(self, msg: object, **kwargs) -> None:
        self.log(C.LOG_LVL_DEBUG, msg, **kwargs)

    def info(self, msg: object, **kwargs) -> None:
        self.log(C.LOG_LVL_INFO, msg, **kwargs)

    def warning(self, msg: object, **kwargs) -> None:
        self.log(C.LOG_LVL_WARNING, msg, **kwargs)

    def error(self, msg: object, **kwargs) -> None:
        self.log(C.LOG_LVL_ERROR, msg, **kwargs)

    def critical(self, msg: object, **kwargs) -> None:
        self.log(C.LOG_LVL_CRITICAL, msg, **kwargs)

    def exception(self, msg: object, exc_info=True, **kwargs) -> None:
        self.log(C.LOG_LVL_ERROR, msg, exc_info=exc_info, **kwargs)


class FilterName(object):
    """Filter on logger name according to a regex"""

    def __init__(self, name_re):
        """Initialise name filter

        @param name_re: regular expression used to filter names (using search and not match)
        """
        assert name_re
        import re

        self.name_re = re.compile(name_re)

    def filter(self, record):
        if self.name_re.search(record.name) is not None:
            return 1
        return 0

    def dict_filter(self, dict_record):
        """Filter using a dictionary record

        @param dict_record: dictionary with at list a key "name" with logger name
        @return: True if message should be logged
        """

        class LogRecord(object):
            pass

        log_record = LogRecord()
        log_record.name = dict_record["name"]
        return self.filter(log_record) == 1


class ConfigureBase:
    LOGGER_CLASS = Logger
    # True if color location is specified in fmt (with COLOR_START)
    _color_location = False

    def __init__(
        self,
        level=None,
        fmt=None,
        output=None,
        logger=None,
        colors=False,
        levels_taints_dict=None,
        force_colors=False,
        backend_data=None,
    ):
        """Configure a backend

        @param level: one of C.LOG_LEVELS
        @param fmt: format string, pretty much as in std logging.
            Accept the following keywords (maybe more depending on backend):
            - "message"
            - "levelname"
            - "name" (logger name)
        @param logger: if set, use it as a regular expression to filter on logger name.
            Use search to match expression, so ^ or $ can be necessary.
        @param colors: if True use ANSI colors to show log levels
        @param force_colors: if True ANSI colors are used even if stdout is not a tty
        """
        self.backend_data = backend_data
        self.pre_treatment()
        self.configure_level(level)
        self.configure_format(fmt)
        self.configure_output(output)
        self.configure_logger(logger)
        self.configure_colors(colors, force_colors, levels_taints_dict)
        self.post_treatment()
        self.update_current_logger()

    def update_current_logger(self):
        """update existing logger to the class needed for this backend"""
        if self.LOGGER_CLASS is None:
            return
        for name, logger in list(_loggers.items()):
            _loggers[name] = self.LOGGER_CLASS(logger)

    def pre_treatment(self):
        pass

    def configure_level(self, level):
        if level is not None:
            # we deactivate methods below level
            level_idx = C.LOG_LEVELS.index(level)

            def dev_null(self, msg):
                pass

            for _level in C.LOG_LEVELS[:level_idx]:
                setattr(Logger, _level.lower(), dev_null)

    def configure_format(self, fmt):
        if fmt is not None:
            if fmt != "%(message)s":  # %(message)s is the same as None
                Logger.fmt = fmt
            if COLOR_START in fmt:
                ConfigureBase._color_location = True
                if fmt.find(COLOR_END, fmt.rfind(COLOR_START)) < 0:
                    # color_start not followed by an end, we add it
                    Logger.fmt += COLOR_END

    def configure_output(self, output):
        if output is not None:
            if output != C.LOG_OPT_OUTPUT_SEP + C.LOG_OPT_OUTPUT_DEFAULT:
                # TODO: manage other outputs
                raise NotImplementedError("Basic backend only manage default output yet")

    def configure_logger(self, logger):
        if logger:
            Logger.filter_name = FilterName(logger)

    def configure_colors(self, colors, force_colors, levels_taints_dict):
        if colors:
            # if color are used, we need to handle levels_taints_dict
            for level in list(levels_taints_dict.keys()):
                # we wants levels in uppercase to correspond to contstants
                levels_taints_dict[level.upper()] = levels_taints_dict[level]
            taints = self.__class__.taints = {}
            for level in C.LOG_LEVELS:
                # we want use values and use constant value as default
                taint_list = levels_taints_dict.get(
                    level, C.LOG_OPT_TAINTS_DICT[1][level]
                )
                ansi_list = []
                for elt in taint_list:
                    elt = elt.upper()
                    try:
                        ansi = getattr(A, "FG_{}".format(elt))
                    except AttributeError:
                        try:
                            ansi = getattr(A, elt)
                        except AttributeError:
                            # we use raw string if element is unknown
                            ansi = elt
                    ansi_list.append(ansi)
                taints[level] = "".join(ansi_list)

    def post_treatment(self):
        pass

    def manage_outputs(self, outputs_raw):
        """Parse output option in a backend agnostic way, and fill handlers consequently

        @param outputs_raw: output option as enterred in environment variable or in configuration
        """
        if not outputs_raw:
            return
        outputs = outputs_raw.split(C.LOG_OPT_OUTPUT_SEP)
        global handlers
        if len(outputs) == 1:
            handlers[C.LOG_OPT_OUTPUT_FILE] = [outputs.pop()]

        for output in outputs:
            if not output:
                continue
            if output[-1] == ")":
                # we have options
                opt_begin = output.rfind("(")
                options = output[opt_begin + 1 : -1]
                output = output[:opt_begin]
            else:
                options = None

            if output not in (
                C.LOG_OPT_OUTPUT_DEFAULT,
                C.LOG_OPT_OUTPUT_FILE,
                C.LOG_OPT_OUTPUT_MEMORY,
            ):
                raise ValueError("Invalid output [%s]" % output)

            if output == C.LOG_OPT_OUTPUT_DEFAULT:
                # no option for defaut handler
                handlers[output] = None
            elif output == C.LOG_OPT_OUTPUT_FILE:
                if not options:
                    ValueError(
                        "{handler} output need a path as option".format(handle=output)
                    )
                handlers.setdefault(output, []).append(options)
                options = None  # option are parsed, we can empty them
            elif output == C.LOG_OPT_OUTPUT_MEMORY:
                # we have memory handler, option can be the len limit or None
                try:
                    limit = int(options)
                    options = None  # option are parsed, we can empty them
                except (TypeError, ValueError):
                    limit = C.LOG_OPT_OUTPUT_MEMORY_LIMIT
                handlers[output] = limit

            if options:  # we should not have unparsed options
                raise ValueError(
                    "options [{options}] are not supported for {handler} output".format(
                        options=options, handler=output
                    )
                )

    @staticmethod
    def memory_get(size=None):
        """Return buffered logs

        @param size: number of logs to return
        """
        raise NotImplementedError

    @classmethod
    def ansi_colors(cls, level, message):
        """Colorise message depending on level for terminals

        @param level: one of C.LOG_LEVELS
        @param message: formatted message to log
        @return: message with ANSI escape codes for coloration
        """

        try:
            start = cls.taints[level]
        except KeyError:
            start = ""

        if cls._color_location:
            return message % {"color_start": start, "color_end": A.RESET}
        else:
            return "%s%s%s" % (start, message, A.RESET)

    @staticmethod
    def get_profile():
        """Try to find profile value using introspection"""
        raise NotImplementedError


class ConfigureCustom(ConfigureBase):
    LOGGER_CLASS = None

    def __init__(self, logger_class, *args, **kwargs):
        ConfigureCustom.LOGGER_CLASS = logger_class


configure_cls = {
    None: ConfigureBase,
    C.LOG_BACKEND_CUSTOM: ConfigureCustom,
}  # XXX: (key: backend, value: Configure subclass) must be filled when new backend are added


def configure(backend_, **options):
    """Configure logging behaviour
    @param backend: can be:
        C.LOG_BACKEND_BASIC: use a basic print based logging
        C.LOG_BACKEND_CUSTOM: use a given Logger subclass
    """
    global backend
    if backend is not None:
        raise exceptions.InternalError("Logging can only be configured once")
    backend = backend_

    try:
        configure_class = configure_cls[backend]
    except KeyError:
        raise ValueError("unknown backend [{}]".format(backend))
    if backend == C.LOG_BACKEND_CUSTOM:
        logger_class = options.pop("logger_class")
        configure_class(logger_class, **options)
    else:
        configure_class(**options)


def memory_get(size=None):
    if not C.LOG_OPT_OUTPUT_MEMORY in handlers:
        raise ValueError("memory output is not used")
    return configure_cls[backend].memory_get(size)


def getLogger(name=C.LOG_BASE_LOGGER) -> Logger:
    try:
        logger_class = configure_cls[backend].LOGGER_CLASS
    except KeyError:
        raise ValueError(
            "This method should not be called with backend [{}]".format(backend)
        )
    return _loggers.setdefault(name, logger_class(name))


_root_logger = getLogger()


def debug(msg, **kwargs):
    _root_logger.debug(msg, **kwargs)


def info(msg, **kwargs):
    _root_logger.info(msg, **kwargs)


def warning(msg, **kwargs):
    _root_logger.warning(msg, **kwargs)


def error(msg, **kwargs):
    _root_logger.error(msg, **kwargs)


def critical(msg, **kwargs):
    _root_logger.critical(msg, **kwargs)