import importlib
from threading import Thread
from types import ModuleType
from typing import Optional, Callable, Any
import logging


_logger = logging.getLogger(__name__)


class InternalClient:
    def __init__(
            self, name: str, args: tuple[str, ...], nsm_url: str):
        self.name = name
        self.args = args
        self.nsm_url = nsm_url
        self._lib: Optional[ModuleType] = None
        self._thread: Optional[Thread] = None
        self._start_func: Optional[Callable] = None
        self._stop_func: Optional[Callable] = None
        self._start_data: Optional[Any] = None
        self._stop_data: Optional[Any] = None

    def main_loop(self):
        'target of the _thread attribute'

        if self.name == 'sooperlooper_nsm':
            module_name = 'sooperlooper'
        else:
            module_name = self.name.replace('ray-', '')

        # import the client module
        try:
            self._lib = importlib.import_module(module_name)
        except BaseException as e:
            _logger.warning(f'Failed to import module {module_name} '
                            f'for internal client {self.name}\n'
                            + str(e))
            return

        # run the internal_prepare function
        try:
            funcs = self._lib.internal_prepare(
                *self.args, nsm_url=self.nsm_url)
        except BaseException as e:
            _logger.warning(
                'Failed to load internal_prepare function of '
                f'the internal client {self.name}\n'
                + str(e))
            return
        
        # check if internal_prepare success
        if isinstance(funcs, int):
            _logger.warning(f'InternalClient {self.name}: '
                            f'internal_prepare return error code {funcs}')
            return
        if len(funcs) == 2:
            funcs: tuple[Callable, Callable]
            self._start_func, self._stop_func = funcs
        elif len(funcs) == 4:
            funcs: tuple[Callable, Callable, Any, Any]
            self._start_func, self._stop_func, \
                self._start_data, self._stop_data = funcs
        else:
            _logger.warning(
                f'InternalClient {self.name}: '
                f'internal_prepare did return {len(funcs)} args. '
                f'2 are needed, the start_func and the stop_func')
            return
        
        # run
        if self._start_data is None:
            self._start_func()
        else:
            self._start_func(self._start_data)
        
        # finished, allow garbage to clear memory
        self._start_func = None
        self._stop_func = None
        self._start_data = None
        self._stop_data = None
    
    def start(self):
        if self.running:
            return
        
        self._thread = Thread(target=self.main_loop)
        self._thread.daemon = True
        self._thread.start()
    
    def stop(self):
        if not self.running:
            return
        
        if self._stop_func is None:
            _logger.error(f'Impossible to stop Internal Client {self.name},'
                          'stop_func is not defined')
            return

        if self._stop_data is None:
            self._stop_func()
        else:
            self._stop_func(self._stop_data)

    def kill(self):
        '''Does not really kill the thread,
        it makes the 'running' property lying'''
        if not self.running:
            return
        
        self._thread = None

    @property
    def running(self) -> bool:
        if self._thread is None:
            return False
        return self._thread.is_alive()