# -----------------------------------------------------------------------------
# Dynamic Module Loader
# -----------------------------------------------------------------------------
import importlib
from openscada_lite.modules.security.controller import SecurityController
from openscada_lite.modules.security.model import SecurityModel
from openscada_lite.modules.security.service import SecurityService
from openscada_lite.modules.base.base_controller import BaseController
import logging

logger = logging.getLogger(__name__)


async def module_loader(config: dict, socketio_obj, event_bus, app) -> dict:
    for module_entry in config.get("modules", []):
        if isinstance(module_entry, dict):
            module_name = module_entry.get("name", "")
        else:
            module_name = str(module_entry)

        if module_name == "security":
            continue  # Security module is loaded separately

        base_path = f"openscada_lite.modules.{module_name}"
        class_prefix = module_name.capitalize()

        logger.info(f"[INIT] Loading module: {module_name}")

        model_cls = getattr(importlib.import_module(f"{base_path}.model"), f"{class_prefix}Model")
        logger.debug(f"[INIT] Model class loaded: {module_name}")
        controller_cls = getattr(
            importlib.import_module(f"{base_path}.controller"),
            f"{class_prefix}Controller",
        )
        logger.debug(f"[INIT] Controller class loaded: {module_name}")
        service_cls = getattr(
            importlib.import_module(f"{base_path}.service"), f"{class_prefix}Service"
        )
        logger.debug(f"[INIT] Service class loaded: {module_name}")
        model = model_cls()
        logger.debug(f"[INIT] Model initialized: {module_name}")
        controller: BaseController = controller_cls(model, socketio_obj, module_name, app)
        logger.debug(f"[INIT] Controller initialized: {module_name}")
        service = service_cls(event_bus, model, controller)
        logger.debug(f"[INIT] Service initialized: {module_name}")
        controller.set_service(service)
        if hasattr(service, "async_init"):
            logger.debug(f"[INIT] async_init: {module_name}")
            await service.async_init()

    logger.info("[INIT] Loading Security module")
    # Security module is always loaded regardless of config
    security_model = SecurityModel()
    security_controller = SecurityController(security_model, socketio_obj, "security", app)
    security_service = SecurityService(event_bus, security_model, security_controller)
    security_controller.set_service(security_service)
    logger.debug("[INIT] Security module loaded")