"""

@relation(SDOC-SRS-3, scope=file)

"""

import hashlib

import io

import os

import re

import time

import uuid

from pathlib import Path

from typing import Optional, Tuple

from docutils.core import publish_parts

from docutils.parsers.rst import directives, roles

from docutils.utils import SystemMessage

from markupsafe import Markup

from pygments.lexers import _load_lexers

from strictdoc.backend.sdoc.models.document import SDocDocument

from strictdoc.core.project_config import ProjectConfig, ProjectFeature

from strictdoc.export.rst.directives.raw_html_role import raw_html_role

from strictdoc.export.rst.directives.sphinx_style_math import (

    MathDirective,

    MathDirectiveForServer,

    eq_role,

    eq_role_for_server,

    math_role,

    math_role_for_server,

)

from strictdoc.export.rst.directives.wildcard_enhanced_image import (

    STRICTDOC_REFERENCE_PATH_SETTING,

    WildcardEnhancedImage,

)

from strictdoc.helpers.file_system import file_open_read_bytes

MAX_RETRIES_FOR_CACHE_FILESYSTEM_LOCKING = 3

class RstToHtmlFragmentWriter:

    directives.register_directive("image", WildcardEnhancedImage)

    roles.register_local_role("rawhtml", raw_html_role)

    # FIXME: It doesn't feel right to load lexers like this.

    _load_lexers("strictdoc.export.rst.strictdoc_lexer")

    BASE_SETTINGS = {

        # This is important for code syntax highlighting. The setting of

        # "short" is coupled to the CSS file that we auto-generated using Pygments:

        # strictdoc/export/html/_static/pygments.css

        "syntax_highlight": "short",

        "syntax_highlight_opts": {

            "linenos": "inline",  # "table"

        },

    }

    def __init__(

        self,

        *,

        project_config: ProjectConfig,

        context_document: Optional[SDocDocument],

    ):

        self.source_path: str

        path_to_output_dir_md5: str = hashlib.md5(

            project_config.output_dir.encode("utf-8")

        ).hexdigest()

        path_to_tmp_dir = project_config.get_path_to_cache_dir()

        self.path_to_rst_cache_dir = os.path.join(

            path_to_tmp_dir, "rst", path_to_output_dir_md5

        )

        self.reference_path = os.getcwd()

        if context_document is not None:

            assert context_document.meta is not None

            self.reference_path = (

                context_document.meta.output_document_dir_full_path

            )

            # This is a delicate move. Based on a user report and our findings,

            # the csv-table RST directive relies on the 'source path' to

            # calculate paths to CSV files.

            # Our case is, however, special: we do not render RST files but

            # rather RST fragments in memory, and because of that we don't have

            # RST files to point to with 'source_path=' below.

            # At the same time, passing the output folder of the document works

            # because this RST-to-HTML writer resolves path to CSV assets

            # that are copied to that output folder by StrictDoc.

            # See CSVTable().get_csv_data() where the source_path is used.

            self.source_path = os.path.join(

                context_document.meta.output_document_dir_full_path,

                "STRICTDOC-FRAGMENT.rst",

            )

        else:

            self.source_path = "<string>"

        self.context_document: Optional[SDocDocument] = context_document

        if project_config.is_feature_activated(ProjectFeature.MATHJAX):

            if project_config.is_running_on_server:

                roles.register_canonical_role("eq", eq_role_for_server)

                roles.register_canonical_role("math", math_role_for_server)

                directives.register_directive("math", MathDirectiveForServer)

            else:

                roles.register_canonical_role("eq", eq_role)

                roles.register_canonical_role("math", math_role)

                directives.register_directive("math", MathDirective)

    def write(self, rst_fragment: str, use_cache: bool = True) -> Markup:

        assert isinstance(rst_fragment, str), rst_fragment

        # Do not try to cache very small fragments.

        if len(rst_fragment) < 40:

            return Markup(self._write_no_cache(rst_fragment))

        path_to_rst_fragment_bucket_dir = os.path.join(

            self.path_to_rst_cache_dir, str(len(rst_fragment))

        )

        fragment_md5 = hashlib.md5(rst_fragment.encode("utf-8")).hexdigest()

        path_to_cached_fragment = os.path.join(

            path_to_rst_fragment_bucket_dir, fragment_md5

        )

        if use_cache and os.path.isdir(path_to_rst_fragment_bucket_dir):

            if os.path.isfile(path_to_cached_fragment):

                with file_open_read_bytes(

                    path_to_cached_fragment

                ) as cached_fragment_file_:

                    return Markup(cached_fragment_file_.read().decode("UTF-8"))

        else:

            Path(path_to_rst_fragment_bucket_dir).mkdir(

                parents=True, exist_ok=True

            )

        rendered_html: str = self._write_no_cache(rst_fragment)

        rendered_html_bytes = rendered_html.encode("UTF-8")

        if use_cache:

            # Thread-safe cache update strategy:

            # 1) write bytes to a unique temp file, then

            # 2) atomically replace the target cache file with os.replace().

            # This ensures that concurrent readers either see the old complete

            # file or the new complete file, but never a partially written file.

            # (os.replace is atomic when source and destination are on the same

            # filesystem, which is true because both paths are in one cache dir.)

            tmp_path_to_cached_fragment = (

                f"{path_to_cached_fragment}.{uuid.uuid4().hex}.tmp"

            )

            with open(

                tmp_path_to_cached_fragment, "wb"

            ) as cached_fragment_file_:

                cached_fragment_file_.write(rendered_html_bytes)

            # On Windows in particular, we might get interference from Windows Defender

            # for obtaining the file system locks. As a work-around, we try multiple times...

            for attempt in range(MAX_RETRIES_FOR_CACHE_FILESYSTEM_LOCKING):

                try:

                    os.replace(

                        tmp_path_to_cached_fragment, path_to_cached_fragment

                    )

                    break  # Success!

                except PermissionError as e:

                    if attempt < MAX_RETRIES_FOR_CACHE_FILESYSTEM_LOCKING - 1:

                        # Wait 100ms, then 200ms, etc., to let Windows Defender release the lock

                        time.sleep(0.1 * (attempt + 1))

                    else:

                        # Surface the original error

                        raise e

        return Markup(rendered_html)

    def _write_no_cache(self, rst_fragment: str) -> str:

        assert isinstance(rst_fragment, str), rst_fragment

        # How do I convert a docutils document tree into an HTML string?

        # https://stackoverflow.com/a/32168938/598057

        # Use a io.StringIO as the warning stream to prevent warnings from

        # being printed to sys.stderr.

        # https://www.programcreek.com/python/example/88126/docutils.core.publish_parts

        warning_stream = io.StringIO()

        settings = {

            **self.BASE_SETTINGS,

            "warning_stream": warning_stream,

            STRICTDOC_REFERENCE_PATH_SETTING: self.reference_path,

        }

        output = publish_parts(

            rst_fragment,

            writer="html",

            settings_overrides=settings,

            source_path=self.source_path,

        )

        if warning_stream.tell() > 0:

            warnings = warning_stream.getvalue().rstrip("\n")

            # A typical RST warning:

            # """

            # path-to-output-folder/file.rst:4: (WARNING/2) Bullet list ends

            # without a blank line; unexpected unindent.

            # """

            match = re.search(

                r".*:(?P<line>\d+): \(.*\) (?P<message>.*)", warnings

            )

            if match is not None:

                error_message = (

                    f"RST markup syntax error on line {match.group('line')}: "

                    f"{match.group('message')}"

                )

            else:

                error_message = f"RST markup syntax error: {warnings}"

            final_message = (

                f"problems when converting RST to HTML: {error_message}\n"

                "RST fragment: >>>\n"

                f"{rst_fragment}"

                "<<<"

            )

            raise RuntimeError(final_message)

        html: str = output["html_body"]

        return html

    def write_with_validation(

        self, rst_fragment: str

    ) -> Tuple[Optional[str], Optional[str]]:

        # How do I convert a docutils document tree into an HTML string?

        # https://stackoverflow.com/a/32168938/598057

        # Use a io.StringIO as the warning stream to prevent warnings from

        # being printed to sys.stderr.

        # https://www.programcreek.com/python/example/88126/docutils.core.publish_parts

        warning_stream = io.StringIO()

        settings = {

            **self.BASE_SETTINGS,

            "warning_stream": warning_stream,

            STRICTDOC_REFERENCE_PATH_SETTING: self.reference_path,

        }

        try:

            output = publish_parts(

                rst_fragment, writer="html", settings_overrides=settings

            )

            warnings = (

                warning_stream.getvalue().rstrip("\n")

                if warning_stream.tell() > 0

                else None

            )

        except SystemMessage as exception:

            output = None

            warnings = str(exception)

        if warnings is not None and len(warnings) > 0:

            # A typical RST warning:

            # """

            # <string>:4: (WARNING/2) Bullet list ends without a blank line;

            # unexpected unindent.

            # """

            match = re.search(

                r".*<.*>:(?P<line>\d+): \(.*\) (?P<message>.*)", warnings

            )

            if match is not None:

                error_message = (

                    f"RST markup syntax error on line {match.group('line')}: "

                    f"{match.group('message')}"

                )

            else:

                error_message = f"RST markup syntax error: {warnings}"

            return None, error_message

        html = output["html_body"]

        return html, None

    @staticmethod

    def write_anchor_link(title: str, href: str) -> str:

        return f"""\

:rawhtml:`<a href="{href}">🔗&nbsp;{title}</a>`\

"""