import fnmatch
import os
import tempfile
import time
from threading import Lock
from sbvirtualdisplay.easyprocess import EasyProcess
from sbvirtualdisplay import xauth

mutex = Lock()
MIN_DISPLAY_NR = 1000
USED_DISPLAY_NR_LIST = []


class AbstractDisplay(EasyProcess):
    """Common parent for Xvfb and Xephyr"""
    def __init__(self, use_xauth=False):
        mutex.acquire()
        try:
            self.display = self.search_for_display()
            while self.display in USED_DISPLAY_NR_LIST:
                self.display += 1
            USED_DISPLAY_NR_LIST.append(self.display)
        finally:
            mutex.release()
        if use_xauth and not xauth.is_installed():
            raise xauth.NotFoundError()
        self.use_xauth = use_xauth
        self._old_xauth = None
        self._xauth_filename = None
        EasyProcess.__init__(self, self._cmd)

    @property
    def new_display_var(self):
        return ":%s" % (self.display)

    @property
    def _cmd(self):
        raise NotImplementedError()

    def lock_files(self):
        tmpdir = "/tmp"
        pattern = ".X*-lock"
        # remove path.py dependency
        names = fnmatch.filter(os.listdir(tmpdir), pattern)
        ls = [os.path.join(tmpdir, child) for child in names]
        ls = [p for p in ls if os.path.isfile(p)]
        return ls

    def search_for_display(self):
        # search for free display
        ls = [int(x.split("X")[1].split("-")[0]) for x in self.lock_files()]
        if len(ls):
            display = max(MIN_DISPLAY_NR, max(ls) + 3)
        else:
            display = MIN_DISPLAY_NR
        return display

    def redirect_display(self, on):
        """
        on:
         * True -> set $DISPLAY to virtual screen
         * False -> set $DISPLAY to original screen
        :param on: bool
        """
        d = self.new_display_var if on else self.old_display_var
        if d is None:
            del os.environ["DISPLAY"]
        else:
            os.environ["DISPLAY"] = d

    def start(self):
        """
        start display
        :rtype: self
        """
        if self.use_xauth:
            self._setup_xauth()
        EasyProcess.start(self)
        self.old_display_var = os.environ.get("DISPLAY", None)
        self.redirect_display(True)
        # wait until X server is active
        time.sleep(0.1)
        return self

    def stop(self):
        """
        stop display
        :rtype: self
        """
        self.redirect_display(False)
        EasyProcess.stop(self)
        if self.use_xauth:
            self._clear_xauth()
        return self

    def __enter__(self):
        """Used by the :keyword:`with` statement"""
        self.start()
        return self

    def __exit__(self, *exc_info):
        """Used by the :keyword:`with` statement"""
        self.stop()

    def _setup_xauth(self):
        """Set up the Xauthority file & the XAUTHORITY environment variable."""
        handle, filename = tempfile.mkstemp(
            prefix="PyVirtualDisplay.", suffix=".Xauthority"
        )
        self._xauth_filename = filename
        os.close(handle)
        # Save old environment
        self._old_xauth = {}
        self._old_xauth["AUTHFILE"] = os.getenv("AUTHFILE")
        self._old_xauth["XAUTHORITY"] = os.getenv("XAUTHORITY")

        os.environ["AUTHFILE"] = os.environ["XAUTHORITY"] = filename
        cookie = xauth.generate_mcookie()
        xauth.call("add", self.new_display_var, ".", cookie)

    def _clear_xauth(self):
        """Clear the Xauthority file and restore the environment variables."""
        os.remove(self._xauth_filename)
        for varname in ["AUTHFILE", "XAUTHORITY"]:
            if self._old_xauth[varname] is None:
                del os.environ[varname]
            else:
                os.environ[varname] = self._old_xauth[varname]
        self._old_xauth = None