from typing import Optional, Any, Union, Sequence, Iterator, TextIO
from netmiko.base_connection import BaseConnection
from netmiko.no_enable import NoEnable
import time
import re
from netmiko import log


class TeldatCITBase(NoEnable, BaseConnection):
    def session_preparation(self) -> None:
        # Prompt is "*"
        self._test_channel_read(pattern=r"\*")
        self.set_base_prompt()
        # Clear the read buffer
        time.sleep(0.3 * self.global_delay_factor)
        self.clear_buffer()

    def disable_paging(
        self,
        command: str = "",
        delay_factor: Optional[float] = None,
        cmd_verify: bool = True,
        pattern: Optional[str] = None,
    ) -> str:
        """Teldat doesn't have pagging"""
        return ""

    def set_base_prompt(
        self,
        pri_prompt_terminator: str = "*",
        alt_prompt_terminator: str = "*",
        delay_factor: float = 1.0,
        pattern: Optional[str] = None,
    ) -> str:
        """
        Teldat base prompt is "hostname *"
        """
        return super().set_base_prompt(
            pri_prompt_terminator=pri_prompt_terminator,
            alt_prompt_terminator=alt_prompt_terminator,
            delay_factor=delay_factor,
            pattern=pattern,
        )

    def cleanup(self, command: str = "logout") -> None:
        """Gracefully exit the SSH session."""
        self._base_mode()

        if self.session_log:
            self.session_log.fin = True

        # Always try to send final 'logout'
        self.write_channel(command + self.RETURN)
        output = ""
        for _ in range(30):
            time.sleep(0.1)
            output += self.read_channel()
            if "Do you wish to end" in output:
                self.write_channel("yes" + self.RETURN)
                break

    def _check_monitor_mode(self, check_string: str = "+", pattern: str = "") -> bool:
        return super().check_config_mode(check_string=check_string, pattern=pattern)

    def check_config_mode(
        self, check_string: str = ">", pattern: str = "", force_regex: bool = False
    ) -> bool:
        return super().check_config_mode(
            check_string=check_string, pattern=pattern, force_regex=force_regex
        )

    def _check_running_config_mode(
        self, check_string: str = "$", pattern: str = ""
    ) -> bool:
        return super().check_config_mode(check_string=check_string, pattern=pattern)

    def _monitor_mode(
        self, monitor_command: str = "p 3", pattern: str = r"\+", re_flags: int = 0
    ) -> str:
        """
        Enter into monitor_mode.
        On Teldat devices always go to base mode before entering other modes
        Cannot reuse super.config_mode() because config mode check is called only with
        defaults in BaseConnection
        """
        self._base_mode()  # Teldat does not allow mode switching, go to base mode first

        output = ""
        self.write_channel(self.normalize_cmd(monitor_command))
        # Make sure you read until you detect the command echo (avoid getting out of sync)
        if self.global_cmd_verify is not False:
            output += self.read_until_pattern(
                pattern=re.escape(monitor_command.strip())
            )
        if not re.search(pattern, output, flags=re_flags):
            output += self.read_until_pattern(pattern=pattern, re_flags=re_flags)
        if not self._check_monitor_mode():
            raise ValueError("Failed to enter monitor mode.")
        return output

    def config_mode(
        self, config_command: str = "p 4", pattern: str = "onfig>", re_flags: int = 0
    ) -> str:
        self._base_mode()
        return super().config_mode(
            config_command=config_command, pattern=pattern, re_flags=re_flags
        )

    def _running_config_mode(
        self, config_command: str = "p 5", pattern: str = r"onfig\$", re_flags: int = 0
    ) -> str:
        """Enter running config mode."""
        self._base_mode()

        output = ""
        self.write_channel(self.normalize_cmd(config_command))
        # Make sure you read until you detect the command echo (avoid getting out of sync)
        if self.global_cmd_verify is not False:
            output += self.read_until_pattern(pattern=re.escape(config_command.strip()))
        if not re.search(pattern, output, flags=re_flags):
            output += self.read_until_pattern(pattern=pattern, re_flags=re_flags)
        if not self._check_running_config_mode():
            raise ValueError("Failed to enter running config mode.")
        return output

    def send_config_set(
        self,
        config_commands: Union[str, Sequence[str], Iterator[str], TextIO, None] = None,
        *,
        exit_config_mode: bool = False,
        **kwargs: Any,
    ) -> str:
        """
        For Teldat devices always enter config mode
        """
        return super().send_config_set(
            config_commands=config_commands,
            exit_config_mode=exit_config_mode,
            **kwargs,
        )

    def save_config(
        self, cmd: str = "save yes", confirm: bool = False, confirm_response: str = ""
    ) -> str:
        if not self.check_config_mode() or not self._check_running_config_mode():
            raise ValueError("Cannot save if not in config or running config mode")
        # Some devices are slow so match on trailing-prompt if you can
        output = self._send_command_str(
            command_string=cmd, strip_prompt=False, strip_command=False
        )
        return output

    def exit_config_mode(self, exit_config: str = "", pattern: str = "") -> str:
        return self._base_mode()

    def _base_mode(self, exit_cmd: str = "\x10", pattern: str = r"\*") -> str:
        """
        Exit from other modes (monitor, config, running config).
        Send CTRL+P to the device
        """
        output = ""
        self.write_channel(self.normalize_cmd(exit_cmd))
        # Teldat - exit_cmd not printable
        output += self.read_until_pattern(pattern=pattern)
        log.debug(f"_base_mode: {output}")
        return output


class TeldatCITSSH(TeldatCITBase):
    pass


class TeldatCITTelnet(TeldatCITBase):
    def telnet_login(
        self,
        pri_prompt_terminator: str = r"\*",
        alt_prompt_terminator: str = r"\*",
        username_pattern: str = "Username:",
        pwd_pattern: str = "Password:",
        delay_factor: float = 1.0,
        max_loops: int = 60,
    ) -> str:
        return super().telnet_login(
            pri_prompt_terminator=pri_prompt_terminator,
            alt_prompt_terminator=alt_prompt_terminator,
            username_pattern=username_pattern,
            pwd_pattern=pwd_pattern,
            delay_factor=delay_factor,
            max_loops=max_loops,
        )