import vim

from . import connection
from . import opts
from . import util


class Listener:

    @classmethod
    def create(cls):
        if opts.Options.get('background_listener', int):
            return BackgroundListener()
        return ForegroundListener()


class ForegroundListener:

    def __init__(self):
        self.__server = connection.SocketCreator(util.InputStream())

    def start(self):
        self.__server.start(opts.Options.get('server'),
                            opts.Options.get('port', int),
                            opts.Options.get('timeout', int))

    def stop(self):
        self.__server.clear()

    def is_listening(self):
        return False

    def is_ready(self):
        return self.__server.has_socket()

    def status(self):
        return "inactive"

    def create_connection(self):
        handler = connection.ConnectionHandler(*self.__server.socket())
        self.stop()
        return handler


class BackgroundListener:

    def __init__(self):
        self.__server = connection.SocketServer()

    def start(self):
        if opts.Options.get("auto_start", int):
            vim.command('autocmd Vdebug CursorHold,CursorHoldI,CursorMoved,CursorMovedI,FocusGained,FocusLost * python3 debugger.start_if_ready()')
        self.__server.start(opts.Options.get('server'),
                            opts.Options.get('port', int))

    def stop(self):
        if opts.Options.get("auto_start", bool):
            vim.command('augroup Vdebug')
            vim.command('autocmd!')
            vim.command('augroup END')
        self.__server.stop()

    def status(self):
        if not self.__server:
            return "inactive"
        if self.is_ready():
            return "ready"
        if self.__server.is_alive():
            return "listening"
        return "inactive"

    def is_ready(self):
        return self.__server.has_socket()

    def is_listening(self):
        return not self.is_ready() and self.__server.is_alive()

    def create_connection(self):
        handler = connection.ConnectionHandler(*self.__server.socket())
        self.stop()
        return handler